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