org.apache.beam.runners.flink

Interface FlinkStreamingPortablePipelineTranslator.PTransformTranslator<T>

Enclosing class:

FlinkStreamingPortablePipelineTranslator

public static interface FlinkStreamingPortablePipelineTranslator.PTransformTranslator<T>

Method Summary

Modifier and Type	Method and Description
void	translate(java.lang.String id, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, T t)

Method Detail

translate

void translate(java.lang.String id,
               org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
               T t)