Package org.apache.storm.daemon.ui
Class UIHelpers
java.lang.Object
org.apache.storm.daemon.ui.UIHelpers
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidconfigFilter(org.eclipse.jetty.server.Server server, jakarta.servlet.Servlet servlet, List<FilterConfiguration> filtersConfs) static voidconfigFilter(org.eclipse.jetty.server.Server server, jakarta.servlet.Servlet servlet, List<FilterConfiguration> filtersConfs, Map<String, String> params) Config filter.static voidconfigFilters(org.eclipse.jetty.servlet.ServletContextHandler context, List<FilterConfiguration> filtersConfs) Config filters.static voidconfigSsl(org.eclipse.jetty.server.Server server, Integer port, String ksPath, String ksPassword, String ksType, String keyPassword, String tsPath, String tsPassword, String tsType, Boolean needClientAuth, Boolean wantClientAuth, boolean enableSslReload) static voidconfigSsl(org.eclipse.jetty.server.Server server, Integer port, String ksPath, String ksPassword, String ksType, String keyPassword, String tsPath, String tsPassword, String tsType, Boolean needClientAuth, Boolean wantClientAuth, Integer headerBufferSize, boolean enableSslReload) configSsl.static org.eclipse.jetty.servlet.FilterHoldercorsFilterHandle.static MapexceptionToJson(Exception ex, int statusCode) Converts exception into json map.getActiveAction(ProfileRequest profileRequest, Map config, String topologyId) getActiveAction.static ListgetActiveProfileActions(Nimbus.Iface client, String id, String component, Map config) getActiveProfileActions.getAllTopologiesSummary(List<TopologySummary> topologies, Map<String, Object> config) getAllTopologiesSummary.static Map<String,List<ExecutorSummary>> getBoltExecutors(List<ExecutorSummary> executorSummaries, StormTopology stormTopology, boolean sys) getBoltExecutors.getBuildVisualization(Nimbus.Iface client, Map<String, Object> config, String window, String id, boolean sys) getBuildVisualization.getClusterSummary(ClusterSummary clusterSummary, String user, Map<String, Object> conf) Converts thrift call result into map fit for UI/api.getComponentPage(Nimbus.Iface client, String id, String component, String window, boolean sys, String user, Map config) getComponentPage.getInputMap(Map.Entry<GlobalStreamId, Grouping> entryInput) getInputMap.static StringgetJsonResponseBody(Object data, String callback, boolean needSerialize) static MapgetJsonResponseHeaders(String callback, Map headers) getJsonResponseHeaders.static StringgetLogviewerLink.static intgetLogviewerPort(Map<String, Object> config) Get logviewer port depending on whether the logviewer is secure or not.static StringgetNimbusLogLink(String host, Map<String, Object> config) Get log link to nimbus log.getNimbusSummary(ClusterSummary clusterInfo, Map<String, Object> config) getNimbusSummary.getOwnerResourceSummaries(List<OwnerResourceSummary> ownerResourceSummaries, Map<String, Object> conf) Get prettified ownerResourceSummaries.getOwnerResourceSummary(List<OwnerResourceSummary> ownerResourceSummaries, Nimbus.Iface client, String id, Map<String, Object> config) Get a specific owner resource summary.getPrettifiedSupervisorMap(SupervisorSummary supervisorSummary, Map<String, Object> config) Get supervisor info in a map.getProfilingDisabled.static Map<String,List<ExecutorSummary>> getSpoutExecutors(List<ExecutorSummary> executorSummaries, StormTopology stormTopology) getSpoutExecutors.getStatDisplayMap(Map<String, Double> rawDisplayMap) getStatDisplayMap.getStatMapFromExecutorSummary(ExecutorSummary executorSummary) getStatMapFromExecutorSummary.getStreamBox(Object visualization) getStreamBox.static StringgetSupervisorLogLink(String host, Map<String, Object> config) Get log link to supervisor log.getSupervisorPageInfo(SupervisorPageInfo supervisorPageInfo, Map<String, Object> config) getSupervisorPageInfo.getSupervisorSummary(List<SupervisorSummary> supervisors, jakarta.ws.rs.core.SecurityContext securityContext, Map<String, Object> config) getSupervisorSummary.getTopolgoyLogConfig(LogConfig logConfig) getTopolgoyLogConfig.getTopologyHistoryInfo(TopologyHistoryInfo topologyHistory) Get topology history.getTopologyLag(StormTopology userTopology, Map<String, Object> config) getTopologyLag.getTopologyMap(TopologySummary topologySummary) getTopologyMap.getTopologyOpResponse(String id, String op) getTopologyOpResponse.getTopologyProfilingDump(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingDump.getTopologyProfilingDumpHeap(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingDumpHeap.getTopologyProfilingDumpJstack(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingRestartWorker(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingRestartWorker.getTopologyProfilingStart(Nimbus.Iface client, String id, String hostPort, String timeout, Map<String, Object> config) getTopologyProfilingStart.getTopologyProfilingStop(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingStop.getTopologySummary(TopologyPageInfo topologyPageInfo, String window, Map<String, Object> config, String remoteUser) getTopologySummary.getTopologyWorkers(TopologyInfo topologyInfo, Map config) getTopologyWorkers.getVisualizationData(Nimbus.Iface client, String window, String topoId, boolean sys) getVisualizationData.static StringgetWindowHint(String window) getWindowHint.static StringgetWorkerDumpLink.static StringGet log link to supervisor log.getWorkerSummaries(SupervisorPageInfo supervisorPageInfo, Map<String, Object> config) getWorkerSummaries.static booleanisSecureLogviewer(Map<String, Object> config) Check if logviewer is secure.static org.eclipse.jetty.server.ServerjettyCreateServer(Integer port, String host, Integer httpsPort, Boolean disableHttpBinding) Construct a Jetty Server instance.static org.eclipse.jetty.server.ServerjettyCreateServer(Integer port, String host, Integer httpsPort, Integer headerBufferSize, Boolean disableHttpBinding) Construct a Jetty Server instance.static jakarta.ws.rs.core.ResponsemakeStandardResponse(Object data, String callback) static jakarta.ws.rs.core.ResponsemakeStandardResponse(Object data, String callback, boolean needsSerialization, jakarta.ws.rs.core.Response.Status status) makeStandardResponse.static jakarta.ws.rs.core.ResponsemakeStandardResponse(Object data, String callback, jakarta.ws.rs.core.Response.Status status) static org.eclipse.jetty.servlet.FilterHoldermkAccessLoggingFilterHandle.static StringPrettified executor info.static StringprettyUptimeMs(int ms) prettyUptimeMs.static StringprettyUptimeMs(String ms) prettyUptimeMs.static StringprettyUptimeSec(int secs) prettyUptimeSec.static StringprettyUptimeSec(String sec) Prettify uptime string.static StringprettyUptimeStr(String val, Object[][] dividers) Prettify uptime string.putTopologyActivate(Nimbus.Iface client, String id) putTopologyActivate.putTopologyDeactivate(Nimbus.Iface client, String id) putTopologyDeactivate.putTopologyDebugActionSpct(Nimbus.Iface client, String id, String action, String spct, String component) putTopologyDebugActionSpct.putTopologyKill(Nimbus.Iface client, String id, String waitTime) putTopologyKill.putTopologyLogLevel(Nimbus.Iface client, Map<String, Map> namedLogLevel, String id) putTopologyLogLevel.putTopologyRebalance(Nimbus.Iface client, String id, String waitTime) putTopologyRebalance.static StringsanitizeStreamName(String streamName) Sanitizes streamName for use as an identifier in the visualization.sanitizeTransferredStats.static voidsetTopologyProfilingAction(Nimbus.Iface client, String id, String hostPort, Long timestamp, Map<String, Object> config, ProfileAction profileAction) setTopologyProfilingAction.static voidstormRunJetty(Integer port, Integer headerBufferSize, IConfigurator configurator) static voidstormRunJetty(Integer port, String host, Integer httpsPort, Integer headerBufferSize, IConfigurator configurator) Modified version of run-jetty Assumes configurator sets handler.unauthorizedUserJson(String user) Unauthorized user json.unpackBoltPageInfo(ComponentPageInfo componentPageInfo, String topologyId, String window, boolean sys, Map config) unpackBoltPageInfo.unpackOwnerResourceSummary(OwnerResourceSummary ownerResourceSummary) Prettify OwnerResourceSummary.unpackSpoutPageInfo(ComponentPageInfo componentPageInfo, String topologyId, String window, boolean sys, Map config) unpackSpoutPageInfo.static Stringurl formatter for log links.static StringwrapJsonInCallback(String callback, String response) wrapJsonInCallback.
- 
Constructor Details- 
UIHelperspublic UIHelpers()
 
- 
- 
Method Details- 
prettyUptimeStrPrettify uptime string.- Parameters:
- val- val.
- dividers- dividers.
- Returns:
- prettified uptime string.
 
- 
prettyUptimeSecPrettify uptime string.- Parameters:
- sec- uptime in seconds.
- Returns:
- prettified uptime string.
 
- 
prettyUptimeSecprettyUptimeSec.- Parameters:
- secs- secs
- Returns:
- prettyUptimeSec
 
- 
prettyUptimeMsprettyUptimeMs.- Parameters:
- ms- ms
- Returns:
- prettyUptimeMs
 
- 
prettyUptimeMsprettyUptimeMs.- Parameters:
- ms- ms
- Returns:
- prettyUptimeMs
 
- 
urlFormaturl formatter for log links.- Parameters:
- fmt- string format
- args- hostname and other arguments.
- Returns:
- string formatter
 
- 
prettyExecutorInfoPrettified executor info.- Parameters:
- e- from Nimbus call
- Returns:
- prettified executor info string
 
- 
unauthorizedUserJsonUnauthorized user json.- Parameters:
- user- User id.
- Returns:
- Unauthorized user json.
 
- 
configSsl
- 
configSslpublic static void configSsl(org.eclipse.jetty.server.Server server, Integer port, String ksPath, String ksPassword, String ksType, String keyPassword, String tsPath, String tsPassword, String tsType, Boolean needClientAuth, Boolean wantClientAuth, Integer headerBufferSize, boolean enableSslReload) configSsl.- Parameters:
- server- server
- port- port
- ksPath- ksPath
- ksPassword- ksPassword
- ksType- ksType
- keyPassword- keyPassword
- tsPath- tsPath
- tsPassword- tsPassword
- tsType- tsType
- needClientAuth- needClientAuth
- wantClientAuth- wantClientAuth
- headerBufferSize- headerBufferSize
- enableSslReload- enable ssl reload
 
- 
corsFilterHandlepublic static org.eclipse.jetty.servlet.FilterHolder corsFilterHandle()corsFilterHandle.- Returns:
- corsFilterHandle
 
- 
mkAccessLoggingFilterHandlepublic static org.eclipse.jetty.servlet.FilterHolder mkAccessLoggingFilterHandle()mkAccessLoggingFilterHandle.- Returns:
- mkAccessLoggingFilterHandle
 
- 
configFilterpublic static void configFilter(org.eclipse.jetty.server.Server server, jakarta.servlet.Servlet servlet, List<FilterConfiguration> filtersConfs) 
- 
configFilterpublic static void configFilter(org.eclipse.jetty.server.Server server, jakarta.servlet.Servlet servlet, List<FilterConfiguration> filtersConfs, Map<String, String> params) Config filter.- Parameters:
- server- Server
- servlet- Servlet
- filtersConfs- FiltersConfs
- params- Filter params
 
- 
configFilterspublic static void configFilters(org.eclipse.jetty.servlet.ServletContextHandler context, List<FilterConfiguration> filtersConfs) Config filters.- Parameters:
- context- Servlet context
- filtersConfs- filter confs
 
- 
jettyCreateServerpublic static org.eclipse.jetty.server.Server jettyCreateServer(Integer port, String host, Integer httpsPort, Boolean disableHttpBinding) Construct a Jetty Server instance.
- 
jettyCreateServerpublic static org.eclipse.jetty.server.Server jettyCreateServer(Integer port, String host, Integer httpsPort, Integer headerBufferSize, Boolean disableHttpBinding) Construct a Jetty Server instance.
- 
stormRunJettypublic static void stormRunJetty(Integer port, String host, Integer httpsPort, Integer headerBufferSize, IConfigurator configurator) throws Exception Modified version of run-jetty Assumes configurator sets handler.- Throws:
- Exception
 
- 
stormRunJettypublic static void stormRunJetty(Integer port, Integer headerBufferSize, IConfigurator configurator) throws Exception - Throws:
- Exception
 
- 
wrapJsonInCallbackwrapJsonInCallback.- Parameters:
- callback- callbackParameterName
- response- response
- Returns:
- wrapJsonInCallback
 
- 
getJsonResponseHeadersgetJsonResponseHeaders.- Parameters:
- callback- callbackParameterName
- headers- headers
- Returns:
- getJsonResponseHeaders
 
- 
getJsonResponseBody
- 
exceptionToJsonConverts exception into json map.- Parameters:
- ex- Exception to be converted.
- statusCode- Status code to be returned.
- Returns:
- Map to be converted into json.
 
- 
makeStandardResponse
- 
makeStandardResponse
- 
makeStandardResponsepublic static jakarta.ws.rs.core.Response makeStandardResponse(Object data, String callback, boolean needsSerialization, jakarta.ws.rs.core.Response.Status status) makeStandardResponse.- Parameters:
- data- data
- callback- callbackParameterName
- needsSerialization- needsSerialization
- Returns:
- makeStandardResponse
 
- 
getClusterSummarypublic static Map<String,Object> getClusterSummary(ClusterSummary clusterSummary, String user, Map<String, Object> conf) Converts thrift call result into map fit for UI/api.- Parameters:
- clusterSummary- Obtained from Nimbus.
- user- User Making request
- conf- Storm Conf
- Returns:
- Cluster Summary for display on UI/monitoring purposes via API
 
- 
unpackOwnerResourceSummarypublic static Map<String,Object> unpackOwnerResourceSummary(OwnerResourceSummary ownerResourceSummary) Prettify OwnerResourceSummary.- Parameters:
- ownerResourceSummary- ownerResourceSummary
- Returns:
- Map of prettified OwnerResourceSummary.
 
- 
getOwnerResourceSummariespublic static Map<String,Object> getOwnerResourceSummaries(List<OwnerResourceSummary> ownerResourceSummaries, Map<String, Object> conf) Get prettified ownerResourceSummaries.- Parameters:
- ownerResourceSummaries- ownerResourceSummaries from thrift call
- conf- Storm conf
- Returns:
- map to be converted to json.
 
- 
getTopologyMapgetTopologyMap.- Parameters:
- topologySummary- topologySummary
- Returns:
- getTopologyMap
 
- 
getOwnerResourceSummarypublic static Map<String,Object> getOwnerResourceSummary(List<OwnerResourceSummary> ownerResourceSummaries, Nimbus.Iface client, String id, Map<String, Object> config) throws org.apache.storm.thrift.TExceptionGet a specific owner resource summary.- Parameters:
- ownerResourceSummaries- Result from thrift call.
- client- client
- id- Owner id.
- config- Storm conf.
- Returns:
- prettified owner resource summary.
- Throws:
- org.apache.storm.thrift.TException
 
- 
getLogviewerLinkpublic static String getLogviewerLink(String host, String fname, Map<String, Object> config, int port) getLogviewerLink.- Parameters:
- host- host
- fname- fname
- config- config
- port- port
- Returns:
- getLogviewerLink.
 
- 
getNimbusLogLinkGet log link to nimbus log.- Parameters:
- host- nimbus host name
- config- storm config
- Returns:
- log link.
 
- 
getSupervisorLogLinkGet log link to supervisor log.- Parameters:
- host- supervisor host name
- config- storm config
- Returns:
- log link.
 
- 
getWorkerLogLinkpublic static String getWorkerLogLink(String host, int port, Map<String, Object> config, String topologyId) Get log link to supervisor log.- Parameters:
- host- supervisor host name
- config- storm config
- Returns:
- log link.
 
- 
getPrettifiedSupervisorMappublic static Map<String,Object> getPrettifiedSupervisorMap(SupervisorSummary supervisorSummary, Map<String, Object> config) Get supervisor info in a map.- Parameters:
- supervisorSummary- from nimbus call.
- config- Storm config.
- Returns:
- prettified supervisor info map.
 
- 
getTopologyHistoryInfoGet topology history.- Parameters:
- topologyHistory- from Nimbus call.
- Returns:
- map ready to be returned.
 
- 
isSecureLogviewerCheck if logviewer is secure.- Parameters:
- config- Storm config.
- Returns:
- true if logiviwer is secure.
 
- 
getLogviewerPortGet logviewer port depending on whether the logviewer is secure or not.- Parameters:
- config- Storm config.
- Returns:
- appropriate port.
 
- 
getWorkerSummariespublic static List<Map> getWorkerSummaries(SupervisorPageInfo supervisorPageInfo, Map<String, Object> config) getWorkerSummaries.- Parameters:
- supervisorPageInfo- supervisorPageInfo
- config- config
- Returns:
- getWorkerSummaries
 
- 
getSupervisorSummarypublic static Map<String,Object> getSupervisorSummary(List<SupervisorSummary> supervisors, jakarta.ws.rs.core.SecurityContext securityContext, Map<String, Object> config) getSupervisorSummary.- Parameters:
- supervisors- supervisor summary list.
- securityContext- security context injected.
- config- Storm config.
- Returns:
- Prettified JSON.
 
- 
getSupervisorPageInfopublic static Map<String,Object> getSupervisorPageInfo(SupervisorPageInfo supervisorPageInfo, Map<String, Object> config) getSupervisorPageInfo.- Parameters:
- supervisorPageInfo- supervisorPageInfo
- config- config
- Returns:
- getSupervisorPageInfo
 
- 
getAllTopologiesSummarypublic static Map<String,Object> getAllTopologiesSummary(List<TopologySummary> topologies, Map<String, Object> config) getAllTopologiesSummary.- Parameters:
- topologies- topologies
- config- config
- Returns:
- getAllTopologiesSummary
 
- 
getWindowHintgetWindowHint.- Parameters:
- window- window
- Returns:
- getWindowHint
 
- 
getStatDisplayMapgetStatDisplayMap.- Parameters:
- rawDisplayMap- rawDisplayMap
- Returns:
- getStatDisplayMap
 
- 
getTopologySummarypublic static Map<String,Object> getTopologySummary(TopologyPageInfo topologyPageInfo, String window, Map<String, Object> config, String remoteUser) getTopologySummary.- Parameters:
- topologyPageInfo- topologyPageInfo
- window- window
- config- config
- remoteUser- remoteUser
- Returns:
- getTopologySummary
 
- 
getTopologyWorkersgetTopologyWorkers.- Parameters:
- topologyInfo- topologyInfo
- config- config
- Returns:
- getTopologyWorkers.
 
- 
getTopologyLagpublic static Map<String,Map<String, getTopologyLagObject>> (StormTopology userTopology, Map<String, Object> config) getTopologyLag.- Parameters:
- userTopology- userTopology
- config- config
- Returns:
- getTopologyLag.
 
- 
getBoltExecutorspublic static Map<String,List<ExecutorSummary>> getBoltExecutors(List<ExecutorSummary> executorSummaries, StormTopology stormTopology, boolean sys) getBoltExecutors.- Parameters:
- executorSummaries- executorSummaries
- stormTopology- stormTopology
- sys- sys
- Returns:
- getBoltExecutors.
 
- 
getSpoutExecutorspublic static Map<String,List<ExecutorSummary>> getSpoutExecutors(List<ExecutorSummary> executorSummaries, StormTopology stormTopology) getSpoutExecutors.- Parameters:
- executorSummaries- executorSummaries
- stormTopology- stormTopology
- Returns:
- getSpoutExecutors.
 
- 
sanitizeStreamNameSanitizes streamName for use as an identifier in the visualization. Replaces all characters except A-Z, a-z, '.', '-', and '_' with '_'. If streamName does not start with A-Z or a-z, adds '_s' prefix.- Parameters:
- streamName- non-null streamName
- Returns:
- sanitized stream name
 
- 
sanitizeTransferredStatspublic static Map<String,Map<String, sanitizeTransferredStatsLong>> (Map<String, Map<String, Long>> stats) sanitizeTransferredStats.- Parameters:
- stats- stats
- Returns:
- sanitizeTransferredStats
 
- 
getStatMapFromExecutorSummarygetStatMapFromExecutorSummary.- Parameters:
- executorSummary- executorSummary
- Returns:
- getStatMapFromExecutorSummary
 
- 
getInputMapgetInputMap.- Parameters:
- entryInput- entryInput
- Returns:
- getInputMap
 
- 
getVisualizationDatapublic static Map<String,Object> getVisualizationData(Nimbus.Iface client, String window, String topoId, boolean sys) throws org.apache.storm.thrift.TException getVisualizationData.- Parameters:
- client- client
- window- window
- topoId- topoId
- sys- sys
- Returns:
- getVisualizationData
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getStreamBoxgetStreamBox.- Parameters:
- visualization- visualization
- Returns:
- getStreamBox
 
- 
getBuildVisualizationpublic static Map<String,Object> getBuildVisualization(Nimbus.Iface client, Map<String, Object> config, String window, String id, boolean sys) throws org.apache.storm.thrift.TExceptiongetBuildVisualization.- Parameters:
- client- client
- config- config
- window- window
- id- id
- sys- sys
- Returns:
- getBuildVisualization
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getActiveActionpublic static Map<String,Object> getActiveAction(ProfileRequest profileRequest, Map config, String topologyId) getActiveAction.- Parameters:
- profileRequest- profileRequest
- config- config
- topologyId- topologyId
- Returns:
- getActiveAction
 
- 
getActiveProfileActionspublic static List getActiveProfileActions(Nimbus.Iface client, String id, String component, Map config) throws org.apache.storm.thrift.TException getActiveProfileActions.- Parameters:
- client- client
- id- id
- component- component
- config- config
- Returns:
- getActiveProfileActions
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getWorkerDumpLinkpublic static String getWorkerDumpLink(String host, long port, String topologyId, Map<String, Object> config) getWorkerDumpLink.- Parameters:
- host- host
- port- port
- topologyId- topologyId
- config- config
- Returns:
- getWorkerDumpLink
 
- 
unpackBoltPageInfopublic static Map<String,Object> unpackBoltPageInfo(ComponentPageInfo componentPageInfo, String topologyId, String window, boolean sys, Map config) unpackBoltPageInfo.- Parameters:
- componentPageInfo- componentPageInfo
- topologyId- topologyId
- window- window
- sys- sys
- config- config
- Returns:
- unpackBoltPageInfo
 
- 
unpackSpoutPageInfopublic static Map<String,Object> unpackSpoutPageInfo(ComponentPageInfo componentPageInfo, String topologyId, String window, boolean sys, Map config) unpackSpoutPageInfo.- Parameters:
- componentPageInfo- componentPageInfo
- topologyId- topologyId
- window- window
- sys- sys
- config- config
- Returns:
- unpackSpoutPageInfo
 
- 
getComponentPagepublic static Map<String,Object> getComponentPage(Nimbus.Iface client, String id, String component, String window, boolean sys, String user, Map config) throws org.apache.storm.thrift.TException getComponentPage.- Parameters:
- client- client
- id- id
- component- component
- window- window
- sys- sys
- user- user
- config- config
- Returns:
- getComponentPage
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getTopolgoyLogConfiggetTopolgoyLogConfig.- Parameters:
- logConfig- logConfig
- Returns:
- getTopolgoyLogConfig
 
- 
getTopologyOpResponsegetTopologyOpResponse.- Parameters:
- id- id
- op- op
- Returns:
- getTopologyOpResponse
 
- 
putTopologyActivatepublic static Map<String,Object> putTopologyActivate(Nimbus.Iface client, String id) throws org.apache.storm.thrift.TException putTopologyActivate.- Parameters:
- client- client
- id- id
- Returns:
- putTopologyActivate
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
putTopologyDeactivatepublic static Map<String,Object> putTopologyDeactivate(Nimbus.Iface client, String id) throws org.apache.storm.thrift.TException putTopologyDeactivate.- Parameters:
- client- client
- id- id
- Returns:
- putTopologyDeactivate
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
putTopologyDebugActionSpctpublic static Map<String,Object> putTopologyDebugActionSpct(Nimbus.Iface client, String id, String action, String spct, String component) throws org.apache.storm.thrift.TException putTopologyDebugActionSpct.- Parameters:
- client- client
- id- id
- action- action
- spct- spct
- component- component
- Returns:
- putTopologyDebugActionSpct
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
putTopologyRebalancepublic static Map<String,Object> putTopologyRebalance(Nimbus.Iface client, String id, String waitTime) throws org.apache.storm.thrift.TException putTopologyRebalance.- Parameters:
- client- client
- id- id
- waitTime- waitTime
- Returns:
- putTopologyRebalance
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
putTopologyKillpublic static Map<String,Object> putTopologyKill(Nimbus.Iface client, String id, String waitTime) throws org.apache.storm.thrift.TException putTopologyKill.- Parameters:
- client- client
- id- id
- waitTime- waitTime
- Returns:
- putTopologyKill
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
setTopologyProfilingActionpublic static void setTopologyProfilingAction(Nimbus.Iface client, String id, String hostPort, Long timestamp, Map<String, Object> config, ProfileAction profileAction) throws org.apache.storm.thrift.TExceptionsetTopologyProfilingAction.- Parameters:
- client- client
- id- id
- hostPort- hostPort
- timestamp- timestamp
- config- config
- profileAction- profileAction
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getTopologyProfilingStartpublic static Map<String,Object> getTopologyProfilingStart(Nimbus.Iface client, String id, String hostPort, String timeout, Map<String, Object> config) throws org.apache.storm.thrift.TExceptiongetTopologyProfilingStart.- Parameters:
- client- client
- id- id
- hostPort- hostPort
- timeout- timeout
- config- config
- Returns:
- getTopologyProfilingStart
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getTopologyProfilingStoppublic static Map<String,Object> getTopologyProfilingStop(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) throws org.apache.storm.thrift.TExceptiongetTopologyProfilingStop.- Parameters:
- client- client
- id- id
- hostPort- hostPort
- config- config
- Returns:
- getTopologyProfilingStop
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getProfilingDisabledgetProfilingDisabled.- Returns:
- getProfilingDisabled
 
- 
getTopologyProfilingDumppublic static Map<String,Object> getTopologyProfilingDump(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) throws org.apache.storm.thrift.TExceptiongetTopologyProfilingDump.- Parameters:
- client- client
- id- id
- hostPort- hostPort
- config- config
- Returns:
- getTopologyProfilingDump
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getTopologyProfilingDumpJstackpublic static Map<String,Object> getTopologyProfilingDumpJstack(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyProfilingRestartWorkerpublic static Map<String,Object> getTopologyProfilingRestartWorker(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) throws org.apache.storm.thrift.TExceptiongetTopologyProfilingRestartWorker.- Parameters:
- client- client
- id- id
- hostPort- hostPort
- config- config
- Returns:
- getTopologyProfilingRestartWorker
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getTopologyProfilingDumpHeappublic static Map<String,Object> getTopologyProfilingDumpHeap(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) throws org.apache.storm.thrift.TExceptiongetTopologyProfilingDumpHeap.- Parameters:
- client- client
- id- id
- hostPort- hostport
- config- config
- Returns:
- getTopologyProfilingDumpHeap
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
putTopologyLogLevelpublic static Map<String,Object> putTopologyLogLevel(Nimbus.Iface client, Map<String, Map> namedLogLevel, String id) throws org.apache.storm.thrift.TExceptionputTopologyLogLevel.- Parameters:
- client- client
- namedLogLevel- namedLogLevel
- id- id
- Returns:
- putTopologyLogLevel.
- Throws:
- org.apache.storm.thrift.TException- TException
 
- 
getNimbusSummarypublic static Map<String,Object> getNimbusSummary(ClusterSummary clusterInfo, Map<String, Object> config) getNimbusSummary.- Parameters:
- clusterInfo- clusterInfo
- config- config
- Returns:
- getNimbusSummary
 
 
-