IN1
- Type of the first input.IN2
- Type of the second input.OUT
- Type of the returned elements.@PublicEvolving public abstract class RichCoProcessFunction<IN1,IN2,OUT> extends AbstractRichFunction implements CoProcessFunction<IN1,IN2,OUT>
CoProcessFunction
. As a RichFunction
, it gives
access to the RuntimeContext
and provides
setup and teardown methods: RichFunction.open(org.apache.flink.configuration.Configuration)
and RichFunction.close()
.CoProcessFunction.Context, CoProcessFunction.OnTimerContext
Constructor and Description |
---|
RichCoProcessFunction() |
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onTimer, processElement1, processElement2
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.