:動的パーティション

概要

Select 句の列を使用して、パーティションの値を指定できます。

insert overwrite table tablename partition (partcol1, partcol2 ...) select_statement from from_statement;

例

create table total_revenues (revenue bigint) partitioned by (region string);
    insert overwrite table total_revenues partition(region)
        select total_price as revenue, region
            from sale_detail;

上記の例のとおり、SQL を実行する前にどのパーティションが生成されるか、ユーザーにはわかりません。 SELECT 文の実行が完了しないと、region 値で作成されたパーティションがどれかユーザーは確認できません。 そのため、動的パーティションといいます。

create table sale_detail_dypart like sale_detail; --Create target table.

• -- 例 1:

  insert overwrite table sale_detail_dypart partition (sale_date, region)
  select shop_name,customer_id,total_price,sale_date,region from sale_detail;
      -- 正常終了します。

  • 'sale_detail' テーブルの sale_date の値によって､ターゲットテーブルの sale_date パーティション値が決まります。また、region の値によって、ターゲットテーブルの region パーティションの値が決まります。
  • 動的パーティションでは、select_statement フィールドとターゲットテーブルの動的パーティションとの対応付けは、フィールドの順序で決まります。 たとえば、SELECT 文が次のように記述されているとします。

    select shop_name,customer_id,total_price,region,sale_date from
              sale_detail;

    region の値によってターゲットテーブルの sale_date パーティション値が決まり、sale_date の値によってターゲットテーブルの region パーティション値が決まります。
• -- 例 2:

  insert overwrite table sale_detail_dypart partition (sale_date='2013', region)
          select shop_name,customer_id,total_price,region from sale_detail;
      -- 正常に終了します。マルチパーティション。セカンダリパーティションを指定します。

• -- 例 3:

  insert overwrite table sale_detail_dypart partition (sale_date='2013', region)
          select shop_name,customer_id,total_price from sale_detail;
      -- エラー情報が返されます。 動的パーティションを挿入する場合、動的パーティション列を Select リストに含めなければなりません。

• -- 例 4:

  insert overwrite table sales partition (region='china', sale_date)
  select shop_name,customer_id,total_price,sale_date from sale_detail;
      -- エラー情報が返されます。 下位のサブパーティションのみを指定することはできません。上位パーティションを動的に挿入する必要があります。

create table parttable(a int, b double) partitioned by (p string);
insert into parttable partition(p) select key, value, current_timestmap() from src;
select * from parttable;