メインコンテンツまでスキップ
バージョン: 4.x

CREATE TABLE

説明​

現在のデータベースまたは指定されたデータベースに新しいテーブルを作成します。テーブルは複数の列を持つことができ、各列の定義には名前、データ型、および必要に応じて以下の属性が含まれます：

  • キーかどうか
  • 集約セマンティクスを持つかどうか
  • 生成列かどうか
  • 値が必要かどうか（NOT NULL）
  • 自動インクリメント列かどうか
  • 挿入時にデフォルト値があるかどうか
  • 更新時にデフォルト値があるかどうか

さらに、このコマンドは以下のバリエーションもサポートしています：

  • CREATE TABLE … AS SELECT（データが事前に入力されたテーブルを作成する。CTASとも呼ばれる）
  • CREATE TABLE … LIKE（既存のテーブルの空のコピーを作成する）

構文​

CREATE [ EXTERNAL ] TABLE [ IF NOT EXISTS ] <table_name>
    (<columns_definition> [ <indexes_definition> ])
    [ ENGINE = <table_engine_type> ]
    [ <key_type> KEY (<key_cols>)
        [ CLUSTER BY (<cluster_cols>) ]
    ]
    [ COMMENT '<table_comment>' ]
    [ <partitions_definition> ]
    [ DISTRIBUTED BY { HASH (<distribute_cols>) | RANDOM }
        [ BUCKETS { <bucket_count> | AUTO } ]
    ]
    [ <roll_up_definition> ]
    [ PROPERTIES (
          -- Table property
          <table_property>
          -- Additional table properties
          [ , ... ]) 
    ]

ここで:

columns_definition
  : -- Column definition
    <col_name> <col_type>
      [ KEY ]
      [ <col_aggregate_type> ]
      [ [ GENERATED ALWAYS ] AS (<col_generate_expression>) ]
      [ [NOT] NULL ]
      [ AUTO_INCREMENT(<col_auto_increment_start_value>) ]
      [ DEFAULT <col_default_value> ]
      [ ON UPDATE CURRENT_TIMESTAMP (<col_on_update_precision>) ]
      [ COMMENT '<col_comment>' ]
    -- Additional column definitions
    [ , <col_name> <col_type> [ ... ] ]
indexes_definition
  : -- Index definition
    INDEX [ IF NOT EXISTS ]
      <index_name> (<index_cols>)
      [ USING <index_type> ]
      [ PROPERTIES (
            -- Table property
            <index_property>
            -- Additional table properties
            [ , ... ]) 
      ]
      [ COMMENT '<index_comment>' ]
    -- Additional index definitions
    [ , <index_name> (<index_cols>) [ ... ] ]
partitions_definition
  : AUTO PARTITION BY RANGE(<auto_partition_function>(<auto_partition_arguments>))
    <origin_partitions_definition>
  | AUTO PARTITION BY LIST(<partition_cols>)
    <origin_partitions_definition>
  | PARTITION BY <partition_type> (<partition_cols>)
    <origin_partitions_definition>

  • ここで:

    <origin_partitions_definition>
    : (
        -- Partition definition
        <one_partition_definition>
        -- Additional partition definition
        [ , ... ]
      )

    <one_partition_definition>
    : PARTITION [ IF NOT EXISTS ] <partition_name>
        VALUES LESS THAN <partition_value_list>
    | PARTITION [ IF NOT EXISTS ] <partition_name>
        VALUES [ <partition_lower_bound>, <partition_upper_bound>)
    | FROM <partition_lower_bound> TO <partition_upper_bound>
        INTERVAL <n> [ <datetime_unit> ]
    | PARTITION [ IF NOT EXISTS ] <partition_name>
        VALUES IN {
            (<partition_value> [, <partition_value> [ ... ] ])
            | <partition_value>
        }
roll_up_definition
  : ROLLUP (
        -- Rollup definition
        <rollup_name> (<rollup_cols>)
        [ DUPLICATE KEY (<duplicate_cols>) ]
        -- Additional rollup definition
        [ , <rollup_name> (<rollup_cols>) [ ... ] ]
    )

