[flink] Replace legacy SourceFunction with v2 Source#4614

Merged

tsreaper merged 8 commits intoapache:masterfrom

yunfengzhou-hub:2.0-preview-source

Dec 13, 2024

Commits on Dec 6, 2024

[flink] Replace legacy SourceFunction with v2 Source
yunfengzhou-hub
committed
[flink] Remove deprecated SourceFunction in existing Flink versions
yunfengzhou-hub
committed

Commits on Dec 12, 2024

[flink] Extract SourceListState as public utility class
yunfengzhou-hub
committed

Commits on Dec 13, 2024

[flink] Enrich TestingSourceOperator Javadoc with reference info
yunfengzhou-hub
committed