Class DataFetcherOutputCollector<O>

  • Type Parameters:
    O - output type.
    All Implemented Interfaces:
    java.io.Serializable, OutputCollector<O>

    public final class DataFetcherOutputCollector<O>
    extends java.lang.Object
    implements OutputCollector<O>
    This collector receives data from DataFetcher and forwards it to the next operator.
    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)
      Multi-destination emit.
      void emit​(O output)
      Single-destination emit.
      void emitLatencymark​(LatencyMark latencymark)
      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

      • DataFetcherOutputCollector

        public DataFetcherOutputCollector​(OperatorVertex nextOperatorVertex,
                                          int edgeIndex,
                                          InputWatermarkManager watermarkManager)
        It forwards output to the next operator.
        Parameters:
        nextOperatorVertex - next operator to emit data and watermark
        edgeIndex - edge index
        watermarkManager - watermark manager
    • Method Detail

      • emit

        public void emit​(O output)
        Description copied from interface: OutputCollector
        Single-destination emit.
        Specified by:
        emit in interface OutputCollector<O>
        Parameters:
        output - value.
      • emit

        public <T> void emit​(java.lang.String dstVertexId,
                             T 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<O>
        Type Parameters:
        T - output type.
        Parameters:
        dstVertexId - destination vertex id.
        output - value.