Packages

trait TimerValues extends Serializable

Class used to provide access to timer values for processing and event time populated before method invocations using the arbitrary state API v2.

Annotations
@Evolving()
Source
TimerValues.scala
Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimerValues
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def getCurrentProcessingTimeInMs(): Long

    Function to get the current processing time as milliseconds in epoch time.

    Function to get the current processing time as milliseconds in epoch time.

    returns

    - the current processing time in milliseconds

    Note

    This will return a constant value throughout the duration of a streaming query trigger, even if the trigger is re-executed.

  2. abstract def getCurrentWatermarkInMs(): Long

    Function to get the current event time watermark as milliseconds in epoch time.

    Function to get the current event time watermark as milliseconds in epoch time.

    returns

    - the current event time watermark in milliseconds

    Note

    This can be called only when watermark is set before calling transformWithState.

    ,

    The watermark gets propagated at the end of each query. As a result, this method will return 0 (1970-01-01T00:00:00) for the first micro-batch.