首先得新建两张表
一张按照原始表结构设计,第二张是准备分区的表
这边我的分区字段是quotime
![](https://img.laitimes.com/img/__Qf2AjLwojIjJCLyojI0JCLiAzNvwVZ2x2bzNXak9CX90TQNNkRrFlQKBTSvwFbslmZvwFMwQzLcVmepNHdu9mZvwFVywUNMZTY18CX052bm9CXxEEVOBzZ610MJpHW4Z0MMBjVtJWd0ckW65UbM5WOHJWa5kHT20ESjBjUIF2LcRHelR3LcJzLctmch1mclRXY39DNyEDOzQTM2ETMyUDM4EDMy8CX0Vmbu4GZzNmLn9Gbi1yZtl2Lc9CX6MHc0RHaiojIsJye.jpg)
然后在转换添加sql
里面可以这么写
这样当第一次运行时会把表数据放到第一张表里,第二次时会把第一张表数据动态分区到第二张分区表里
其中有两个要注意的,
1.建立分区表时要添加分隔符,比如
row format delimited fields terminated by ';'
2.以上方法导入时要在查询的最后一位添加part的分区字段
首先得新建两张表
一张按照原始表结构设计,第二张是准备分区的表
这边我的分区字段是quotime
然后在转换添加sql
里面可以这么写
这样当第一次运行时会把表数据放到第一张表里,第二次时会把第一张表数据动态分区到第二张分区表里
其中有两个要注意的,
1.建立分区表时要添加分隔符,比如
row format delimited fields terminated by ';'
2.以上方法导入时要在查询的最后一位添加part的分区字段