public class IcebergManifestFile extends ObjectsFile<IcebergManifestEntry>
ManifestEntry
s, representing the additional changes
since last snapshot.compression, fileIO, pathFactory, readerFactory, serializer
Constructor and Description |
---|
IcebergManifestFile(FileIO fileIO,
RowType partitionType,
FormatReaderFactory readerFactory,
FormatWriterFactory writerFactory,
String compression,
PathFactory pathFactory,
MemorySize targetFileSize) |
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) |
delete, exists, fileIO, fileSize, read, read, read, readFromIterator, readWithIOException, readWithIOException, writeWithoutRolling, writeWithoutRolling
public IcebergManifestFile(FileIO fileIO, RowType partitionType, FormatReaderFactory readerFactory, FormatWriterFactory writerFactory, String compression, PathFactory pathFactory, MemorySize targetFileSize)
public static IcebergManifestFile create(FileStoreTable table, IcebergPathFactory pathFactory)
public List<IcebergManifestFileMeta> rollingWrite(Iterator<IcebergManifestEntry> entries, long sequenceNumber) throws IOException
IOException
public SingleFileWriter<IcebergManifestEntry,IcebergManifestFileMeta> createWriter(long sequenceNumber)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.