一、语法
CLUSTER BY { expression [ , … ] }
二、参数
| 子句/关键字 | 说明 |
| expression | 指定一个或多个值、运算符和 SQL 函数的组合 |
三、示例
— 创建测试表CREATE EXTERNAL TABLE cb_person (name STRING, age INT)USING PARQUET LOCATION 'cosn://<your_cos_bucket>/test_cluster_by/cb_person'– 写入数据INSERT INTO cb_person VALUES ('Zen',25),('Anil',18),('Shone',16),('Mike',25),('John',18),('Jack',16)– CLUSTER BY ageSELECT age, name FROM cb_person CLUSTER BY age– CLUSTER BY (2 partitions)SET spark.sql.shuffle.partitions = 2SELECT age, name FROM cb_person CLUSTER BY age