Varaint構文​

CREATE TABLE ... AS SELECT (CTASとも呼ばれます)​

テーブルを生成し、queryから返されたデータでそれを生成します：

CREATE
    [ EXTERNAL ]
    TABLE [ IF NOT EXISTS ] <table_name>
    [ ( <column_definitions> ) ]
    [ <index_definitions> ]
    [ ENGINE = <storage_engine_type> ]
    [ <partitioning_key_type> KEY ( <key_columns> )
        [ CLUSTER BY ( <clustering_columns> ) ]
    ]
    [ COMMENT '<table_description>' ]
    [ <partition_definitions> ]
    [ DISTRIBUTED BY { HASH ( <distribution_columns> ) | RANDOM }
        [ BUCKETS { <number_of_buckets> | AUTO } ]
    ]
    [ <rollup_definitions> ]
    [ PROPERTIES (
          "<table_properties>"
          [ , ... ] 
    ) ]
AS <query>;

CREATE TABLE ... LIKE​

既存のテーブルと同じカラム定義を持つ新しいテーブルを作成します。既存のテーブルからデータはコピーされません。カラムのすべてのプロパティが新しいテーブルに複製されます。rollup名のリストが指定された場合、元のテーブルから対応するrollupも複製されます：

CREATE TABLE <new_table_name> LIKE <existing_table_name>
[ WITH ROLLUP ( <rollup_list> ) ];

必須パラメータ​

テーブルの識別子（名前）を指定します。テーブルが作成されるデータベース内で一意である必要があります。

識別子は文字で始まる必要があり（Unicode名前サポートが有効な場合は任意の言語文字）、識別子文字列全体がバッククォートで囲まれていない限り（例：My Object）、スペースや特殊文字を含むことはできません。

識別子は予約キーワードを使用できません。

詳細については、識別子要件および予約キーワードを参照してください。

<col_name>

カラムの識別子（名前）を指定します。作成されるテーブル内で一意である必要があります。

識別子は文字（Unicode名前サポートが有効な場合は任意の言語文字）、数字、または記号@で始まる必要があり、識別子文字列全体がバッククォートで囲まれていない限り（例：My Object）、スペースや特殊文字を含むことはできません。

詳細については、識別子要件および予約キーワードを参照してください。

<col_type>

カラムのデータ型を指定します。

テーブルカラムに指定できるデータ型の詳細については、データ型セクションを参照してください。

CTASの必須パラメータ。データを格納するSELECT文を指定します。

<source_table>

CREATE TABLE ... LIKEの必須パラメータ。コピーする元のテーブルを指定します。

オプションパラメータ​

データモデル関連パラメータ​

<key_type>

テーブルのデータモデル。オプション値はDUPLICATE（詳細モデル）、UNIQUE（主キーモデル）、AGGREGATE（集約モデル）です。データモデルの詳細については、データモデルセクションを参照してください。

<key_cols>

テーブルのキーカラム。Dorisでは、Keyカラムはテーブルの最初のK個のカラムである必要があります。単一tablet内のデータは、これらのカラムによって順序が保持されます。Keyの制限とKeyカラムの選択方法については、データモデルセクションの各サブセクションを参照してください。

<cluster_cols>

データローカルソートカラム。データモデルがUNIQUE（主キーモデル）の場合にのみ使用できます。<cluster_cols>が指定された場合、<key_cols>の代わりに<cluster_cols>によってデータがソートされます。

<col_aggregate_type>

カラムの集約方法。テーブルが集約モデルの場合にのみ使用できます。集約方法の詳細については、集約モデルセクションを参照してください。

バケット関連パラメータ​

<distribute_cols> および <bucket_count>

バケットカラムとバケット数。詳細モデルのバケットカラムは任意のカラムにできます。集約モデルと主キーモデルのバケットカラムはキーカラムと一致する必要があります。バケット数は任意の正の整数です。バケットの詳細については、手動バケットおよび自動バケットセクションを参照してください。

カラムデフォルト値関連パラメータ​

[ GENERATED ALWAYS ] AS (<col_generate_expression>)

