Package org.apache.beam.runners.dataflow

Interface TransformTranslator<TransformT extends PTransform>

public interface TransformTranslator<TransformT extends PTransform>

A TransformTranslator knows how to translate a particular subclass of PTransform for the Cloud Dataflow service. It does so by mutating the TransformTranslator.TranslationContext.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	TransformTranslator.StepTranslationContext	The interface for a TransformTranslator to build a Dataflow step.
static interface	TransformTranslator.TranslationContext	The interface provided to registered callbacks for interacting with the DataflowRunner, including reading and writing the values of PCollections and side inputs.

Method Summary

Modifier and Type	Method	Description
void	translate(TransformT transform, TransformTranslator.TranslationContext context)

Method Details

translate

void translate(TransformT transform,
 TransformTranslator.TranslationContext context)