@Internal public abstract class EpochAwareAllRoundProcessFunction<I,O> extends org.apache.flink.streaming.api.functions.ProcessFunction<I,O> implements EpochAware
ProcessFunction
that also provide the attach epoch with each record. It is
executed as all-round inside the iteration.Constructor and Description |
---|
EpochAwareAllRoundProcessFunction() |
Modifier and Type | Method and Description |
---|---|
abstract void |
processElement(I input,
int epoch,
org.apache.flink.streaming.api.functions.ProcessFunction.Context context,
org.apache.flink.util.Collector<O> collector) |
void |
processElement(I input,
org.apache.flink.streaming.api.functions.ProcessFunction.Context context,
org.apache.flink.util.Collector<O> collector) |
void |
setEpochSupplier(java.util.function.Supplier<Integer> epochSupplier) |
public void setEpochSupplier(java.util.function.Supplier<Integer> epochSupplier)
setEpochSupplier
in interface EpochAware
public final void processElement(I input, org.apache.flink.streaming.api.functions.ProcessFunction.Context context, org.apache.flink.util.Collector<O> collector) throws Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.