Package org.apache.nemo.compiler.frontend.beam.transform

Class DefaultOutputManager<OutputT>

  • Type Parameters:
    OutputT - output type
    All Implemented Interfaces:
    org.apache.beam.runners.core.DoFnRunners.OutputManager
    public final class DefaultOutputManager<OutputT>
extends java.lang.Object
implements org.apache.beam.runners.core.DoFnRunners.OutputManager
    Default output emitter that uses outputCollector.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> void output​(org.apache.beam.sdk.values.TupleTag<T> tag, org.apache.beam.sdk.util.WindowedValue<T> output)  

      • Methods inherited from class java.lang.Object

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

    • 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