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

Add support for time-bounded joins in DataStream API

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Labels:
      None

      Description

      The goal is to implement a DataStream API to join together two streams based on a key and user defined time boundaries. 

      This feature should mirror what is already possible in Flink SQL:

      SELECT s1.value, s2.value FROM Table s1 JOIN Table s2 ON o.key = s.key AND o.rowtime BETWEEN s.rowtime AND s.rowtime + INTERVAL '1' HOUR;
      

        Attachments

          Activity

            People

            • Assignee:
              florianschmidt Florian Schmidt
              Reporter:
              florianschmidt Florian Schmidt
            • Votes:
              0 Vote for this issue
              Watchers:
              13 Start watching this issue

              Dates

              • Created:
                Updated: