org.apache.beam.sdk.util.construction

Interface PTransformTranslation.TransformTranslator<T extends PTransform<?,?>>

All Known Implementing Classes:

ExternalTranslation.ExternalTranslator, ParDoTranslation.ParDoTranslator

Enclosing class:

PTransformTranslation

public static interface PTransformTranslation.TransformTranslator<T extends PTransform<?,?>>

A translator between a Java-based PTransform and a protobuf for that transform.

When going to a protocol buffer message, the translator produces a payload corresponding to the Java representation while registering components that transform references.

Method Summary

Modifier and Type	Method and Description
boolean	canTranslate(PTransform<?,?> pTransform)
@Nullable java.lang.String	getUrn(T transform)
org.apache.beam.model.pipeline.v1.RunnerApi.PTransform	translate(AppliedPTransform<?,?,?> appliedPTransform, java.util.List<AppliedPTransform<?,?,?>> subtransforms, SdkComponents components)

Method Detail

getUrn

@Nullable java.lang.String getUrn(T transform)

canTranslate

boolean canTranslate(PTransform<?,?> pTransform)

translate

org.apache.beam.model.pipeline.v1.RunnerApi.PTransform translate(AppliedPTransform<?,?,?> appliedPTransform,
                                                                 java.util.List<AppliedPTransform<?,?,?>> subtransforms,
                                                                 SdkComponents components)
                                                          throws java.io.IOException

Throws:

java.io.IOException