Packages

case class TTLConfig(ttlDuration: Duration) extends Product with Serializable

TTL Configuration for state variable. State values will not be returned past ttlDuration, and will be eventually removed from the state store. Any state update resets the ttl to current processing time plus ttlDuration.

Passing a TTL duration of zero will disable the TTL for the state variable. Users can also use the helper method TTLConfig.NONE in Scala or TTLConfig.NONE() in Java to disable TTL for the state variable.

ttlDuration

time to live duration for state stored in the state variable.

Source
TTLConfig.scala
Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TTLConfig
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TTLConfig(ttlDuration: Duration)

    ttlDuration

    time to live duration for state stored in the state variable.

Value Members

  1. def productElementNames: Iterator[String]
    Definition Classes
    Product
  2. val ttlDuration: Duration