Package | Description |
---|---|
org.apache.flink.api.common.io |
Modifier and Type | Method and Description |
---|---|
protected FileInputFormat.FileBaseStatistics |
FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats,
Path[] filePaths,
ArrayList<FileStatus> files) |
protected FileInputFormat.FileBaseStatistics |
FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats,
Path filePath,
FileSystem fs,
ArrayList<FileStatus> files) |
FileInputFormat.FileBaseStatistics |
DelimitedInputFormat.getStatistics(BaseStatistics cachedStats) |
FileInputFormat.FileBaseStatistics |
FileInputFormat.getStatistics(BaseStatistics cachedStats)
Obtains basic file statistics containing only file size.
|
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.api.common.io.BinaryInputFormat.SequentialStatistics |
BinaryInputFormat.createStatistics(List<FileStatus> files,
FileInputFormat.FileBaseStatistics stats)
Fill in the statistics.
|
protected FileInputFormat.FileBaseStatistics |
FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats,
Path[] filePaths,
ArrayList<FileStatus> files) |
protected FileInputFormat.FileBaseStatistics |
FileInputFormat.getFileStats(FileInputFormat.FileBaseStatistics cachedStats,
Path filePath,
FileSystem fs,
ArrayList<FileStatus> files) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.