Fabian Hueske created FLINK-3221:
------------------------------------

             Summary: Move Table API on top of Apache Calcite
                 Key: FLINK-3221
                 URL: https://issues.apache.org/jira/browse/FLINK-3221
             Project: Flink
          Issue Type: Task
          Components: Table API
            Reporter: Fabian Hueske


The goal of this task is to move the Table API on top of Calcite and preserve 
the feature set of the batch part. Calcite is a SQL optimization and 
translation framework. It includes a SQL Parser, a catalog component, a 
validator, and a rule-based (relational) optimizer. This is the first step for 
adding SQL and StreamSQL support to Flink.

Since the streaming part of the Table API is rather a proof-of-concept 
implementation and only features selection and projection, we exclude it from 
this task. With the current Table API, queries can only be embedded into 
DataSet (or DataStream) programs with manually defined schema for 
DataSet/DataStreams. We do not add support for external data stores (CSV, 
Parquet, ORC files, HBase, etc.) as part of this task. Instead we only consume 
data that comes from a DataSet/DataStream operator.

More details can be found in the design document for SQL / StreamSQL on Flink.





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to