生成カラム。現在のカラムより前のカラムを使用して、式<col_generate_expression>を通じて現在のカラムのデータを生成します。生成カラムは、ユーザーが直接挿入または更新するのではなく、他のカラムの値から計算される特殊なデータベーステーブルカラムタイプです。この機能は式の結果を事前計算してデータベースに保存することをサポートし、頻繁なクエリや複雑な計算を必要とするシナリオに適しています。

AUTO_INCREMENT(<col_auto_increment_start_value>)

データインポート時に、Dorisは値が指定されていない自動増分カラムの行に対して、テーブル内で一意の値を割り当てます。<col_auto_increment_start_value>は自動増分カラムの開始値を指定します。自動増分カラムの詳細については、自動増分カラムセクションを参照してください。

DEFAULT <col_default_value>

カラムのデフォルト値。このカラムを含めずに書き込む場合、このデフォルト値が使用されます。デフォルト値が明示的に設定されていない場合、NULLが使用されます。使用可能なデフォルト値には以下があります：

  • NULL：すべての型で使用可能。NULLをデフォルト値として使用。
  • 数値リテラル：数値型でのみ使用可能。
  • 文字列リテラル：文字列型でのみ使用可能。
  • CURRENT_DATE：日付型でのみ使用可能。現在の日付をデフォルト値として使用。
  • CURRENT_TIMESTAMP [ ]：datetime型でのみ使用可能。現在のタイムスタンプをデフォルト値として使用。<defaultValuePrecision>で時間精度を指定可能。
  • PI：double型でのみ使用可能。円周率をデフォルト値として使用。
  • E：double型でのみ使用可能。数学定数eをデフォルト値として使用。
  • BITMAP_EMPTY：カラムがbitmap型の場合にのみ使用可能。空のbitmapを埋める。

ON UPDATE CURRENT_TIMESTAMP (<col_on_update_precision>)

データが更新される際、このカラムに値が指定されていない場合、現在のタイムスタンプを使用してこのカラムのデータを更新します。UNIQUE（主キーモデル）のテーブルでのみ使用可能です。

インデックス関連パラメータ​

<index_name>

インデックスの識別子（名前）を指定します。作成されるテーブル内で一意である必要があります。識別子の詳細については、識別子要件および予約キーワードを参照してください。

<index_cols>

インデックスを追加するカラムのリスト。テーブル内の既存のカラムである必要があります。

<index_type>

インデックスのタイプ。現在、INVERTEDのみサポートされています。

<index_property>

インデックスのプロパティ。詳細な説明については、転置インデックスセクションを参照してください。

自動パーティション関連パラメータ​

パーティションの詳細な説明については、自動パーティションセクションを参照してください。

手動パーティション関連パラメータ​

パーティションの詳細な説明については、「手動パーティション」セクションを参照してください。

<partition_type>

DorisはRANGEパーティションとLISTパーティションをサポートしています。詳細については、手動パーティションセクションを参照してください。

<partition_name>

パーティションの識別子（名前）。作成されるテーブル内で一意である必要があります。識別子の詳細については、識別子要件および予約キーワードを参照してください。

VALUES LESS THAN <partition_value_list>

RANGEパーティション。パーティションデータ範囲は下限から<partition_value_list>までです。

上限を表す場合、<partition_value_list>はMAX_VALUEに簡略化できます。

<partition_value_list>の形式は以下の通りです：((col_1_value, ...), (col_1_value, ...), ...)

VALUES [ <partition_lower_bound>, <partition_upper_bound>)

RANGEパーティション。パーティションデータ範囲は<partition_lower_bound>から<partition_upper_bound>までです。一つのパーティションのみが作成されます。

<partition_lower_bound>と<partition_upper_bound>の形式は以下の通りです：(col_1_value, ...)

FROM <partition_lower_bound> TO <partition_upper_bound>

INTERVAL [ <datetime_unit> ]

RANGEパーティション。パーティションデータ範囲は<partition_lower_bound>から<partition_value_list>までです。<n>ごとにパーティションが作成されます。

<partition_lower_bound>と<partition_upper_bound>の形式は以下の通りです：(col_1_value, ...)

