Class Watermark

  • All Implemented Interfaces:
    Comparable<Watermark>

    public final class Watermark
    extends Object
    implements Comparable<Watermark>
    Watermark represents a point in time. This point in time is composed of a millisecond timestamp and a sequence. There is also a state to denote if the point in time is reached (completed) or not. Watermark are immutable.
    Since:
    9.3