org.apache.paimon.utils

Class FileUtils

java.lang.Object

org.apache.paimon.utils.FileUtils

public class FileUtils
extends Object

Utils for file reading and writing.

Constructor Summary

Constructors

Constructor and Description
FileUtils()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileUtils

public FileUtils()

Method Detail

listVersionedFiles

public static java.util.stream.Stream<Long> listVersionedFiles(FileIO fileIO,
                                                               Path dir,
                                                               String prefix)
                                                        throws IOException

List versioned files for the directory.

Returns:

version stream

Throws:

IOException

listOriginalVersionedFiles

public static java.util.stream.Stream<String> listOriginalVersionedFiles(FileIO fileIO,
                                                                         Path dir,
                                                                         String prefix)
                                                                  throws IOException

List original versioned files for the directory.

Returns:

version stream

Throws:

IOException

listVersionedFileStatus

public static java.util.stream.Stream<FileStatus> listVersionedFileStatus(FileIO fileIO,
                                                                          Path dir,
                                                                          String prefix)
                                                                   throws IOException

List versioned file status for the directory.

Returns:

file status stream

Throws:

IOException

listVersionedDirectories

public static java.util.stream.Stream<FileStatus> listVersionedDirectories(FileIO fileIO,
                                                                           Path dir,
                                                                           String prefix)
                                                                    throws IOException

List versioned directories for the directory.

Returns:

file status stream

Throws:

IOException

checkExists

public static void checkExists(FileIO fileIO,
                               Path file)
                        throws IOException

Throws:

IOException

createFormatReader

public static RecordReader<InternalRow> createFormatReader(FileIO fileIO,
                                                           FormatReaderFactory format,
                                                           Path file,
                                                           @Nullable
                                                           Long fileSize)
                                                    throws IOException

Throws:

IOException