DISTRIBUTE BY

功能描述

DISTRIBUTE BY子句用于根据指定字段对数据进行分桶（重新分区），将相同键值的数据分配到同一个Reducer中。DISTRIBUTE BY不会在桶内进行排序。

语法格式

SELECT projectItem [, ...] FROM table_reference
  DISTRIBUTE BY expression [, ...]

参数说明

注意事项

• DISTRIBUTE BY仅负责分桶，不负责桶内排序。
• 如需在分桶后排序，请配合SORT BY使用。DISTRIBUTE BY和SORT BY可以使用不同字段。
• CLUSTER BY是DISTRIBUTE BY和SORT BY使用相同字段的简写。

示例

根据字段score进行分桶：

SELECT * FROM student DISTRIBUTE BY score; 

分桶后排序：

SELECT * FROM student DISTRIBUTE BY class_id SORT BY score DESC; 

多字段分桶：

SELECT * FROM student DISTRIBUTE BY class_id, name;