org.apache.paimon.flink.sink.partition

Class PartitionMarkDoneTrigger

java.lang.Object

org.apache.paimon.flink.sink.partition.PartitionMarkDoneTrigger

public class PartitionMarkDoneTrigger
extends Object

Trigger to mark partitions done with streaming job.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PartitionMarkDoneTrigger.State State to store partitions.

Constructor Summary

Constructors

Constructor and Description
PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state, PartitionTimeExtractor timeExtractor, java.time.Duration timeInterval, java.time.Duration idleTime, boolean markDoneWhenEndInput)
PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state, PartitionTimeExtractor timeExtractor, java.time.Duration timeInterval, java.time.Duration idleTime, long currentTimeMillis, boolean markDoneWhenEndInput)

Method Summary

Modifier and Type	Method and Description
static PartitionMarkDoneTrigger	create(CoreOptions coreOptions, boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore)
List<String>	donePartitions(boolean endInput)
void	notifyPartition(String partition)
void	snapshotState()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionMarkDoneTrigger

public PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state,
                                PartitionTimeExtractor timeExtractor,
                                @Nullable
                                java.time.Duration timeInterval,
                                @Nullable
                                java.time.Duration idleTime,
                                boolean markDoneWhenEndInput)
                         throws Exception

Throws:

Exception

PartitionMarkDoneTrigger

public PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state,
                                PartitionTimeExtractor timeExtractor,
                                @Nullable
                                java.time.Duration timeInterval,
                                @Nullable
                                java.time.Duration idleTime,
                                long currentTimeMillis,
                                boolean markDoneWhenEndInput)
                         throws Exception

Throws:

Exception

Method Detail

notifyPartition

public void notifyPartition(String partition)

donePartitions

public List<String> donePartitions(boolean endInput)

snapshotState

public void snapshotState()
                   throws Exception

Throws:

Exception

create

public static PartitionMarkDoneTrigger create(CoreOptions coreOptions,
                                              boolean isRestored,
                                              org.apache.flink.api.common.state.OperatorStateStore stateStore)
                                       throws Exception

Throws:

Exception