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)
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–2017 The Apache Software Foundation. All rights reserved.