org.apache.beam.runners.core.construction

Interface PTransforms.TransformPayloadTranslator<T extends PTransform<?,?>>

Enclosing class:

PTransforms

public static interface PTransforms.TransformPayloadTranslator<T extends PTransform<?,?>>

A translator consumes a PTransform application and produces the appropriate FunctionSpec for a distinguished or primitive transform within the Beam runner API.

Method Summary

Modifier and Type	Method and Description
RunnerApi.FunctionSpec	translate(AppliedPTransform<?,?,T> transform, org.apache.beam.runners.core.construction.SdkComponents components)

Method Detail

translate

RunnerApi.FunctionSpec translate(AppliedPTransform<?,?,T> transform,
                                 org.apache.beam.runners.core.construction.SdkComponents components)