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