Uses of Class
org.apache.storm.daemon.Task
Package
Description
-
Uses of Task in org.apache.storm.executor
ModifierConstructorDescriptionExecutorShutdown
(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue) -
Uses of Task in org.apache.storm.executor.bolt
Modifier and TypeMethodDescriptionvoid
ModifierConstructorDescriptionBoltOutputCollectorImpl
(BoltExecutor executor, Task taskData, Random random, boolean isEventLoggers, boolean ackingEnabled, boolean isDebug) -
Uses of Task 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) Modifier and TypeMethodDescriptionvoid
ModifierConstructorDescriptionSpoutOutputCollectorImpl
(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long, TupleInfo> pending) -
Uses of Task in org.apache.storm.stats
Modifier and TypeMethodDescriptionvoid
BoltExecutorStats.boltExecuteTuple
(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask)