Class OperatorWatermarkCollector

    • Constructor Detail

      • OperatorWatermarkCollector

        public OperatorWatermarkCollector​(OperatorVertex operatorVertex)
    • Method Detail

      • emit

        public void emit​(String dstVertexId,
                         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.