Class StreamingTransformTranslator.Translator
java.lang.Object
org.apache.beam.runners.spark.translation.streaming.StreamingTransformTranslator.Translator
- All Implemented Interfaces:
SparkPipelineTranslator
- Enclosing class:
StreamingTransformTranslator
public static class StreamingTransformTranslator.Translator
extends Object
implements SparkPipelineTranslator
Translator matches Beam transformation with the appropriate evaluator.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
hasTranslation
(PTransform<?, ?> transform) <TransformT extends PTransform<?,
?>>
TransformEvaluator<TransformT> translateBounded
(PTransform<?, ?> transform) <TransformT extends PTransform<?,
?>>
TransformEvaluator<TransformT> translateUnbounded
(PTransform<?, ?> transform)
-
Constructor Details
-
Translator
-
-
Method Details
-
hasTranslation
- Specified by:
hasTranslation
in interfaceSparkPipelineTranslator
-
translateBounded
public <TransformT extends PTransform<?,?>> TransformEvaluator<TransformT> translateBounded(PTransform<?, ?> transform) - Specified by:
translateBounded
in interfaceSparkPipelineTranslator
-
translateUnbounded
public <TransformT extends PTransform<?,?>> TransformEvaluator<TransformT> translateUnbounded(PTransform<?, ?> transform) - Specified by:
translateUnbounded
in interfaceSparkPipelineTranslator
-