| Package | Description |
|---|---|
| org.apache.storm.daemon.supervisor | |
| 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) |
| Constructor and Description |
|---|
Container(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int port,
LocalAssignment assignment,
String workerId,
Map<String,Object> topoConf,
AdvancedFSOps ops)
Create a new Container.
|
| Modifier and Type | Method and Description |
|---|---|
static StormTopology |
ConfigUtils.readSupervisorStormCodeGivenPath(String stormCodePath,
AdvancedFSOps ops) |
static StormTopology |
ConfigUtils.readSupervisorTopology(Map conf,
String stormId,
AdvancedFSOps ops) |
StormTopology |
ConfigUtils.readSupervisorTopologyImpl(Map conf,
String stormId,
AdvancedFSOps ops) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.