Uses of Interface
org.apache.flink.streaming.api.functions.source.ParallelSourceFunction

Packages that use ParallelSourceFunction

Package	Description
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.nifi
org.apache.flink.streaming.examples.statemachine.generator
org.apache.flink.streaming.tests
org.apache.flink.test

Uses of ParallelSourceFunction in org.apache.flink.streaming.api.functions.source

Classes in org.apache.flink.streaming.api.functions.source that implement ParallelSourceFunction

Modifier and Type	Class and Description
class	FromSplittableIteratorFunction<T> A SourceFunction that reads elements from an SplittableIterator and emits them.
class	InputFormatSourceFunction<OUT> A SourceFunction that reads data using an InputFormat.
class	RichParallelSourceFunction<OUT> Base class for implementing a parallel data source.
class	StatefulSequenceSource A stateful streaming source that emits each number from a given interval exactly once, possibly in parallel.

Uses of ParallelSourceFunction in org.apache.flink.streaming.connectors.kafka

Classes in org.apache.flink.streaming.connectors.kafka that implement ParallelSourceFunction

Modifier and Type	Class and Description
class	FlinkKafkaConsumer<T> The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka.
class	FlinkKafkaConsumer010<T> The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.10.x.
class	FlinkKafkaConsumer011<T> The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.11.x.
class	FlinkKafkaConsumer08<T> The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.8.x.
class	FlinkKafkaConsumer081<T> Deprecated. Use FlinkKafkaConsumer08
class	FlinkKafkaConsumer082<T> Deprecated. Use FlinkKafkaConsumer08
class	FlinkKafkaConsumer09<T> The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from Apache Kafka 0.9.x.
class	FlinkKafkaConsumerBase<T> Base class of all Flink Kafka Consumer data sources.

Uses of ParallelSourceFunction in org.apache.flink.streaming.connectors.nifi

Classes in org.apache.flink.streaming.connectors.nifi that implement ParallelSourceFunction

Modifier and Type	Class and Description
class	NiFiSource A source that pulls data from Apache NiFi using the NiFi Site-to-Site client.

Uses of ParallelSourceFunction in org.apache.flink.streaming.examples.statemachine.generator

Classes in org.apache.flink.streaming.examples.statemachine.generator that implement ParallelSourceFunction

Modifier and Type	Class and Description
class	EventsGeneratorSource A event stream source that generates the events on the fly.

Uses of ParallelSourceFunction in org.apache.flink.streaming.tests

Classes in org.apache.flink.streaming.tests that implement ParallelSourceFunction

Modifier and Type	Class and Description
class	SequenceGeneratorSource This source function generates a sequence of long values per key.

Uses of ParallelSourceFunction in org.apache.flink.test

Classes in org.apache.flink.test that implement ParallelSourceFunction

Modifier and Type	Class and Description
static class	StatefulStreamingJob.MySource Stub source that emits one record per second.