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

Interface PartitionCommitTrigger

All Known Implementing Classes:

PartitionTimeCommitTrigger, ProcTimeCommitTrigger

@Internal
public interface PartitionCommitTrigger

Partition commit trigger. See PartitionTimeCommitTrigger. See ProcTimeCommitTrigger.

Method Summary

Modifier and Type	Method and Description
void	addPartition(String partition) Add a pending partition.
List<String>	committablePartitions(long checkpointId) Get committable partitions, and cleanup useless watermarks and partitions.
static PartitionCommitTrigger	create(boolean isRestored, OperatorStateStore stateStore, Configuration conf, ClassLoader cl, List<String> partitionKeys, ProcessingTimeService procTimeService)
List<String>	endInput() End input, return committable partitions and clear.
void	snapshotState(long checkpointId, long watermark) Snapshot state.

Method Detail

addPartition

void addPartition(String partition)

Add a pending partition.

committablePartitions

List<String> committablePartitions(long checkpointId)
                            throws IOException

Get committable partitions, and cleanup useless watermarks and partitions.

Throws:

IOException

endInput

List<String> endInput()

End input, return committable partitions and clear.

snapshotState

void snapshotState(long checkpointId,
                   long watermark)
            throws Exception

Snapshot state.

Throws:

Exception

create

static PartitionCommitTrigger create(boolean isRestored,
                                     OperatorStateStore stateStore,
                                     Configuration conf,
                                     ClassLoader cl,
                                     List<String> partitionKeys,
                                     ProcessingTimeService procTimeService)
                              throws Exception

Throws:

Exception