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

Class GBKTransform.GBKOutputCollector

  • All Implemented Interfaces:
    java.io.Serializable, OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>>>
    Enclosing class:
    GBKTransform<K,​InputT,​OutputT>
    public class GBKTransform.GBKOutputCollector
extends java.lang.Object
implements OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>>>
    Wrapper class for OutputCollector.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> void emit​(java.lang.String dstVertexId, T output)
      Emit output value to dstVertexId.
      void emit​(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>> output)
      Emit output.
      void emitLatencymark​(LatencyMark latencymark)
      Emit latencymark.
      void emitWatermark​(Watermark watermark)
      Emit watermark.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

    • Method Detail

      • emit

        public final void emit​(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>> output)
        Emit output. If output is emitted on-time, save its timestamp in the output watermark map.
        Specified by:
        emit in interface OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>>>
        Parameters:
        output - value.

      • emitLatencymark

        public final void emitLatencymark​(LatencyMark latencymark)
        Emit latencymark.
        Specified by:
        emitLatencymark in interface OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>>>
        Parameters:
        latencymark - latencymark

      • emitWatermark

        public final void emitWatermark​(Watermark watermark)
        Emit watermark.
        Specified by:
        emitWatermark in interface OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>>>
        Parameters:
        watermark - watermark

      • emit

        public final <T> void emit​(java.lang.String dstVertexId,
                           T output)
        Emit output value to dstVertexId.
        Specified by:
        emit in interface OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,​OutputT>>>
        Type Parameters:
        T - output type.
        Parameters:
        dstVertexId - destination vertex id.
        output - value.