org.apache.paimon.flink.compact

Class UnawareBucketCompactor

java.lang.Object

org.apache.paimon.flink.compact.UnawareBucketCompactor

public class UnawareBucketCompactor
extends Object

The Compactor of unaware bucket table to execute UnawareAppendCompactionTask.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
UnawareBucketCompactor(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(UnawareAppendCompactionTask 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

UnawareBucketCompactor

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

Method Detail

processElement

public void processElement(UnawareAppendCompactionTask 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()