Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12088

Introduce unbounded streaming inner/left/right/full join operator

    XMLWordPrintableJSON

Details

    Description

      This operator is responsible for unbounded streaming inner/left/right/full 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

      Attachments

        Issue Links

          Activity

            People

              jark Jark Wu
              ykt836 Kurt Young
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m