Package org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions
package org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions
Internal implementation of the Beam runner for Apache Spark.
-
ClassDescriptionSideInputReader that caches results for costly
Materializations
.GroupAlsoByWindowViaOutputBufferFn<K,InputT, W extends BoundedWindow> A FlatMap function that groups by windows in batch mode usingReduceFnRunner
.AStepContext
for Spark Batch Runner execution.SideInputValues
serves as a Kryo serializable container that contains a materialized view of side inputs.SideInputValues.BaseSideInputValues<BinaryT,ValuesT extends @NonNull Object, T> GeneralSideInputValues
forBoundedWindows
in two possible states.SpecializedSideInputValues
for use with theGlobalWindow
in two possible states.Factory function for loadSideInputValues
from aDataset
.SideInputReader using broadcastedSideInputValues
.