Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.generated | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
Supervisor.Iface |
Supervisor.getSupervisorThriftInterface() |
Modifier and Type | Method and Description |
---|---|
static ContainerLauncher |
ContainerLauncher.make(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
IContext sharedContext,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker,
Supervisor.Iface localSupervisor)
Factory to create the right container launcher for the config and the environment.
|
Constructor and Description |
---|
LocalContainer(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
IContext sharedContext,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker,
Supervisor.Iface localSupervisor) |
LocalContainerLauncher(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
IContext sharedContext,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker,
Supervisor.Iface localSupervisor) |
Modifier and Type | Class and Description |
---|---|
static class |
Supervisor.Processor<I extends Supervisor.Iface> |
static class |
Supervisor.Processor.getLocalAssignmentForStorm<I extends Supervisor.Iface> |
static class |
Supervisor.Processor.sendSupervisorAssignments<I extends Supervisor.Iface> |
static class |
Supervisor.Processor.sendSupervisorWorkerHeartbeat<I extends Supervisor.Iface> |
Modifier and Type | Class and Description |
---|---|
static class |
Supervisor.Client |
Modifier and Type | Method and Description |
---|---|
Supervisor.Iface |
SupervisorIfaceFactory.getIface() |
Copyright © 2022 The Apache Software Foundation. All rights reserved.