public interface WatermarkPolicy
The processor must report to this object the timestamp of every event it
receives by calling reportEvent(long)
. It must also ensure that,
even in the absence of events, it keeps checking the current value
of the watermark. When the
watermark advances far enough (as decided by the WatermarkEmissionPolicy
, if in use), it must emit a watermark item to
its output edges.
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 © 2018 Hazelcast, Inc.. All rights reserved.