org.apache.beam.sdk.util.construction

Class ParDoTranslation.ParDoTranslator

java.lang.Object

org.apache.beam.sdk.util.construction.ParDoTranslation.ParDoTranslator

All Implemented Interfaces:

PTransformTranslation.TransformTranslator<ParDo.MultiOutput<?,?>>

Enclosing class:

ParDoTranslation

public static class ParDoTranslation.ParDoTranslator
extends java.lang.Object
implements PTransformTranslation.TransformTranslator<ParDo.MultiOutput<?,?>>

A PTransformTranslation.TransformPayloadTranslator for ParDo.

Method Summary

Modifier and Type	Method and Description
boolean	canTranslate(PTransform<?,?> pTransform)
static PTransformTranslation.TransformTranslator	create()
java.lang.String	getUrn(ParDo.MultiOutput<?,?> 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

Method Detail

create

public static PTransformTranslation.TransformTranslator create()

getUrn

public java.lang.String getUrn(ParDo.MultiOutput<?,?> transform)

Specified by:

getUrn in interface PTransformTranslation.TransformTranslator<ParDo.MultiOutput<?,?>>

canTranslate

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

Specified by:

canTranslate in interface PTransformTranslation.TransformTranslator<ParDo.MultiOutput<?,?>>

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<ParDo.MultiOutput<?,?>>

Throws:

java.io.IOException