Package 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 | 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()