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, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, String tableName, Integer writeId)

Method Summary

Modifier and Type	Method and Description
protected PostponeBucketWriter	createWriter(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()
void	withIgnorePreviousFiles(boolean ignorePrevious) Set whether the write operation should ignore previously stored files.

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

checkpoint, close, compact, compactionMetrics, createConflictAwareWriterCleanChecker, createNoConflictAwareWriterCleanChecker, createWriterContainer, forceBufferSpill, getActiveBuckets, getCompactExecutor, getDefaultBucketNum, getWriterWrapper, notifyNewFiles, notifyNewWriter, prepareCommit, restore, withCompactExecutor, withExecutionMode, withIgnoreNumBucketCheck, 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,
                                    String commitUser,
                                    RowType partitionType,
                                    RowType keyType,
                                    RowType valueType,
                                    java.util.function.BiFunction<CoreOptions,String,FileStorePathFactory> formatPathFactory,
                                    SnapshotManager snapshotManager,
                                    FileStoreScan scan,
                                    CoreOptions options,
                                    String tableName,
                                    @Nullable
                                    Integer writeId)

Method Detail

withIgnorePreviousFiles

public void withIgnorePreviousFiles(boolean ignorePrevious)

Description copied from interface: FileStoreWrite

Set whether the write operation should ignore previously stored files.

Specified by:

withIgnorePreviousFiles in interface FileStoreWrite<KeyValue>

Overrides:

withIgnorePreviousFiles in class AbstractFileStoreWrite<KeyValue>

Parameters:

ignorePrevious - whether the write operation should ignore previously stored files.

createWriter

protected PostponeBucketWriter createWriter(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>