VALUES IN {

​ (<partition_value> [, <partition_value> [ ... ] ])

​ | <partition_value>

​ }

LISTパーティション。パーティションカラムが<partition_value>と等しい行がこのパーティションに属します。

<partition_value>の形式は以下の通りです：(col_1_value, ...)

同期マテリアライズドビュー関連​

注意

rollupを使用した同期マテリアライズドビューの作成機能は制限があり、もはや推奨されません。別のステートメントを使用して同期マテリアライズドビューを作成することをお勧めします。詳細については、CREATE MATERIALIZED VIEWステートメントと同期マテリアライズドビューセクションを参照してください。

<rollup_name>

同期マテリアライズドビューの識別子（名前）。作成されるテーブル内で一意である必要があります。識別子の詳細については、識別子要件および予約キーワードを参照してください。

<rollup_cols>

同期マテリアライズドビューに含まれるカラム。

テーブルプロパティ関連パラメータ​

<table_property>

プロパティ名機能
replication_numレプリカ数。デフォルトのレプリカ数は3です。BEノード数が3未満の場合、BEノード数以下のレプリカ数を指定する必要があります。バージョン0.15以降、このプロパティは自動的にreplication_allocationプロパティに変換されます。例えば、"replication_num" = "3"は自動的に"replication_allocation" = "tag.location.default:3"に変換されます。
replication_allocationTagに基づいてレプリカの分散を設定します。このプロパティはreplication_numプロパティの機能を完全に上書きできます。
min_load_replica_numデータインポート成功に必要な最小レプリカ数を設定します。デフォルト値は-1です。このプロパティが0以下の場合、データインポートには過半数のレプリカが成功する必要があることを示します。
is_being_syncedこのテーブルがCCRによって複製され、現在syncerによって同期されているかどうかを識別するために使用されます。デフォルト値はfalseです。trueに設定された場合、colocate_withとstorage_policyプロパティがクリアされます。dynamic partitionとauto bucket機能は無効になります。つまり、show create tableでは有効に見えますが、実際には効果がありません。is_being_syncedがfalseに設定されると、これらの機能は再開されます。このプロパティはCCR周辺モジュール専用であり、CCR同期プロセス中に手動で設定すべきではありません。
storage_mediumテーブルデータの初期ストレージメディアを宣言します。
storage_cooldown_timeテーブルデータの初期ストレージメディアの有効期限を設定します。この時間を過ぎると、自動的に第一階層ストレージメディアにダウングレードされます。
colocate_withColocation Join機能が必要な場合、このパラメータを使用してColocation Groupを設定します。
bloom_filter_columnsBloom Filterインデックスの追加が必要なカラム名のリストをユーザーが指定します。各カラムのBloom Filterインデックスは独立しており、複合インデックスではありません。例："bloom_filter_columns" = "k1, k2, k3"
compressionDorisテーブルのデフォルトの圧縮方法はLZ4です。バージョン1.1以降、より高い圧縮率のためにZSTDを圧縮方法として指定することがサポートされています。
function_column.sequence_colUnique Keyモデルを使用する場合、Sequenceカラムを指定できます。Keyカラムが同じ場合、Sequenceカラムに従ってREPLACEが実行されます（大きい値が小さい値を置き換える。そうでなければ置き換えられません）。function_column.sequence_colは、sequenceカラムをテーブル内の特定のカラムにマップするために使用されます。これは整数または日付/時刻型（DATE、DATETIME）にできます。このカラムの型は作成後に変更できません。function_column.sequence_colが設定されている場合、function_column.sequence_typeは無視されます。
function_column.sequence_typeUnique Keyモデルを使用する場合、Sequenceカラムを指定できます。Keyカラムが同じ場合、Sequenceカラムに従ってREPLACEが実行されます（大きい値が小さい値を置き換える。そうでなければ置き換えられません）。ここでは、sequenceカラムの型のみを指定する必要があります。日付/時刻型または整数をサポートします。Dorisは隠されたsequenceカラムを作成します。
enable_unique_key_merge_on_writeUniqueテーブルがMerge-on-Write実装を使用するかどうか。このプロパティはバージョン2.1以前ではデフォルトで無効、バージョン2.1以降ではデフォルトで有効です。
light_schema_changeLight Schema Change最適化を使用するかどうか。trueに設定された場合、valueカラムの追加と削除操作をより高速かつ同期的に完了できます。この機能はバージョン2.0.0以降でデフォルトで有効です。
disable_auto_compactionこのテーブルの自動compactionを無効にするかどうか。このプロパティがtrueに設定された場合、バックグラウンドの自動compactionプロセスはこのテーブルのすべてのtabletをスキップします。
enable_single_replica_compaction非推奨。 この機能はピア選択におけるデータ正確性リスクのため、Doris 4.1.2以降削除されており、有効にすることは推奨されません。このテーブルのsingle-replica compactionを有効にするかどうか。このプロパティがtrueに設定された場合、テーブルのtabletのすべてのレプリカのうち一つのレプリカのみが実際のcompactionアクションを実行し、他のレプリカはそのレプリカからcompactionされたrowsetを取得します。
enable_duplicate_without_keys_by_defaulttrueに設定された場合、テーブル作成時にUnique、Aggregate、またはDuplicateが指定されていない場合、ソートカラムとプレフィックスインデックスなしのDuplicateモデルテーブルがデフォルトで作成されます。
skip_write_index_on_loadこのテーブルのデータインポート中にインデックス書き込みをスキップするかどうか。このプロパティがtrueに設定された場合、データインポート中にインデックスが書き込まれず（現在転置インデックスにのみ有効）、compactionまで遅延されます。これにより、初回書き込みとcompaction中のインデックス重複書き込みのCPUとIOリソース消費を回避し、高スループットインポートのパフォーマンスを向上させることができます。
compaction_policyこのテーブルのcompactionマージポリシーを設定します。time_seriesまたはsize_basedtime_seriesのみサポートしています：rowsetのディスク容量が一定サイズまで蓄積されると、バージョンマージが実行されます。マージされたrowsetは直接base compactionフェーズに昇格されます。これにより、継続的なインポートシナリオでのcompactの書き込み増幅を効果的に削減します。このポリシーはtime_series_compactionプレフィックスのパラメータを使用してcompactionの実行を調整します。
time_series_compaction_goal_size_mbytescompactionマージポリシーがtime_seriesの場合、このパラメータは各compactionの入力ファイルサイズを調整するために使用されます。出力ファイルサイズは入力と同程度になります。
time_series_compaction_file_count_thresholdcompactionマージポリシーがtime_seriesの場合、このパラメータは各compactionの最小入力ファイル数を調整するために使用されます。tabletのファイル数がこの設定を超えると、compactionがトリガーされます。
time_series_compaction_time_threshold_secondscompactionマージポリシーがtime_seriesの場合、このパラメータはcompaction間の最長間隔を調整するために使用されます。つまり、長時間実行されていない場合にcompactionがトリガーされます。単位は秒です。
time_series_compaction_level_thresholdcompactionマージポリシーがtime_seriesの場合、このパラメータのデフォルトは1です。2に設定された場合、一度マージされたセグメントが再度マージされ、セグメントサイズがtime_series_compaction_goal_size_mbytesに達することを制御し、セグメント数を削減する効果を実現するために使用されます。
group_commit_interval_msこのテーブルのGroup Commitバッチ間隔を設定します。単位はmsで、デフォルト値は10000ms（10秒）です。Group Commitのタイミングはgroup_commit_interval_msとgroup_commit_data_bytesのどちらが先に設定値に達するかに依存します。
group_commit_data_bytesこのテーブルのGroup Commitバッチデータサイズを設定します。単位はbytesで、デフォルト値は134217728（128MB）です。Group Commitのタイミングはgroup_commit_interval_msとgroup_commit_data_bytesのどちらが先に設定値に達するかに依存します。
enable_mow_light_deleteMowのUniqueテーブルでDeleteステートメントでDelete predicateを書き込むかどうか。有効にした場合、Deleteステートメントのパフォーマンスが向上しますが、Delete後の部分カラム更新で一部のデータエラーが発生する可能性があります。無効にした場合、正確性を保証するためにDeleteステートメントのパフォーマンスが低下します。このプロパティのデフォルト値はfalseです。このプロパティはUnique Merge-on-Writeテーブルでのみ有効にできます。
動的パーティション関連プロパティ動的パーティションについては、データパーティション - 動的パーティションを参照してください
enable_unique_key_skip_bitmap_columnUnique Merge-on-Writeテーブルで柔軟なカラム更新機能を有効にするかどうか。このプロパティはUnique Merge-on-Writeテーブルでのみ有効にできます。（バージョン3.1.0以降サポート）

