[jira] [Created] (FLINK-14390) Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator.

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14390) Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator.

Shang Yuanchun (Jira)
Xu Yang created FLINK-14390:
-------------------------------

             Summary: Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator.
                 Key: FLINK-14390
                 URL: https://issues.apache.org/jira/browse/FLINK-14390
             Project: Flink
          Issue Type: Sub-task
          Components: Library / Machine Learning
            Reporter: Xu Yang


This PR adds sql operators (select, groupby, join, etc.) which apply on <code>AlgoOperator</code>s. It is equivalent to applying the sql operators on the output tables of the <code>AlgoOperator</code>s.
 * Add SqlOperators for implementation of the sql operators that apply on <code>AlgoOperator</code>s.
 * Update AlgoOperator by adding some methods of sql operations.
 * Update BatchOperator by adding some methods of sql operations.
 * Update StreamOperator by adding some methods of sql operations.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)