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.