public class FileUtils extends Object
Constructor and Description |
---|
FileUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
checkExists(FileIO fileIO,
Path file) |
static RecordReader<InternalRow> |
createFormatReader(FileIO fileIO,
FormatReaderFactory format,
Path file,
Long fileSize) |
static java.util.stream.Stream<String> |
listOriginalVersionedFiles(FileIO fileIO,
Path dir,
String prefix)
List original versioned files for the directory.
|
static java.util.stream.Stream<FileStatus> |
listVersionedDirectories(FileIO fileIO,
Path dir,
String prefix)
List versioned directories for the directory.
|
static java.util.stream.Stream<Long> |
listVersionedFiles(FileIO fileIO,
Path dir,
String prefix)
List versioned files for the directory.
|
static java.util.stream.Stream<FileStatus> |
listVersionedFileStatus(FileIO fileIO,
Path dir,
String prefix)
List versioned file status for the directory.
|
public static java.util.stream.Stream<Long> listVersionedFiles(FileIO fileIO, Path dir, String prefix) throws IOException
IOException
public static java.util.stream.Stream<String> listOriginalVersionedFiles(FileIO fileIO, Path dir, String prefix) throws IOException
IOException
public static java.util.stream.Stream<FileStatus> listVersionedFileStatus(FileIO fileIO, Path dir, String prefix) throws IOException
IOException
public static java.util.stream.Stream<FileStatus> listVersionedDirectories(FileIO fileIO, Path dir, String prefix) throws IOException
IOException
public static void checkExists(FileIO fileIO, Path file) throws IOException
IOException
public static RecordReader<InternalRow> createFormatReader(FileIO fileIO, FormatReaderFactory format, Path file, @Nullable Long fileSize) throws IOException
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.