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.
EncoderFactory
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.
MultiOutputCoder<T>	Coder to serialize and deserialize Tuple2, WindowedValue{/@code} to be used in spark encoders while applying DoFn.
RowHelpers	Helper functions for working with Row.
SchemaHelpers	A SchemaHelpers for the Spark Batch Runner.
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.