I
- Type of the input elements.O
- Type of the returned elements.@PublicEvolving public abstract class RichProcessFunction<I,O> extends AbstractRichFunction implements ProcessFunction<I,O>
ProcessFunction
. 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()
.ProcessFunction.Context, ProcessFunction.OnTimerContext
Constructor and Description |
---|
RichProcessFunction() |
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onTimer, processElement
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.