Package org.apache.spark.sql.streaming

Class TimeMode

Object

org.apache.spark.sql.streaming.TimeMode

@Experimental
@Evolving
public class TimeMode
extends Object

Represents the time modes (used for specifying timers and ttl) possible for the Dataset operations transformWithState.

Constructor Summary

Constructors

Constructor	Description
TimeMode()

Method Summary

Modifier and Type	Method	Description
static final TimeMode	EventTime()	Stateful processor that uses event time to register timers.
static final TimeMode	None()	Neither timers nor ttl is supported in this mode.
static final TimeMode	ProcessingTime()	Stateful processor that uses query processing time to register timers and calculate ttl expiration.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TimeMode

public TimeMode()

Method Details

None

public static final TimeMode None()

Neither timers nor ttl is supported in this mode.

ProcessingTime

public static final TimeMode ProcessingTime()

Stateful processor that uses query processing time to register timers and calculate ttl expiration.

EventTime

public static final TimeMode EventTime()

Stateful processor that uses event time to register timers. Note that ttl is not supported in this TimeMode.