Uses of Class
backtype.storm.generated.StormTopology

Packages that use StormTopology

Package	Description
backtype.storm
backtype.storm.drpc
backtype.storm.generated
backtype.storm.nimbus
backtype.storm.scheduler
backtype.storm.serialization
backtype.storm.task
backtype.storm.testing
backtype.storm.topology
backtype.storm.transactional
backtype.storm.utils
storm.trident
storm.trident.topology

Uses of StormTopology in backtype.storm

Methods in backtype.storm that return StormTopology

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

Methods in backtype.storm with parameters of type StormTopology

Modifier and Type	Method and Description
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)
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 backtype.storm.drpc

Methods in backtype.storm.drpc that return StormTopology

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

Uses of StormTopology in backtype.storm.generated

Methods in backtype.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 backtype.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 backtype.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 resultHandler)
void	Nimbus.AsyncClient.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback 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 resultHandler)
void	Nimbus.AsyncClient.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)

Method parameters in backtype.storm.generated with type arguments of type StormTopology

Modifier and Type	Method and Description
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 backtype.storm.generated with parameters of type StormTopology

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

Uses of StormTopology in backtype.storm.nimbus

Methods in backtype.storm.nimbus with parameters of type StormTopology

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

Uses of StormTopology in backtype.storm.scheduler

Methods in backtype.storm.scheduler that return StormTopology

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

Constructors in backtype.storm.scheduler with parameters of type StormTopology

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

Uses of StormTopology in backtype.storm.serialization

Constructors in backtype.storm.serialization with parameters of type StormTopology

Constructor and Description
SerializationFactory.IdDictionary(StormTopology topology)

Uses of StormTopology in backtype.storm.task

Methods in backtype.storm.task that return StormTopology

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

Constructors in backtype.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 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 backtype.storm.testing

Methods in backtype.storm.testing that return StormTopology

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

Uses of StormTopology in backtype.storm.topology

Methods in backtype.storm.topology that return StormTopology

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

Uses of StormTopology in backtype.storm.transactional

Methods in backtype.storm.transactional that return StormTopology

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

Uses of StormTopology in backtype.storm.utils

Methods in backtype.storm.utils with parameters of type StormTopology

Modifier and Type	Method and Description
static ComponentCommon	Utils.getComponentCommon(StormTopology topology, String id)
static ComponentCommon	ThriftTopologyUtils.getComponentCommon(StormTopology topology, String componentId)
static Set<String>	ThriftTopologyUtils.getComponentIds(StormTopology topology)

Uses of StormTopology in storm.trident

Methods in storm.trident that return StormTopology

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

Uses of StormTopology in storm.trident.topology

Methods in storm.trident.topology that return StormTopology

Modifier and Type	Method and Description
StormTopology	TridentTopologyBuilder.buildTopology()