org.apache.paimon.flink.compact

Class AppendTableCompactor

java.lang.Object

org.apache.paimon.flink.compact.AppendTableCompactor

public class AppendTableCompactor
extends Object

The Compactor of unaware bucket table to execute AppendCompactTask.

Field Summary

Fields

Modifier and Type	Field and Description
protected Queue<Future<CommitMessage>>	result

Constructor Summary

Constructors

Constructor and Description
AppendTableCompactor(FileStoreTable table, String commitUser, java.util.function.Supplier<ExecutorService> lazyCompactExecutor, org.apache.flink.metrics.MetricGroup metricGroup)

Method Summary

Modifier and Type	Method and Description
void	close()
List<Committable>	prepareCommit(boolean waitCompaction, long checkpointId)
void	processElement(AppendCompactTask task)
Iterable<Future<CommitMessage>>	result()

Methods inherited from class java.lang.Object

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

Field Detail

result

protected final transient Queue<Future<CommitMessage>> result

Constructor Detail

AppendTableCompactor

public AppendTableCompactor(FileStoreTable table,
                            String commitUser,
                            java.util.function.Supplier<ExecutorService> lazyCompactExecutor,
                            @Nullable
                            org.apache.flink.metrics.MetricGroup metricGroup)

Method Detail

processElement

public void processElement(AppendCompactTask task)
                    throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception

prepareCommit

public List<Committable> prepareCommit(boolean waitCompaction,
                                       long checkpointId)
                                throws IOException

Throws:

IOException

result

public Iterable<Future<CommitMessage>> result()