[FLINK-16109] Move the Python scalar operators and table operators to separate package

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Resolved
• Fix Version/s: 1.11.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Huang Xingbo
• Reporter: Dian Fu
• Created: 17/Feb/20 03:39
• Updated: 17/Feb/20 08:18
• Resolved: 17/Feb/20 08:18

Description

Currently both the Python scalar operators and table operators are under the same package org.apache.flink.table.runtime.operators.python. There are already many operators under this package. After introducing the aggregate function support and Vectorized Python function support in the future, there will be more and more operators under the same package. 

We could improve it by the following package structure: org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.table
org.apache.flink.table.runtime.operators.python.aggregate (in the future)
org.apache.flink.table.runtime.operators.python.scalar.arrow (in the future)

As these classes are internal, it's safe to do so and there are no backwards compatibility issues.

Issue Links

• links to: GitHub Pull Request #11105