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.utils	Internal utils to translate Beam pipelines to Spark streaming.

Classes

Class	Description
PipelineTranslatorBatch	PipelineTranslator for executing a Pipeline in Spark in batch mode.