Package | Description |
---|---|
org.apache.storm.daemon.nimbus | |
org.apache.storm.daemon.supervisor | |
org.apache.storm.utils |
Modifier and Type | Field and Description |
---|---|
static SimpleVersion |
Nimbus.MIN_VERSION_SUPPORT_RPC_HEARTBEAT |
Modifier and Type | Method and Description |
---|---|
protected List<String> |
BasicContainer.frameworkClasspath(SimpleVersion topoVersion) |
protected String |
BasicContainer.getWorkerClassPath(String stormJar,
List<String> dependencyLocations,
SimpleVersion topoVersion)
Compute the classpath for the worker process.
|
protected String |
BasicContainer.getWorkerLogWriter(SimpleVersion topoVersion) |
protected String |
BasicContainer.getWorkerMain(SimpleVersion topoVersion) |
Modifier and Type | Field and Description |
---|---|
static SimpleVersion |
VersionInfo.OUR_VERSION |
Modifier and Type | Method and Description |
---|---|
static NavigableMap<SimpleVersion,List<String>> |
Utils.getConfiguredClasspathVersions(Map<String,Object> conf,
List<String> currentClassPath)
Get a map of version to classpath from the conf Config.SUPERVISOR_WORKER_VERSION_CLASSPATH_MAP
|
static NavigableMap<SimpleVersion,String> |
Utils.getConfiguredWorkerLogWriterVersions(Map<String,Object> conf)
Get a map of version to worker log writer from the conf Config.SUPERVISOR_WORKER_VERSION_LOGWRITER_MAP
|
static NavigableMap<SimpleVersion,String> |
Utils.getConfiguredWorkerMainVersions(Map<String,Object> conf)
Get a map of version to worker main from the conf Config.SUPERVISOR_WORKER_VERSION_MAIN_MAP
|
Modifier and Type | Method and Description |
---|---|
int |
SimpleVersion.compareTo(SimpleVersion o) |
static <T> T |
Utils.getCompatibleVersion(NavigableMap<SimpleVersion,T> versionedMap,
SimpleVersion desiredVersion,
String what,
T defaultValue) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
Utils.getCompatibleVersion(NavigableMap<SimpleVersion,T> versionedMap,
SimpleVersion desiredVersion,
String what,
T defaultValue) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.