Uses of Interface
org.apache.storm.generated.Nimbus.Iface

Packages that use Nimbus.Iface

Package	Description
org.apache.storm
org.apache.storm.daemon.nimbus
org.apache.storm.daemon.supervisor
org.apache.storm.daemon.ui
org.apache.storm.generated
org.apache.storm.loadgen
org.apache.storm.perf.utils
org.apache.storm.starter
org.apache.storm.utils

Uses of Nimbus.Iface in org.apache.storm

Classes in org.apache.storm that implement Nimbus.Iface

Modifier and Type	Class and Description
class	LocalCluster A 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

Modifier and Type	Class and Description
class	Nimbus

Uses of Nimbus.Iface in org.apache.storm.daemon.supervisor

Methods in org.apache.storm.daemon.supervisor that return Nimbus.Iface

Modifier and Type	Method and Description
Nimbus.Iface	Supervisor.getLocalNimbus()

Methods in org.apache.storm.daemon.supervisor with parameters of type Nimbus.Iface

Modifier and Type	Method and Description
void	Supervisor.setLocalNimbus(Nimbus.Iface nimbus)

Uses of Nimbus.Iface in org.apache.storm.daemon.ui

Methods in org.apache.storm.daemon.ui with parameters of type Nimbus.Iface

Modifier and Type	Method and Description
static List	UIHelpers.getActiveProfileActions(Nimbus.Iface client, String id, String component, Map config) getActiveProfileActions.
static Map<String,Object>	UIHelpers.getBuildVisualization(Nimbus.Iface client, Map<String,Object> config, String window, String id, boolean sys) getBuildVisualization.
static Map<String,Object>	UIHelpers.getComponentPage(Nimbus.Iface client, String id, String component, String window, boolean sys, String user, Map config) getComponentPage.
static Map<String,Object>	UIHelpers.getOwnerResourceSummary(List<OwnerResourceSummary> ownerResourceSummaries, Nimbus.Iface client, String id, Map<String,Object> config) Get a specific owner resource summary.
static Map<String,Object>	UIHelpers.getTopologyProfilingDump(Nimbus.Iface client, String id, String hostPort, Map<String,Object> config) getTopologyProfilingDump.
static Map<String,Object>	UIHelpers.getTopologyProfilingDumpHeap(Nimbus.Iface client, String id, String hostPort, Map<String,Object> config) getTopologyProfilingDumpHeap.
static Map<String,Object>	UIHelpers.getTopologyProfilingDumpJstack(Nimbus.Iface client, String id, String hostPort, Map<String,Object> config)
static Map<String,Object>	UIHelpers.getTopologyProfilingRestartWorker(Nimbus.Iface client, String id, String hostPort, Map<String,Object> config) getTopologyProfilingRestartWorker.
static Map<String,Object>	UIHelpers.getTopologyProfilingStart(Nimbus.Iface client, String id, String hostPort, String timeout, Map<String,Object> config) getTopologyProfilingStart.
static Map<String,Object>	UIHelpers.getTopologyProfilingStop(Nimbus.Iface client, String id, String hostPort, Map<String,Object> config) getTopologyProfilingStop.
static Map<String,Object>	UIHelpers.getVisualizationData(Nimbus.Iface client, String window, String topoId, boolean sys) getVisualizationData.
static Map<String,Object>	UIHelpers.putTopologyActivate(Nimbus.Iface client, String id) putTopologyActivate.
static Map<String,Object>	UIHelpers.putTopologyDeactivate(Nimbus.Iface client, String id) putTopologyDeactivate.
static Map<String,Object>	UIHelpers.putTopologyDebugActionSpct(Nimbus.Iface client, String id, String action, String spct, String component) putTopologyDebugActionSpct.
static Map<String,Object>	UIHelpers.putTopologyKill(Nimbus.Iface client, String id, String waitTime) putTopologyKill.
static Map<String,Object>	UIHelpers.putTopologyLogLevel(Nimbus.Iface client, Map<String,Map> namedLogLevel, String id) putTopologyLogLevel.
static Map<String,Object>	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

Classes in org.apache.storm.generated with type parameters of type Nimbus.Iface

Modifier and Type	Class and Description
static 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	Nimbus.Processor.createStateInZookeeper<I extends Nimbus.Iface>
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	Nimbus.Processor.getComponentPageInfo<I extends Nimbus.Iface>
static class	Nimbus.Processor.getComponentPendingProfileActions<I extends Nimbus.Iface>
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	Nimbus.Processor.getOwnerResourceSummaries<I extends Nimbus.Iface>
static class	Nimbus.Processor.getSupervisorAssignments<I extends Nimbus.Iface>
static class	Nimbus.Processor.getSupervisorPageInfo<I extends Nimbus.Iface>
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	Nimbus.Processor.getTopologyInfoWithOpts<I extends Nimbus.Iface>
static class	Nimbus.Processor.getTopologyPageInfo<I extends Nimbus.Iface>
static class	Nimbus.Processor.getUserTopology<I extends Nimbus.Iface>
static class	Nimbus.Processor.isRemoteBlobExists<I extends Nimbus.Iface>
static class	Nimbus.Processor.isTopologyNameAllowed<I extends Nimbus.Iface>
static class	Nimbus.Processor.killTopology<I extends Nimbus.Iface>
static class	Nimbus.Processor.killTopologyWithOpts<I extends Nimbus.Iface>
static class	Nimbus.Processor.listBlobs<I extends Nimbus.Iface>
static class	Nimbus.Processor.processWorkerMetrics<I extends Nimbus.Iface>
static class	Nimbus.Processor.rebalance<I extends Nimbus.Iface>
static class	Nimbus.Processor.sendSupervisorWorkerHeartbeat<I extends Nimbus.Iface>
static class	Nimbus.Processor.sendSupervisorWorkerHeartbeats<I extends Nimbus.Iface>
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	Nimbus.Processor.submitTopologyWithOpts<I extends Nimbus.Iface>
static class	Nimbus.Processor.updateBlobReplication<I extends Nimbus.Iface>
static class	Nimbus.Processor.uploadBlobChunk<I extends Nimbus.Iface>
static class	Nimbus.Processor.uploadChunk<I extends Nimbus.Iface>
static class	Nimbus.Processor.uploadNewCredentials<I extends Nimbus.Iface>

Classes in org.apache.storm.generated that implement Nimbus.Iface

Modifier and Type	Class and Description
static class	Nimbus.Client

Uses of Nimbus.Iface in org.apache.storm.loadgen

Methods in org.apache.storm.loadgen with parameters of type Nimbus.Iface

Modifier and Type	Method and Description
void	LoadMetricsServer.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

Constructor and Description
ScopedTopologySet(Nimbus.Iface client) Constructor.

Uses of Nimbus.Iface in org.apache.storm.perf.utils

Methods in org.apache.storm.perf.utils with parameters of type Nimbus.Iface

Modifier and Type	Method and Description
void	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

Methods in org.apache.storm.starter with parameters of type Nimbus.Iface

Modifier and Type	Method and Description
static 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

Methods in org.apache.storm.utils that return Nimbus.Iface

Modifier and Type	Method and Description
Nimbus.Iface	NimbusClient.getClient() Get the underlying thrift client.

Methods in org.apache.storm.utils with parameters of type Nimbus.Iface

Modifier and Type	Method and Description
static 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.

Constructors in org.apache.storm.utils with parameters of type Nimbus.Iface

Constructor and Description
LocalOverride(Nimbus.Iface client)