Class DefaultOutputManager<OutputT>

  • Type Parameters:
    OutputT - output type
    All Implemented Interfaces:
    org.apache.beam.runners.core.DoFnRunners.OutputManager

    public final class DefaultOutputManager<OutputT>
    extends Object
    implements org.apache.beam.runners.core.DoFnRunners.OutputManager
    Default output emitter that uses outputCollector.
    • Method Detail

      • output

        public <T> void output​(org.apache.beam.sdk.values.TupleTag<T> tag,
                               org.apache.beam.sdk.util.WindowedValue<T> output)
        Specified by:
        output in interface org.apache.beam.runners.core.DoFnRunners.OutputManager