Uses of Class
org.apache.storm.executor.spout.SpoutExecutor
-
Uses of SpoutExecutor in org.apache.storm.executor.spout
Modifier and TypeMethodDescriptionvoid
SpoutExecutor.ackSpoutMsg
(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo) void
SpoutExecutor.failSpoutMsg
(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo, String reason) ModifierConstructorDescriptionSpoutOutputCollectorImpl
(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long, TupleInfo> pending)