アクセス制御要件​

このSQLコマンドを実行するユーザーは、少なくとも以下の権限を持っている必要があります：

権限オブジェクト説明
CREATE_PRIVDatabase
SELECT_PRIVTable、ViewCTASを実行する際に、クエリするテーブル、ビュー、またはマテリアライズドビューでSELECT_PRIVが必要

使用上の注意​

  • データベース（Database）には同じ名前のテーブル（Table）またはビュー（View）を含めることはできません。

  • テーブル名、カラム名、rollup名は予約キーワードを使用できません。

  • CREATE TABLE ... LIKE：

    • このコマンドはDorisの内部テーブルでのみ使用できます。
    • 明示的に指定されたrollupのみがコピーされます。
    • すべての同期マテリアライズドビューは複製されません。

  • CREATE TABLE ... AS SELECT (CTAS)：

    • SELECTリスト内のカラム名のエイリアスが有効なカラムの場合、CTASステートメントでカラム定義は不要です。省略された場合、カラム名とデータ型はベースクエリから推測されます：

      CREATE TABLE <table_name> AS SELECT ...

  • または、以下の構文を使用して明示的に名前を指定することもできます：

    CREATE TABLE <table_name> ( <col1_name>, <col2_name>, ... ) AS SELECT ...

  • パーティショニングとバケッティング

    • テーブルはバケッティング列を指定する必要がありますが、パーティションの指定は省略可能です。パーティショニングとバケッティングの詳細については、Data Partitioningのドキュメントを参照してください。
    • Dorisのテーブルはパーティション化するか、しないかを選択できます。この属性はテーブル作成時に決定され、後から変更することはできません。つまり、パーティション化されたテーブルでは、後の使用でパーティションを追加または削除することができますが、非パーティションテーブルでは後からパーティションを追加することはできません。
    • パーティションとバケット列は、テーブル作成後に変更することはできません。パーティションとバケット列の型を変更することも、これらの列を追加または削除することもできません。

  • Dynamic Partitioning

    • dynamic partitioning機能は、主にユーザーがパーティションを自動的に管理するのを支援するために使用されます。特定のルールを設定することで、Dorisシステムは定期的に新しいパーティションを追加したり、古いパーティションを削除したりします。詳細については、Dynamic Partitioningのドキュメントを参照してください。

  • Automatic Partitioning

  • Synchronized Materialized Views

    • ユーザーはテーブル作成時に複数のsynchronized materialized views（ROLLUP）を作成できます。Synchronized materialized viewsはテーブル作成後にも追加できます。テーブル作成文に含めることで、すべてのsynchronized materialized viewsを一度に作成することが容易になります。
    • Synchronized materialized viewsがテーブル作成時に作成される場合、その後のすべてのデータインポート操作は、materialized viewsのデータを同期的に生成します。Materialized viewsの数は、データインポートの効率に影響を与える可能性があります。
    • Materialized viewsの紹介については、Synchronized Materialized Viewsのドキュメントを参照してください。

  • Indexes

    • ユーザーはテーブル作成時に複数の列インデックスを作成できます。インデックスはテーブル作成後にも追加できます。
    • 後の使用でインデックスが追加され、テーブルに既存のデータがある場合、すべてのデータを書き直す必要があります。そのため、インデックス作成にかかる時間は現在のデータ量に依存します。

