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 voidack(Tuple input)List<Integer>emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)Returns the task ids that received the tuples.voidemitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)voidfail(Tuple input)voidflush()voidresetTimeout(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()
-
-