@ThreadSafe public class FileStorePathFactory extends Object
Path
s for manifest files.Modifier and Type | Field and Description |
---|---|
static org.apache.flink.configuration.ConfigOption<String> |
PARTITION_DEFAULT_NAME |
Constructor and Description |
---|
FileStorePathFactory(org.apache.flink.core.fs.Path root) |
FileStorePathFactory(org.apache.flink.core.fs.Path root,
org.apache.flink.table.types.logical.RowType partitionType,
String defaultPartValue,
String formatIdentifier) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.core.fs.Path |
bucketPath(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket) |
DataFilePathFactory |
createDataFilePathFactory(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket) |
static RowDataPartitionComputer |
getPartitionComputer(org.apache.flink.table.types.logical.RowType partitionType,
String defaultPartValue) |
String |
getPartitionString(org.apache.flink.table.data.binary.BinaryRowData partition)
IMPORTANT: This method is NOT THREAD SAFE.
|
org.apache.flink.core.fs.Path |
newManifestFile() |
org.apache.flink.core.fs.Path |
newManifestList() |
org.apache.flink.core.fs.Path |
root() |
org.apache.flink.core.fs.Path |
toManifestFilePath(String manifestFileName) |
org.apache.flink.core.fs.Path |
toManifestListPath(String manifestListName) |
String |
uuid() |
public static final org.apache.flink.configuration.ConfigOption<String> PARTITION_DEFAULT_NAME
public FileStorePathFactory(org.apache.flink.core.fs.Path root)
public org.apache.flink.core.fs.Path root()
@VisibleForTesting public static RowDataPartitionComputer getPartitionComputer(org.apache.flink.table.types.logical.RowType partitionType, String defaultPartValue)
public org.apache.flink.core.fs.Path newManifestFile()
public org.apache.flink.core.fs.Path newManifestList()
public org.apache.flink.core.fs.Path toManifestFilePath(String manifestFileName)
public org.apache.flink.core.fs.Path toManifestListPath(String manifestListName)
public DataFilePathFactory createDataFilePathFactory(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket)
public org.apache.flink.core.fs.Path bucketPath(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket)
public String getPartitionString(org.apache.flink.table.data.binary.BinaryRowData partition)
@VisibleForTesting public String uuid()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.