[jira] [Created] (FLINK-12743) Introduce unbounded streaming anti/semi join operator

["Jark Wu (JIRA)" <ji...@apache.org>]

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)