@Internal public abstract class EpochAwareCoProcessFunction<I1,I2,O> extends org.apache.flink.streaming.api.functions.co.CoProcessFunction<I1,I2,O> implements EpochAware
CoProcessFunction
that also provide the attach epoch with each record. It
is executed as all-round inside the iteration.Constructor and Description |
---|
EpochAwareCoProcessFunction() |
Modifier and Type | Method and Description |
---|---|
void |
processElement1(I1 input,
org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context,
org.apache.flink.util.Collector<O> collector) |
abstract void |
processElement1(I1 input,
int epoch,
org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context,
org.apache.flink.util.Collector<O> collector) |
void |
processElement2(I2 input,
org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context,
org.apache.flink.util.Collector<O> collector) |
abstract void |
processElement2(I2 input,
int epoch,
org.apache.flink.streaming.api.functions.co.CoProcessFunction.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 processElement1(I1 input, org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context, org.apache.flink.util.Collector<O> collector) throws Exception
public final void processElement2(I2 input, org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context, org.apache.flink.util.Collector<O> collector) throws Exception
public abstract void processElement1(I1 input, int epoch, org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context, org.apache.flink.util.Collector<O> collector) throws Exception
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.