@ThreadSafe public class DataFilePathFactory extends Object
Path
s for data files.Modifier and Type | Field and Description |
---|---|
static String |
CHANGELOG_FILE_PREFIX |
static String |
DATA_FILE_PREFIX |
Constructor and Description |
---|
DataFilePathFactory(org.apache.flink.core.fs.Path root,
String partition,
int bucket,
String formatIdentifier) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.core.fs.Path |
bucketPath(org.apache.flink.core.fs.Path tablePath,
String partition,
int bucket) |
org.apache.flink.core.fs.Path |
newChangelogPath() |
org.apache.flink.core.fs.Path |
newPath() |
org.apache.flink.core.fs.Path |
toPath(String fileName) |
String |
uuid() |
public static final String DATA_FILE_PREFIX
public static final String CHANGELOG_FILE_PREFIX
public org.apache.flink.core.fs.Path newPath()
public org.apache.flink.core.fs.Path newChangelogPath()
public org.apache.flink.core.fs.Path toPath(String fileName)
@VisibleForTesting public String uuid()
public static org.apache.flink.core.fs.Path bucketPath(org.apache.flink.core.fs.Path tablePath, String partition, int bucket)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.