Uses of Interface
org.apache.storm.generated.Nimbus.Iface
Package
Description
-
Uses of Nimbus.Iface in org.apache.storm
Modifier and TypeClassDescriptionclass
A stand alone storm cluster that runs inside a single process. -
Uses of Nimbus.Iface in org.apache.storm.daemon.nimbus
-
Uses of Nimbus.Iface in org.apache.storm.daemon.supervisor
-
Uses of Nimbus.Iface in org.apache.storm.daemon.supervisor.timer
Modifier and TypeMethodDescriptionSynchronizeAssignments.getAllAssignmentsFromNumaSupervisors
(Nimbus.Iface nimbus, String node) -
Uses of Nimbus.Iface in org.apache.storm.daemon.ui
Modifier and TypeMethodDescriptionstatic List
UIHelpers.getActiveProfileActions
(Nimbus.Iface client, String id, String component, Map config) getActiveProfileActions.UIHelpers.getBuildVisualization
(Nimbus.Iface client, Map<String, Object> config, String window, String id, boolean sys) getBuildVisualization.UIHelpers.getComponentPage
(Nimbus.Iface client, String id, String component, String window, boolean sys, String user, Map config) getComponentPage.UIHelpers.getOwnerResourceSummary
(List<OwnerResourceSummary> ownerResourceSummaries, Nimbus.Iface client, String id, Map<String, Object> config) Get a specific owner resource summary.UIHelpers.getTopologyProfilingDump
(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingDump.UIHelpers.getTopologyProfilingDumpHeap
(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingDumpHeap.UIHelpers.getTopologyProfilingDumpJstack
(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) UIHelpers.getTopologyProfilingRestartWorker
(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingRestartWorker.UIHelpers.getTopologyProfilingStart
(Nimbus.Iface client, String id, String hostPort, String timeout, Map<String, Object> config) getTopologyProfilingStart.UIHelpers.getTopologyProfilingStop
(Nimbus.Iface client, String id, String hostPort, Map<String, Object> config) getTopologyProfilingStop.UIHelpers.getVisualizationData
(Nimbus.Iface client, String window, String topoId, boolean sys) getVisualizationData.UIHelpers.putTopologyActivate
(Nimbus.Iface client, String id) putTopologyActivate.UIHelpers.putTopologyDeactivate
(Nimbus.Iface client, String id) putTopologyDeactivate.UIHelpers.putTopologyDebugActionSpct
(Nimbus.Iface client, String id, String action, String spct, String component) putTopologyDebugActionSpct.UIHelpers.putTopologyKill
(Nimbus.Iface client, String id, String waitTime) putTopologyKill.UIHelpers.putTopologyLogLevel
(Nimbus.Iface client, Map<String, Map> namedLogLevel, String id) putTopologyLogLevel.UIHelpers.putTopologyRebalance
(Nimbus.Iface client, String id, String waitTime) putTopologyRebalance.static void
UIHelpers.setTopologyProfilingAction
(Nimbus.Iface client, String id, String hostPort, Long timestamp, Map<String, Object> config, ProfileAction profileAction) setTopologyProfilingAction. -
Uses of Nimbus.Iface in org.apache.storm.generated
Modifier and TypeClassDescriptionstatic class
Nimbus.Processor<I extends Nimbus.Iface>
static class
Nimbus.Processor.activate<I extends Nimbus.Iface>
static class
Nimbus.Processor.beginBlobDownload<I extends Nimbus.Iface>
static class
Nimbus.Processor.beginCreateBlob<I extends Nimbus.Iface>
static class
Nimbus.Processor.beginFileUpload<I extends Nimbus.Iface>
static class
Nimbus.Processor.beginUpdateBlob<I extends Nimbus.Iface>
static class
Nimbus.Processor.cancelBlobUpload<I extends Nimbus.Iface>
static class
static class
Nimbus.Processor.deactivate<I extends Nimbus.Iface>
static class
Nimbus.Processor.debug<I extends Nimbus.Iface>
static class
Nimbus.Processor.deleteBlob<I extends Nimbus.Iface>
static class
Nimbus.Processor.downloadBlobChunk<I extends Nimbus.Iface>
static class
Nimbus.Processor.downloadChunk<I extends Nimbus.Iface>
static class
Nimbus.Processor.finishBlobUpload<I extends Nimbus.Iface>
static class
Nimbus.Processor.finishFileUpload<I extends Nimbus.Iface>
static class
Nimbus.Processor.getBlobMeta<I extends Nimbus.Iface>
static class
Nimbus.Processor.getBlobReplication<I extends Nimbus.Iface>
static class
Nimbus.Processor.getClusterInfo<I extends Nimbus.Iface>
static class
static class
static class
Nimbus.Processor.getLeader<I extends Nimbus.Iface>
static class
Nimbus.Processor.getLogConfig<I extends Nimbus.Iface>
static class
Nimbus.Processor.getNimbusConf<I extends Nimbus.Iface>
static class
static class
static class
static class
Nimbus.Processor.getTopology<I extends Nimbus.Iface>
static class
Nimbus.Processor.getTopologyConf<I extends Nimbus.Iface>
static class
Nimbus.Processor.getTopologyHistory<I extends Nimbus.Iface>
static class
Nimbus.Processor.getTopologyInfo<I extends Nimbus.Iface>
static class
static class
static class
static class
Nimbus.Processor.getTopologyPageInfo<I extends Nimbus.Iface>
static class
static class
Nimbus.Processor.getTopologySummary<I extends Nimbus.Iface>
static class
static class
Nimbus.Processor.getUserTopology<I extends Nimbus.Iface>
static class
Nimbus.Processor.isRemoteBlobExists<I extends Nimbus.Iface>
static class
static class
Nimbus.Processor.killTopology<I extends Nimbus.Iface>
static class
static class
Nimbus.Processor.listBlobs<I extends Nimbus.Iface>
static class
static class
Nimbus.Processor.rebalance<I extends Nimbus.Iface>
static class
static class
static class
Nimbus.Processor.setBlobMeta<I extends Nimbus.Iface>
static class
Nimbus.Processor.setLogConfig<I extends Nimbus.Iface>
static class
Nimbus.Processor.setWorkerProfiler<I extends Nimbus.Iface>
static class
Nimbus.Processor.submitTopology<I extends Nimbus.Iface>
static class
static class
static class
Nimbus.Processor.uploadBlobChunk<I extends Nimbus.Iface>
static class
Nimbus.Processor.uploadChunk<I extends Nimbus.Iface>
static class
-
Uses of Nimbus.Iface in org.apache.storm.loadgen
Modifier and TypeMethodDescriptionvoid
LoadMetricsServer.monitorFor
(double execTimeMins, Nimbus.Iface client, Collection<String> topoNames) Monitor the list of topologies for the given time frame. -
Uses of Nimbus.Iface in org.apache.storm.perf.utils
Modifier and TypeMethodDescriptionvoid
BasicMetricsCollector.collect
(Nimbus.Iface client) static MetricsSample
MetricsSample.factory
(Nimbus.Iface client, String topologyName) static void
Helper.kill
(Nimbus.Iface client, String topoName) -
Uses of Nimbus.Iface in org.apache.storm.starter
Modifier and TypeMethodDescriptionstatic void
FastWordCountTopology.kill
(Nimbus.Iface client, String name) static void
InOrderDeliveryTest.kill
(Nimbus.Iface client, String name) static void
FastWordCountTopology.printMetrics
(Nimbus.Iface client, String name) static void
InOrderDeliveryTest.printMetrics
(Nimbus.Iface client, String name) -
Uses of Nimbus.Iface in org.apache.storm.utils
Modifier and TypeMethodDescriptionstatic String
Utils.getTopologyId
(String name, Nimbus.Iface client) void
Monitor.metrics
(Nimbus.Iface client) void
Monitor.metrics
(Nimbus.Iface client, long now, org.apache.storm.utils.Monitor.MetricsState state) void
NimbusClient.WithNimbus.run
(Nimbus.Iface client) Run what you need with the nimbus client.