What types of StreamGrouping are available in Storm?

There are several types of StreamGrouping in Storm.

  1. FieldsGrouping: Grouping based on specified fields.
  2. Shuffle grouping: randomly sending tuples to any one of the downstream tasks.
  3. AllGrouping: sends all tuples to all downstream tasks.
  4. GlobalGrouping: Send all tuples to one downstream task.
  5. No grouping: Send tuples downstream in the order they were received.
  6. DirectGrouping: Send tuples to the specified downstream task.
  7. If the downstream task is within the same worker process, it will be grouped according to ShuffleGrouping; otherwise, it will be grouped according to FieldsGrouping.
Leave a Reply 0

Your email address will not be published. Required fields are marked *