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

Interface PartitionCommitPredicate

All Known Implementing Classes:

PartitionTimeCommitPredicate, ProcTimeCommitPredicate

@Internal
public interface PartitionCommitPredicate

Partition commit predicate. See PartitionTimeCommitPredicate. See ProcTimeCommitPredicate

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PartitionCommitPredicate.PredicateContext Context that PartitionCommitPredicate can use for getting context about a partition.

Method Summary

Modifier and Type	Method and Description
static PartitionCommitPredicate	create(Configuration conf, ClassLoader cl, List<String> partitionKeys)
static PartitionCommitPredicate	createPartitionTimeCommitPredicate(Configuration conf, ClassLoader cl, List<String> partitionKeys)
static PartitionCommitPredicate.PredicateContext	createPredicateContext(String partition, long createProcTime, long currentProcTime, long currentWatermark)
static PartitionCommitPredicate	createProcTimeCommitPredicate(Configuration conf)
boolean	isPartitionCommittable(PartitionCommitPredicate.PredicateContext predicateContext)

Method Detail

isPartitionCommittable

boolean isPartitionCommittable(PartitionCommitPredicate.PredicateContext predicateContext)

createPredicateContext

static PartitionCommitPredicate.PredicateContext createPredicateContext(String partition,
                                                                        long createProcTime,
                                                                        long currentProcTime,
                                                                        long currentWatermark)

createPartitionTimeCommitPredicate

static PartitionCommitPredicate createPartitionTimeCommitPredicate(Configuration conf,
                                                                   ClassLoader cl,
                                                                   List<String> partitionKeys)

createProcTimeCommitPredicate

static PartitionCommitPredicate createProcTimeCommitPredicate(Configuration conf)

create

static PartitionCommitPredicate create(Configuration conf,
                                       ClassLoader cl,
                                       List<String> partitionKeys)