public class FileUtils extends Object
Modifier and Type | Field and Description |
---|---|
static ForkJoinPool |
COMMON_IO_FORK_JOIN_POOL |
Constructor and Description |
---|
FileUtils() |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.connector.file.src.reader.BulkFormat.Reader<org.apache.flink.table.data.RowData> |
createFormatReader(org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> format,
org.apache.flink.core.fs.Path file) |
static void |
deleteOrWarn(org.apache.flink.core.fs.Path file) |
static long |
getFileSize(org.apache.flink.core.fs.Path path) |
static java.util.stream.Stream<Long> |
listVersionedFiles(org.apache.flink.core.fs.Path dir,
String prefix)
List versioned files for the directory.
|
static String |
readFileUtf8(org.apache.flink.core.fs.Path file) |
static <T> List<T> |
readListFromFile(org.apache.flink.core.fs.Path path,
ObjectSerializer<T> serializer,
org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> readerFactory) |
static org.apache.flink.core.fs.FileStatus[] |
safelyListFileStatus(org.apache.flink.core.fs.Path file) |
static void |
writeFileUtf8(org.apache.flink.core.fs.Path file,
String content) |
static void |
writeOutputStreamUtf8(org.apache.flink.core.fs.FSDataOutputStream out,
String content) |
public static final ForkJoinPool COMMON_IO_FORK_JOIN_POOL
public static <T> List<T> readListFromFile(org.apache.flink.core.fs.Path path, ObjectSerializer<T> serializer, org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> readerFactory) throws IOException
IOException
public static long getFileSize(org.apache.flink.core.fs.Path path) throws IOException
IOException
public static String readFileUtf8(org.apache.flink.core.fs.Path file) throws IOException
IOException
public static void writeFileUtf8(org.apache.flink.core.fs.Path file, String content) throws IOException
IOException
public static void writeOutputStreamUtf8(org.apache.flink.core.fs.FSDataOutputStream out, String content) throws IOException
IOException
public static void deleteOrWarn(org.apache.flink.core.fs.Path file)
@Nullable public static org.apache.flink.core.fs.FileStatus[] safelyListFileStatus(org.apache.flink.core.fs.Path file) throws IOException
IOException
public static java.util.stream.Stream<Long> listVersionedFiles(org.apache.flink.core.fs.Path dir, String prefix) throws IOException
IOException
public static org.apache.flink.connector.file.src.reader.BulkFormat.Reader<org.apache.flink.table.data.RowData> createFormatReader(org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> format, org.apache.flink.core.fs.Path file) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.