[FLINK-12708] Introduce new Interfaces for source and sink to make Blink runner work

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 03/Jun/19 09:19
• Updated: 13/Jun/19 06:45
• Resolved: 13/Jun/19 06:45

Description

In order to support Blink batch and temporal table join, we need some new source&sink interfaces.

1. Introduce InputFormatTableSource

• add isBounded interface to StreamTableSource
• InputFormatTableSource extends StreamTableSource and expose getInputFormat
• removes BatchTableSource and StreamTableSource in blink planner
• support it in blink and flink planner

2. Introduce OutputFormatTableSink

• OutputFormatTableSink extends StreamTableSink expose getOutputFormat
• removes BatchTableSink in blink planner
• support it in blink and flink planner

3. Introduce LookupableTableSource

• removes LookupableTableSource and LookupConfig in blink planner
• support it only in blink planner

4. Expose getTableStats in TableSource

• support it in blink and flink planner

Issue Links

• is a child of: FLINK-11488 Add a basic Blink planner framework
• links to: GitHub Pull Request #8678