Packages

t

org.apache.spark.sql.streaming

ExpiredTimerInfo

trait ExpiredTimerInfo extends Serializable

Class used to provide access to expired timer's expiry time.

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

Abstract Value Members

  1. abstract def getExpiryTimeInMs(): Long

    Function to return the expired timer's expiry time as milliseconds in epoch time.

    Function to return the expired timer's expiry time as milliseconds in epoch time.

    returns

    - the expired timer's expiry time in milliseconds