org.apache.paimon.flink.sink.partition

Class PartitionMarkDone

java.lang.Object

org.apache.paimon.flink.sink.partition.PartitionMarkDone

All Implemented Interfaces:

Closeable, AutoCloseable, PartitionListener

public class PartitionMarkDone
extends Object
implements PartitionListener

Mark partition done.

Constructor Summary

Constructors

Constructor and Description
PartitionMarkDone(InternalRowPartitionComputer partitionComputer, PartitionMarkDoneTrigger trigger, List<PartitionMarkDoneAction> actions, boolean waitCompaction, FlinkConnectorOptions.PartitionMarkDoneActionMode partitionMarkDoneActionMode)

Method Summary

Modifier and Type	Method and Description
void	close()
static Optional<PartitionMarkDone>	create(ClassLoader cl, boolean isStreaming, boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, FileStoreTable table)
static void	markDone(List<String> partitions, List<PartitionMarkDoneAction> actions)
void	notifyCommittable(List<ManifestCommittable> committables)
void	snapshotState()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionMarkDone

public PartitionMarkDone(InternalRowPartitionComputer partitionComputer,
                         PartitionMarkDoneTrigger trigger,
                         List<PartitionMarkDoneAction> actions,
                         boolean waitCompaction,
                         FlinkConnectorOptions.PartitionMarkDoneActionMode partitionMarkDoneActionMode)

Method Detail

create

public static Optional<PartitionMarkDone> create(ClassLoader cl,
                                                 boolean isStreaming,
                                                 boolean isRestored,
                                                 org.apache.flink.api.common.state.OperatorStateStore stateStore,
                                                 FileStoreTable table)
                                          throws Exception

Throws:

Exception

notifyCommittable

public void notifyCommittable(List<ManifestCommittable> committables)

Specified by:

notifyCommittable in interface PartitionListener

markDone

public static void markDone(List<String> partitions,
                            List<PartitionMarkDoneAction> actions)

snapshotState

public void snapshotState()
                   throws Exception

Specified by:

snapshotState in interface PartitionListener

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException