Package org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions

Internal implementation of the Beam runner for Apache Spark.

See: Description

Class Summary

Class	Description
GroupAlsoByWindowViaOutputBufferFn<K,InputT,W extends BoundedWindow>	A FlatMap function that groups by windows in batch mode using ReduceFnRunner.
NoOpStepContext	A StepContext for Spark Batch Runner execution.
SparkSideInputReader	A SideInputReader for the Spark Batch Runner.

Package org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions Description

Internal implementation of the Beam runner for Apache Spark.