Uses of Interface
org.apache.flink.connector.file.table.stream.PartitionCommitTrigger

Packages that use PartitionCommitTrigger

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

Uses of PartitionCommitTrigger in org.apache.flink.connector.file.table.stream

Classes in org.apache.flink.connector.file.table.stream that implement PartitionCommitTrigger

Modifier and Type	Class	Description
class	PartitionTimeCommitTrigger	Partition commit trigger by partition time and watermark.
class	ProcTimeCommitTrigger	Partition commit trigger by creation time and processing time service.

Methods in org.apache.flink.connector.file.table.stream that return PartitionCommitTrigger

Modifier and Type	Method	Description
static PartitionCommitTrigger	PartitionCommitTrigger.create(boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, org.apache.flink.configuration.Configuration conf, ClassLoader cl, List<String> partitionKeys, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService procTimeService)