Uses of Class
org.apache.storm.generated.StormTopology

Packages that use StormTopology

Package	Description
org.apache.storm
org.apache.storm.drpc
org.apache.storm.eventhubs.samples
org.apache.storm.flux
org.apache.storm.flux.api
org.apache.storm.generated
org.apache.storm.hbase.trident
org.apache.storm.hdfs.trident
org.apache.storm.hive.trident
org.apache.storm.jdbc.topology
org.apache.storm.kafka.trident
org.apache.storm.mongodb.trident
org.apache.storm.nimbus
org.apache.storm.perf
org.apache.storm.perf.utils
org.apache.storm.redis.trident
org.apache.storm.scheduler
org.apache.storm.scheduler.resource
org.apache.storm.serialization
org.apache.storm.solr.topology
org.apache.storm.solr.trident
org.apache.storm.starter
org.apache.storm.starter.trident
org.apache.storm.starter.util
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.transactional
org.apache.storm.trident
org.apache.storm.trident.topology
org.apache.storm.utils

Uses of StormTopology in org.apache.storm

Methods in org.apache.storm that return StormTopology

Modifier and Type	Method and Description
StormTopology	ILocalCluster.getTopology(String id)

Methods in org.apache.storm with parameters of type StormTopology

Modifier and Type	Method and Description
void	ISubmitterHook.notify(TopologyInfo topologyInfo, Map stormConf, StormTopology topology)
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology) Submits a topology to run on the cluster.
void	ILocalCluster.submitTopology(String topologyName, Map conf, StormTopology topology)
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopologyAs(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.
void	ILocalCluster.submitTopologyWithOpts(String topologyName, Map conf, StormTopology topology, SubmitOptions submitOpts)
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.

Uses of StormTopology in org.apache.storm.drpc

Methods in org.apache.storm.drpc that return StormTopology

Modifier and Type	Method and Description
StormTopology	LinearDRPCTopologyBuilder.createLocalTopology(ILocalDRPC drpc)
StormTopology	LinearDRPCTopologyBuilder.createRemoteTopology()

Uses of StormTopology in org.apache.storm.eventhubs.samples

Methods in org.apache.storm.eventhubs.samples that return StormTopology

Modifier and Type	Method and Description
protected StormTopology	EventHubLoop.buildTopology(EventHubSpout eventHubSpout)
protected StormTopology	OpaqueTridentEventCount.buildTopology(EventHubSpout eventHubSpout)
protected StormTopology	EventCount.buildTopology(EventHubSpout eventHubSpout)
protected StormTopology	TransactionalTridentEventCount.buildTopology(EventHubSpout eventHubSpout)

Methods in org.apache.storm.eventhubs.samples with parameters of type StormTopology

Modifier and Type	Method and Description
protected void	EventCount.submitTopology(String[] args, StormTopology topology)

Uses of StormTopology in org.apache.storm.flux

Methods in org.apache.storm.flux that return StormTopology

Modifier and Type	Method and Description
static StormTopology	FluxBuilder.buildTopology(ExecutionContext context) Given a topology definition, return a Storm topology that can be run either locally or remotely.

Uses of StormTopology in org.apache.storm.flux.api

Methods in org.apache.storm.flux.api that return StormTopology

Modifier and Type	Method and Description
StormTopology	TopologySource.getTopology(Map<String,Object> config)

Uses of StormTopology in org.apache.storm.generated

Methods in org.apache.storm.generated that return StormTopology

Modifier and Type	Method and Description
StormTopology	StormTopology.deepCopy()
StormTopology	Nimbus.getTopology_result.get_success()
StormTopology	Nimbus.getUserTopology_result.get_success()
StormTopology	Nimbus.submitTopology_args.get_topology()
StormTopology	Nimbus.submitTopologyWithOpts_args.get_topology()
StormTopology	Nimbus.AsyncClient.getTopology_call.getResult()
StormTopology	Nimbus.AsyncClient.getUserTopology_call.getResult()
StormTopology	Nimbus.Iface.getTopology(String id) Returns the compiled topology that contains ackers and metrics consumsers.
StormTopology	Nimbus.Client.getTopology(String id)
StormTopology	Nimbus.Iface.getUserTopology(String id) Returns the user specified topology as submitted originally.
StormTopology	Nimbus.Client.getUserTopology(String id)
StormTopology	Nimbus.Client.recv_getTopology()
StormTopology	Nimbus.Client.recv_getUserTopology()

Methods in org.apache.storm.generated that return types with arguments of type StormTopology

Modifier and Type	Method and Description
org.apache.thrift.async.AsyncMethodCallback<StormTopology>	Nimbus.AsyncProcessor.getTopology.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid)
org.apache.thrift.async.AsyncMethodCallback<StormTopology>	Nimbus.AsyncProcessor.getUserTopology.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid)

