Package org.apache.nemo.runtime.executor.datatransfer

Class OperatorWatermarkCollector

  • All Implemented Interfaces:
    java.io.Serializable, OutputCollector
    public final class OperatorWatermarkCollector
extends java.lang.Object
implements OutputCollector
    This class is used for collecting watermarks for an OperatorVertex. InputWatermarkManager emits watermarks to this class.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void emit​(java.lang.Object output)
      Single-destination emit.
      void emit​(java.lang.String dstVertexId, java.lang.Object output)
      Multi-destination emit.
      void emitLatencymark​(LatencyMark latencymakr)
      Emit latencymark to downstream vertices.
      void emitWatermark​(Watermark watermark)
      Emit watermark to downstream vertices.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • OperatorWatermarkCollector

        public OperatorWatermarkCollector​(OperatorVertex operatorVertex)

    • Method Detail

      • emit

        public void emit​(java.lang.Object output)
        Description copied from interface: OutputCollector
        Single-destination emit.
        Specified by:
        emit in interface OutputCollector
        Parameters:
        output - value.

      • emit

        public void emit​(java.lang.String dstVertexId,
                 java.lang.Object output)
        Description copied from interface: OutputCollector
        Multi-destination emit. Currently unused, but might come in handy for operations like multi-output map.
        Specified by:
        emit in interface OutputCollector
        Parameters:
        dstVertexId - destination vertex id.
        output - value.