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

Class PipelineTranslatorCommon

java.lang.Object

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

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

Direct Known Subclasses:

PipelineTranslatorBatch, PipelineTranslatorStreaming

@Internal
public class PipelineTranslatorCommon
extends PipelineTranslator

Holds the translator registry shared by the batch and the streaming translator, and the registry lookup.

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
PipelineTranslatorCommon()

Method Summary

Modifier and Type	Method	Description
protected <InT extends PInput, OutT extends POutput, TransformT extends PTransform<InT, OutT>> @Nullable TransformTranslator<InT,OutT,TransformT>	getTransformTranslator(TransformT transform)	Returns a TransformTranslator for the given PTransform if known.

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

PipelineTranslatorCommon

public PipelineTranslatorCommon()

Method Details

getTransformTranslator

protected <InT extends PInput,
OutT extends POutput,
TransformT extends PTransform<InT,
OutT>>
@Nullable TransformTranslator<InT,OutT,TransformT> getTransformTranslator(TransformT transform)

Returns a TransformTranslator for the given PTransform if known.

Specified by:

getTransformTranslator in class PipelineTranslator