Modifier and Type | Method and Description |
---|---|
FileStatus |
FlinkFileIO.getFileStatus(Path path) |
FileStatus[] |
FlinkFileIO.listStatus(Path path) |
Modifier and Type | Method and Description |
---|---|
FileStatus |
PluginFileIO.getFileStatus(Path path) |
FileStatus |
FileIO.getFileStatus(Path path)
Return a file status object that represents the path.
|
default FileStatus[] |
FileIO.listDirectories(Path path)
List the statuses of the directories in the given path if the path is a directory.
|
FileStatus[] |
PluginFileIO.listStatus(Path path) |
FileStatus[] |
FileIO.listStatus(Path path)
List the statuses of the files/directories in the given path if the path is a directory.
|
Modifier and Type | Method and Description |
---|---|
FileStatus |
HadoopFileIO.getFileStatus(Path path) |
FileStatus[] |
HadoopFileIO.listStatus(Path path) |
Modifier and Type | Method and Description |
---|---|
FileStatus |
LocalFileIO.getFileStatus(Path path) |
FileStatus[] |
LocalFileIO.listStatus(Path path) |
Modifier and Type | Method and Description |
---|---|
static List<DataFileMeta> |
FileMetaUtils.construct(FileIO fileIO,
String format,
String location,
Table paimonTable,
java.util.function.Predicate<FileStatus> filter,
Path dir,
Map<Path,Path> rollback) |
Modifier and Type | Method and Description |
---|---|
protected List<FileStatus> |
OrphanFilesClean.tryBestListingDirs(Path dir)
If failed to list directory, just return an empty result because it's OK to not delete them.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
OrphanFilesClean.oldEnough(FileStatus status) |
Modifier and Type | Method and Description |
---|---|
FileStatus |
HadoopCompliantFileIO.getFileStatus(Path path) |
FileStatus[] |
HadoopCompliantFileIO.listStatus(Path path) |
Modifier and Type | Method and Description |
---|---|
FileStatus |
HadoopCompliantFileIO.getFileStatus(Path path) |
FileStatus[] |
HadoopCompliantFileIO.listStatus(Path path) |
Modifier and Type | Method and Description |
---|---|
static java.util.stream.Stream<FileStatus> |
FileUtils.listVersionedDirectories(FileIO fileIO,
Path dir,
String prefix)
List versioned directories for the directory.
|
static java.util.stream.Stream<FileStatus> |
FileUtils.listVersionedFileStatus(FileIO fileIO,
Path dir,
String prefix)
List versioned file status for the directory.
|
Modifier and Type | Method and Description |
---|---|
List<Path> |
SnapshotManager.tryGetNonChangelogFiles(java.util.function.Predicate<FileStatus> fileStatusFilter) |
List<Path> |
SnapshotManager.tryGetNonSnapshotFiles(java.util.function.Predicate<FileStatus> fileStatusFilter)
Try to get non snapshot files.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.