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

Class TransformTranslator.Translator

java.lang.Object

org.apache.beam.runners.spark.translation.TransformTranslator.Translator

All Implemented Interfaces:

SparkPipelineTranslator

Enclosing class:

TransformTranslator

public static class TransformTranslator.Translator
extends Object
implements SparkPipelineTranslator

Translator matches Beam transformation with the appropriate evaluator.

Constructor Summary

Constructors

Constructor	Description
Translator()

Method Summary

Modifier and Type	Method	Description
boolean	hasTranslation(PTransform<?,?> transform)
<TransformT extends PTransform<?, ?>> TransformEvaluator<TransformT>	translateBounded(PTransform<?,?> transform)
<TransformT extends PTransform<?, ?>> TransformEvaluator<TransformT>	translateUnbounded(PTransform<?,?> transform)

Methods inherited from class java.lang.Object

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

Constructor Details

Translator

public Translator()

Method Details

hasTranslation

public boolean hasTranslation(PTransform<?,?> transform)

Specified by:

hasTranslation in interface SparkPipelineTranslator

translateBounded

public <TransformT extends PTransform<?,
?>>
TransformEvaluator<TransformT> translateBounded(PTransform<?,?> transform)

Specified by:

translateBounded in interface SparkPipelineTranslator

translateUnbounded

public <TransformT extends PTransform<?,
?>>
TransformEvaluator<TransformT> translateUnbounded(PTransform<?,?> transform)

Specified by:

translateUnbounded in interface SparkPipelineTranslator