org.apache.paimon.utils

Class FileStorePathFactory

java.lang.Object

org.apache.paimon.utils.FileStorePathFactory

@ThreadSafe
public class FileStorePathFactory
extends Object

Factory which produces Paths for manifest files.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BUCKET_PATH_PREFIX
static String	INDEX_MANIFEST_PREFIX
static String	INDEX_PATH
static String	INDEX_PREFIX
static String	MANIFEST_LIST_PREFIX
static String	MANIFEST_PATH
static String	MANIFEST_PREFIX
static String	STATISTICS_PATH
static String	STATISTICS_PREFIX

Constructor Summary

Constructors

Constructor and Description
FileStorePathFactory(Path root, RowType partitionType, String defaultPartValue, String formatIdentifier, String dataFilePrefix, String changelogFilePrefix, boolean legacyPartitionName, boolean fileSuffixIncludeCompression, String fileCompression, String dataFilePathDirectory, List<Path> externalPaths)

Method Summary

Modifier and Type	Method and Description
Path	bucketPath(BinaryRow partition, int bucket)
DataFilePathFactory	createDataFilePathFactory(BinaryRow partition, int bucket)
Path	dataFilePath()
List<Path>	getHierarchicalPartitionPath(BinaryRow partition)
static InternalRowPartitionComputer	getPartitionComputer(RowType partitionType, String defaultPartValue, boolean legacyPartitionName)
String	getPartitionString(BinaryRow partition) IMPORTANT: This method is NOT THREAD SAFE.
PathFactory	indexFileFactory()
PathFactory	indexManifestFileFactory()
Path	indexPath()
PathFactory	manifestFileFactory()
PathFactory	manifestListFactory()
Path	manifestPath()
Path	newManifestFile()
Path	newManifestList()
Path	relativeBucketPath(BinaryRow partition, int bucket)
Path	root()
Path	statisticsPath()
PathFactory	statsFileFactory()
Path	toManifestFilePath(String manifestFileName)
Path	toManifestListPath(String manifestListName)
String	uuid()

Methods inherited from class java.lang.Object

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

Field Detail

MANIFEST_PATH

public static final String MANIFEST_PATH

See Also:

Constant Field Values

MANIFEST_PREFIX

public static final String MANIFEST_PREFIX

See Also:

Constant Field Values

MANIFEST_LIST_PREFIX

public static final String MANIFEST_LIST_PREFIX

See Also:

Constant Field Values

INDEX_MANIFEST_PREFIX

public static final String INDEX_MANIFEST_PREFIX

See Also:

Constant Field Values

INDEX_PATH

public static final String INDEX_PATH

See Also:

Constant Field Values

INDEX_PREFIX

public static final String INDEX_PREFIX

See Also:

Constant Field Values

STATISTICS_PATH

public static final String STATISTICS_PATH

See Also:

Constant Field Values

STATISTICS_PREFIX

public static final String STATISTICS_PREFIX

See Also:

Constant Field Values

BUCKET_PATH_PREFIX

public static final String BUCKET_PATH_PREFIX

See Also:

Constant Field Values

Constructor Detail

FileStorePathFactory

public FileStorePathFactory(Path root,
                            RowType partitionType,
                            String defaultPartValue,
                            String formatIdentifier,
                            String dataFilePrefix,
                            String changelogFilePrefix,
                            boolean legacyPartitionName,
                            boolean fileSuffixIncludeCompression,
                            String fileCompression,
                            @Nullable
                            String dataFilePathDirectory,
                            List<Path> externalPaths)

Method Detail

root

public Path root()

manifestPath

public Path manifestPath()

indexPath

public Path indexPath()

statisticsPath

public Path statisticsPath()

dataFilePath

public Path dataFilePath()

getPartitionComputer

@VisibleForTesting
public static InternalRowPartitionComputer getPartitionComputer(RowType partitionType,
                                                                                   String defaultPartValue,
                                                                                   boolean legacyPartitionName)

newManifestFile

public Path newManifestFile()

newManifestList

public Path newManifestList()

toManifestFilePath

public Path toManifestFilePath(String manifestFileName)

toManifestListPath

public Path toManifestListPath(String manifestListName)

createDataFilePathFactory

public DataFilePathFactory createDataFilePathFactory(BinaryRow partition,
                                                     int bucket)

bucketPath

public Path bucketPath(BinaryRow partition,
                       int bucket)

relativeBucketPath

public Path relativeBucketPath(BinaryRow partition,
                               int bucket)

getPartitionString

public String getPartitionString(BinaryRow partition)

IMPORTANT: This method is NOT THREAD SAFE.

getHierarchicalPartitionPath

public List<Path> getHierarchicalPartitionPath(BinaryRow partition)

uuid

@VisibleForTesting
public String uuid()

manifestFileFactory

public PathFactory manifestFileFactory()

manifestListFactory

public PathFactory manifestListFactory()

indexManifestFileFactory

public PathFactory indexManifestFileFactory()

indexFileFactory

public PathFactory indexFileFactory()

statsFileFactory

public PathFactory statsFileFactory()