Class AbstractDoFnTransform<InputT,​InterT,​OutputT>

  • Type Parameters:
    InputT - input type.
    InterT - intermediate type.
    OutputT - output type.
    All Implemented Interfaces:
    Serializable, Transform<org.apache.beam.sdk.util.WindowedValue<InputT>,​org.apache.beam.sdk.util.WindowedValue<OutputT>>
    Direct Known Subclasses:
    DoFnTransform, GroupByKeyAndWindowDoFnTransform, PushBackDoFnTransform

    public abstract class AbstractDoFnTransform<InputT,​InterT,​OutputT>
    extends Object
    implements Transform<org.apache.beam.sdk.util.WindowedValue<InputT>,​org.apache.beam.sdk.util.WindowedValue<OutputT>>
    This is a base class for Beam DoFn Transforms.
    See Also:
    Serialized Form
    • Nested Class Summary

    • Constructor Summary

      Constructors 
      Constructor Description
      AbstractDoFnTransform​(org.apache.beam.sdk.transforms.DoFn<InterT,​OutputT> doFn, org.apache.beam.sdk.coders.Coder<InputT> inputCoder, Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputCoders, org.apache.beam.sdk.values.TupleTag<OutputT> mainOutputTag, List<org.apache.beam.sdk.values.TupleTag<?>> additionalOutputTags, org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy, Map<Integer,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputs, org.apache.beam.sdk.options.PipelineOptions options, org.apache.beam.sdk.transforms.display.DisplayData displayData, org.apache.beam.sdk.transforms.DoFnSchemaInformation doFnSchemaInformation, Map<String,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputMapping)
      AbstractDoFnTransform constructor.
    • Constructor Detail

      • AbstractDoFnTransform

        public AbstractDoFnTransform​(org.apache.beam.sdk.transforms.DoFn<InterT,​OutputT> doFn,
                                     org.apache.beam.sdk.coders.Coder<InputT> inputCoder,
                                     Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputCoders,
                                     org.apache.beam.sdk.values.TupleTag<OutputT> mainOutputTag,
                                     List<org.apache.beam.sdk.values.TupleTag<?>> additionalOutputTags,
                                     org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy,
                                     Map<Integer,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputs,
                                     org.apache.beam.sdk.options.PipelineOptions options,
                                     org.apache.beam.sdk.transforms.display.DisplayData displayData,
                                     org.apache.beam.sdk.transforms.DoFnSchemaInformation doFnSchemaInformation,
                                     Map<String,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputMapping)
        AbstractDoFnTransform constructor.
        Parameters:
        doFn - doFn
        inputCoder - input coder
        outputCoders - output coders
        mainOutputTag - main output tag
        additionalOutputTags - additional output tags
        windowingStrategy - windowing strategy
        sideInputs - side inputs
        options - pipeline options
        displayData - display data.
    • Method Detail

      • getDoFn

        public final org.apache.beam.sdk.transforms.DoFn getDoFn()
        Getter function for DoFn.
        Returns:
        DoFn.
      • getOutputCollector

        public final OutputCollector<org.apache.beam.sdk.util.WindowedValue<OutputT>> getOutputCollector()
        Getter function for output collector.
        Returns:
        output collector.