org.apache.paimon.manifest

Class ManifestFile

java.lang.Object

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

org.apache.paimon.manifest.ManifestFile

All Implemented Interfaces:

SimpleFileReader<ManifestEntry>

public class ManifestFile
extends ObjectsFile<ManifestEntry>

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ManifestFile.Factory Creator of ManifestFile.
class	ManifestFile.ManifestEntryWriter Writer for ManifestEntry.

Field Summary

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

compression, fileIO, pathFactory, readerFactory, serializer

Method Summary

Modifier and Type	Method and Description
ManifestFile.ManifestEntryWriter	createManifestEntryWriter(Path manifestPath)
RollingFileWriter<ManifestEntry,ManifestFileMeta>	createRollingWriter()
List<ExpireFileEntry>	readExpireFileEntries(String fileName, Long fileSize)
long	suggestedFileSize()
List<ManifestFileMeta>	write(List<ManifestEntry> entries) Write several ManifestEntrys into manifest files.

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

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

Methods inherited from class java.lang.Object

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

Method Detail

suggestedFileSize

@VisibleForTesting
public long suggestedFileSize()

readExpireFileEntries

public List<ExpireFileEntry> readExpireFileEntries(String fileName,
                                                   @Nullable
                                                   Long fileSize)

write

public List<ManifestFileMeta> write(List<ManifestEntry> entries)

Write several ManifestEntrys into manifest files.

NOTE: This method is atomic.

createRollingWriter

public RollingFileWriter<ManifestEntry,ManifestFileMeta> createRollingWriter()

createManifestEntryWriter

public ManifestFile.ManifestEntryWriter createManifestEntryWriter(Path manifestPath)