Uses of Class
org.apache.storm.executor.spout.SpoutExecutor
-
Packages that use SpoutExecutor Package Description org.apache.storm.executor.spout -
-
Uses of SpoutExecutor in org.apache.storm.executor.spout
Methods in org.apache.storm.executor.spout with parameters of type SpoutExecutor Modifier and Type Method Description void
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 SpoutExecutor Constructor Description SpoutOutputCollectorImpl(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long,TupleInfo> pending)
-