Tablestore SDK for Java を使用して、時系列テーブルの Lastpoint インデックスを作成し、各時系列の最新のデータポイントを読み取ります。
前提条件
作業を開始する前に、以下の準備ができていることを確認してください。
Tablestore SDK for Java 5.17.1 以降をインストールし、時系列クライアントを初期化してあること。 最新バージョンのご使用を推奨します。
Lastpoint インデックスをサポートするリージョンに時系列モデルインスタンスがあること。 サポートされているリージョンと機能の詳細については、「Lastpoint インデックス」をご参照ください。
説明
createTimeseriesLastpointIndex API を呼び出して、時系列テーブルの Lastpoint インデックスを作成します。 このインデックスには、システムが生成したパーティションキー _#h、時系列識別子、および各時系列の最新のデータポイントが含まれます。
public CreateTimeseriesLastpointIndexResponse createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request) throws TableStoreException, ClientException
Lastpoint インデックスの作成は非同期です。 includeBaseData が true の場合、Tablestore はまず時系列テーブルから既存データを同期します。 最初の同期が完了すると、インデックスは増分同期に移行します。 新しいデータは、ローカルインデックス作成によって同期レイテンシーなしで同期されます。 includeBaseData が false の場合、インデックスはインデックス作成前に書き込まれたデータを除外しますが、新しいデータは同期します。
1 つの時系列テーブルには、合計で最大 10 個の Lastpoint インデックスと分析ストアを作成できます。 Lastpoint インデックスの作成は無料です。 ストレージと読み取りは課金対象です。 SQL クエリと多次元インデックスのクエリには、追加料金が発生します。 課金の詳細については、「時系列モデルの課金」、「SQL クエリの課金」、および「多次元インデックスの課金」をご参照ください。
次の例では、example_timeseries_table に example_lastpoint_index を作成し、既存データを含めます。
TimeseriesClient timeseriesClient = client.asTimeseriesClient();
CreateTimeseriesLastpointIndexRequest request =
new CreateTimeseriesLastpointIndexRequest(
"example_timeseries_table",
"example_lastpoint_index",
true);
timeseriesClient.createTimeseriesLastpointIndex(request);
時系列テーブルの作成時に Lastpoint インデックスを作成することもできます。
パラメーター
CreateTimeseriesLastpointIndexRequest には、次のパラメーターが含まれます。
|
名前 |
タイプ |
説明 |
|
timeseriesTableName (必須) |
|
時系列テーブルの名前。 |
|
lastpointIndexName (必須) |
|
Lastpoint インデックスの名前。 |
|
includeBaseData (必須) |
|
インデックスが作成される前に書き込まれたデータを同期するかどうかを指定します。 値が |