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

Class PipelineTranslatorBatch

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.PipelineTranslator

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

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

@Internal
public class PipelineTranslatorBatch
extends PipelineTranslatorCommon

Translator for batch pipelines, the registry and the lookup live in the common base.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.runners.spark.structuredstreaming.translation.PipelineTranslator

PipelineTranslator.TranslationState, PipelineTranslator.UnresolvedTranslation<InT,T>

Constructor Summary

Constructors

Constructor	Description
PipelineTranslatorBatch()

Method Summary

Methods inherited from class org.apache.beam.runners.spark.structuredstreaming.translation.batch.PipelineTranslatorCommon

getTransformTranslator

Methods inherited from class org.apache.beam.runners.spark.structuredstreaming.translation.PipelineTranslator

createEvaluationContext, detectStreamingMode, replaceTransforms, translate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PipelineTranslatorBatch

public PipelineTranslatorBatch()