Package org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Internal helpers to translate Beam pipelines to Spark streaming.

See: Description

Class Summary

Class	Description
CoderHelpers	Serialization utility class.
EncoderHelpers	Encoders utility class.
EncoderHelpers.DecodeUsingBeamCoder<T>	Catalyst Expression that deserializes elements using Beam Coder.
EncoderHelpers.EncodeUsingBeamCoder<T>	Catalyst Expression that serializes elements using Beam Coder.
KVHelpers	Helper functions for working with KV.
MultiOuputCoder<T>	Coder to serialize and deserialize Tuple2, WindowedValue{/@code} to be used in spark encoders while applying DoFn.
ReduceFnRunnerHelpers<K,InputT,W extends BoundedWindow>	Helpers to use ReduceFnRunner.
ReduceFnRunnerHelpers.GABWOutputWindowedValue<K,V>	OutputWindowedValue for ReduceFnRunner.
RowHelpers	Helper functions for working with Row.
SideInputBroadcast	Broadcast helper for side inputs.
WindowingHelpers	Helper functions for working with windows.

Package org.apache.beam.runners.spark.structuredstreaming.translation.helpers Description

Internal helpers to translate Beam pipelines to Spark streaming.