public interface WatermarkPolicy
getCurrentWatermark()
can be called at any
time to see this change.Modifier and Type | Method and Description |
---|---|
long |
getCurrentWatermark()
Called to get the current watermark in the absence of an observed
event.
|
long |
reportEvent(long timestamp)
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 timestampLong.MIN_VALUE
if there is
insufficient information to determine any watermark (e.g., no events
observed)long getCurrentWatermark()
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.