public static class SplittableParDo.ProcessKeyedElementsTranslator extends java.lang.Object implements PTransformTranslation.TransformPayloadTranslator<SplittableParDo.ProcessKeyedElements<?,?,?,?>>
SplittableParDo.ProcessKeyedElements
.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>
Modifier and Type | Method and Description |
---|---|
static PTransformTranslation.TransformPayloadTranslator |
create() |
java.lang.String |
getUrn()
Provides a unique URN for transforms represented by this
TransformPayloadTranslator . |
org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec |
translate(AppliedPTransform<?,?,SplittableParDo.ProcessKeyedElements<?,?,?,?>> transform,
SdkComponents components)
Translates the given transform represented by the provided
AppliedPTransform to a
FunctionSpec with a URN and a payload. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromConfigRow, getUrn, toConfigRow
public static PTransformTranslation.TransformPayloadTranslator create()
public java.lang.String getUrn()
PTransformTranslation.TransformPayloadTranslator
TransformPayloadTranslator
.getUrn
in interface PTransformTranslation.TransformPayloadTranslator<SplittableParDo.ProcessKeyedElements<?,?,?,?>>
public org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(AppliedPTransform<?,?,SplittableParDo.ProcessKeyedElements<?,?,?,?>> transform, SdkComponents components) throws java.io.IOException
PTransformTranslation.TransformPayloadTranslator
AppliedPTransform
to a
FunctionSpec
with a URN and a payload.translate
in interface PTransformTranslation.TransformPayloadTranslator<SplittableParDo.ProcessKeyedElements<?,?,?,?>>
transform
- an AppliedPTransform
that includes the transform to be expanded.components
- components of the pipeline that includes the transform.java.io.IOException