Uses of Class
org.apache.storm.daemon.Task
Packages that use Task
Package
Description
-
Uses of Task in org.apache.storm.executor
Fields in org.apache.storm.executor with type parameters of type TaskMethods in org.apache.storm.executor with parameters of type TaskConstructor parameters in org.apache.storm.executor with type arguments of type TaskModifierConstructorDescriptionExecutorShutdown
(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue) -
Uses of Task in org.apache.storm.executor.bolt
Method parameters in org.apache.storm.executor.bolt with type arguments of type TaskModifier and TypeMethodDescriptionvoid
Constructors in org.apache.storm.executor.bolt with parameters of type TaskModifierConstructorDescriptionBoltOutputCollectorImpl
(BoltExecutor executor, Task taskData, Random random, boolean isEventLoggers, boolean ackingEnabled, boolean isDebug) -
Uses of Task in org.apache.storm.executor.spout
Methods in org.apache.storm.executor.spout with parameters of type TaskModifier 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) Method parameters in org.apache.storm.executor.spout with type arguments of type TaskModifier and TypeMethodDescriptionvoid
Constructors in org.apache.storm.executor.spout with parameters of type TaskModifierConstructorDescriptionSpoutOutputCollectorImpl
(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
Methods in org.apache.storm.stats with parameters of type TaskModifier and TypeMethodDescriptionvoid
BoltExecutorStats.boltExecuteTuple
(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask)