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