Jark Wu created FLINK-12743:
-------------------------------
Summary: Introduce unbounded streaming anti/semi join operator
Key: FLINK-12743
URL: https://issues.apache.org/jira/browse/FLINK-12743
Project: Flink
Issue Type: New Feature
Components: Table SQL / Runtime
Reporter: Jark Wu
Assignee: Jark Wu
This operator is responsible for unbounded streaming semi/anti join, and will
be optimized in following cases:
1. If the join keys (with equality condition) are also primary key, we will
have a more efficient state layout
2. If the inputs have primary keys, but join keys are not primary key, we can
also come up with an efficient state layout
3. Inputs don't have primary keys, this will go to default implementation
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
