org.apache.beam.runners.flink

Interface FlinkBatchPortablePipelineTranslator.PTransformTranslator

Enclosing class:

FlinkBatchPortablePipelineTranslator

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface FlinkBatchPortablePipelineTranslator.PTransformTranslator

Transform translation interface.

Method Summary

Modifier and Type	Method and Description
void	translate(org.apache.beam.sdk.util.construction.graph.PipelineNode.PTransformNode transform, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, FlinkBatchPortablePipelineTranslator.BatchTranslationContext context) Translate a PTransform into the given translation context.

Method Detail

translate

void translate(org.apache.beam.sdk.util.construction.graph.PipelineNode.PTransformNode transform,
               org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
               FlinkBatchPortablePipelineTranslator.BatchTranslationContext context)

Translate a PTransform into the given translation context.