public interface ILocalClusterTrackedTopologyAware extends ILocalCluster
This is here mostly for backwards compatibility. Please see LocalCluster for more details on testing a Storm Topology.
ILocalCluster.ILocalTopology| Modifier and Type | Method and Description |
|---|---|
ILocalCluster.ILocalTopology |
submitTopology(String topologyName,
Map<String,Object> conf,
TrackedTopology topology)
Submit a tracked topology to be run in local mode.
|
ILocalCluster.ILocalTopology |
submitTopologyWithOpts(String topologyName,
Map<String,Object> conf,
TrackedTopology topology,
SubmitOptions submitOpts)
Submit a tracked topology to be run in local mode.
|
activate, advanceClusterTime, advanceClusterTime, deactivate, getClusterInfo, getClusterState, getTopology, getTopologyConf, getTopologyInfo, getTopologyInfoByName, getTopologyInfoByNameWithOpts, getTopologyInfoWithOpts, getTopologySummaries, getTopologySummary, getTopologySummaryByName, getTrackedId, killTopology, killTopologyWithOpts, rebalance, shutdown, submitTopology, submitTopologyWithOpts, uploadNewCredentialscloseILocalCluster.ILocalTopology submitTopology(String topologyName, Map<String,Object> conf, TrackedTopology topology) throws org.apache.storm.thrift.TException
Submit a tracked topology to be run in local mode.
topologyName - the name of the topology to useconf - the config for the topologytopology - the topology itself.org.apache.storm.thrift.TException - on any error from nimbusILocalCluster.ILocalTopology submitTopologyWithOpts(String topologyName, Map<String,Object> conf, TrackedTopology topology, SubmitOptions submitOpts) throws org.apache.storm.thrift.TException
Submit a tracked topology to be run in local mode.
topologyName - the name of the topology to useconf - the config for the topologytopology - the topology itself.submitOpts - options for topologyorg.apache.storm.thrift.TException - on any error from nimbusCopyright © 2021 The Apache Software Foundation. All rights reserved.