Reza ardeshir rokni created BEAM-7386:
-----------------------------------------
Summary: Add Utility BiTemporalStreamJoin
Key: BEAM-7386
URL: https://issues.apache.org/jira/browse/BEAM-7386
Project: Beam
Issue Type: Improvement
Components: sdk-ideas
Affects Versions: 2.12.0
Reporter: Reza ardeshir rokni
Add utility class that enables a temporal join between two streams where Stream
A is matched to Stream B where
A.timestamp = (max(b.timestamp) where b.timestamp <= a.timestamp)
This will use the following overall flow:
KV(key, Timestamped<V>)
| Window
| GBK
| Statefull DoFn
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
