t

org. apache. spark. sql. streaming

TimerValues

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
@Experimental () @Evolving ()
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. All

Abstract Value Members

  1. abstract def getCurrentProcessingTimeInMs () : Long

    Get the current processing time as milliseconds in epoch time.

    Get the current processing time as milliseconds in epoch time.

    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

    Get the current event time watermark as milliseconds in epoch time.

    Get the current event time watermark as milliseconds in epoch time.

    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.

Concrete Value Members

  1. final def != ( arg0: Any ) : Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def == ( arg0: Any ) : Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf [ T0] : T0
    Definition Classes
    Any
  5. def clone () : AnyRef
    Attributes
    protected[ lang]
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... ) @native () @IntrinsicCandidate ()
  6. final def eq ( arg0: AnyRef ) : Boolean
    Definition Classes
    AnyRef
  7. def equals ( arg0: Any ) : Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass () : Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native () @IntrinsicCandidate ()
  9. def hashCode () : Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native () @IntrinsicCandidate ()
  10. final def isInstanceOf [ T0] : Boolean
    Definition Classes
    Any
  11. final def ne ( arg0: AnyRef ) : Boolean
    Definition Classes
    AnyRef
  12. final def notify () : Unit
    Definition Classes
    AnyRef
    Annotations
    @native () @IntrinsicCandidate ()
  13. final def notifyAll () : Unit
    Definition Classes
    AnyRef
    Annotations
    @native () @IntrinsicCandidate ()
  14. final def synchronized [ T0] ( arg0: ⇒ T0 ) : T0
    Definition Classes
    AnyRef
  15. def toString () : String
    Definition Classes
    AnyRef → Any
  16. final def wait ( arg0: Long , arg1: Int ) : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... )
  17. final def wait ( arg0: Long ) : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... ) @native ()
  18. final def wait () : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... )

Deprecated Value Members

  1. def finalize () : Unit
    Attributes
    protected[ lang]
    Definition Classes
    AnyRef
    Annotations
    @throws ( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped