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

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

Internal utilities to translate Beam pipelines to Spark batching.

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.functions	Internal implementation of the Beam runner for Apache Spark.
org.apache.beam.runners.spark.structuredstreaming.translation.helpers	Internal helpers to translate Beam pipelines to Spark streaming.
org.apache.beam.runners.spark.structuredstreaming.translation.streaming
org.apache.beam.runners.spark.structuredstreaming.translation.utils	Internal utils to translate Beam pipelines to Spark streaming.

Classes

Class	Description
PipelineTranslatorBatch	Translator for batch pipelines, the registry and the lookup live in the common base.
PipelineTranslatorCommon	Holds the translator registry shared by the batch and the streaming translator, and the registry lookup.