[Task]: Introduce new Flink source implementations based on FLIP-27 Source interfaces.

[becketqin]

What needs to happen?

This task is a part of Flink batch runner migration from DataSet API to DataStream API. Because we are going to use DataStream for both streaming and batch job execution, we need to change the existing source implementations to be based on FLIP-27 Source interfaces. This will allow DataStream to run with bounded input in batch execution mode.

Issue Priority

Priority: 2 (default / most normal work should be filed as P2)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[becketqin]

.take-issue