Package | Description |
---|---|
org.apache.flink.connector.file.table.stream |
Modifier and Type | Method and Description |
---|---|
static PartitionCommitPredicate.PredicateContext |
PartitionCommitPredicate.createPredicateContext(String partition,
long createProcTime,
long currentProcTime,
long currentWatermark) |
Modifier and Type | Method and Description |
---|---|
boolean |
PartitionTimeCommitPredicate.isPartitionCommittable(PartitionCommitPredicate.PredicateContext predicateContext) |
boolean |
PartitionCommitPredicate.isPartitionCommittable(PartitionCommitPredicate.PredicateContext predicateContext) |
boolean |
ProcTimeCommitPredicate.isPartitionCommittable(PartitionCommitPredicate.PredicateContext predicateContext) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.