You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Chinmay Kolhatkar (JIRA)" <ji...@apache.org> on 2016/07/24 06:44:20 UTC

[jira] [Commented] (APEXMALHAR-1818) Integrate Calcite to support SQL

    [ https://issues.apache.org/jira/browse/APEXMALHAR-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15390972#comment-15390972 ] 

Chinmay Kolhatkar commented on APEXMALHAR-1818:
-----------------------------------------------

Hi,

I had a quick discussion with thomas on this. I would like to work on this.

As a first phase I'm planning to create an Apex Module (which can generate a sub-DAG at launch time), to convert SQL to a subDAG.
At the first, I would like to take a simple SQL statement (SELECT * FROM TABLE WHERE CONDITION) to convert into sub DAG.
This will be a standalone operator will get added to apex DAG by developer and based on SQL provide, convert that into a subDAG.

For eg. A -> CalciteModule -> C
will translate to 
A -> Projection -> Filter -> C

One this is achieved, we can look at further phases of integration.

I've been looking into this code (https://github.com/milinda/samza-sql/blob/master/samza-sql-planner/src/main/java/org/apache/samza/sql/QueryExecutor.java)  for example on creating a POC. Please suggest if there is a better example that I can look at.

Also, please suggest on above approach for phase one.

Thanks,
Chinmay.


> Integrate Calcite to support SQL
> --------------------------------
>
>                 Key: APEXMALHAR-1818
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-1818
>             Project: Apache Apex Malhar
>          Issue Type: New Feature
>          Components: query operators
>            Reporter: Amol
>              Labels: roadmap
>
> Once we have ability to generate a subdag, we should take a look at integrating Calcite into Apex. The operator that enables populate DAG, should use Calcite to generate the DAG, given a SQL query.



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