org.apache.paimon.operation

Class AppendOnlyUnawareBucketFileStoreWrite

java.lang.Object

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

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

org.apache.paimon.operation.AppendOnlyFileStoreWrite

org.apache.paimon.operation.AppendOnlyUnawareBucketFileStoreWrite

All Implemented Interfaces:

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

public class AppendOnlyUnawareBucketFileStoreWrite
extends AppendOnlyFileStoreWrite

AppendOnlyFileStoreWrite for BucketMode.BUCKET_UNAWARE.

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
AppendOnlyUnawareBucketFileStoreWrite(FileIO fileIO, RawFileSplitRead read, long schemaId, 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)
void	withIgnorePreviousFiles(boolean ignorePrevious) Set whether the write operation should ignore previously stored files.

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, createConflictAwareWriterCleanChecker, createNoConflictAwareWriterCleanChecker, createWriterContainer, getActiveBuckets, getCompactExecutor, getWriterWrapper, notifyNewFiles, restore, withCompactExecutor, withExecutionMode, 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, withInsertOnly, withIOManager, withMemoryPool, withMemoryPoolFactory, withMetricRegistry, write

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

checkpoint, restore

Constructor Detail

AppendOnlyUnawareBucketFileStoreWrite

public AppendOnlyUnawareBucketFileStoreWrite(FileIO fileIO,
                                             RawFileSplitRead read,
                                             long schemaId,
                                             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

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<InternalRow>

Overrides:

withIgnorePreviousFiles in class AbstractFileStoreWrite<InternalRow>

Parameters:

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

createWriterCleanChecker

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

Specified by:

createWriterCleanChecker in class AbstractFileStoreWrite<InternalRow>