class MaxWatermarkProvider extends WatermarkProvider with Logging
Watermark provider that sets the watermark to the maximum observed event time. In order to protect from malformed messages with timestamps from the future, values greater than a predefined threshold above the current time are rejected and do not advance the watermark.
- Alphabetic
- By Inheritance
- MaxWatermarkProvider
- Logging
- WatermarkProvider
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new MaxWatermarkProvider(validWatermarkDiff: Duration)(implicit timeProvider: TimeProvider = TimeProvider.system)
- validWatermarkDiff
Upper limit for setting watermarks greater than the current time.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def currentWatermark: Timestamp
Returns the current watermark.
Returns the current watermark.
- Definition Classes
- MaxWatermarkProvider → WatermarkProvider
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def initialize(initialWatermark: Timestamp): Timestamp
Initializes the provider to a specified watermark.
Initializes the provider to a specified watermark.
- initialWatermark
The initial watermark to initialize to.
- returns
The initial watermark.
- Definition Classes
- MaxWatermarkProvider → WatermarkProvider
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val log: Logger
- Attributes
- protected
- Definition Classes
- Logging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def observeEvent(timestamp: Timestamp): Timestamp
Observes a new event and moves the watermark forward if needed.
Observes a new event and moves the watermark forward if needed.
- timestamp
Timestamp of the new event.
- returns
The current watermark.
- Definition Classes
- MaxWatermarkProvider → WatermarkProvider
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()