org.apache.beam.runners.dataflow

Class PrimitiveParDoSingleFactory.PayloadTranslator

java.lang.Object

org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.PayloadTranslator

All Implemented Interfaces:

org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>

Enclosing class:

PrimitiveParDoSingleFactory<InputT,OutputT>

public static class PrimitiveParDoSingleFactory.PayloadTranslator
extends java.lang.Object
implements org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>

A translator for PrimitiveParDoSingleFactory.ParDoSingle.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator

org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>, org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator.WithDefaultRehydration<T extends PTransform<?,?>>

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator	create()
java.lang.String	getUrn(PrimitiveParDoSingleFactory.ParDoSingle<?,?> transform)
org.apache.beam.runners.core.construction.PTransformTranslation.RawPTransform<?,?>	rehydrate(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform protoTransform, org.apache.beam.runners.core.construction.RehydratedComponents rehydratedComponents)
org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec	translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,PrimitiveParDoSingleFactory.ParDoSingle<?,?>> transform, org.apache.beam.runners.core.construction.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 org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator create()

getUrn

public java.lang.String getUrn(PrimitiveParDoSingleFactory.ParDoSingle<?,?> transform)

Specified by:

getUrn in interface org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>

translate

public org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,PrimitiveParDoSingleFactory.ParDoSingle<?,?>> transform,
                                                                          org.apache.beam.runners.core.construction.SdkComponents components)
                                                                   throws java.io.IOException

Specified by:

translate in interface org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>

Throws:

java.io.IOException

rehydrate

public org.apache.beam.runners.core.construction.PTransformTranslation.RawPTransform<?,?> rehydrate(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform protoTransform,
                                                                                                    org.apache.beam.runners.core.construction.RehydratedComponents rehydratedComponents)
                                                                                             throws java.io.IOException

Specified by:

rehydrate in interface org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>

Throws:

java.io.IOException