Examples​

Basic Examples​

Detail Model

CREATE TABLE t1
(
  c1 INT,
  c2 STRING
)
DUPLICATE KEY(c1)
DISTRIBUTED BY HASH(c1)
PROPERTIES (
  'replication_num' = '1'
);

集約モデル

CREATE TABLE t2
(
  c1 INT,
  c2 INT MAX
)
AGGREGATE KEY(c1)
DISTRIBUTED BY HASH(c1)
PROPERTIES (
  'replication_num' = '1'
);

主キーモデル

CREATE TABLE t3
(
  c1 INT,
  c2 INT
)
UNIQUE KEY(c1)
DISTRIBUTED BY HASH(c1)
PROPERTIES (
  'replication_num' = '1'
);

生成列の使用

CREATE TABLE t4
(
  c1 INT,
  c2 INT GENERATED ALWAYS AS (c1 + 1)
)
DUPLICATE KEY(c1)
DISTRIBUTED BY HASH(c1)
PROPERTIES (
  'replication_num' = '1'
);

列のデフォルト値の指定

CREATE TABLE t5
(
  c1 INT,
  c2 INT DEFAULT 10
)
DUPLICATE KEY(c1)
DISTRIBUTED BY HASH(c1)
PROPERTIES (
  'replication_num' = '1'
);

