Tablestore:オフラインデータの一括エクスポート

前提条件

Tablestore SDK for Java をインストールし、クライアントを初期化します。

説明

プライマリキー範囲に基づいて、データテーブルから連続した行をスキャンします。レスポンスには、プライマリキーが開始キー以上かつ終了キー未満の行が含まれます。com.alicloud.openservices.tablestore.model.tunnel サブパッケージの BulkExportQueryCriteria を使用して、開始プライマリキーと終了プライマリキー、返される列、フィルター、およびデータブロックのエンコーディングタイプを設定します。レスポンスは、行データを ByteBuffer でエンコードされたバイトとして返します。これを一致するパーサーでデコードして行リストに変換します。DBT_PLAIN_BUFFER は PlainBufferBlockParser と、DBT_SIMPLE_ROW_MATRIX は SimpleRowMatrixBlockParser とペアになります。getNextStartPrimaryKey() が null 以外の値を返した場合、さらに行が残っていることを示します。そのキーからスキャンを続行してください。

public BulkExportResponse bulkExport(BulkExportRequest bulkExportRequest) throws TableStoreException, ClientException

次の例では、1 回の呼び出しで bulk_export_demo テーブルからプライマリキー範囲 [row00, row99) を読み取ります。この例では DBT_PLAIN_BUFFER エンコーディングを使用し、一致するパーサーで結果をデコードします。

String tableName = "bulk_export_demo";

// 開始プライマリキー (含む)
PrimaryKey startPk = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("row00"))
        .build();
// 終了プライマリキー (含まない)
PrimaryKey endPk = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("row99"))
        .build();

// BulkExportQueryCriteria は model.tunnel サブパッケージにあります
BulkExportQueryCriteria criteria = new BulkExportQueryCriteria(tableName);
criteria.setInclusiveStartPrimaryKey(startPk);
criteria.setExclusiveEndPrimaryKey(endPk);
criteria.setDataBlockType(DataBlockType.DBT_PLAIN_BUFFER);
criteria.addColumnsToGet("pk");
criteria.addColumnsToGet("col1");

BulkExportRequest request = new BulkExportRequest(criteria);
BulkExportResponse response = client.bulkExport(request);

// response.getRows() は ByteBuffer を返します。一致するパーサーを使用して List に解析します
// DBT_PLAIN_BUFFER       -> PlainBufferBlockParser
// DBT_SIMPLE_ROW_MATRIX  -> SimpleRowMatrixBlockParser
PlainBufferBlockParser parser = new PlainBufferBlockParser(response.getRows());
List<Row> rows = parser.getRows();
System.out.println("Rows returned: " + rows.size());
for (Row row : rows) {
    System.out.println(row);
}

// nextStartPrimaryKey が null でない場合は、さらにデータが残っており、ページネーションを続行する必要があることを示します
System.out.println("Has next: " + (response.getNextStartPrimaryKey() != null));

パラメーター

レスポンス

例

String tableName = "bulk_export_demo";

PrimaryKey startPk = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("row00"))
        .build();
PrimaryKey endPk = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("row99"))
        .build();

int totalRows = 0;
while (startPk != null) {
    BulkExportQueryCriteria criteria = new BulkExportQueryCriteria(tableName);
    criteria.setInclusiveStartPrimaryKey(startPk);
    criteria.setExclusiveEndPrimaryKey(endPk);
    criteria.setDataBlockType(DataBlockType.DBT_PLAIN_BUFFER);

    BulkExportResponse response = client.bulkExport(new BulkExportRequest(criteria));

    PlainBufferBlockParser parser = new PlainBufferBlockParser(response.getRows());
    List<Row> rows = parser.getRows();
    totalRows += rows.size();

    // nextStartPrimaryKey が null の場合は、すべてのデータが読み取られたことを示します
    startPk = response.getNextStartPrimaryKey();
}
System.out.println("Total rows scanned: " + totalRows);