public abstract static class PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>> extends java.lang.Object implements PTransformTranslation.TransformPayloadTranslator<T>
PTransformTranslation.TransformPayloadTranslator
for transforms that contain no references to components,
so they do not need a specialized rehydration.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>
Constructor and Description |
---|
NotSerializable() |
Modifier and Type | Method and Description |
---|---|
static PTransformTranslation.TransformPayloadTranslator.NotSerializable<?> |
forUrn(java.lang.String urn) |
org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec |
translate(AppliedPTransform<?,?,T> 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, getUrn, toConfigRow
public static PTransformTranslation.TransformPayloadTranslator.NotSerializable<?> forUrn(java.lang.String urn)
public final org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(AppliedPTransform<?,?,T> transform, SdkComponents components) throws java.io.IOException
PTransformTranslation.TransformPayloadTranslator
AppliedPTransform
to a
FunctionSpec
with a URN and a payload.translate
in interface PTransformTranslation.TransformPayloadTranslator<T extends PTransform<?,?>>
transform
- an AppliedPTransform
that includes the transform to be expanded.components
- components of the pipeline that includes the transform.java.io.IOException