public static class CombineTranslation.CombineGloballyPayloadTranslator extends java.lang.Object implements PTransformTranslation.TransformPayloadTranslator<Combine.Globally<?,?>>
PTransformTranslation.TransformPayloadTranslator
for Combine.Globally
.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getUrn()
Provides a unique URN for transforms represented by this
TransformPayloadTranslator . |
org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec |
translate(AppliedPTransform<?,?,Combine.Globally<?,?>> 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 java.lang.String getUrn()
PTransformTranslation.TransformPayloadTranslator
TransformPayloadTranslator
.getUrn
in interface PTransformTranslation.TransformPayloadTranslator<Combine.Globally<?,?>>
public org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(AppliedPTransform<?,?,Combine.Globally<?,?>> transform, SdkComponents components) throws java.io.IOException
PTransformTranslation.TransformPayloadTranslator
AppliedPTransform
to a
FunctionSpec
with a URN and a payload.translate
in interface PTransformTranslation.TransformPayloadTranslator<Combine.Globally<?,?>>
transform
- an AppliedPTransform
that includes the transform to be expanded.components
- components of the pipeline that includes the transform.java.io.IOException