Interface OutputCollector<O>

    • Method Detail

      • emit

        void emit​(O output)
        Single-destination emit.
        Parameters:
        output - value.
      • emitWatermark

        void emitWatermark​(Watermark watermark)
        Emit watermark to downstream vertices.
        Parameters:
        watermark - watermark
      • emit

        <T> void emit​(String dstVertexId,
                      T output)
        Multi-destination emit. Currently unused, but might come in handy for operations like multi-output map.
        Type Parameters:
        T - output type.
        Parameters:
        dstVertexId - destination vertex id.
        output - value.