Uses of Interface
org.apache.storm.generated.Nimbus.Iface
Packages that use Nimbus.Iface
Package
Description
-
Uses of Nimbus.Iface in org.apache.storm
Classes in org.apache.storm that implement Nimbus.IfaceModifier and TypeClassDescriptionclassA stand alone storm cluster that runs inside a single process. -
Uses of Nimbus.Iface in org.apache.storm.daemon.nimbus
Classes in org.apache.storm.daemon.nimbus that implement Nimbus.Iface -
Uses of Nimbus.Iface in org.apache.storm.daemon.supervisor
Methods in org.apache.storm.daemon.supervisor that return Nimbus.IfaceMethods in org.apache.storm.daemon.supervisor with parameters of type Nimbus.Iface -
Uses of Nimbus.Iface in org.apache.storm.daemon.supervisor.timer
Methods in org.apache.storm.daemon.supervisor.timer with parameters of type Nimbus.IfaceModifier and TypeMethodDescriptionSynchronizeAssignments.getAllAssignmentsFromNumaSupervisors(Nimbus.Iface nimbus, String node) -
Uses of Nimbus.Iface in org.apache.storm.daemon.ui
Methods in org.apache.storm.daemon.ui with parameters of type Nimbus.IfaceModifier and TypeMethodDescriptionstatic ListUIHelpers.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 voidUIHelpers.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
Classes in org.apache.storm.generated with type parameters of type Nimbus.IfaceModifier and TypeClassDescriptionstatic classNimbus.Processor<I extends Nimbus.Iface>static classNimbus.Processor.activate<I extends Nimbus.Iface>static classNimbus.Processor.beginBlobDownload<I extends Nimbus.Iface>static classNimbus.Processor.beginCreateBlob<I extends Nimbus.Iface>static classNimbus.Processor.beginFileUpload<I extends Nimbus.Iface>static classNimbus.Processor.beginUpdateBlob<I extends Nimbus.Iface>static classNimbus.Processor.cancelBlobUpload<I extends Nimbus.Iface>static classstatic classNimbus.Processor.deactivate<I extends Nimbus.Iface>static classNimbus.Processor.debug<I extends Nimbus.Iface>static classNimbus.Processor.deleteBlob<I extends Nimbus.Iface>static classNimbus.Processor.downloadBlobChunk<I extends Nimbus.Iface>static classNimbus.Processor.downloadChunk<I extends Nimbus.Iface>static classNimbus.Processor.finishBlobUpload<I extends Nimbus.Iface>static classNimbus.Processor.finishFileUpload<I extends Nimbus.Iface>static classNimbus.Processor.getBlobMeta<I extends Nimbus.Iface>static classNimbus.Processor.getBlobReplication<I extends Nimbus.Iface>static classNimbus.Processor.getClusterInfo<I extends Nimbus.Iface>static classstatic classstatic classNimbus.Processor.getLeader<I extends Nimbus.Iface>static classNimbus.Processor.getLogConfig<I extends Nimbus.Iface>static classNimbus.Processor.getNimbusConf<I extends Nimbus.Iface>static classstatic classstatic classstatic classNimbus.Processor.getTopology<I extends Nimbus.Iface>static classNimbus.Processor.getTopologyConf<I extends Nimbus.Iface>static classNimbus.Processor.getTopologyHistory<I extends Nimbus.Iface>static classNimbus.Processor.getTopologyInfo<I extends Nimbus.Iface>static classstatic classstatic classstatic classNimbus.Processor.getTopologyPageInfo<I extends Nimbus.Iface>static classstatic classNimbus.Processor.getTopologySummary<I extends Nimbus.Iface>static classstatic classNimbus.Processor.getUserTopology<I extends Nimbus.Iface>static classNimbus.Processor.isRemoteBlobExists<I extends Nimbus.Iface>static classstatic classNimbus.Processor.killTopology<I extends Nimbus.Iface>static classstatic classNimbus.Processor.listBlobs<I extends Nimbus.Iface>static classstatic classNimbus.Processor.rebalance<I extends Nimbus.Iface>static classstatic classstatic classNimbus.Processor.setBlobMeta<I extends Nimbus.Iface>static classNimbus.Processor.setLogConfig<I extends Nimbus.Iface>static classNimbus.Processor.setWorkerProfiler<I extends Nimbus.Iface>static classNimbus.Processor.submitTopology<I extends Nimbus.Iface>static classstatic classstatic classNimbus.Processor.uploadBlobChunk<I extends Nimbus.Iface>static classNimbus.Processor.uploadChunk<I extends Nimbus.Iface>static classClasses in org.apache.storm.generated that implement Nimbus.Iface -
Uses of Nimbus.Iface in org.apache.storm.loadgen
Methods in org.apache.storm.loadgen with parameters of type Nimbus.IfaceModifier and TypeMethodDescriptionvoidLoadMetricsServer.monitorFor(double execTimeMins, Nimbus.Iface client, Collection<String> topoNames) Monitor the list of topologies for the given time frame.Constructors in org.apache.storm.loadgen with parameters of type Nimbus.Iface -
Uses of Nimbus.Iface in org.apache.storm.perf.utils
Methods in org.apache.storm.perf.utils with parameters of type Nimbus.IfaceModifier and TypeMethodDescriptionvoidBasicMetricsCollector.collect(Nimbus.Iface client) static MetricsSampleMetricsSample.factory(Nimbus.Iface client, String topologyName) static voidHelper.kill(Nimbus.Iface client, String topoName) -
Uses of Nimbus.Iface in org.apache.storm.starter
Methods in org.apache.storm.starter with parameters of type Nimbus.IfaceModifier and TypeMethodDescriptionstatic voidFastWordCountTopology.kill(Nimbus.Iface client, String name) static voidInOrderDeliveryTest.kill(Nimbus.Iface client, String name) static voidFastWordCountTopology.printMetrics(Nimbus.Iface client, String name) static voidInOrderDeliveryTest.printMetrics(Nimbus.Iface client, String name) -
Uses of Nimbus.Iface in org.apache.storm.utils
Methods in org.apache.storm.utils that return Nimbus.IfaceMethods in org.apache.storm.utils with parameters of type Nimbus.IfaceModifier and TypeMethodDescriptionstatic StringUtils.getTopologyId(String name, Nimbus.Iface client) voidMonitor.metrics(Nimbus.Iface client) voidMonitor.metrics(Nimbus.Iface client, long now, org.apache.storm.utils.Monitor.MetricsState state) voidNimbusClient.WithNimbus.run(Nimbus.Iface client) Run what you need with the nimbus client.Constructors in org.apache.storm.utils with parameters of type Nimbus.Iface