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)
