Class DoFnTransform<InputT,​OutputT>

  • Type Parameters:
    InputT - input type.
    OutputT - output type.
    All Implemented Interfaces:
    Serializable, Transform<org.apache.beam.sdk.util.WindowedValue<InputT>,​org.apache.beam.sdk.util.WindowedValue<OutputT>>

    public final class DoFnTransform<InputT,​OutputT>
    extends AbstractDoFnTransform<InputT,​InputT,​OutputT>
    DoFn transform implementation when there is no side input.
    See Also:
    Serialized Form
    • Nested Class Summary

    • Constructor Summary

      Constructors 
      Constructor Description
      DoFnTransform​(org.apache.beam.sdk.transforms.DoFn<InputT,​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, 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)
      DoFnTransform Constructor.
    • Constructor Detail

      • DoFnTransform

        public DoFnTransform​(org.apache.beam.sdk.transforms.DoFn<InputT,​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,
                             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)
        DoFnTransform Constructor.
        Parameters:
        doFn - doFn
        inputCoder - input coder
        outputCoders - output coders
        mainOutputTag - main output tag
        additionalOutputTags - additional output tags
        windowingStrategy - windowing strategy
        options - pipeline options
        displayData - display data.
    • Method Detail

      • wrapDoFn

        protected org.apache.beam.sdk.transforms.DoFn wrapDoFn​(org.apache.beam.sdk.transforms.DoFn initDoFn)
      • onData

        public void onData​(org.apache.beam.sdk.util.WindowedValue<InputT> data)
        Description copied from interface: Transform
        On data received.
        Parameters:
        data - data received.
      • onWatermark

        public void onWatermark​(Watermark watermark)
        Description copied from interface: Transform
        On watermark received. This method should be called for the minimum watermark among input streams (input watermark). Transform may emit collected data after receiving watermarks.
        Parameters:
        watermark - watermark
      • beforeClose

        protected void beforeClose()