public class AppendOnlyFixedBucketFileStoreWrite extends AppendOnlyFileStoreWrite
AbstractFileStoreWrite.WriterContainer<T>
FileStoreWrite.State<T>
cacheManager, options
compactionMetrics, ioManager, isStreamingMode, snapshotManager, tableName, writers
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) |
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) |
compactRewrite, createWriter, forceBufferSpill, writeBundle
close, notifyNewWriter, prepareCommit, withMemoryPoolFactory, withMetricRegistry
checkpoint, compact, createConflictAwareWriterCleanChecker, createNoConflictAwareWriterCleanChecker, createWriterContainer, getActiveBuckets, getCompactExecutor, getWriterWrapper, notifyNewFiles, restore, withCompactExecutor, withExecutionMode, withIgnorePreviousFiles, withInsertOnly, withIOManager, write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, compact, notifyNewFiles, prepareCommit, withCompactExecutor, withExecutionMode, withIgnorePreviousFiles, withInsertOnly, withIOManager, withMemoryPool, withMemoryPoolFactory, withMetricRegistry, write
checkpoint, restore
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)
protected CompactManager getCompactManager(BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, ExecutorService compactExecutor, @Nullable DeletionVectorsMaintainer dvMaintainer)
getCompactManager
in class AppendOnlyFileStoreWrite
protected java.util.function.Function<AbstractFileStoreWrite.WriterContainer<InternalRow>,Boolean> createWriterCleanChecker()
createWriterCleanChecker
in class AbstractFileStoreWrite<InternalRow>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.