Storm2 WordCountWithGroupingsAndAck:Storm2 WordCountWithGrouping...
Storm2-WordCountWithGroupingsAndAck //这里创建了2个spout实例。对于预期的输出,运行分组中的示例。 builder.setSpout(SENTENCE_SPOUT_ID, spout, 2);运行后创建和删除拓扑。在prod中更改以下代码。 cluster.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());等待秒(10); cluster.killTopology(TOPOLOGY_NAME); cluster.shutdown(); checkins.txt和log4j存在于maven项目的资源文件夹中。一旦jaar被创建,它就在类路径中。 -----风
文件列表
Storm2-WordCountWithGroupingsAndAck-master.zip
(预估有个32文件)
Storm2-WordCountWithGroupingsAndAck-master
Storm2-WordCountWithGroupingsAndAck
pom.xml
2KB
Chapter1 (1).iml
5KB
.settings
org.eclipse.m2e.core.prefs
86B
org.eclipse.core.resources.prefs
150B
org.eclipse.jdt.core.prefs
238B
src
main
暂无评论