MaxCompute:時間計算関数に基づく自動パーティションテーブル

構文

時間計算関数に基づいて自動パーティションテーブルを作成します。

CREATE [OR REPLACE] TABLE [IF NOT EXISTS] <table_name> (<col_name> <data_type>, ... )
[COMMENT <table_comment>]
AUTO PARTITIONED BY (<auto_partition_expression> [AS <auto_partition_column_name>]);

パラメーター

例

• 例 1: 時刻/日付型の列データを日単位で切り捨てて、自動パーティションを計算および生成します。

  TIMESTAMP 型の時間データ列 sale_time を含む自動パーティションテーブル sale_detail を作成します。DDL 文で、この列データを日単位で切り捨て、計算結果に基づいて AUTO PARTITION テーブルのパーティションを生成します。

  CREATE TABLE IF NOT EXISTS sale_detail(
   shop_name     STRING,
   total_price   DOUBLE,
   sale_time    TIMESTAMP )
  AUTO PARTITIONED BY (TRUNC_TIME(sale_time, 'day'));

  この文で作成された sale_detail 自動パーティションテーブルには、shop_name、total_price、sale_time、_pt_col_0_ の 4 つのカラムが含まれています。 _pt_col_0_ カラムは自動的に生成されたパーティション列で、そのデータの型は STRING です。 DESC sale_detail; 文を実行して、テーブル情報を表示できます。 以下は結果の例です:

  +------------------------------------------------------------------------------------+
  | Owner:                    ALIYUN$***                             |
  | Project:                  ***                                    |
  | TableComment:                                                                      |
  +------------------------------------------------------------------------------------+
  | CreateTime:               2025-06-26 11:21:55                                      |
  | LastDDLTime:              2025-06-26 11:21:55                                      |
  | LastModifiedTime:         2025-06-26 11:21:55                                      |
  +------------------------------------------------------------------------------------+
  | InternalTable: YES      | Size: 0                                                  |
  +------------------------------------------------------------------------------------+
  | Native Columns:                                                                    |
  +------------------------------------------------------------------------------------+
  | Field           | Type       | Label | Comment                                     |
  +------------------------------------------------------------------------------------+
  | shop_name       | string     |       |                                             |
  | total_price     | double     |       |                                             |
  | sale_time       | timestamp  |       |                                             |
  +------------------------------------------------------------------------------------+
  | Partition Columns:                                                                 |
  +------------------------------------------------------------------------------------+
  | _pt_col_0_      | string     |                                                     |
  +------------------------------------------------------------------------------------+

  説明

  AUTO PARTITION 列のパーティション生成計算ロジックを表示するには、SHOW CREATE TABLE を使用できます。

• 例 2: 生成されるパーティション列の名前を明示的に指定します。

  例 1 に基づいて、明示的に指定されたパーティション列名 sale_date を追加して、自動パーティションテーブル sale_detail2 を作成します。

  CREATE TABLE IF NOT EXISTS sale_detail2(
   shop_name     STRING,
   total_price   DOUBLE,
   sale_time    TIMESTAMP )
  AUTO PARTITIONED BY (TRUNC_TIME(sale_time, 'day') AS sale_date);

• 例 3: TRUNC_TIME 関数の入力データ列が DATE データ型で、日単位でパーティション分割されている場合、次の簡略化された構文がサポートされます。

  CREATE TABLE IF NOT EXISTS sale_detail3(
   shop_name     STRING,
   total_price   DOUBLE,
   sale_date    DATE )
  AUTO PARTITIONED BY (TRUNC_TIME(sale_date , 'day'));
  
  -- 上記の SQL 文は次のように簡略化できます
  CREATE TABLE IF NOT EXISTS sale_detail3(
   shop_name     STRING,
   total_price   DOUBLE,
   sale_date    DATE )
  AUTO PARTITIONED BY (sale_date);

  重要

  この簡略化された構文は DATE データ型のみをサポートし、DATETIME/TIMESTAMP/TIMESTAMP_NTZ データ型はサポートしていません。

