public class ChangelogCompactTask extends Object implements Serializable
ChangelogCompactTask
to compact several changelog files from the same partition into one
file, in order to reduce the number of small files.Constructor and Description |
---|
ChangelogCompactTask(long checkpointId,
BinaryRow partition,
Map<Integer,List<DataFileMeta>> newFileChangelogFiles,
Map<Integer,List<DataFileMeta>> compactChangelogFiles) |
Modifier and Type | Method and Description |
---|---|
long |
checkpointId() |
Map<Integer,List<DataFileMeta>> |
compactChangelogFiles() |
List<Committable> |
doCompact(FileStoreTable table) |
boolean |
equals(Object o) |
int |
hashCode() |
Map<Integer,List<DataFileMeta>> |
newFileChangelogFiles() |
BinaryRow |
partition() |
String |
toString() |
public ChangelogCompactTask(long checkpointId, BinaryRow partition, Map<Integer,List<DataFileMeta>> newFileChangelogFiles, Map<Integer,List<DataFileMeta>> compactChangelogFiles)
public long checkpointId()
public BinaryRow partition()
public Map<Integer,List<DataFileMeta>> newFileChangelogFiles()
public Map<Integer,List<DataFileMeta>> compactChangelogFiles()
public List<Committable> doCompact(FileStoreTable table) throws Exception
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.