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

  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 Details

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