backtype.storm.spout
Interface ISpoutOutputCollector
- All Known Implementing Classes:
- SpoutOutputCollector
public interface ISpoutOutputCollector
Method Summary |
java.util.List<java.lang.Integer> |
emit(java.lang.String streamId,
java.util.List<java.lang.Object> tuple,
java.lang.Object messageId)
Returns the task ids that received the tuples. |
void |
emitDirect(int taskId,
java.lang.String streamId,
java.util.List<java.lang.Object> tuple,
java.lang.Object messageId)
|
void |
reportError(java.lang.Throwable error)
|
emit
java.util.List<java.lang.Integer> emit(java.lang.String streamId,
java.util.List<java.lang.Object> tuple,
java.lang.Object messageId)
- Returns the task ids that received the tuples.
emitDirect
void emitDirect(int taskId,
java.lang.String streamId,
java.util.List<java.lang.Object> tuple,
java.lang.Object messageId)
reportError
void reportError(java.lang.Throwable error)