[FLINK-16008] Add rules to transpose the join condition of Python Correlate node

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Resolved
• Fix Version/s: 1.11.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Huang Xingbo
• Reporter: Huang Xingbo
• Created: 12/Feb/20 00:56
• Updated: 13/Mar/20 03:07
• Resolved: 13/Mar/20 03:07

Description

Because the conditions can’t be executed in Python correlate node, this rule will transpose the conditions after the Python correlate node if the join type is inner join.

Issue Links

• links to: GitHub Pull Request #11299