AnalyticDB:ホットデータとコールドデータの階層型ストレージ

テーブル作成時

CREATE TABLE 文の storage_policy パラメーターを使用してポリシーを指定します。

CREATE TABLE your_table (
    ...
)
PARTITION BY ...
PROPERTIES (
    "storage_policy" = "MIXED",   -- HOT、COLD、または MIXED
    "hot_partition_count" = "5"   -- storage_policy = MIXED の場合に必須
);

既存テーブルの場合

ストレージポリシーを変更するには、ALTER TABLE を使用します。この文を実行後、移行の進捗状況を追跡できます。「ストレージポリシー変更の進捗状況の照会」をご参照ください。

-- 5 個のホットパーティションを持つ混合ストレージに切り替え
ALTER TABLE your_table
SET PROPERTIES (
    "storage_policy" = "MIXED",
    "hot_partition_count" = "5"
);

構文の完全なリファレンスについては、「CREATE TABLE」および「ALTER TABLE」をご参照ください。

新しいパーティションが挿入された場合

すべてのパーティションが再ソートされ、正確に N 個のホットパーティションが維持されます。キー値が最小のパーティションがホットからコールドに格下げされます。

例： hot_partition_count が 5 です。新しいパーティション 20241226（最大のキー値）が挿入されました。BUILD ジョブ実行後、システムは 20241226 をホットに昇格させ、20241221（以前の最小ホットパーティション）をコールドに移動します。

ホットパーティション数を変更した場合

• N から M（M > N）に増加： M - N 個のコールドパーティション（キー値が最大のもの）がホットに昇格します。

• N から M（M < N）に減少： N - M 個のホットパーティション（キー値が最小のもの）がコールドに格下げされます。

例 — 5 から 6 に増加： パーティション 20241220（最大のコールドパーティションキー）がコールドからホットに移動します。

例 — 5 から 4 に減少： パーティション 20241221（最小のホットパーティションキー）がホットからコールドに移動します。

すべてのテーブルを照会

SELECT * FROM information_schema.table_usage;

特定のテーブルを照会

SELECT * FROM information_schema.table_usage
WHERE table_schema = '<schema_name>' AND table_name = '<table_name>';

レスポンスパラメーター

使用上の注意：

• すべてのサイズ値（rt_*、hot_*、cold_*）は、INSERT、UPDATE、DELETE、および BUILD 操作の実行に伴って変化します。

• データ書き込み後に hot_total_size と cold_total_size の両方が 0 の場合、データはリアルタイムで同期されます。rt_total_size は現在のサイズを反映します。リアルタイムデータを既存データに変換するには、BUILD 文を実行してください。その後、hot_total_size と cold_total_size に値が設定されます。

• 設定された hot_partition_count は、シャードごとのホットパーティション数を示します。照会される hot_partition_count は、すべてのシャードを跨いだ UNION であり、シャード間でパーティションの分布が異なる場合、設定値より大きくなる可能性があります。

例 — 照会された `hot_partition_count` と設定値の比較：

テーブル A には 2 つのシャードがあり、hot_partition_count は 2 に設定されています。

• シャード 1：P4、P5 がホット。P1、P2、P3 がコールド。

• シャード 2：P3、P4 がホット。P1、P2 がコールド。

照会される値は UNION：{P4, P5} ∪ {P3, P4} = {P3, P4, P5} となるため、hot_partition_count は 3 を返します。

すべてのテーブルを照会

SELECT * FROM information_schema.storage_policy_modify_progress;

特定のテーブルを照会

SELECT * FROM information_schema.storage_policy_modify_progress
WHERE table_schema = '<schema_name>' AND table_name = '<table_name>';

レスポンスパラメーター