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

["Xu Yang (Jira)" <ji...@apache.org>]

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)