Uses of Class
org.apache.storm.executor.spout.SpoutExecutor
Packages that use SpoutExecutor
-
Uses of SpoutExecutor in org.apache.storm.executor.spout
Methods in org.apache.storm.executor.spout with parameters of type SpoutExecutorModifier 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) Constructors in org.apache.storm.executor.spout with parameters of type SpoutExecutorModifierConstructorDescriptionSpoutOutputCollectorImpl
(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long, TupleInfo> pending)