学堂 学堂 学堂公众号手机端

Storm中的StreamGrouping有以下几种类型

lewis 2年前 (2023-11-03) 阅读数 7 #技术

Storm中的StreamGrouping有以下几种类型:

  1. FieldsGrouping:根据指定的字段进行分组。

  2. ShuffleGrouping:随机将元组发送到下游的任何一个任务。


  3. AllGrouping:将所有的元组发送到所有的下游任务。

  4. GlobalGrouping:将所有的元组发送到下游的一个任务。

  5. NoneGrouping:按照传入的元组的顺序将元组发送到下游的任务。

  6. DirectGrouping:将元组发送到指定的下游任务。

  7. LocalOrShuffleGrouping:如果下游的任务在同一个工作者进程中,则按照ShuffleGrouping进行分组,否则按照FieldsGrouping进行分组。

版权声明

本文仅代表作者观点,不代表博信信息网立场。

热门