Tablestore:テーブルの作成

テーブルスキーマ

tableMeta は TableMeta オブジェクトで、次のパラメータが含まれます。

プライマリキー列

tableMeta.primaryKey[] の各要素は PrimaryKeySchema オブジェクトで、次のパラメータが含まれます。

事前定義列

tableMeta.definedColumns[] の各要素は DefinedColumnSchema オブジェクトで、次のパラメータが含まれます。

テーブル設定

tableOptions は TableOptions オブジェクトで、次のパラメータが含まれます。

予約済みの読み取り/書き込みスループット

reservedThroughput は ReservedThroughput オブジェクトで、次のパラメータが含まれます。

キャパシティーユニット

reservedThroughput.capacityUnit は CapacityUnit オブジェクトで、次のパラメータが含まれます。

セカンダリインデックス

indexMeta[] の各要素は IndexMeta オブジェクトで、次のパラメータが含まれます。

ストリーム設定

streamSpecification は StreamSpecification オブジェクトで、次のパラメータが含まれます。

ローカルトランザクション設定

enableLocalTxn は Boolean 値です。このパラメーターを設定する際は、以下の制限にご留意ください。

• ローカルトランザクションは、Tablestore SDK for Java 5.11.0 以降でのみサポートされています。

• ローカルトランザクションと自動採番主キー列は併用できません。自動採番主キー列が設定されている場合、ローカルトランザクションを有効にしても適用されません。

• 既存のテーブルでローカルトランザクションを有効にするには、チケットを送信。

サーバーサイド暗号化設定

sseSpecification は SSESpecification オブジェクトで、次のパラメータが含まれます。

テーブルスキーマとデータバージョンの設定

次の例では、2 つのプライマリキー列と 1 つの事前定義列を持つテーブルを作成します。また、最大バージョンオフセットを設定し、更新を無効化します。

TableMeta tableMeta = new TableMeta("example_table");
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("id", PrimaryKeyType.STRING));
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("device_id", PrimaryKeyType.INTEGER));
tableMeta.addDefinedColumn("status", DefinedColumnType.STRING);

TableOptions tableOptions = new TableOptions();
tableOptions.setTimeToLive(-1);
tableOptions.setMaxVersions(1);
tableOptions.setMaxTimeDeviation(86400L);
tableOptions.setAllowUpdate(false);

CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
client.createTable(request);

テーブルとセカンダリインデックスの同時作成

次の例では、example_table_index という名前のグローバルセカンダリインデックスをテーブルと同時に作成します。インデックスのプライマリキー列 category は、先にテーブルの事前定義列として定義しておく必要があります。

TableMeta tableMeta = new TableMeta("example_table");
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("id", PrimaryKeyType.STRING));
tableMeta.addDefinedColumn("category", DefinedColumnType.STRING);

TableOptions tableOptions = new TableOptions();
tableOptions.setTimeToLive(-1);
tableOptions.setMaxVersions(1);

IndexMeta indexMeta = new IndexMeta("example_table_index");
indexMeta.addPrimaryKeyColumn("category");
indexMeta.setIndexType(IndexType.IT_GLOBAL_INDEX);
indexMeta.setIndexUpdateMode(IndexUpdateMode.IUM_ASYNC_INDEX);

List<IndexMeta> indexMetas = new ArrayList<IndexMeta>();
indexMetas.add(indexMeta);
CreateTableRequest request =
        new CreateTableRequest(tableMeta, tableOptions, indexMetas);
client.createTable(request);

ストリームの有効化

次の例では、テーブル作成時にストリームを有効にし、増分ログの有効期間を 24 時間に設定します。

TableMeta tableMeta = new TableMeta("example_table");
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("id", PrimaryKeyType.STRING));

TableOptions tableOptions = new TableOptions();
tableOptions.setTimeToLive(-1);
tableOptions.setMaxVersions(1);

CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
request.setStreamSpecification(new StreamSpecification(true, 24));
client.createTable(request);

ローカルトランザクションの有効化

次の例では、setLocalTxnEnabled を呼び出して、テーブル作成時にローカルトランザクションを有効にします。

TableMeta tableMeta = new TableMeta("example_table");
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("id", PrimaryKeyType.STRING));

TableOptions tableOptions = new TableOptions();
tableOptions.setTimeToLive(-1);
tableOptions.setMaxVersions(1);

CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
request.setLocalTxnEnabled(true);
client.createTable(request);

テーブルの暗号化

次の例では、KMS サービスキーまたは Bring Your Own Key (BYOK) を使用してテーブルを暗号化します。

TableMeta tableMeta = new TableMeta("example_table");
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("id", PrimaryKeyType.STRING));

TableOptions tableOptions = new TableOptions();
tableOptions.setTimeToLive(-1);
tableOptions.setMaxVersions(1);

CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
request.setSseSpecification(
        new SSESpecification(true, SSEKeyType.SSE_KMS_SERVICE));
client.createTable(request);

TableMeta tableMeta = new TableMeta("example_table");
tableMeta.addPrimaryKeyColumn(
        new PrimaryKeySchema("id", PrimaryKeyType.STRING));

TableOptions tableOptions = new TableOptions();
tableOptions.setTimeToLive(-1);
tableOptions.setMaxVersions(1);

CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions);
String keyId = "key-xxxx****";
String roleArn = "acs:ram::1234****:role/example-role";
request.setSseSpecification(
        new SSESpecification(true, SSEKeyType.SSE_BYOK, keyId, roleArn));
client.createTable(request);