public interface WatermarkPolicy
getCurrentWatermark()can be called at any time to see this change.
|Modifier and Type||Method and Description|
Called to get the current watermark in the absence of an observed event.
Called to report the observation of an event with the given timestamp.
long reportEvent(long timestamp)
If the returned value is greater than the event's timestamp it means that the event should be dropped.
timestamp- event's timestamp
Long.MIN_VALUEif there is insufficient information to determine any watermark (e.g., no events observed)
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.