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)
