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 (AbstractRichFunction.open(org.apache.flink.configuration.Configuration)
and AbstractRichFunction.close()
.
SourceFunction.SourceContext<T>
Constructor and Description |
---|
RichParallelSourceFunction() |
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
cancel, run
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.