说明
支持内核:SparkSQL。
适用表范围:外部 Iceberg 表、原生 Iceberg 表。
用途:设置表数据插入时的排序方式。
语法
ALTER TABLE table_identifierWRITE [LOCALLY] ORDERED BY{col_name [ASC|DESC] [NULLS FIRST|LAST]}[, ...]
参数
table_identifier
:数据表名称示例
ALTER TABLE dempts WRITE ORDERED BY category, id;-- use optional ASC/DEC keyword to specify sort order of each field (default ASC)ALTER TABLE dempts WRITE ORDERED BY category ASC, id DESC;-- use optional NULLS FIRST/NULLS LAST keyword to specify null order of each field (default FIRST)ALTER TABLE dempts WRITE ORDERED BY category ASC NULLS LAST, id DESC NULLS FIRST;-- To order within each task, not across tasksALTER TABLE dempts WRITE LOCALLY ORDERED BY category, id;