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)
String	newChangelogFileName()
Path	newChangelogPath()
Path	newPath()
Path	newPath(String prefix)
Path	toAlignedPath(String fileName, DataFileMeta aligned)
Path	toPath(DataFileMeta file)
Path	toPath(FileEntry file)

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

newChangelogFileName

public String newChangelogFileName()

newPath

public Path newPath(String prefix)

toPath

public Path toPath(DataFileMeta file)

toPath

public Path toPath(FileEntry file)

toAlignedPath

public Path toAlignedPath(String fileName,
                          DataFileMeta aligned)

dataFileToFileIndexPath

public static Path dataFileToFileIndexPath(Path dataFilePath)

createNewFileIndexFilePath

public static Path createNewFileIndexFilePath(Path filePath)

formatIdentifier

public static String formatIdentifier(String fileName)