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

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Component/s: Library / Machine Learning
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Xu Yang
• Created: 14/Oct/19 11:41
• Updated: 16/Oct/22 08:29
• Resolved: 16/Oct/22 08:29

Description

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.

Issue Links

• links to: GitHub Pull Request #9897