[FLINK-5441] Directly allow SQL queries on a Table

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3.0
• Component/s: Table SQL / API
• Assignee: Jark Wu
• Reporter: Timo Walther
• Created: 10/Jan/17 15:47
• Updated: 14/Mar/17 08:18
• Resolved: 14/Mar/17 08:18

Description

Right now a user has to register a table before it can be used in SQL queries. In order to allow more fluent programming we propose calling SQL directly on a table. An underscore can be used to reference the current table:

myTable.sql("SELECT a, b, c FROM _ WHERE d = 12")

Issue Links

• links to: GitHub Pull Request #3107