org.apache.paimon.io

Class DataFilePathFactory

java.lang.Object

org.apache.paimon.io.DataFilePathFactory

@ThreadSafe
public class DataFilePathFactory
extends Object

Factory which produces new Paths for data files.

Field Summary

Fields

Modifier and Type	Field and Description
static String	INDEX_PATH_SUFFIX

Constructor Summary

Constructors

Constructor and Description
DataFilePathFactory(Path parent, String formatIdentifier, String dataFilePrefix, String changelogFilePrefix, boolean fileSuffixIncludeCompression, String fileCompression)

Method Summary

Modifier and Type	Method and Description
static Path	createNewFileIndexFilePath(Path filePath)
static Path	dataFileToFileIndexPath(Path dataFilePath)
static String	formatIdentifier(String fileName)
Path	newChangelogPath()
Path	newPath()
Path	toPath(String fileName)
String	uuid()

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_PATH_SUFFIX

public static final String INDEX_PATH_SUFFIX

See Also:

Constant Field Values

Constructor Detail

DataFilePathFactory

public DataFilePathFactory(Path parent,
                           String formatIdentifier,
                           String dataFilePrefix,
                           String changelogFilePrefix,
                           boolean fileSuffixIncludeCompression,
                           String fileCompression)

Method Detail

newPath

public Path newPath()

newChangelogPath

public Path newChangelogPath()

toPath

public Path toPath(String fileName)

uuid

@VisibleForTesting
public String uuid()

dataFileToFileIndexPath

public static Path dataFileToFileIndexPath(Path dataFilePath)

createNewFileIndexFilePath

public static Path createNewFileIndexFilePath(Path filePath)

formatIdentifier

public static String formatIdentifier(String fileName)