org.apache.flink.iteration.functions

Class EpochAwareCoProcessFunction<I1,I2,O>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.co.CoProcessFunction<I1,I2,O>

org.apache.flink.iteration.functions.EpochAwareCoProcessFunction<I1,I2,O>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, EpochAware

@Internal
public abstract class EpochAwareCoProcessFunction<I1,I2,O>
extends org.apache.flink.streaming.api.functions.co.CoProcessFunction<I1,I2,O>
implements EpochAware

A specialized CoProcessFunction that also provide the attach epoch with each record. It is executed as all-round inside the iteration.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.co.CoProcessFunction

org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context, org.apache.flink.streaming.api.functions.co.CoProcessFunction.OnTimerContext

Constructor Summary

Constructors

Constructor and Description
EpochAwareCoProcessFunction()

Method Summary

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)

Methods inherited from class org.apache.flink.streaming.api.functions.co.CoProcessFunction

onTimer

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EpochAwareCoProcessFunction

public EpochAwareCoProcessFunction()

Method Detail

setEpochSupplier

public void setEpochSupplier(java.util.function.Supplier<Integer> epochSupplier)

Specified by:

setEpochSupplier in interface EpochAware

processElement1

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

Specified by:

processElement1 in class org.apache.flink.streaming.api.functions.co.CoProcessFunction<I1,I2,O>

Throws:

Exception

processElement2

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

Specified by:

processElement2 in class org.apache.flink.streaming.api.functions.co.CoProcessFunction<I1,I2,O>

Throws:

Exception

processElement1

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

Throws:

Exception

processElement2

public abstract void processElement2(I2 input,
                                     int epoch,
                                     org.apache.flink.streaming.api.functions.co.CoProcessFunction.Context context,
                                     org.apache.flink.util.Collector<O> collector)
                              throws Exception

Throws:

Exception