[FLINK-11703] Introduce TableEnvironment and support registerDataStream and sqlQuery

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 21/Feb/19 04:27
• Updated: 08/Mar/19 08:41
• Resolved: 08/Mar/19 08:40

Description

In order to support plan test, we need the ability to register a DataStream (or TableSource) and perform sql query on it.

This issue is aiming to introduce a basic and simple TableEnvironment which only support registerDataStream and sqlQuery.

In the context of FLINK-11067 and FLINK-11068 (convert TableEnvironments and Tables to interfaces), the introduced TableEnvironment in table-planner-blink is a temporary solution and will be refactored/moved to a BlinkPlanner, once FLINK-11067, FLINK-11068 is done.

Issue Links

• is a child of: FLINK-11488 Add a basic Blink planner framework
• is blocked by: FLINK-11449 Uncouple the Expression class from RexNodes
• links to: GitHub Pull Request #7851
• links to: GitHub Pull Request #7923