public abstract class CompactTask extends Object implements Callable<CompactResult>
Constructor and Description |
---|
CompactTask(CompactionMetrics.Reporter metricsReporter) |
Modifier and Type | Method and Description |
---|---|
CompactResult |
call() |
protected abstract CompactResult |
doCompact()
Perform compaction.
|
protected String |
logMetric(long startMillis,
List<DataFileMeta> compactBefore,
List<DataFileMeta> compactAfter) |
public CompactTask(@Nullable CompactionMetrics.Reporter metricsReporter)
public CompactResult call() throws Exception
call
in interface Callable<CompactResult>
Exception
protected String logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)
protected abstract CompactResult doCompact() throws Exception
CompactResult
of compact before and compact after files.Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.