| Package | Description |
|---|---|
| org.apache.storm.daemon.worker | |
| org.apache.storm.executor | |
| org.apache.storm.executor.bolt | |
| org.apache.storm.executor.spout |
| Constructor and Description |
|---|
WorkerTransfer(WorkerState workerState,
Map<String,Object> topologyConf,
int maxTaskIdInTopo) |
| Modifier and Type | Field and Description |
|---|---|
protected WorkerState |
Executor.workerData |
| Modifier and Type | Method and Description |
|---|---|
WorkerState |
Executor.getWorkerData() |
| Modifier and Type | Method and Description |
|---|---|
static Executor |
LocalExecutor.mkExecutor(WorkerState workerState,
List<Long> executorId,
Map<String,String> initialCredentials) |
static Executor |
Executor.mkExecutor(WorkerState workerState,
List<Long> executorId,
Map<String,String> credentials) |
| Constructor and Description |
|---|
Executor(WorkerState workerData,
List<Long> executorId,
Map<String,String> credentials,
String type) |
ExecutorTransfer(WorkerState workerData,
Map<String,Object> topoConf) |
| Constructor and Description |
|---|
BoltExecutor(WorkerState workerData,
List<Long> executorId,
Map<String,String> credentials) |
| Constructor and Description |
|---|
SpoutExecutor(WorkerState workerData,
List<Long> executorId,
Map<String,String> credentials) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.