public class AppendOnlyUnawareBucketFileStoreWrite extends AppendOnlyFileStoreWrite
AbstractFileStoreWrite.WriterContainer<T>
FileStoreWrite.State<T>
cacheManager, options
compactionMetrics, ioManager, isStreamingMode, snapshotManager, tableName, writers
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) |
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.
|
compactRewrite, createWriter, forceBufferSpill, writeBundle
close, notifyNewWriter, prepareCommit, withMemoryPoolFactory, withMetricRegistry
checkpoint, compact, createConflictAwareWriterCleanChecker, createNoConflictAwareWriterCleanChecker, createWriterContainer, getActiveBuckets, getCompactExecutor, getWriterWrapper, notifyNewFiles, restore, withCompactExecutor, withExecutionMode, withInsertOnly, withIOManager, write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, compact, notifyNewFiles, prepareCommit, withCompactExecutor, withExecutionMode, withInsertOnly, withIOManager, withMemoryPool, withMemoryPoolFactory, withMetricRegistry, write
checkpoint, restore
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)
protected CompactManager getCompactManager(BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, ExecutorService compactExecutor, @Nullable DeletionVectorsMaintainer dvMaintainer)
getCompactManager
in class AppendOnlyFileStoreWrite
public void withIgnorePreviousFiles(boolean ignorePrevious)
FileStoreWrite
withIgnorePreviousFiles
in interface FileStoreWrite<InternalRow>
withIgnorePreviousFiles
in class AbstractFileStoreWrite<InternalRow>
ignorePrevious
- whether the write operation should ignore previously stored files.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.