Package org.apache.flink.connector.file.table.stream

Class ProcTimeCommitTrigger

java.lang.Object

org.apache.flink.connector.file.table.stream.ProcTimeCommitTrigger

All Implemented Interfaces:

PartitionCommitTrigger

@Internal
public class ProcTimeCommitTrigger
extends Object
implements PartitionCommitTrigger

Partition commit trigger by creation time and processing time service. It'll commit the partition predicated to be committable by PartitionCommitPredicate

Constructor Summary

Constructors

Constructor	Description
ProcTimeCommitTrigger(boolean isRestored, OperatorStateStore stateStore, ProcessingTimeService procTimeService, PartitionCommitPredicate partitionCommitPredicate)

Method Summary

Modifier and Type	Method	Description
void	addPartition(String partition)	Add a pending partition.
List<String>	committablePartitions(long checkpointId)	Get committable partitions, and cleanup useless watermarks and partitions.
List<String>	endInput()	End input, return committable partitions and clear.
void	snapshotState(long checkpointId, long watermark)	Snapshot state.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcTimeCommitTrigger

public ProcTimeCommitTrigger(boolean isRestored,
                             OperatorStateStore stateStore,
                             ProcessingTimeService procTimeService,
                             PartitionCommitPredicate partitionCommitPredicate)
                      throws Exception

Throws:

Exception

Method Detail

addPartition

public void addPartition(String partition)

Description copied from interface: PartitionCommitTrigger

Add a pending partition.

Specified by:

addPartition in interface PartitionCommitTrigger

committablePartitions

public List<String> committablePartitions(long checkpointId)

Description copied from interface: PartitionCommitTrigger

Get committable partitions, and cleanup useless watermarks and partitions.

Specified by:

committablePartitions in interface PartitionCommitTrigger

snapshotState

public void snapshotState(long checkpointId,
                          long watermark)
                   throws Exception

Description copied from interface: PartitionCommitTrigger

Snapshot state.

Specified by:

snapshotState in interface PartitionCommitTrigger

Throws:

Exception

endInput

public List<String> endInput()

Description copied from interface: PartitionCommitTrigger

End input, return committable partitions and clear.

Specified by:

endInput in interface PartitionCommitTrigger