| Package | Description | 
|---|---|
| org.apache.storm.executor | |
| org.apache.storm.executor.bolt | |
| org.apache.storm.executor.spout | 
| 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) | 
Copyright © 2020 The Apache Software Foundation. All rights reserved.