org.apache.paimon.iceberg.manifest

Class IcebergManifestFile

java.lang.Object

org.apache.paimon.utils.ObjectsFile<IcebergManifestEntry>

org.apache.paimon.iceberg.manifest.IcebergManifestFile

All Implemented Interfaces:

SimpleFileReader<IcebergManifestEntry>

public class IcebergManifestFile
extends ObjectsFile<IcebergManifestEntry>

This file includes several Iceberg ManifestEntrys, representing the additional changes since last snapshot.

Field Summary

Fields inherited from class org.apache.paimon.utils.ObjectsFile

compression, fileIO, pathFactory, readerFactory, serializer

Constructor Summary

Constructors

Constructor and Description
IcebergManifestFile(FileIO fileIO, RowType partitionType, FormatReaderFactory readerFactory, FormatWriterFactory writerFactory, String compression, PathFactory pathFactory, MemorySize targetFileSize)

Method Summary

Modifier and Type	Method and Description
static IcebergManifestFile	create(FileStoreTable table, IcebergPathFactory pathFactory)
SingleFileWriter<IcebergManifestEntry,IcebergManifestFileMeta>	createWriter(long sequenceNumber)
List<IcebergManifestFileMeta>	rollingWrite(Iterator<IcebergManifestEntry> entries, long sequenceNumber)

Methods inherited from class org.apache.paimon.utils.ObjectsFile

delete, exists, fileIO, fileSize, read, read, read, readFromIterator, readWithIOException, readWithIOException, writeWithoutRolling, writeWithoutRolling

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergManifestFile

public IcebergManifestFile(FileIO fileIO,
                           RowType partitionType,
                           FormatReaderFactory readerFactory,
                           FormatWriterFactory writerFactory,
                           String compression,
                           PathFactory pathFactory,
                           MemorySize targetFileSize)

Method Detail

create

public static IcebergManifestFile create(FileStoreTable table,
                                         IcebergPathFactory pathFactory)

rollingWrite

public List<IcebergManifestFileMeta> rollingWrite(Iterator<IcebergManifestEntry> entries,
                                                  long sequenceNumber)
                                           throws IOException

Throws:

IOException

createWriter

public SingleFileWriter<IcebergManifestEntry,IcebergManifestFileMeta> createWriter(long sequenceNumber)