flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Next steps: SQL / StreamSQL support
Date Mon, 21 Mar 2016 16:56:09 GMT
Hi everybody,

on Friday we merged the working branch to put the Table API on top of
Calcite back to master.
This was the first step towards adding SQL support to Flink as outlined in
the design document [1] (the document was updated to reflect design
decisions done while implementing task 1).

According to the design doc, the next step is to add support for SQL
queries on DataSets and Table API Tables.  We created two JIRA issues to
track this effort:
- FLINK-3639: Add methods to register DataSets and Tables in
- FLINK-3640: Add support for SQL queries on registered DataSets and Tables

Subsequent efforts will be to add support for SQL queries on external
tables (CSV, Parquet, etc files, DBMS, etc.), extending coverage of SQL
standard (sort, outer joins, etc.), and defining table sinks to emit the

The following document shows the syntax to register tables (DataSets,
DataStreams, Tables, external sources), query them, and to define table
sinks to write a Table to an external storage system [2].

At the same time, we are working on extending the Table API for streaming
tables (FLINK-3547).

As usual, feedback, comments, and contributions are highly welcome :-)

Best, Fabian


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message