Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.localizer | |
org.apache.storm.utils |
Modifier and Type | Field and Description |
---|---|
protected AdvancedFSOps |
Container.ops |
Modifier and Type | Method and Description |
---|---|
static AdvancedFSOps |
AdvancedFSOps.make(Map<String,Object> conf)
Factory to create a new AdvancedFSOps.
|
Modifier and Type | Method and Description |
---|---|
static List<String> |
BasicContainer.getDependencyLocationsFor(Map<String,Object> conf,
String topologyId,
AdvancedFSOps ops,
String stormRoot) |
static String |
BasicContainer.getStormVersionFor(Map<String,Object> conf,
String topologyId,
AdvancedFSOps ops,
String stormRoot) |
Constructor and Description |
---|
Container(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
ResourceIsolationInterface resourceIsolationManager,
String workerId,
Map<String,Object> topoConf,
AdvancedFSOps ops,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker)
Create a new Container.
|
Constructor and Description |
---|
LocallyCachedTopologyBlob(String topologyId,
boolean isLocalMode,
Map<String,Object> conf,
AdvancedFSOps fsOps,
LocallyCachedTopologyBlob.TopologyBlobType type,
String owner,
StormMetricsRegistry metricsRegistry)
Create a new LocallyCachedBlob.
|
Modifier and Type | Method and Description |
---|---|
static StormTopology |
ConfigUtils.readSupervisorStormCodeGivenPath(String stormCodePath,
AdvancedFSOps ops) |
static StormTopology |
ConfigUtils.readSupervisorTopology(Map<String,Object> conf,
String stormId,
AdvancedFSOps ops) |
StormTopology |
ConfigUtils.readSupervisorTopologyImpl(Map<String,Object> conf,
String stormId,
AdvancedFSOps ops) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.