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.Utils	Encoder / expression utils that are called from generated code.
SideInputBroadcast	Broadcast helper for side inputs.

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

Internal helpers to translate Beam pipelines to Spark streaming.