Storm中的StreamGrouping有以下幾種類型:
FieldsGrouping:根據指定的字段進行分組。
ShuffleGrouping:隨機將元組發送到下游的任何一個任務。
AllGrouping:將所有的元組發送到所有的下游任務。
GlobalGrouping:將所有的元組發送到下游的一個任務。
NoneGrouping:按照傳入的元組的順序將元組發送到下游的任務。
DirectGrouping:將元組發送到指定的下游任務。
LocalOrShuffleGrouping:如果下游的任務在同一個工作者進程中,則按照ShuffleGrouping進行分組,否則按照FieldsGrouping進行分組。