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

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

Internal helpers to translate Beam pipelines to Spark streaming.

Related Packages

Package	Description
org.apache.beam.runners.spark.structuredstreaming.translation	Internal translators for running Beam pipelines on Spark.
org.apache.beam.runners.spark.structuredstreaming.translation.batch	Internal utilities to translate Beam pipelines to Spark batching.
org.apache.beam.runners.spark.structuredstreaming.translation.utils	Internal utils to translate Beam pipelines to Spark streaming.

Class	Description
CoderHelpers	Serialization utility class.
EncoderFactory
EncoderHelpers	Encoders utility class.
EncoderHelpers.Utils	Encoder / expression utils that are called from generated code.
EncoderProvider
EncoderProvider.Factory<T>