public class PartitionMarkDoneTrigger extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
PartitionMarkDoneTrigger.State
State to store partitions.
|
Constructor and Description |
---|
PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state,
PartitionTimeExtractor timeExtractor,
java.time.Duration timeInterval,
java.time.Duration idleTime,
boolean markDoneWhenEndInput) |
PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state,
PartitionTimeExtractor timeExtractor,
java.time.Duration timeInterval,
java.time.Duration idleTime,
long currentTimeMillis,
boolean markDoneWhenEndInput) |
Modifier and Type | Method and Description |
---|---|
static PartitionMarkDoneTrigger |
create(CoreOptions coreOptions,
boolean isRestored,
org.apache.flink.api.common.state.OperatorStateStore stateStore) |
List<String> |
donePartitions(boolean endInput) |
void |
notifyPartition(String partition) |
void |
snapshotState() |
public PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state, PartitionTimeExtractor timeExtractor, @Nullable java.time.Duration timeInterval, @Nullable java.time.Duration idleTime, boolean markDoneWhenEndInput) throws Exception
Exception
public PartitionMarkDoneTrigger(PartitionMarkDoneTrigger.State state, PartitionTimeExtractor timeExtractor, @Nullable java.time.Duration timeInterval, @Nullable java.time.Duration idleTime, long currentTimeMillis, boolean markDoneWhenEndInput) throws Exception
Exception
public void notifyPartition(String partition)
public static PartitionMarkDoneTrigger create(CoreOptions coreOptions, boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore) throws Exception
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.