Package org.apache.storm.task

## Interface IOutputCollector

- All Superinterfaces:
    `IErrorReporter`
  All Known Implementing Classes:
    `BaseStatefulBoltExecutor.AnchoringOutputCollector`, `BoltOutputCollectorImpl`, `CoordinatedBolt.CoordinatedOutputCollector`, `OutputCollector`

      public interface IOutputCollector
      extends IErrorReporter

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | `ack​(Tuple input)` |
    `List<Integer>` | `emit​(String streamId, Collection<Tuple> anchors, List<Object> tuple)` | Returns the task ids that received the tuples.
    `void` | `emitDirect​(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)` |
    `void` | `fail​(Tuple input)` |
    `void` | `flush()` |
    `void` | `resetTimeout​(Tuple input)` |

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

      `reportError`

- - ### Method Detail

    - #### emit

          List<Integer> emit​(String streamId,
                             Collection<Tuple> anchors,
                             List<Object> tuple)

      Returns the task ids that received the tuples.

    - #### emitDirect

          void emitDirect​(int taskId,
                          String streamId,
                          Collection<Tuple> anchors,
                          List<Object> tuple)

    - #### ack

          void ack​(Tuple input)

    - #### fail

          void fail​(Tuple input)

    - #### resetTimeout

          void resetTimeout​(Tuple input)

    - #### flush

          void flush()