首先得建立兩張表
一張按照原始表結構設計,第二張是準備分區的表
這邊我的分區字段是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的分區字段