Methods in org.apache.storm.generated with parameters of type StormTopology

Modifier and Type	Method and Description
int	StormTopology.compareTo(StormTopology other)
boolean	StormTopology.equals(StormTopology that)
void	Nimbus.Client.send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.Client.send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.getTopology_result.set_success(StormTopology success)
void	Nimbus.getUserTopology_result.set_success(StormTopology success)
void	Nimbus.submitTopology_args.set_topology(StormTopology topology)
void	Nimbus.submitTopologyWithOpts_args.set_topology(StormTopology topology)
void	Nimbus.Iface.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.Client.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.AsyncIface.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Nimbus.AsyncClient.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Nimbus.Iface.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.Client.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.AsyncIface.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Nimbus.AsyncClient.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler)

Method parameters in org.apache.storm.generated with type arguments of type StormTopology

Modifier and Type	Method and Description
void	Nimbus.AsyncIface.getTopology(String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	Nimbus.AsyncClient.getTopology(String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	Nimbus.AsyncIface.getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	Nimbus.AsyncClient.getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	Nimbus.AsyncProcessor.getTopology.start(I iface, Nimbus.getTopology_args args, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	Nimbus.AsyncProcessor.getUserTopology.start(I iface, Nimbus.getUserTopology_args args, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)

Constructors in org.apache.storm.generated with parameters of type StormTopology

Constructor and Description
getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
getUserTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
StormTopology(StormTopology other) Performs a deep copy on other.
submitTopology_args(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
submitTopology_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)
submitTopologyWithOpts_args(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
submitTopologyWithOpts_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)

Constructor parameters in org.apache.storm.generated with type arguments of type StormTopology

Constructor and Description
getTopology_call(String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)
getUserTopology_call(String id, org.apache.thrift.async.AsyncMethodCallback<StormTopology> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport)

Uses of StormTopology in org.apache.storm.hbase.trident

Methods in org.apache.storm.hbase.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	WordCountTrident.buildTopology(String hbaseRoot)

Uses of StormTopology in org.apache.storm.hdfs.trident

Methods in org.apache.storm.hdfs.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	TridentFileTopology.buildTopology(String hdfsUrl)
static StormTopology	TridentSequenceTopology.buildTopology(String hdfsUrl)

Uses of StormTopology in org.apache.storm.hive.trident

Methods in org.apache.storm.hive.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	TridentHiveTopology.buildTopology(String metaStoreURI, String dbName, String tblName, Object keytab, Object principal)

Uses of StormTopology in org.apache.storm.jdbc.topology

Methods in org.apache.storm.jdbc.topology that return StormTopology

Modifier and Type	Method and Description
StormTopology	UserPersistanceTridentTopology.getTopology()
abstract StormTopology	AbstractUserTopology.getTopology()
StormTopology	UserPersistanceTopology.getTopology()

Uses of StormTopology in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	TridentKafkaConsumerTopology.newTopology(ITridentDataSource tridentSpout) See TridentKafkaConsumerTopology.newTopology(LocalDRPC, ITridentDataSource)
static StormTopology	TridentKafkaConsumerTopology.newTopology(org.apache.storm.LocalDRPC drpc, ITridentDataSource tridentSpout)
static StormTopology	KafkaProducerTopology.newTopology(String brokerUrl, String topicName)

Methods in org.apache.storm.kafka.trident with parameters of type StormTopology

Modifier and Type	Method and Description
void	LocalSubmitter.submit(String name, Config config, StormTopology topology)

Constructors in org.apache.storm.kafka.trident with parameters of type StormTopology

Constructor and Description
LocalSubmitter(StormTopology topology, org.apache.storm.LocalDRPC drpc, org.apache.storm.LocalCluster cluster, String name)

Uses of StormTopology in org.apache.storm.mongodb.trident

Methods in org.apache.storm.mongodb.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	WordCountTrident.buildTopology(String url, String collectionName)

Uses of StormTopology in org.apache.storm.nimbus

Methods in org.apache.storm.nimbus with parameters of type StormTopology

Modifier and Type	Method and Description
void	StrictTopologyValidator.validate(String topologyName, Map topologyConf, StormTopology topology)
void	ITopologyValidator.validate(String topologyName, Map topologyConf, StormTopology topology)
void	DefaultTopologyValidator.validate(String topologyName, Map topologyConf, StormTopology topology)

Uses of StormTopology in org.apache.storm.perf

Methods in org.apache.storm.perf that return StormTopology

Modifier and Type	Method and Description
static StormTopology	ConstSpoutOnlyTopo.getTopology()
static StormTopology	FileReadWordCountTopo.getTopology(Map config)
static StormTopology	HdfsSpoutNullBoltTopo.getTopology(Map config)
static StormTopology	KafkaSpoutNullBoltTopo.getTopology(Map config)
static StormTopology	ConstSpoutNullBoltTopo.getTopology(Map conf)
static StormTopology	KafkaHdfsTopo.getTopology(Map config)
static StormTopology	ConstSpoutIdBoltNullBoltTopo.getTopology(Map conf)
static StormTopology	StrGenSpoutHdfsBoltTopo.getTopology(Map topoConf)

Uses of StormTopology in org.apache.storm.perf.utils

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

Modifier and Type	Method and Description
static void	Helper.runOnClusterAndPrintMetrics(Integer durationSec, String topoName, Map topoConf, StormTopology topology)
static org.apache.storm.LocalCluster	Helper.runOnLocalCluster(String topoName, StormTopology topology)

Uses of StormTopology in org.apache.storm.redis.trident

Methods in org.apache.storm.redis.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	WordCountTridentRedisCluster.buildTopology(String redisHostPort)
static StormTopology	WordCountTridentRedisClusterMap.buildTopology(String redisHostPort)
static StormTopology	WordCountTridentRedis.buildTopology(String redisHost, Integer redisPort)
static StormTopology	WordCountTridentRedisMap.buildTopology(String redisHost, Integer redisPort)

Uses of StormTopology in org.apache.storm.scheduler

Methods in org.apache.storm.scheduler that return StormTopology

Modifier and Type	Method and Description
StormTopology	TopologyDetails.getTopology()

Constructors in org.apache.storm.scheduler with parameters of type StormTopology

Constructor and Description
TopologyDetails(String topologyId, Map topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails,String> executorToComponents, int launchTime, String owner)
TopologyDetails(String topologyId, Map topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails,String> executorToComponents, String owner)
TopologyDetails(String topologyId, Map topologyConf, StormTopology topology, int numWorkers, String owner)

Uses of StormTopology in org.apache.storm.scheduler.resource

Methods in org.apache.storm.scheduler.resource with parameters of type StormTopology

Modifier and Type	Method and Description
static Map<String,Map<String,Double>>	ResourceUtils.getBoltsResources(StormTopology topology, Map topologyConf)
static Map<String,Map<String,Double>>	ResourceUtils.getSpoutsResources(StormTopology topology, Map topologyConf)

Uses of StormTopology in org.apache.storm.serialization

Constructors in org.apache.storm.serialization with parameters of type StormTopology

Constructor and Description
IdDictionary(StormTopology topology)

Uses of StormTopology in org.apache.storm.solr.topology

Methods in org.apache.storm.solr.topology that return StormTopology

Modifier and Type	Method and Description
protected abstract StormTopology	SolrTopology.getTopology()
protected StormTopology	SolrJsonTopology.getTopology()
protected StormTopology	SolrFieldsTopology.getTopology()

Methods in org.apache.storm.solr.topology with parameters of type StormTopology

Modifier and Type	Method and Description
protected void	SolrTopology.submitTopologyLocalCluster(StormTopology topology, Config config)
protected void	SolrTopology.submitTopologyRemoteCluster(String arg, StormTopology topology, Config config)

Uses of StormTopology in org.apache.storm.solr.trident

Methods in org.apache.storm.solr.trident that return StormTopology

Modifier and Type	Method and Description
protected StormTopology	SolrJsonTridentTopology.getTopology()
protected StormTopology	SolrFieldsTridentTopology.getTopology()

Uses of StormTopology in org.apache.storm.starter

Methods in org.apache.storm.starter with parameters of type StormTopology

Modifier and Type	Method and Description
void	ThroughputVsLatency.C.submitTopology(String name, Map stormConf, StormTopology topology)

Uses of StormTopology in org.apache.storm.starter.trident

Methods in org.apache.storm.starter.trident that return StormTopology

Modifier and Type	Method and Description
static StormTopology	TridentMinMaxOfDevicesTopology.buildDevicesTopology() Creates a topology with device-id and count (which are whole numbers) as tuple fields in a stream and it finally generates result stream based on min amd max with device-id and count values.
static StormTopology	TridentWordCount.buildTopology(org.apache.storm.LocalDRPC drpc)
static StormTopology	TridentReach.buildTopology(org.apache.storm.LocalDRPC drpc)
static StormTopology	TridentMapExample.buildTopology(org.apache.storm.LocalDRPC drpc)
static StormTopology	TridentHBaseWindowingStoreTopology.buildTopology(WindowsStoreFactory windowsStore)
static StormTopology	TridentWindowingInmemoryStoreTopology.buildTopology(WindowsStoreFactory windowStore, WindowConfig windowConfig)
static StormTopology	TridentMinMaxOfVehiclesTopology.buildVehiclesTopology() Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.
static StormTopology	TridentMinMaxOfDevicesTopology.buildVehiclesTopology() Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfDevicesTopology.Vehicle and TridentMinMaxOfDevicesTopology.Driver respectively.

Uses of StormTopology in org.apache.storm.starter.util

Methods in org.apache.storm.starter.util with parameters of type StormTopology

Modifier and Type	Method and Description
static void	StormRunner.runTopologyLocally(StormTopology topology, String topologyName, Config conf, int runtimeInSeconds)
static void	StormRunner.runTopologyRemotely(StormTopology topology, String topologyName, Config conf)

Uses of StormTopology in org.apache.storm.task

Methods in org.apache.storm.task that return StormTopology

Modifier and Type	Method and Description
StormTopology	GeneralTopologyContext.getRawTopology() Gets the Thrift object representing the topology.

Constructors in org.apache.storm.task with parameters of type StormTopology

Constructor and Description
GeneralTopologyContext(StormTopology topology, Map stormConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId)
TopologyContext(StormTopology topology, Map stormConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId, String codeDir, String pidDir, Integer taskId, Integer workerPort, List<Integer> workerTasks, Map<String,Object> defaultResources, Map<String,Object> userResources, Map<String,Object> executorData, Map<Integer,Map<Integer,Map<String,IMetric>>> registeredMetrics, clojure.lang.Atom openOrPrepareWasCalled)
WorkerTopologyContext(StormTopology topology, Map stormConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId, String codeDir, String pidDir, Integer workerPort, List<Integer> workerTasks, Map<String,Object> defaultResources, Map<String,Object> userResources)

Uses of StormTopology in org.apache.storm.testing

Methods in org.apache.storm.testing that return StormTopology

Modifier and Type	Method and Description
StormTopology	TrackedTopology.getTopology()

Uses of StormTopology in org.apache.storm.topology

Methods in org.apache.storm.topology that return StormTopology

Modifier and Type	Method and Description
StormTopology	TopologyBuilder.createTopology()

Uses of StormTopology in org.apache.storm.transactional

Methods in org.apache.storm.transactional that return StormTopology

Modifier and Type	Method and Description
StormTopology	TransactionalTopologyBuilder.buildTopology() Deprecated.

Uses of StormTopology in org.apache.storm.trident

Methods in org.apache.storm.trident that return StormTopology

Modifier and Type	Method and Description
StormTopology	TridentTopology.build()

Uses of StormTopology in org.apache.storm.trident.topology

Methods in org.apache.storm.trident.topology that return StormTopology

Modifier and Type	Method and Description
StormTopology	TridentTopologyBuilder.buildTopology(Map<String,Number> masterCoordResources)

Uses of StormTopology in org.apache.storm.utils

Methods in org.apache.storm.utils that return StormTopology

Modifier and Type	Method and Description
static StormTopology	Utils.addVersions(StormTopology topology) Add version information to the given topology
static StormTopology	ConfigUtils.readSupervisorStormCodeGivenPath(String stormCodePath, AdvancedFSOps ops)
static StormTopology	ConfigUtils.readSupervisorTopology(Map conf, String stormId, AdvancedFSOps ops)
StormTopology	ConfigUtils.readSupervisorTopologyImpl(Map conf, String stormId, AdvancedFSOps ops)

Methods in org.apache.storm.utils with parameters of type StormTopology

Modifier and Type	Method and Description
static StormTopology	Utils.addVersions(StormTopology topology) Add version information to the given topology
static ComponentCommon	Utils.getComponentCommon(StormTopology topology, String id)
static ComponentCommon	ThriftTopologyUtils.getComponentCommon(StormTopology topology, String componentId)
static Set<String>	ThriftTopologyUtils.getComponentIds(StormTopology topology)
static Map<String,Map<String,Object>>	TopologySpoutLag.lag(StormTopology stormTopology, Map topologyConf)