package logical
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- trait LogicalGroupState[S] extends AnyRef
Internal class representing State
Value Members
- case object EventTime extends TimeMode with Product with Serializable
- case object EventTimeTimeout extends GroupStateTimeout with Product with Serializable
- 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.
- case object NoTimeout extends GroupStateTimeout with Product with Serializable
Types of timeouts used in FlatMapGroupsWithState
- case object ProcessingTime extends TimeMode with Product with Serializable
- case object ProcessingTimeTimeout extends GroupStateTimeout with Product with Serializable
- object TimeModes