public abstract class CompactTask extends Object implements Callable<CompactResult>
Constructor and Description |
---|
CompactTask(List<DataFileMeta> inputs) |
Modifier and Type | Method and Description |
---|---|
CompactResult |
call() |
protected abstract CompactResult |
doCompact(List<DataFileMeta> inputs)
Perform compaction.
|
protected String |
logMetric(long startMillis,
List<DataFileMeta> compactBefore,
List<DataFileMeta> compactAfter) |
public CompactTask(List<DataFileMeta> inputs)
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(List<DataFileMeta> inputs) throws Exception
inputs
- the candidate files to be compactedCompactResult
of compact before and compact after files.Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.