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 © 2022 The Apache Software Foundation. All rights reserved.