public void run(String[] args) throws Exception {
final StormTopology topology = getTopology();
final Config config = getConfig();
if (args.length == 0) {
submitTopologyLocalCluster(topology, config);
} else {
submitTopologyRemoteCluster(args[1], topology, config);
}
}
|