Apache Storm在雅虎财经上的应用

ster cluster = new LocalCluster(); cluster.submitTopology("YahooFinanceStorm", config, builder.createTopology()); Thread.sleep(10000); cluster.shutdown(); }}构建和运行应用程序完整的应用程序有三个Java代码。他们如下 - YahooFinanceSpout.java PriceCutOffBolt.java YahooFinanceStorm.java 应用程序可以使用以下命令构建 - javac -cp “/path/to/storm/apache-storm-0.9.5/lib/*”:”/path/to/yahoofinance/lib/*” *.java应用程序可以使用以下命令运行 - javac -cp “/path/to/storm/apache-storm-0.9.5/lib/*”:”/path/to/yahoofinance/lib/*”:.YahooFinanceStorm输出输出将类似于以下内容 - GOOGL : falseAAPL : falseINTC : true