storm數據流分組

數據流分組定義了一個數據流中的tuple如何分發給topology中不一樣bolt的task。 Shuffle grouping(隨機分組):這種方式會隨機分發 tuple 給 bolt 的各個 task,每一個bolt 實例接收到的相同數量的 tuple。 Fields grouping(按字段分組):根據指定字段的值進行分組。好比說,一個數據流根據「word」字段進行分組,全部具備相同「word
相關文章
相關標籤/搜索