org.apache.flink.streaming.api.functions.source

Interface ParallelSourceFunction<OUT>

Type Parameters:

OUT - The type of the records produced by this source.

All Superinterfaces:

Function, Serializable, SourceFunction<OUT>

All Known Implementing Classes:

ArrowSourceFunction, DataGeneratorSource, EventsGeneratorSource, FlinkDynamoDBStreamsConsumer, FlinkKafkaConsumer, FlinkKafkaConsumerBase, FlinkKafkaShuffleConsumer, FlinkKinesisConsumer, FromSplittableIteratorFunction, InputFormatSourceFunction, NiFiSource, PubSubSource, RichParallelSourceFunction, SequenceGeneratorSource, StatefulSequenceSource, StatefulStreamingJob.MySource

@Public
public interface ParallelSourceFunction<OUT>
extends SourceFunction<OUT>

A stream data source that is executed in parallel. Upon execution, the runtime will execute as many parallel instances of this function as configured parallelism of the source.

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.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

SourceFunction.SourceContext<T>

Method Summary

Methods inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

cancel, run