Modifier and Type | Method and Description |
---|---|
StormTopology |
ILocalCluster.getTopology(String id) |
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.
|
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)
Deprecated.
|
StormTopology |
LinearDRPCTopologyBuilder.createRemoteTopology()
Deprecated.
|
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) |
StormTopology |
Nimbus.Client.getTopology(String id) |
StormTopology |
Nimbus.Iface.getUserTopology(String id) |
StormTopology |
Nimbus.Client.getUserTopology(String id) |
StormTopology |
Nimbus.Client.recv_getTopology() |
StormTopology |
Nimbus.Client.recv_getUserTopology() |
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<Nimbus.AsyncClient.submitTopology_call> resultHandler) |
void |
Nimbus.AsyncClient.submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.submitTopology_call> 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<Nimbus.AsyncClient.submitTopologyWithOpts_call> resultHandler) |
void |
Nimbus.AsyncClient.submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.submitTopologyWithOpts_call> resultHandler) |
Constructor and Description |
---|
getTopology_result(StormTopology success,
NotAliveException e) |
getUserTopology_result(StormTopology success,
NotAliveException e) |
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<Nimbus.AsyncClient.submitTopology_call> 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<Nimbus.AsyncClient.submitTopologyWithOpts_call> 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 |
---|---|
void |
ITopologyValidator.validate(String topologyName,
Map topologyConf,
StormTopology topology) |
void |
DefaultTopologyValidator.validate(String topologyName,
Map topologyConf,
StormTopology topology) |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TopologyDetails.getTopology() |
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) |
Constructor and Description |
---|
IdDictionary(StormTopology topology) |
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 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 |
---|---|
static ComponentCommon |
Utils.getComponentCommon(StormTopology topology,
String id) |
static ComponentCommon |
ThriftTopologyUtils.getComponentCommon(StormTopology topology,
String componentId) |
static Set<String> |
ThriftTopologyUtils.getComponentIds(StormTopology topology) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
TridentWordCount.buildTopology(backtype.storm.LocalDRPC drpc) |
static StormTopology |
TridentReach.buildTopology(backtype.storm.LocalDRPC drpc) |
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 |
TridentTopology.build() |
Modifier and Type | Method and Description |
---|---|
StormTopology |
TridentTopologyBuilder.buildTopology() |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.