例: 時間計算関数に基づいて作成されたパーティションテーブル sale_detail2 にデータを書き込みます。

-- プロジェクトのローカルタイムゾーンを東八区に設定します。
set odps.sql.timezone=Asia/Shanghai;

-- 上記のパーティションテーブル sale_detail2 の作成方法と同じです。
CREATE TABLE IF NOT EXISTS sale_detail2(
 shop_name     STRING,
 total_price   DOUBLE,
 sale_time    TIMESTAMP )
AUTO PARTITIONED BY (TRUNC_TIME(sale_time, 'day') AS sale_date);


INSERT INTO sale_detail2 VALUES
  ('chongqin_shop',101101,timestamp '2025-02-04 01:15:30'),
  ('shenzhen_shop',202202,timestamp '2024-03-29 15:30:30'),
  ('hangzhou_shop',303303,timestamp '2025-02-04 08:30:30'),
  ('shanghai_shop',404404,timestamp '2025-02-28 01:50:30');
  

この例では、sale_time 時刻データ列の値と、TRUNC_TIME 計算後に生成されるパーティション値の対応は次のとおりです。

• 例 1: select * クエリを実行すると、生成されたパーティション列はデフォルトで表示されません。

  -- 全表スキャンを有効にする 
  set odps.sql.allow.fullscan=true;
  
  SELECT * FROM sale_detail2;
  
  -- 結果
  +------------+-------------+------------+
  | shop_name  | total_price | sale_time  | 
  +------------+-------------+------------+
  | hangzhou_shop | 303303.0    | 2025-02-04 08:30:30 | 
  | shanghai_shop | 404404.0    | 2025-02-28 01:50:30 | 
  | shenzhen_shop | 202202.0    | 2024-03-29 15:30:30 | 
  | chongqin_shop | 101101.0    | 2025-02-04 01:15:30 | 
  +------------+-------------+------------+

• 例 2: 出力に生成されたパーティション列を表示するには、SELECT *,sale_date from sale_detail2; を実行します。 sale_date 列は、テーブルの作成時に指定されたパーティション列の名前です。

  SELECT *,sale_date from sale_detail2;
  
  -- 結果
  +------------+-------------+------------+------------+
  | shop_name  | total_price | sale_time  | sale_date  | 
  +------------+-------------+------------+------------+
  | shanghai_shop | 404404.0    | 2025-02-28 01:50:30 | 2025-02-27 | 
  | hangzhou_shop | 303303.0    | 2025-02-04 08:30:30 | 2025-02-04 | 
  | shenzhen_shop | 202202.0    | 2024-03-29 15:30:30 | 2024-03-29 | 
  | chongqin_shop | 101101.0    | 2025-02-04 01:15:30 | 2025-02-03 | 
  +------------+-------------+------------+------------+

時間計算関数に基づく自動パーティションテーブルのパーティションプルーニング

自動パーティションテーブルをクエリする場合、パーティションプルーニングは次のシナリオでのみサポートされます。

SELECT * FROM sale_detail2 WHERE sale_date > '2025-02-03';

-- 結果
+------------+-------------+------------+
| shop_name  | total_price | sale_time  | 
+------------+-------------+------------+
| shanghai_shop | 404404.0    | 2025-02-28 01:50:30 | 
| hangzhou_shop | 303303.0    | 2025-02-04 08:30:30 | 
+------------+-------------+------------+

SELECT * FROM sale_detail2 WHERE sale_time > '2025-02-04 08:00:00';

-- 結果
+------------+-------------+------------+
| shop_name  | total_price | sale_time  | 
+------------+-------------+------------+
| shanghai_shop | 404404.0    | 2025-02-28 01:50:30 | 
| hangzhou_shop | 303303.0    | 2025-02-04 08:30:30 | 
+------------+-------------+------------+