com.lancedb.lance.compaction

Class Compaction

java.lang.Object

com.lancedb.lance.compaction.Compaction

public class Compaction
extends Object

The entrypoint of distributed compaction-related methods.

Constructor Summary

Constructors

Constructor and Description
Compaction()

Method Summary

Modifier and Type	Method and Description
static CompactionMetrics	commitCompaction(Dataset dataset, List<RewriteResult> rewriteResults, CompactionOptions compactionOptions)
static CompactionMetrics	nativeCommitCompaction(Dataset dataset, List<RewriteResult> rewriteResults, Optional<Long> targetRowsPerFragment, Optional<Long> maxRowsPerGroup, Optional<Long> maxBytesPerFile, Optional<Boolean> materializeDeletions, Optional<Float> materializeDeletionsThreshold, Optional<Long> numThreads, Optional<Long> batchSize, Optional<Boolean> deferIndexRemap)
static CompactionPlan	planCompaction(Dataset dataset, CompactionOptions compactionOptions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Compaction

public Compaction()

Method Detail

planCompaction

public static CompactionPlan planCompaction(Dataset dataset,
                                            CompactionOptions compactionOptions)

commitCompaction

public static CompactionMetrics commitCompaction(Dataset dataset,
                                                 List<RewriteResult> rewriteResults,
                                                 CompactionOptions compactionOptions)

nativeCommitCompaction

public static CompactionMetrics nativeCommitCompaction(Dataset dataset,
                                                       List<RewriteResult> rewriteResults,
                                                       Optional<Long> targetRowsPerFragment,
                                                       Optional<Long> maxRowsPerGroup,
                                                       Optional<Long> maxBytesPerFile,
                                                       Optional<Boolean> materializeDeletions,
                                                       Optional<Float> materializeDeletionsThreshold,
                                                       Optional<Long> numThreads,
                                                       Optional<Long> batchSize,
                                                       Optional<Boolean> deferIndexRemap)