Package org.apache.beam.runners.spark.stateful

package org.apache.beam.runners.spark.stateful

Spark-specific stateful operators.

Related Packages

Package	Description
org.apache.beam.runners.spark	Internal implementation of the Beam runner for Apache Spark.

Classes

Class	Description
SparkGroupAlsoByWindowViaWindowSet	An implementation of GroupByKeyViaGroupByKeyOnly.GroupAlsoByWindow logic for grouping by windows and controlling trigger firings and pane accumulation.
SparkStateInternals<K>	An implementation of StateInternals for the SparkRunner.
SparkTimerInternals	An implementation of TimerInternals for the SparkRunner.
StateAndTimers	State and Timers wrapper.
StateSpecFunctions	A class containing StateSpec mappingFunctions.