Bulk Operation

FLINK-28045 Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API

FLINK-28045 Remove usage of FromElementsFunction

FLINK-28045 Cascade deprecation to non-private methods that reference SourceFunction

FLINK-28045 Promote Kinesis connector support to PublicEvolving

FLINK-28045 Migrate SourceFunction in Tests to Source V2 API

FLINK-28045 Migrate ParallelSourceFunction classes to Source V2 API or prepare for removal

FLINK-28045 Migrage Google PubSub connector to V2

FLINK-28045 Migrate RabbitMQ connector to Source V2 API

FLINK-28045 Cascade deprecation to classes that implement SourceFunction

FLINK-28045 Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods

FLINK-28045 Migrate o.a.f.streaming.examples to the new Source API

FLINK-28045 Introduce Source API utilities for throttling number of records emitted per second.

FLINK-28045 Promote ExternallyInducedSourceReader to non-experimental @Public

FLINK-28045 Introduce Source API alternative to SourceExecutionContext#fromElements(*) methods

FLINK-28045 Introduce Source API alternative to FiniteTestSource

FLINK-28045 Annotate StreamExecutionEnvironment#readFile()/readTextFile(*) methods deprecated in favor of FileSource#forRecordStreamFormat/forBulkFileFormat

FLINK-28045 Annotate SourceFunction as deprecated