org.apache.paimon.postpone

Class PostponeBucketFileStoreWrite

java.lang.Object

org.apache.paimon.operation.AbstractFileStoreWrite<KeyValue>

org.apache.paimon.postpone.PostponeBucketFileStoreWrite

All Implemented Interfaces:

FileStoreWrite<KeyValue>, Restorable<List<FileStoreWrite.State<KeyValue>>>

public class PostponeBucketFileStoreWrite
extends AbstractFileStoreWrite<KeyValue>

FileStoreWrite for bucket = -2 tables.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.operation.AbstractFileStoreWrite

AbstractFileStoreWrite.WriterContainer<T>

Nested classes/interfaces inherited from interface org.apache.paimon.operation.FileStoreWrite

FileStoreWrite.State<T>

Field Summary

Fields inherited from class org.apache.paimon.operation.AbstractFileStoreWrite

compactionMetrics, ioManager, isStreamingMode, snapshotManager, tableName, writers

Constructor Summary

Constructors

Constructor and Description
PostponeBucketFileStoreWrite(FileIO fileIO, TableSchema schema, RowType partitionType, RowType keyType, RowType valueType, Map<String,FileStorePathFactory> format2PathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, String tableName)

Method Summary

Modifier and Type	Method and Description
protected PostponeBucketWriter	createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer deletionVectorsMaintainer)
protected java.util.function.Function<AbstractFileStoreWrite.WriterContainer<KeyValue>,Boolean>	createWriterCleanChecker()

Methods inherited from class org.apache.paimon.operation.AbstractFileStoreWrite

checkpoint, close, compact, createConflictAwareWriterCleanChecker, createNoConflictAwareWriterCleanChecker, createWriterContainer, forceBufferSpill, getActiveBuckets, getCompactExecutor, getWriterWrapper, notifyNewFiles, notifyNewWriter, prepareCommit, restore, withCompactExecutor, withExecutionMode, withIgnorePreviousFiles, withInsertOnly, withIOManager, withMemoryPoolFactory, withMetricRegistry, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.operation.FileStoreWrite

withMemoryPool

Constructor Detail

PostponeBucketFileStoreWrite

public PostponeBucketFileStoreWrite(FileIO fileIO,
                                    TableSchema schema,
                                    RowType partitionType,
                                    RowType keyType,
                                    RowType valueType,
                                    Map<String,FileStorePathFactory> format2PathFactory,
                                    SnapshotManager snapshotManager,
                                    FileStoreScan scan,
                                    CoreOptions options,
                                    String tableName)

Method Detail

createWriter

protected PostponeBucketWriter createWriter(@Nullable
                                            Long snapshotId,
                                            BinaryRow partition,
                                            int bucket,
                                            List<DataFileMeta> restoreFiles,
                                            long restoredMaxSeqNumber,
                                            @Nullable
                                            CommitIncrement restoreIncrement,
                                            ExecutorService compactExecutor,
                                            @Nullable
                                            DeletionVectorsMaintainer deletionVectorsMaintainer)

Specified by:

createWriter in class AbstractFileStoreWrite<KeyValue>

createWriterCleanChecker

protected java.util.function.Function<AbstractFileStoreWrite.WriterContainer<KeyValue>,Boolean> createWriterCleanChecker()

Specified by:

createWriterCleanChecker in class AbstractFileStoreWrite<KeyValue>