バケッティング手法

CREATE TABLE t6
(
  c1 INT,
  c2 INT
)
DUPLICATE KEY(c1)
DISTRIBUTED BY RANDOM
PROPERTIES (
  'replication_num' = '1'
);

自動パーティショニング

CREATE TABLE t7
(
  c1 INT,
  c2 DATETIME NOT NULL
)
DUPLICATE KEY(c1)
AUTO PARTITION BY RANGE(date_trunc(c2, 'day')) ()
DISTRIBUTED BY RANDOM
PROPERTIES (
  'replication_num' = '1'
);

Range Partitioning

CREATE TABLE t8
(
  c1 INT,
  c2 DATETIME NOT NULL
)
DUPLICATE KEY(c1)
PARTITION BY RANGE(c2) (
  FROM ('2020-01-01') TO ('2020-01-10') INTERVAL 1 DAY
)
DISTRIBUTED BY RANDOM
PROPERTIES (
  'replication_num' = '1'
);

List Partitioning

CREATE TABLE t9
(
  c1 INT,
  c2 DATE NOT NULL
)
DUPLICATE KEY(c1)
PARTITION BY LIST(c2) (
  PARTITION p1 VALUES IN (('2020-01-01'),('2020-01-02'))
)
DISTRIBUTED BY RANDOM
PROPERTIES (
  'replication_num' = '1'
);

ストレージメディアとクールダウン時間

CREATE TABLE example_db.table_hash
(
    k1 BIGINT,
    k2 LARGEINT,
    v1 VARCHAR(2048),
    v2 SMALLINT DEFAULT "10"
)
UNIQUE KEY(k1, k2)
DISTRIBUTED BY HASH (k1, k2) BUCKETS 32
PROPERTIES(
    "storage_medium" = "SSD",
    "storage_cooldown_time" = "2015-06-04 00:00:00"
);

storage_policyプロパティを使用したテーブルのコールド・ホット階層データ移行戦略の設定

  1. テーブルが移行戦略と正常に関連付けられるように、まずs3リソースとstorage policyを作成する必要があります。

    -- Non-partitioned table
    CREATE TABLE IF NOT EXISTS create_table_use_created_policy 
    (
        k1 BIGINT,
        k2 LARGEINT,
        v1 VARCHAR(2048)
    )
    UNIQUE KEY(k1)
    DISTRIBUTED BY HASH (k1) BUCKETS 3
    PROPERTIES(
        "storage_policy" = "test_create_table_use_policy",
        "replication_num" = "1"
    );

    -- Partitioned table
    CREATE TABLE create_table_partion_use_created_policy
    (
        k1 DATE,
        k2 INT,
        V1 VARCHAR(2048) REPLACE
    ) PARTITION BY RANGE (k1) (
        PARTITION p1 VALUES LESS THAN ("2022-01-01") ("storage_policy" = "test_create_table_partition_use_policy_1" ,"replication_num"="1"),
        PARTITION p2 VALUES LESS THAN ("2022-02-01") ("storage_policy" = "test_create_table_partition_use_policy_2" ,"replication_num"="1")
    ) DISTRIBUTED BY HASH(k2) BUCKETS 1;

