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

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)

Method Summary

Modifier and Type	Method and Description
Path	bucketPath(BinaryRow partition, int bucket)
DataFilePathFactory	createDataFilePathFactory(BinaryRow partition, int bucket)
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()
PathFactory	manifestFileFactory()
PathFactory	manifestListFactory()
Path	newManifestFile()
Path	newManifestList()
Path	relativeBucketPath(BinaryRow partition, int bucket)
Path	root()
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

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)

Method Detail

root

public Path root()

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()