Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
This operator is responsible for unbounded streaming inner/left/right/full join, and will be optimized in following cases:
- If the join keys (with equality condition) are also primary key, we will have a more efficient state layout
- If the inputs have primary keys, but join keys are not primary key, we can also come up with an efficient state layout
- Inputs don't have primary keys, this will go to default implementation
Attachments
Issue Links
- is a child of
-
FLINK-11489 Add an initial Blink SQL streaming runtime
- Closed
- links to