Package | Description |
---|---|
org.apache.storm.executor | |
org.apache.storm.executor.bolt | |
org.apache.storm.executor.spout | |
org.apache.storm.stats |
Modifier and Type | Field and Description |
---|---|
protected ArrayList<Task> |
Executor.idToTask |
Modifier and Type | Method and Description |
---|---|
void |
Executor.metricsTick(Task task,
TupleImpl tuple) |
Constructor and Description |
---|
ExecutorShutdown(Executor executor,
List<Utils.SmartThread> threads,
ArrayList<Task> taskDatas,
JCQueue recvQueue) |
Modifier and Type | Method and Description |
---|---|
void |
BoltExecutor.init(ArrayList<Task> idToTask,
int idToTaskBase) |
Constructor and Description |
---|
BoltOutputCollectorImpl(BoltExecutor executor,
Task taskData,
Random random,
boolean isEventLoggers,
boolean ackingEnabled,
boolean isDebug) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
void |
SpoutExecutor.init(ArrayList<Task> idToTask,
int idToTaskBase) |
Constructor and Description |
---|
SpoutOutputCollectorImpl(ISpout spout,
SpoutExecutor executor,
Task taskData,
MutableLong emittedCount,
boolean hasAckers,
Random random,
Boolean isEventLoggers,
Boolean isDebug,
RotatingMap<Long,TupleInfo> pending) |
Modifier and Type | Method and Description |
---|---|
void |
BoltExecutorStats.boltExecuteTuple(String component,
String stream,
long latencyMs,
long workerUptimeSecs,
Task firstExecutorTask) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.