Modifier and Type | Method and Description |
---|---|
StormTopology |
ILocalCluster.getTopology(String id) |
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.
|
Modifier and Type | Method and Description |
---|---|
StormTopology |
LinearDRPCTopologyBuilder.createLocalTopology(ILocalDRPC drpc) |
StormTopology |
LinearDRPCTopologyBuilder.createRemoteTopology() |
Modifier and Type | Method and Description |
---|---|
protected StormTopology |
TransactionalTridentEventCount.buildTopology(EventHubSpout eventHubSpout) |
protected StormTopology |
OpaqueTridentEventCount.buildTopology(EventHubSpout eventHubSpout) |
protected StormTopology |
EventHubLoop.buildTopology(EventHubSpout eventHubSpout) |
protected StormTopology |
EventCount.buildTopology(EventHubSpout eventHubSpout) |
Modifier and Type | Method and Description |
---|---|
protected void |
EventCount.submitTopology(String[] args,
StormTopology topology) |
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.
|
Modifier and Type | Method and Description |
---|---|
StormTopology |
TopologySource.getTopology(Map<String,Object> config) |
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() |
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) |
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) |
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) |
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 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 resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
WordCountTrident.buildTopology(String hbaseRoot) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
TridentSequenceTopology.buildTopology(String hdfsUrl) |
static StormTopology |
TridentFileTopology.buildTopology(String hdfsUrl) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
TridentHiveTopology.buildTopology(String metaStoreURI,
String dbName,
String tblName,
Object keytab,
Object principal) |
Modifier and Type | Method and Description |
---|---|
StormTopology |
UserPersistanceTridentTopology.getTopology() |
StormTopology |
UserPersistanceTopology.getTopology() |
abstract StormTopology |
AbstractUserTopology.getTopology() |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
TridentKafkaConsumerTopology.newTopology(ITridentDataSource tridentSpout)
|
static StormTopology |
TridentKafkaConsumerTopology.newTopology(org.apache.storm.LocalDRPC drpc,
ITridentDataSource tridentSpout) |
static StormTopology |
KafkaProducerTopology.newTopology(String brokerUrl,
String topicName) |
Modifier and Type | Method and Description |
---|---|
void |
LocalSubmitter.submit(String name,
Config config,
StormTopology topology) |
Constructor and Description |
---|
LocalSubmitter(StormTopology topology,
org.apache.storm.LocalDRPC drpc,
org.apache.storm.LocalCluster cluster,
String name) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
WordCountTrident.buildTopology(String url,
String collectionName) |
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) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
ConstSpoutOnlyTopo.getTopology() |
static StormTopology |
KafkaSpoutNullBoltTopo.getTopology(Map config) |
static StormTopology |
KafkaHdfsTopo.getTopology(Map config) |
static StormTopology |
StrGenSpoutHdfsBoltTopo.getTopology(Map topoConf) |
static StormTopology |
HdfsSpoutNullBoltTopo.getTopology(Map config) |
static StormTopology |
FileReadWordCountTopo.getTopology(Map config) |
static StormTopology |
ConstSpoutNullBoltTopo.getTopology(Map conf) |
static StormTopology |
ConstSpoutIdBoltNullBoltTopo.getTopology(Map conf) |
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) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
WordCountTridentRedisClusterMap.buildTopology(String redisHostPort) |
static StormTopology |
WordCountTridentRedisCluster.buildTopology(String redisHostPort) |
static StormTopology |
WordCountTridentRedisMap.buildTopology(String redisHost,
Integer redisPort) |
static StormTopology |
WordCountTridentRedis.buildTopology(String redisHost,
Integer redisPort) |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TopologyDetails.getTopology() |
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) |
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) |
Constructor and Description |
---|
IdDictionary(StormTopology topology) |
Modifier and Type | Method and Description |
---|---|
protected abstract StormTopology |
SolrTopology.getTopology() |
protected StormTopology |
SolrJsonTopology.getTopology() |
protected StormTopology |
SolrFieldsTopology.getTopology() |
Modifier and Type | Method and Description |
---|---|
protected void |
SolrTopology.submitTopologyLocalCluster(StormTopology topology,
Config config) |
protected void |
SolrTopology.submitTopologyRemoteCluster(String arg,
StormTopology topology,
Config config) |
Modifier and Type | Method and Description |
---|---|
protected StormTopology |
SolrJsonTridentTopology.getTopology() |
protected StormTopology |
SolrFieldsTridentTopology.getTopology() |
Modifier and Type | Method and Description |
---|---|
void |
ThroughputVsLatency.C.submitTopology(String name,
Map stormConf,
StormTopology topology) |
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. |
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) |
Modifier and Type | Method and Description |
---|---|
StormTopology |
GeneralTopologyContext.getRawTopology()
Gets the Thrift object representing the topology.
|
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) |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TrackedTopology.getTopology() |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TopologyBuilder.createTopology() |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TransactionalTopologyBuilder.buildTopology()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StormTopology |
TridentTopology.build() |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TridentTopologyBuilder.buildTopology(Map<String,Number> masterCoordResources) |
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) |
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) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.