Package org.apache.beam.runners.dataflow

Class PrimitiveParDoSingleFactory.PayloadTranslator

java.lang.Object
org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.PayloadTranslator
All Implemented Interfaces:
org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>
Enclosing class:
PrimitiveParDoSingleFactory<InputT,OutputT>
public static class PrimitiveParDoSingleFactory.PayloadTranslator extends Object implements org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>
A translator for PrimitiveParDoSingleFactory.ParDoSingle.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator

    org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator
    create()
     
    String
    getUrn()
     
    org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec
    translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,PrimitiveParDoSingleFactory.ParDoSingle<?,?>> transform, org.apache.beam.sdk.util.construction.SdkComponents components)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator

    fromConfigRow, getUrn, toConfigRow

  • Method Details

    • create

      public static org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator create()

    • getUrn

      public String getUrn()
      Specified by:
      getUrn in interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>

    • translate

      public org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,PrimitiveParDoSingleFactory.ParDoSingle<?,?>> transform, org.apache.beam.sdk.util.construction.SdkComponents components) throws IOException
      Specified by:
      translate in interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<PrimitiveParDoSingleFactory.ParDoSingle<?,?>>
      Throws:
      IOException