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

Interface SparkPipelineTranslator

All Known Implementing Classes:

StreamingTransformTranslator.Translator, TransformTranslator.Translator

public interface SparkPipelineTranslator

Translator to support translation between Beam transformations and Spark transformations.

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)

Method Details

hasTranslation

boolean hasTranslation(PTransform<?,?> transform)

translateBounded

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

translateUnbounded

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