public class MergeTreeCompactTask extends CompactTask
Constructor and Description |
---|
MergeTreeCompactTask(Comparator<org.apache.flink.table.data.RowData> keyComparator,
long minFileSize,
CompactRewriter rewriter,
CompactUnit unit,
boolean dropDelete) |
Modifier and Type | Method and Description |
---|---|
protected CompactResult |
doCompact(List<DataFileMeta> inputs)
Perform compaction.
|
protected String |
logMetric(long startMillis,
List<DataFileMeta> compactBefore,
List<DataFileMeta> compactAfter) |
call
public MergeTreeCompactTask(Comparator<org.apache.flink.table.data.RowData> keyComparator, long minFileSize, CompactRewriter rewriter, CompactUnit unit, boolean dropDelete)
protected CompactResult doCompact(List<DataFileMeta> inputs) throws Exception
CompactTask
doCompact
in class CompactTask
inputs
- the candidate files to be compactedCompactResult
of compact before and compact after files.Exception
protected String logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)
logMetric
in class CompactTask
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.