Skip to content
This repository was archived by the owner on Jun 16, 2023. It is now read-only.

Grouping

Jump to bottom
longdafeng edited this page Oct 14, 2014 · 3 revisions
  1. fieldsGrouping -- this is like "group by" in SQL, tuples with the same value of target field will be sent to the same task
  2. globalGrouping -- all tuples will be sent to the first task of the component.
  3. shuffleGrouping -- all tuples will be shuffle sent to tasks of the component,
  4. localOrShuffleGrouping 本worker优先，如果本worker内有目标component的task，则随机从本worker内部的目标component的task中进行选择，否则就和普通的shuffleGrouping一样
  5. noneGrouping 随机发送tuple到目标component上，但无法保证平均
  6. allGrouping 发送给target component所有task
  7. directGrouping 发送指定目标task
  8. customGrouping 使用用户接口CustomStreamGrouping选择出目标task
Clone this wiki locally