Class DataflowRunner.DataflowTransformTranslator

java.lang.Object
org.apache.beam.runners.dataflow.DataflowRunner.DataflowTransformTranslator
All Implemented Interfaces:
org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar
Enclosing class:
DataflowRunner

@AutoService(org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar.class) public static class DataflowRunner.DataflowTransformTranslator extends Object implements org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar
  • Constructor Details

    • DataflowTransformTranslator

      public DataflowTransformTranslator()
  • Method Details

    • getTransformPayloadTranslators

      public Map<? extends Class<? extends PTransform>,? extends org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator> getTransformPayloadTranslators()
      Specified by:
      getTransformPayloadTranslators in interface org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar