Packages

package logical

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. trait LogicalGroupState[S] extends AnyRef

    Internal class representing State

Value Members

  1. case object EventTime extends TimeMode with Product with Serializable
  2. case object EventTimeTimeout extends GroupStateTimeout with Product with Serializable
  3. case object NoTime extends TimeMode with Product with Serializable

    TimeMode types used in transformWithState operator

    TimeMode types used in transformWithState operator

    Note that we need to keep TimeMode.None() named as "NoTime" in case class here because a case class named "None" will introduce naming collision with scala native type None. See SPARK-51151 for more info.

  4. case object NoTimeout extends GroupStateTimeout with Product with Serializable

    Types of timeouts used in FlatMapGroupsWithState

  5. case object ProcessingTime extends TimeMode with Product with Serializable
  6. case object ProcessingTimeTimeout extends GroupStateTimeout with Product with Serializable
  7. object TimeModes

Ungrouped