public class FlattenTranslator extends java.lang.Object implements PTransformTranslation.TransformPayloadTranslator<Flatten.PCollections<?>>
Window.Assign
to and from RunnerApi
representations.Modifier and Type | Class and Description |
---|---|
static class |
FlattenTranslator.Registrar
Registers
FlattenTranslator . |
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<?,?,Flatten.PCollections<?>> 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<Flatten.PCollections<?>>
public org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(AppliedPTransform<?,?,Flatten.PCollections<?>> transform, SdkComponents components)
PTransformTranslation.TransformPayloadTranslator
AppliedPTransform
to a
FunctionSpec
with a URN and a payload.translate
in interface PTransformTranslation.TransformPayloadTranslator<Flatten.PCollections<?>>
transform
- an AppliedPTransform
that includes the transform to be expanded.components
- components of the pipeline that includes the transform.