You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2014/10/19 18:35:33 UTC

[jira] [Created] (FLINK-1174) Add operator for temporal joins over time windows of two DataStreams

Gyula Fora created FLINK-1174:
---------------------------------

             Summary: Add operator for temporal joins over time windows of two DataStreams
                 Key: FLINK-1174
                 URL: https://issues.apache.org/jira/browse/FLINK-1174
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Gyula Fora
            Priority: Minor


There is a variety of use-cases that need an operator for joining data stream over predefined time windows by some field. 

Currently there is no dedicated operator to support this, however it could be implemented as a special case of the windowReduce operator of the ConnectedDataStream which applies the a CoWindowFunction on the list of tuples in the time windows for the two data streams.

There is a temporal cross operator that has already been implemented which can serve as a good starting point here:

https://github.com/mbalassi/incubator-flink/commit/876d4792478378177ad644f121c2b2460600b792





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)