OUT- The type of the records produced by this source.
@Public public abstract class RichParallelSourceFunction<OUT> extends AbstractRichFunction implements ParallelSourceFunction<OUT>
The data source has access to context information (such as the number of parallel instances of
the source, and which parallel instance the current instance is) via
AbstractRichFunction.getRuntimeContext(). It also provides additional life-cycle methods (
|Constructor and Description|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.