Package | Description |
---|---|
org.apache.storm.daemon.supervisor |
Modifier and Type | Class and Description |
---|---|
class |
BasicContainerLauncher
Launch containers with no security using standard java commands.
|
class |
LocalContainerLauncher
Launch Containers in local mode.
|
class |
RunAsUserContainerLauncher |
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 |
---|
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) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.