Class OperatorVertexOutputCollector<O>

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

    public final class OperatorVertexOutputCollector<O>
    extends Object
    implements OutputCollector<O>
    OutputCollector implementation. This emits four types of outputs 1) internal main outputs: this output becomes the input of internal Transforms 2) internal additional outputs: this additional output becomes the input of internal Transforms 3) external main outputs: this external output is emitted to OutputWriter 4) external additional outputs: this external output is emitted to OutputWriter
    See Also:
    Serialized Form
    • Constructor Detail

      • OperatorVertexOutputCollector

        public OperatorVertexOutputCollector​(IRVertex irVertex,
                                             List<NextIntraTaskOperatorInfo> internalMainOutputs,
                                             Map<String,​List<NextIntraTaskOperatorInfo>> internalAdditionalOutputs,
                                             List<OutputWriter> externalMainOutputs,
                                             Map<String,​List<OutputWriter>> externalAdditionalOutputs)
        Constructor of the output collector.
        Parameters:
        irVertex - the ir vertex that emits the output
        internalMainOutputs - internal main outputs
        internalAdditionalOutputs - internal additional outputs
        externalMainOutputs - external main outputs
        externalAdditionalOutputs - external additional outputs
    • 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​(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.