org.apache.beam.sdk.util.construction

Class ExternalTranslation.ExternalTranslator

java.lang.Object

org.apache.beam.sdk.util.construction.ExternalTranslation.ExternalTranslator

All Implemented Interfaces:

PTransformTranslation.TransformTranslator<External.ExpandableTransform<?,?>>

Enclosing class:

ExternalTranslation

public static class ExternalTranslation.ExternalTranslator
extends java.lang.Object
implements PTransformTranslation.TransformTranslator<External.ExpandableTransform<?,?>>

Translator for ExpandableTransform.

Constructor Summary

Constructors

Constructor and Description
ExternalTranslator()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExternalTranslator

public ExternalTranslator()

Method Detail

create

public static PTransformTranslation.TransformTranslator create()

getUrn

public @Nullable java.lang.String getUrn(External.ExpandableTransform transform)

Specified by:

getUrn in interface PTransformTranslation.TransformTranslator<External.ExpandableTransform<?,?>>

canTranslate

public boolean canTranslate(PTransform<?,?> pTransform)

Specified by:

canTranslate in interface PTransformTranslation.TransformTranslator<External.ExpandableTransform<?,?>>

translate

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

Specified by:

translate in interface PTransformTranslation.TransformTranslator<External.ExpandableTransform<?,?>>

Throws:

java.io.IOException