Module rlink::core::watermark [−][src]
Structs
Watermarks are the progress indicators in the data streams. A watermark signifies that no events with a timestamp smaller or equal to the watermark’s time will occur after the water. A watermark with timestamp T indicates that the stream’s event time has progressed to time T.
Constants
Traits
A TimestampAssigner assigns event time timestamps to elements. These timestamps are used by
all functions that operate on event time, for example event time windows.
The WatermarkStrategy defines how to generate Watermarks in the stream sources. The
WatermarkStrategy is a builder/factory for the WatermarkGenerator that generates the watermarks
and the TimestampAssigner which assigns the internal timestamp of a record.