第一个storm代码-wordcount-本地模式

       代码都是差不多的,一个spout,三个bolt,一个topology,就说几个小问题:     1.书上给的代码用了一个Utils.waitForMillis(1)在spout里,一个waitForSeconds(10)在topology里,我用的storm-core是1.0.2版本的(别的版本莫名其妙依赖包有点小问题,书上用的是0.9.1-incubating),这两个方法是没有的
相关文章
相关标签/搜索