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 © 2019 The Apache Software Foundation. All Rights Reserved.