Uses of Class
org.apache.paimon.deletionvectors.DeletionVectorsMaintainer

Packages that use DeletionVectorsMaintainer

Package	Description
org.apache.paimon.append
org.apache.paimon.compact
org.apache.paimon.deletionvectors
org.apache.paimon.mergetree.compact
org.apache.paimon.operation

Uses of DeletionVectorsMaintainer in org.apache.paimon.append

Constructors in org.apache.paimon.append with parameters of type DeletionVectorsMaintainer

Constructor and Description
AutoCompactTask(DeletionVectorsMaintainer dvMaintainer, List<DataFileMeta> toCompact, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)
BucketedAppendCompactManager(ExecutorService executor, List<DataFileMeta> restored, DeletionVectorsMaintainer dvMaintainer, int minFileNum, int maxFileNum, long targetFileSize, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)
FullCompactTask(DeletionVectorsMaintainer dvMaintainer, Collection<DataFileMeta> inputs, long targetFileSize, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)

Uses of DeletionVectorsMaintainer in org.apache.paimon.compact

Methods in org.apache.paimon.compact with parameters of type DeletionVectorsMaintainer

Modifier and Type	Method and Description
static CompactDeletionFile	CompactDeletionFile.generateFiles(DeletionVectorsMaintainer maintainer) Used by async compaction, when compaction task is completed, deletions file will be generated immediately, so when updateCompactResult, we need to merge old deletion files (just delete them).
static CompactDeletionFile	CompactDeletionFile.lazyGeneration(DeletionVectorsMaintainer maintainer) For sync compaction, only create deletion files when prepareCommit.

Constructors in org.apache.paimon.compact with parameters of type DeletionVectorsMaintainer

Constructor and Description
LazyCompactDeletionFile(DeletionVectorsMaintainer maintainer)

Uses of DeletionVectorsMaintainer in org.apache.paimon.deletionvectors

Methods in org.apache.paimon.deletionvectors that return DeletionVectorsMaintainer

Modifier and Type	Method and Description
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.create()
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition)
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition, int bucket)
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.createOrRestore(Map<String,DeletionVector> deletionVectors)

Methods in org.apache.paimon.deletionvectors with parameters of type DeletionVectorsMaintainer

Modifier and Type	Method and Description
static DeletionVector.Factory	DeletionVector.factory(DeletionVectorsMaintainer dvMaintainer)

Uses of DeletionVectorsMaintainer in org.apache.paimon.mergetree.compact

Methods in org.apache.paimon.mergetree.compact with parameters of type DeletionVectorsMaintainer

Modifier and Type	Method and Description
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.FirstRowMergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<Boolean> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.LookupMergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)

Constructors in org.apache.paimon.mergetree.compact with parameters of type DeletionVectorsMaintainer

Constructor and Description
LookupChangelogMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory, java.util.function.Function<InternalRow,T> lookup, RecordEqualiser valueEqualiser, LookupStrategy lookupStrategy, DeletionVectorsMaintainer deletionVectorsMaintainer, UserDefinedSeqComparator userDefinedSeqComparator)
LookupMergeTreeCompactRewriter(int maxLevel, CoreOptions.MergeEngine mergeEngine, LookupLevels<T> lookupLevels, FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter, LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T> wrapperFactory, boolean produceChangelog, DeletionVectorsMaintainer dvMaintainer, CoreOptions options)
MergeTreeCompactManager(ExecutorService executor, Levels levels, CompactStrategy strategy, Comparator<InternalRow> keyComparator, long compactionFileSize, int numSortedRunStopTrigger, CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter, DeletionVectorsMaintainer dvMaintainer, boolean lazyGenDeletionFile)

Uses of DeletionVectorsMaintainer in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as DeletionVectorsMaintainer

Modifier and Type	Field and Description
protected DeletionVectorsMaintainer	FileStoreWrite.State.deletionVectorsMaintainer
DeletionVectorsMaintainer	AbstractFileStoreWrite.WriterContainer.deletionVectorsMaintainer

Methods in org.apache.paimon.operation with parameters of type DeletionVectorsMaintainer

Modifier and Type	Method and Description
protected abstract RecordWriter<T>	AbstractFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer deletionVectorsMaintainer)
protected MergeTreeWriter	KeyValueFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected RecordWriter<InternalRow>	AppendOnlyFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected CompactManager	AppendOnlyUnawareBucketFileStoreWrite.getCompactManager(BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected CompactManager	AppendOnlyFixedBucketFileStoreWrite.getCompactManager(BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected abstract CompactManager	AppendOnlyFileStoreWrite.getCompactManager(BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)

Constructors in org.apache.paimon.operation with parameters of type DeletionVectorsMaintainer

Constructor and Description
State(BinaryRow partition, int bucket, long baseSnapshotId, long lastModifiedCommitIdentifier, Collection<DataFileMeta> dataFiles, long maxSequenceNumber, IndexMaintainer<T> indexMaintainer, DeletionVectorsMaintainer deletionVectorsMaintainer, CommitIncrement commitIncrement)
WriterContainer(RecordWriter<T> writer, IndexMaintainer<T> indexMaintainer, DeletionVectorsMaintainer deletionVectorsMaintainer, Long baseSnapshotId)