[FLINK-19719] [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major
• Assignee: Unassigned
• Reporter: Jingsong Lee
• Created: 20/Oct/20 02:55
• Updated: 30/Jan/24 16:32
• Resolved: 08/Jun/21 01:46

Description

FLIP: https://cwiki.apache.org/confluence/display/FLINK/FLIP-146%3A+Improve+new+TableSource+and+TableSink+interfaces

Issue Links

• is a parent of: FLINK-19937 Support sink parallelism option for all connectors
• relates to: FLINK-34270 Update connector developer-facing doc for FLIP-367 & 146

Sub-Tasks

• Introduce new Providers and parallelism API: Closed
• Implement new providers for blink planner: Closed
• Implement ParallelismProvider for sink in blink planner: Closed
• Migrate Filesystem connector to new table source sink interface: Closed
• Migrate Hive connector to new table source sink interface: Closed
• Introduce BulkFormatFactory to integrate new FileSource to table: Closed
• Integrate Filesystem and Hive connector with changelog format (e.g. debezium-json): Closed
• Filter push down not work for filesystem connector: Closed
• Introduce new provider for unified Sink API and implement in planner: Closed