backtype.storm.topology
Interface IBasicOutputCollector
- All Known Implementing Classes:
- BasicOutputCollector
public interface IBasicOutputCollector
Method Summary |
java.util.List<java.lang.Integer> |
emit(java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
|
void |
emitDirect(int taskId,
java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
|
void |
reportError(java.lang.Throwable t)
|
emit
java.util.List<java.lang.Integer> emit(java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
emitDirect
void emitDirect(int taskId,
java.lang.String streamId,
java.util.List<java.lang.Object> tuple)
reportError
void reportError(java.lang.Throwable t)