org.apache.paimon.operation

Class AppendOnlyFixedBucketFileStoreWrite

java.lang.Object

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

org.apache.paimon.operation.MemoryFileStoreWrite<InternalRow>

org.apache.paimon.operation.AppendOnlyFileStoreWrite

org.apache.paimon.operation.AppendOnlyFixedBucketFileStoreWrite

All Implemented Interfaces:

BundleFileStoreWriter, FileStoreWrite<InternalRow>, Restorable<List<FileStoreWrite.State<InternalRow>>>

public class AppendOnlyFixedBucketFileStoreWrite
extends AppendOnlyFileStoreWrite

AppendOnlyFileStoreWrite for BucketMode.HASH_FIXED.

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.MemoryFileStoreWrite

cacheManager, options

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

compactionMetrics, ioManager, isStreamingMode, snapshotManager, tableName, writers

Constructor Summary

Constructors

Constructor and Description
AppendOnlyFixedBucketFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, String commitUser, RowType rowType, RowType partitionType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options, DeletionVectorsMaintainer.Factory dvMaintainerFactory, String tableName)

Method Summary

Modifier and Type	Method and Description
protected java.util.function.Function<AbstractFileStoreWrite.WriterContainer<InternalRow>,Boolean>	createWriterCleanChecker()
protected CompactManager	getCompactManager(BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)

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

compactRewrite, createWriter, forceBufferSpill, writeBundle

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

close, notifyNewWriter, prepareCommit, withMemoryPoolFactory, withMetricRegistry

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

checkpoint, compact, compactionMetrics, createConflictAwareWriterCleanChecker, createNoConflictAwareWriterCleanChecker, createWriterContainer, getActiveBuckets, getCompactExecutor, getDefaultBucketNum, getWriterWrapper, notifyNewFiles, restore, withCompactExecutor, withExecutionMode, withIgnoreNumBucketCheck, withIgnorePreviousFiles, withInsertOnly, withIOManager, 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

close, compact, notifyNewFiles, prepareCommit, withCompactExecutor, withExecutionMode, withIgnoreNumBucketCheck, withIgnorePreviousFiles, withInsertOnly, withIOManager, withMemoryPool, withMemoryPoolFactory, withMetricRegistry, write

Methods inherited from interface org.apache.paimon.utils.Restorable

checkpoint, restore

Constructor Detail

AppendOnlyFixedBucketFileStoreWrite

public AppendOnlyFixedBucketFileStoreWrite(FileIO fileIO,
                                           RawFileSplitRead read,
                                           long schemaId,
                                           String commitUser,
                                           RowType rowType,
                                           RowType partitionType,
                                           FileStorePathFactory pathFactory,
                                           SnapshotManager snapshotManager,
                                           FileStoreScan scan,
                                           CoreOptions options,
                                           @Nullable
                                           DeletionVectorsMaintainer.Factory dvMaintainerFactory,
                                           String tableName)

Method Detail

getCompactManager

protected CompactManager getCompactManager(BinaryRow partition,
                                           int bucket,
                                           List<DataFileMeta> restoredFiles,
                                           ExecutorService compactExecutor,
                                           @Nullable
                                           DeletionVectorsMaintainer dvMaintainer)

Specified by:

getCompactManager in class AppendOnlyFileStoreWrite

createWriterCleanChecker

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

Specified by:

createWriterCleanChecker in class AbstractFileStoreWrite<InternalRow>