org.apache.paimon.iceberg

Class IcebergPathFactory

java.lang.Object

org.apache.paimon.iceberg.IcebergPathFactory

public class IcebergPathFactory
extends Object

Path factory for Iceberg metadata files.

Constructor Summary

Constructors

Constructor and Description
IcebergPathFactory(Path metadataDirectory)

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<Path>	getAllMetadataPathBefore(FileIO fileIO, long snapshotId)
PathFactory	manifestFileFactory()
PathFactory	manifestListFactory()
Path	metadataDirectory()
Path	newManifestFile()
Path	newManifestListFile()
Path	toManifestFilePath(String manifestFileName)
Path	toManifestListPath(String manifestListName)
Path	toMetadataPath(long snapshotId)

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergPathFactory

public IcebergPathFactory(Path metadataDirectory)

Method Detail

metadataDirectory

public Path metadataDirectory()

newManifestFile

public Path newManifestFile()

toManifestFilePath

public Path toManifestFilePath(String manifestFileName)

newManifestListFile

public Path newManifestListFile()

toManifestListPath

public Path toManifestListPath(String manifestListName)

toMetadataPath

public Path toMetadataPath(long snapshotId)

getAllMetadataPathBefore

public java.util.stream.Stream<Path> getAllMetadataPathBefore(FileIO fileIO,
                                                              long snapshotId)
                                                       throws IOException

Throws:

IOException

manifestFileFactory

public PathFactory manifestFileFactory()

manifestListFactory

public PathFactory manifestListFactory()