Solutionunvalidated
Using windowUntilChanged to group adjacent records that use the same timestamp — Combine input fluxes preserving overall date ordering using mergeComparing operator. Tension: group adjacent records that use the same timestamp. Outcome: Use `reduce` on each window to merge records as you wish.
8c1a9c4f-aa33-40ee-954e-f51a3da4a595
Using windowUntilChanged to group adjacent records that use the same timestamp — Combine input fluxes preserving overall date ordering using mergeComparing operator. Tension: group adjacent records that use the same timestamp. Outcome: Use reduce on each window to merge records as you wish.