Details
-
Improvement
-
Status: Open
-
P3
-
Resolution: Unresolved
-
2.12.0
-
None
-
None
Description
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 |
