Details
-
New Feature
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
Description
See also: BEAM-70
We should have a library of watermark implementations:
- now: for when items use arrival timestamps
- latest element: for when events arrive in timestamp order
- moving average over last K time intervals
- bucketed moving average, ...
Attachments
Issue Links
- is superceded by
-
BEAM-2939 Fn API SDF support
- Resolved