public static class PrimitiveParDoSingleFactory.PayloadTranslator extends java.lang.Object implements org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>
PrimitiveParDoSingleFactory.ParDoSingle
.org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>
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.model.pipeline.v1.RunnerApi.FunctionSpec |
translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,PrimitiveParDoSingleFactory.ParDoSingle<?,?>> transform,
org.apache.beam.runners.core.construction.SdkComponents components) |
public static org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator create()
public java.lang.String getUrn(PrimitiveParDoSingleFactory.ParDoSingle<?,?> transform)
getUrn
in interface org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>
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
translate
in interface org.apache.beam.runners.core.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>
java.io.IOException