Colocation Group

CREATE TABLE t1 (
    id int(11) COMMENT "",
    value varchar(8) COMMENT ""
)
DUPLICATE KEY(id)
DISTRIBUTED BY HASH(id) BUCKETS 10
PROPERTIES (
    "colocate_with" = "group1"
);

CREATE TABLE t2 (
    id int(11) COMMENT "",
    value1 varchar(8) COMMENT "",
    value2 varchar(8) COMMENT ""
)
DUPLICATE KEY(`id`)
DISTRIBUTED BY HASH(`id`) BUCKETS 10
PROPERTIES (
    "colocate_with" = "group1"
);

索引

CREATE TABLE example_db.table_hash
(
    k1 TINYINT,
    k2 DECIMAL(10, 2) DEFAULT "10.5",
    v1 CHAR(10) REPLACE,
    v2 INT SUM,
    INDEX k1_idx (k1) USING INVERTED COMMENT 'my first index'
)
AGGREGATE KEY(k1, k2)
DISTRIBUTED BY HASH(k1) BUCKETS 32
PROPERTIES (
    "bloom_filter_columns" = "k2"
);

テーブルのレプリケーションプロパティの設定

CREATE TABLE example_db.table_hash
(
    k1 TINYINT,
    k2 DECIMAL(10, 2) DEFAULT "10.5"
)
DISTRIBUTED BY HASH(k1) BUCKETS 32
PROPERTIES (
    "replication_allocation"="tag.location.group_a:1, tag.location.group_b:2"
);

動的パーティショニング

このテーブルは3日前にパーティションを作成し、3日前のパーティションを削除します。例えば、今日が2020-01-08の場合、p20200108、p20200109、p20200110、p20200111という名前のパーティションを作成します。パーティション範囲は以下の通りです：

[types: [DATE]; keys: [2020-01-08]; ‥types: [DATE]; keys: [2020-01-09]; )
[types: [DATE]; keys: [2020-01-09]; ‥types: [DATE]; keys: [2020-01-10]; )
[types: [DATE]; keys: [2020-01-10]; ‥types: [DATE]; keys: [2020-01-11]; )
[types: [DATE]; keys: [2020-01-11]; ‥types: [DATE]; keys: [2020-01-12]; )
CREATE TABLE example_db.dynamic_partition
(
    k1 DATE,
    k2 INT,
    k3 SMALLINT,
    v1 VARCHAR(2048),
    v2 DATETIME DEFAULT "2014-02-04 15:36:00"
)
DUPLICATE KEY(k1, k2, k3)
PARTITION BY RANGE (k1) ()
DISTRIBUTED BY HASH(k2) BUCKETS 32
PROPERTIES(
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.start" = "-3",
    "dynamic_partition.end" = "3",
    "dynamic_partition.prefix" = "p",
    "dynamic_partition.buckets" = "32" 
);

Dynamic Partitionのレプリケーションプロパティの設定

CREATE TABLE example_db.dynamic_partition
(
    k1 DATE,
    k2 INT,
    k3 SMALLINT,
    v1 VARCHAR(2048),
    v2 DATETIME DEFAULT "2014-02-04 15:36:00"
)
PARTITION BY RANGE (k1) ()
DISTRIBUTED BY HASH(k2) BUCKETS 32
PROPERTIES(
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.start" = "-3",
    "dynamic_partition.end" = "3",
    "dynamic_partition.prefix" = "p",
    "dynamic_partition.buckets" = "32",
    "dynamic_partition.replication_allocation" = "tag.location.group_a:3"
 );

CTAS の例​

CREATE TABLE t10
PROPERTIES (
  'replication_num' = '1'
)
AS SELECT * FROM t1;

CREATE TABLE ... LIKE の例​

CREATE TABLE t11 LIKE t10;