OUT- The type of the records produced by this source.
@Public public interface ParallelSourceFunction<OUT> extends SourceFunction<OUT>
This interface acts only as a marker to tell the system that this source may
be executed in parallel. When different parallel instances are required to perform
different tasks, use the
RichParallelSourceFunction to get access to the runtime
context, which reveals information like the number of parallel tasks, and which parallel
task the current instance is.
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.