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

Packages that use PartitionCommitPredicate

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

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

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

Modifier and Type	Class	Description
class	PartitionTimeCommitPredicate	Partition commit predicate by partition time and watermark, if 'watermark' > 'partition-time' + 'delay', the partition is committable.
class	ProcTimeCommitPredicate	Partition commit trigger by creation time and processing time service, if 'current processing time' > 'partition creation time' + 'delay', the partition is committable.

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

Modifier and Type	Method	Description
static PartitionCommitPredicate	PartitionCommitPredicate.create(org.apache.flink.configuration.Configuration conf, ClassLoader cl, List<String> partitionKeys)
static PartitionCommitPredicate	PartitionCommitPredicate.createPartitionTimeCommitPredicate(org.apache.flink.configuration.Configuration conf, ClassLoader cl, List<String> partitionKeys)
static PartitionCommitPredicate	PartitionCommitPredicate.createProcTimeCommitPredicate(org.apache.flink.configuration.Configuration conf)

Constructors in org.apache.flink.connector.file.table.stream with parameters of type PartitionCommitPredicate

Constructor	Description
PartitionTimeCommitTrigger(boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, PartitionCommitPredicate partitionCommitPredicate)
ProcTimeCommitTrigger(boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService procTimeService, PartitionCommitPredicate partitionCommitPredicate)