第一個storm代碼-wordcount-本地模式

       代碼都是差不多的,一個spout,三個bolt,一個topology,就說幾個小問題:     1.書上給的代碼用了一個Utils.waitForMillis(1)在spout裏,一個waitForSeconds(10)在topology裏,我用的storm-core是1.0.2版本的(別的版本莫名其妙依賴包有點小問題,書上用的是0.9.1-incubating),這兩個方法是沒有的
相關文章
相關標籤/搜索