Uses of Class
org.apache.storm.daemon.Task
-
Packages that use Task Package Description org.apache.storm.executor org.apache.storm.executor.bolt org.apache.storm.executor.spout org.apache.storm.stats -
-
Uses of Task in org.apache.storm.executor
Fields in org.apache.storm.executor with type parameters of type Task Modifier and Type Field Description protected ArrayList<Task>
Executor. idToTask
Methods in org.apache.storm.executor with parameters of type Task Modifier and Type Method Description void
Executor. metricsTick(Task task, TupleImpl tuple)
Constructor parameters in org.apache.storm.executor with type arguments of type Task Constructor Description ExecutorShutdown(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 Task Modifier and Type Method Description void
BoltExecutor. init(ArrayList<Task> idToTask, int idToTaskBase)
Constructors in org.apache.storm.executor.bolt with parameters of type Task Constructor Description BoltOutputCollectorImpl(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 Task 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)
Method parameters in org.apache.storm.executor.spout with type arguments of type Task Modifier and Type Method Description void
SpoutExecutor. init(ArrayList<Task> idToTask, int idToTaskBase)
Constructors in org.apache.storm.executor.spout with parameters of type Task Constructor Description SpoutOutputCollectorImpl(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 Task Modifier and Type Method Description void
BoltExecutorStats. boltExecuteTuple(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask)
-