MAPREDUCE服务 MRS-Spark动态分区插入场景内存优化:操作步骤

时间：2024-11-06 14:23:21

MAPREDUCE服务 MRS

操作步骤

在动态分区语句中加入distribute by，by值为分区字段。

示例如下：

insert into table store_returns partition (sr_returned_date_sk) select sr_return_time_sk,sr_item_sk,sr_customer_sk,sr_cdemo_sk,sr_hdemo_sk,sr_addr_sk,sr_store_sk,sr_reason_sk,sr_ticket_number,sr_return_quantity,sr_return_amt,sr_return_tax,sr_return_amt_inc_tax,sr_fee,sr_return_ship_cost,sr_refunded_cash,sr_reversed_charge,sr_store_credit,sr_net_loss,sr_returned_date_sk from ${SOURCE}.store_returns distribute by sr_returned_date_sk;

上一篇：MAPREDUCE服务 MRS-Spark动态分区插入场景内存优化:操作场景

下一篇：MAPREDUCE服务 MRS-Spark动态分区插入场景内存优化:操作场景