Uses of Class
org.apache.storm.generated.StormTopology
Package
Description
-
Uses of StormTopology in org.apache.storm
Modifier and TypeClassDescriptionclass
When running a topology locally, for tests etc.Modifier and TypeMethodDescriptionstatic StormTopology
Thrift.buildTopology
(HashMap<String, Thrift.SpoutDetails> spoutMap, HashMap<String, Thrift.BoltDetails> boltMap, HashMap<String, StateSpoutSpec> stateMap) static StormTopology
Thrift.buildTopology
(Map<String, Thrift.SpoutDetails> spoutMap, Map<String, Thrift.BoltDetails> boltMap) static StormTopology
ExclamationTopology.getStormTopology()
ILocalCluster.getTopology
(String id) Get the compiled storm topology.LocalCluster.getTopology
(String id) LocalCluster.getUserTopology
(String id) Modifier and TypeMethodDescriptionTesting.captureTopology
(StormTopology topology) Rewrites a topology so that all the tuples flowing through it are captured.Modifier and TypeMethodDescriptionTesting.captureTopology
(StormTopology topology) Rewrites a topology so that all the tuples flowing through it are captured.static Map<String,
List<FixedTuple>> Testing.completeTopology
(ILocalCluster cluster, StormTopology topology) Run a topology to completion capturing all of the messages that are emitted.static Map<String,
List<FixedTuple>> Testing.completeTopology
(ILocalCluster cluster, StormTopology topology, CompleteTopologyParam param) Run a topology to completion capturing all of the messages that are emitted.static TrackedTopology
Testing.mkTrackedTopology
(ILocalCluster cluster, StormTopology topology) Deprecated.void
ISubmitterHook.notify
(TopologyInfo topologyInfo, Map<String, Object> topoConf, StormTopology topology) ILocalCluster.submitTopology
(String topologyName, Map<String, Object> conf, StormTopology topology) Submit a topology to be run in local mode.void
LocalCluster.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) LocalCluster.submitTopology
(String topologyName, Map<String, Object> conf, StormTopology topology) static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopologyAs
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.ILocalCluster.submitTopologyWithOpts
(String topologyName, Map<String, Object> conf, StormTopology topology, SubmitOptions submitOpts) Submit a topology to be run in local mode.void
LocalCluster.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) LocalCluster.submitTopologyWithOpts
(String topologyName, Map<String, Object> conf, StormTopology topology, SubmitOptions submitOpts) static void
StormSubmitter.submitTopologyWithProgressBar
(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.static void
StormSubmitter.submitTopologyWithProgressBar
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.Testing.trackAndCaptureTopology
(ILocalCluster cluster, StormTopology topology) Track and capture a topology. -
Uses of StormTopology in org.apache.storm.daemon
Modifier and TypeMethodDescriptionstatic StormTopology
StormCommon.systemTopology
(Map<String, Object> topoConf, StormTopology topology) Construct a new topology structure after adding system components and streams.protected StormTopology
StormCommon.systemTopologyImpl
(Map<String, Object> topoConf, StormTopology topology) Modifier and TypeMethodDescriptionstatic Map<GlobalStreamId,
Grouping> StormCommon.ackerInputs
(StormTopology topology) static void
StormCommon.addAcker
(Map<String, Object> conf, StormTopology topology) static void
StormCommon.addEventLogger
(Map<String, Object> conf, StormTopology topology) static void
StormCommon.addMetricComponents
(Map<String, Object> conf, StormTopology topology) static void
StormCommon.addMetricStreams
(StormTopology topology) static void
StormCommon.addSystemComponents
(Map<String, Object> conf, StormTopology topology) static void
StormCommon.addSystemStreams
(StormTopology topology) StormCommon.allComponents
(StormTopology topology) static Map<GlobalStreamId,
Grouping> StormCommon.eventLoggerInputs
(StormTopology topology) StormCommon.metricsConsumerBoltSpecs
(Map<String, Object> conf, StormTopology topology) StormCommon.stormTaskInfo
(StormTopology userTopology, Map<String, Object> topoConf) StormCommon.stormTaskInfoImpl
(StormTopology userTopology, Map<String, Object> topoConf) static StormTopology
StormCommon.systemTopology
(Map<String, Object> topoConf, StormTopology topology) Construct a new topology structure after adding system components and streams.protected StormTopology
StormCommon.systemTopologyImpl
(Map<String, Object> topoConf, StormTopology topology) static void
StormCommon.validateBasic
(StormTopology topology) static void
StormCommon.validateStructure
(StormTopology topology) -
Uses of StormTopology in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionNimbus.getTopology
(String id) Nimbus.getUserTopology
(String id) TopoCache.readTopology
(String topoId, Subject who) Read a topology.Modifier and TypeMethodDescriptionvoid
TopoCache.addTopology
(String topoId, Subject who, StormTopology topo) Add a new topology.void
Nimbus.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.submitTopologyWithOpts
(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) void
TopoCache.updateTopology
(String topoId, Subject who, StormTopology topo) Update an existing topology . -
Uses of StormTopology in org.apache.storm.daemon.ui
Modifier and TypeMethodDescriptionstatic Map<String,
List<ExecutorSummary>> UIHelpers.getBoltExecutors
(List<ExecutorSummary> executorSummaries, StormTopology stormTopology, boolean sys) getBoltExecutors.static Map<String,
List<ExecutorSummary>> UIHelpers.getSpoutExecutors
(List<ExecutorSummary> executorSummaries, StormTopology stormTopology) getSpoutExecutors.UIHelpers.getTopologyLag
(StormTopology userTopology, Map<String, Object> config) getTopologyLag. -
Uses of StormTopology in org.apache.storm.daemon.worker
-
Uses of StormTopology in org.apache.storm.drpc
Modifier and TypeMethodDescriptionLinearDRPCTopologyBuilder.createLocalTopology
(ILocalDRPC drpc) LinearDRPCTopologyBuilder.createRemoteTopology()
-
Uses of StormTopology in org.apache.storm.flux
Modifier and TypeMethodDescriptionstatic 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
-
Uses of StormTopology in org.apache.storm.generated
Modifier and TypeMethodDescriptionStormTopology.deepCopy()
Nimbus.getTopology_result.get_success()
Nimbus.getUserTopology_result.get_success()
Nimbus.submitTopology_args.get_topology()
Nimbus.submitTopologyWithOpts_args.get_topology()
Nimbus.AsyncClient.getTopology_call.getResult()
Nimbus.AsyncClient.getUserTopology_call.getResult()
Nimbus.Client.getTopology
(String id) Nimbus.Iface.getTopology
(String id) Returns the compiled topology that contains ackers and metrics consumsers.Nimbus.Client.getUserTopology
(String id) Nimbus.Iface.getUserTopology
(String id) Returns the user specified topology as submitted originally.Nimbus.Client.recv_getTopology()
Nimbus.Client.recv_getUserTopology()
Modifier and TypeMethodDescriptionorg.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>
Nimbus.AsyncProcessor.getTopology.getResultHandler
(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid) org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>
Nimbus.AsyncProcessor.getUserTopology.getResultHandler
(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid) Modifier and TypeMethodDescriptionint
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.AsyncClient.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Nimbus.AsyncIface.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Nimbus.Client.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.Iface.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.AsyncClient.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Nimbus.AsyncIface.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Nimbus.Client.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) void
Nimbus.Iface.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) Modifier and TypeMethodDescriptionvoid
Nimbus.AsyncClient.getTopology
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) void
Nimbus.AsyncIface.getTopology
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) void
Nimbus.AsyncClient.getUserTopology
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) void
Nimbus.AsyncIface.getUserTopology
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) void
Nimbus.AsyncProcessor.getTopology.start
(I iface, Nimbus.getTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) void
Nimbus.AsyncProcessor.getUserTopology.start
(I iface, Nimbus.getUserTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) ModifierConstructorDescriptiongetTopology_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.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.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.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) ModifierConstructorDescriptiongetTopology_call
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) getUserTopology_call
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) -
Uses of StormTopology in org.apache.storm.hdfs.trident
Modifier and TypeMethodDescriptionstatic StormTopology
TridentFileTopology.buildTopology
(String hdfsUrl) static StormTopology
TridentSequenceTopology.buildTopology
(String hdfsUrl) -
Uses of StormTopology in org.apache.storm.hive.trident
Modifier and TypeMethodDescriptionstatic StormTopology
TridentHiveTopology.buildTopology
(String metaStoreUri, String dbName, String tblName, Object keytab, Object principal) -
Uses of StormTopology in org.apache.storm.jdbc.topology
Modifier and TypeMethodDescriptionabstract StormTopology
AbstractUserTopology.getTopology()
UserPersistenceTopology.getTopology()
UserPersistenceTridentTopology.getTopology()
-
Uses of StormTopology in org.apache.storm.kafka.bolt
Modifier and TypeMethodDescriptionstatic StormTopology
KafkaProducerTopology.newTopology
(String brokerUrl, String topicName) Create a new topology that writes random UUIDs to Kafka. -
Uses of StormTopology in org.apache.storm.kafka.spout
Modifier and TypeMethodDescriptionprotected StormTopology
KafkaSpoutTopologyMainNamedTopics.getTopologyKafkaSpout
(KafkaSpoutConfig<String, String> spoutConfig) protected StormTopology
KafkaSpoutTopologyMainWildcardTopics.getTopologyKafkaSpout
(KafkaSpoutConfig<String, String> spoutConfig) -
Uses of StormTopology in org.apache.storm.kafka.trident
Modifier and TypeMethodDescriptionstatic StormTopology
TridentKafkaConsumerTopology.newTopology
(ITridentDataSource tridentSpout) Creates a new topology that prints inputs to stdout. -
Uses of StormTopology in org.apache.storm.nimbus
Modifier and TypeMethodDescriptionvoid
DefaultTopologyValidator.validate
(String topologyName, Map topologyConf, StormTopology topology) void
ITopologyValidator.validate
(String topologyName, Map<String, Object> topologyConf, StormTopology topology) void
StrictTopologyValidator.validate
(String topologyName, Map topologyConf, StormTopology topology) -
Uses of StormTopology in org.apache.storm.perf
Modifier and TypeMethodDescriptionstatic StormTopology
KafkaClientSpoutNullBoltTopo.getTopology
(Map<String, Object> config) Create and configure the topology. -
Uses of StormTopology in org.apache.storm.perf.utils
Modifier and TypeMethodDescriptionstatic void
Helper.runOnClusterAndPrintMetrics
(int durationSec, String topoName, Map<String, Object> topoConf, StormTopology topology) -
Uses of StormTopology in org.apache.storm.redis.trident
Modifier and TypeMethodDescriptionstatic StormTopology
WordCountTridentRedis.buildTopology
(String redisHost, Integer redisPort) static StormTopology
WordCountTridentRedisCluster.buildTopology
(String redisHostPort) static StormTopology
WordCountTridentRedisClusterMap.buildTopology
(String redisHostPort) static StormTopology
WordCountTridentRedisMap.buildTopology
(String redisHost, Integer redisPort) -
Uses of StormTopology in org.apache.storm.scheduler
ModifierConstructorDescriptionTopologyDetails
(String topologyId, Map<String, Object> topologyConf, StormTopology topology, int numWorkers, String owner) TopologyDetails
(String topologyId, Map<String, Object> topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails, String> executorToComponents, int launchTime, String owner) TopologyDetails
(String topologyId, Map<String, Object> topologyConf, StormTopology topology, int numWorkers, Map<ExecutorDetails, String> executorToComponents, String owner) -
Uses of StormTopology in org.apache.storm.scheduler.resource
Modifier and TypeMethodDescriptionstatic NormalizedResourceRequest
ResourceUtils.getBoltResources
(StormTopology topology, Map<String, Object> topologyConf, String componentId) static Map<String,
NormalizedResourceRequest> ResourceUtils.getBoltsResources
(StormTopology topology, Map<String, Object> topologyConf) static NormalizedResourceRequest
ResourceUtils.getSpoutResources
(StormTopology topology, Map<String, Object> topologyConf, String componentId) static Map<String,
NormalizedResourceRequest> ResourceUtils.getSpoutsResources
(StormTopology topology, Map<String, Object> topologyConf) static void
ResourceUtils.updateStormTopologyResources
(StormTopology topology, Map<String, Map<String, Double>> resourceUpdatesMap) -
Uses of StormTopology in org.apache.storm.serialization
-
Uses of StormTopology in org.apache.storm.sql
Modifier and TypeMethodDescriptionabstract StormTopology
AbstractStreamsProcessor.build()
Construct the Storm topology based on the SQL. -
Uses of StormTopology in org.apache.storm.st.topology
-
Uses of StormTopology in org.apache.storm.st.topology.window
Modifier and TypeMethodDescriptionSlidingTimeCorrectness.newTopology()
SlidingWindowCorrectness.newTopology()
TumblingTimeCorrectness.newTopology()
TumblingWindowCorrectness.newTopology()
-
Uses of StormTopology in org.apache.storm.starter.trident
Modifier and TypeMethodDescriptionstatic 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
TridentMapExample.buildTopology()
static StormTopology
TridentReach.buildTopology()
static StormTopology
TridentWindowingInmemoryStoreTopology.buildTopology
(WindowsStoreFactory windowStore, WindowConfig windowConfig) static StormTopology
TridentWordCount.buildTopology()
static StormTopology
TridentMinMaxOfDevicesTopology.buildVehiclesTopology()
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfDevicesTopology.Vehicle
andTridentMinMaxOfDevicesTopology.Driver
respectively.static StormTopology
TridentMinMaxOfVehiclesTopology.buildVehiclesTopology()
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.Vehicle
andTridentMinMaxOfVehiclesTopology.Driver
respectively. -
Uses of StormTopology in org.apache.storm.stats
Modifier and TypeMethodDescriptionstatic ComponentPageInfo
StatsUtil.aggCompExecsStats
(Map exec2hostPort, Map task2component, Map<List<Integer>, Map<String, Object>> beats, String window, boolean includeSys, String topologyId, StormTopology topology, String componentId) aggregate component executor stats.static TopologyPageInfo
StatsUtil.aggTopoExecsStats
(String topologyId, Map exec2nodePort, Map task2component, Map<List<Integer>, Map<String, Object>> beats, StormTopology topology, String window, boolean includeSys, IStormClusterState clusterState) aggregate topo executors stats.static String
StatsUtil.componentType
(StormTopology topology, String compId) Get the coponenet type for a give id.StatsUtil.extractDataFromHb
(Map executor2hostPort, Map task2component, Map<List<Integer>, Map<String, Object>> beats, boolean includeSys, StormTopology topology) extracts a list of executor data from heart beats.StatsUtil.extractDataFromHb
(Map executor2hostPort, Map task2component, Map<List<Integer>, Map<String, Object>> beats, boolean includeSys, StormTopology topology, String compId) extracts a list of executor data from heart beats. -
Uses of StormTopology in org.apache.storm.streams
Modifier and TypeMethodDescriptionStreamBuilder.build()
Builds a newStormTopology
for the computation expressed via the stream api. -
Uses of StormTopology in org.apache.storm.task
Modifier and TypeMethodDescriptionGeneralTopologyContext.getRawTopology()
Gets the Thrift object representing the topology.ModifierConstructorDescriptionGeneralTopologyContext
(StormTopology topology, Map<String, Object> topoConf, Map<Integer, String> taskToComponent, Map<String, List<Integer>> componentToSortedTasks, Map<String, Map<String, Fields>> componentToStreamToFields, String stormId) TopologyContext
(StormTopology topology, Map<String, Object> topoConf, Map<Integer, String> taskToComponent, Map<String, List<Integer>> componentToSortedTasks, Map<String, Map<String, Fields>> componentToStreamToFields, Map<String, Long> blobToLastKnownVersionShared, 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, AtomicBoolean openOrPrepareWasCalled, StormMetricRegistry metricRegistry) WorkerTopologyContext
(StormTopology topology, Map<String, Object> topoConf, 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) WorkerTopologyContext
(StormTopology topology, Map<String, Object> topoConf, 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, AtomicReference<Map<Integer, NodeInfo>> taskToNodePort, String assignmentId, AtomicReference<Map<String, String>> nodeToHost) WorkerUserContext
(StormTopology topology, Map<String, Object> topoConf, 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, AtomicReference<Map<Integer, NodeInfo>> taskToNodePort, String assignmentId, AtomicReference<Map<String, String>> nodeToHost) -
Uses of StormTopology in org.apache.storm.testing
ModifierConstructorDescriptionTrackedTopology
(StormTopology origTopo, ILocalCluster cluster) Create a new topology to be tracked. -
Uses of StormTopology in org.apache.storm.topology
-
Uses of StormTopology in org.apache.storm.trident
-
Uses of StormTopology in org.apache.storm.trident.topology
Modifier and TypeMethodDescriptionTridentTopologyBuilder.buildTopology
(Map<String, Number> masterCoordResources) -
Uses of StormTopology in org.apache.storm.utils
Modifier and TypeMethodDescriptionstatic 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<String, Object> conf, String stormId, AdvancedFSOps ops) ConfigUtils.readSupervisorTopologyImpl
(Map<String, Object> conf, String stormId, AdvancedFSOps ops) Modifier and TypeMethodDescriptionstatic StormTopology
Utils.addVersions
(StormTopology topology) Add version information to the given topology.Utils.findComponentCycles
(StormTopology topology, String topoId) Find and return components cycles in the topology graph when starting from spout.static ComponentCommon
ThriftTopologyUtils.getComponentCommon
(StormTopology topology, String componentId) static ComponentCommon
Utils.getComponentCommon
(StormTopology topology, String id) ThriftTopologyUtils.getComponentIds
(StormTopology topology) ServerUtils.getComponentParallelism
(Map<String, Object> topoConf, StormTopology topology) static double
ServerUtils.getEstimatedTotalHeapMemoryRequiredByTopo
(Map<String, Object> topoConf, StormTopology topology) static int
ServerUtils.getEstimatedWorkerCountForRasTopo
(Map<String, Object> topoConf, StormTopology topology) TopologySpoutLag.lag
(StormTopology stormTopology, Map<String, Object> topologyConf) static void
Utils.validateCycleFree
(StormTopology topology, String name) Validate that the topology is cycle free.static void
ServerUtils.validateTopologyAckerBundleResource
(Map<String, Object> topoConf, StormTopology topology, String topoName) RAS scheduler will try to distribute ackers evenly over workers by adding some ackers to each newly launched worker.static void
ServerUtils.validateTopologyWorkerMaxHeapSizeConfigs
(Map<String, Object> stormConf, StormTopology topology, double defaultWorkerMaxHeapSizeMb)
TrackedTopology
directly.