org.apache.storm.spout

## Interface ISpoutOutputCollector

- All Superinterfaces:
    IErrorReporter
  All Known Implementing Classes:
    SpoutOutputCollector, SpoutOutputCollectorImpl

      public interface ISpoutOutputCollector
      extends IErrorReporter

  Methods are not expected to be thread safe. Each thread expected to have a separate instance of this type of object, or else externally synchronize any shared instance.

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method and Description
    --- | ---
    `List<Integer>` | `emit(String streamId, List<Object> tuple, Object messageId)` Returns the task ids that received the tuples.
    `void` | `emitDirect(int taskId, String streamId, List<Object> tuple, Object messageId)`
    `void` | `flush()`
    `long` | `getPendingCount()`

    - ### Methods inherited from interface org.apache.storm.task.IErrorReporter

      `reportError`

- - ### Method Detail

    - #### emit

          List<Integer> emit(String streamId,
                             List<Object> tuple,
                             Object messageId)

      Returns the task ids that received the tuples.

    - #### emitDirect

          void emitDirect(int taskId,
                          String streamId,
                          List<Object> tuple,
                          Object messageId)

    - #### getPendingCount

          long getPendingCount()

    - #### flush

          void flush()

Copyright © 2019 The Apache Software Foundation. All rights reserved.