public class LateFileRecordCountProvider extends RecordCountProvider
| Constructor and Description |
|---|
LateFileRecordCountProvider() |
| Modifier and Type | Method and Description |
|---|---|
Path |
constructLateFilePath(String originalFilename,
FileSystem fs,
Path outputDir)
Construct filename for a late file.
|
long |
getRecordCount(Path path)
Get record count from a given filename (possibly having LATE_COMPONENT{RandomInteger}), using the original
FileNameWithRecordCountFormat. |
static Path |
restoreFilePath(Path path)
Remove the late components in the path added by
LateFileRecordCountProvider. |
convertPath, getNotImplementedException, getRecordCountpublic Path constructLateFilePath(String originalFilename, FileSystem fs, Path outputDir) throws IOException
IOExceptionpublic static Path restoreFilePath(Path path)
LateFileRecordCountProvider.public long getRecordCount(Path path)
FileNameWithRecordCountFormat.getRecordCount in class RecordCountProvider