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)