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.

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

Instance Constructors

  1. new TTLConfig ( ttlDuration: Duration )

    ttlDuration

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

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. final def getClass () : Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native () @IntrinsicCandidate ()
  8. final def isInstanceOf [ T0] : Boolean
    Definition Classes
    Any
  9. final def ne ( arg0: AnyRef ) : Boolean
    Definition Classes
    AnyRef
  10. final def notify () : Unit
    Definition Classes
    AnyRef
    Annotations
    @native () @IntrinsicCandidate ()
  11. final def notifyAll () : Unit
    Definition Classes
    AnyRef
    Annotations
    @native () @IntrinsicCandidate ()
  12. final def synchronized [ T0] ( arg0: ⇒ T0 ) : T0
    Definition Classes
    AnyRef
  13. val ttlDuration : Duration
  14. final def wait ( arg0: Long , arg1: Int ) : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... )
  15. final def wait ( arg0: Long ) : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... ) @native ()
  16. 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 Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped