| Package | Description |
|---|---|
| org.apache.storm.daemon.supervisor |
| Modifier and Type | Class and Description |
|---|---|
class |
StandaloneSupervisor |
| Modifier and Type | Method and Description |
|---|---|
ISupervisor |
Supervisor.getiSupervisor() |
| Constructor and Description |
|---|
Slot(AsyncLocalizer localizer,
Map<String,Object> conf,
ContainerLauncher containerLauncher,
String host,
int port,
LocalState localState,
IStormClusterState clusterState,
ISupervisor supervisor,
AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments,
OnlyLatestExecutor<Integer> metricsExec,
WorkerMetricsProcessor metricsProcessor,
org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics) |
Supervisor(Map<String,Object> conf,
IContext sharedContext,
ISupervisor iSupervisor,
StormMetricsRegistry metricsRegistry)
Constructor for supervisor daemon.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.