划分数据分片

前提条件

安装 Tablestore Java SDK并初始化客户端。

功能说明

在服务端按指定大小将全表数据逻辑划分为若干分片。分片大小为近似值，返回结果包含每个分片的主键范围（lowerBound / upperBound）和分片所在机器的位置提示（location）。可将返回的主键范围传入 RangeRowQueryCriteria，通过范围读取数据或迭代读取数据并行处理各分片。

public ComputeSplitsBySizeResponse computeSplitsBySize(ComputeSplitsBySizeRequest request) throws TableStoreException, ClientException

以下示例将数据表 split_demo 的全表数据按 200 MB 划分为若干分片，并打印每个分片的位置和主键范围。

String tableName = "split_demo";

// 按 200 MB（2 * 100 MB）将全表数据划分为若干分片
ComputeSplitsBySizeRequest request =
        new ComputeSplitsBySizeRequest(tableName, 2);

ComputeSplitsBySizeResponse response = client.computeSplitsBySize(request);

System.out.println("PrimaryKeySchema: " + response.getPrimaryKeySchema());
List<Split> splits = response.getSplits();
System.out.println("Splits size: " + splits.size());

Iterator<Split> iterator = splits.iterator();
while (iterator.hasNext()) {
    Split split = iterator.next();
    // getLowerBound()/getUpperBound() 返回的主键范围可直接传入
    // RangeRowQueryCriteria，交给 getRange 或 createRangeIterator 并行读取
    System.out.println("Location: " + split.getLocation());
    System.out.println("LowerBound: " + split.getLowerBound().jsonize());
    System.out.println("UpperBound: " + split.getUpperBound().jsonize());
}

参数说明

返回值