Tablestore:Pemisahan data untuk pemindaian paralel

Prasyarat

Instal Tablestore SDK for Java dan inisialisasi client.

Deskripsi

Tablestore membagi sebuah tabel secara logis menjadi split dengan ukuran perkiraan yang ditentukan di sisi server. Setiap split mencakup rentang kunci primary (lowerBound / upperBound) dan petunjuk lokasi mesin yang menyimpan split tersebut (location). Teruskan rentang kunci primary ini ke RangeRowQueryCriteria, lalu proses split tersebut secara paralel dengan membaca data berdasarkan rentang atau membaca data menggunakan iterator.

public ComputeSplitsBySizeResponse computeSplitsBySize(ComputeSplitsBySizeRequest request) throws TableStoreException, ClientException

Contoh berikut membagi tabel split_demo menjadi split berukuran sekitar 200 MB dan mencetak lokasi serta rentang kunci primary setiap split.

String tableName = "split_demo";

// Membagi seluruh data tabel menjadi split berukuran sekitar 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("Jumlah split: " + splits.size());

Iterator<Split> iterator = splits.iterator();
while (iterator.hasNext()) {
    Split split = iterator.next();
    // Rentang kunci primary yang dikembalikan oleh getLowerBound() dan getUpperBound() dapat langsung
    // diteruskan ke RangeRowQueryCriteria untuk pembacaan paralel menggunakan getRange atau createRangeIterator.
    System.out.println("Location: " + split.getLocation());
    System.out.println("LowerBound: " + split.getLowerBound().jsonize());
    System.out.println("UpperBound: " + split.getUpperBound().jsonize());
}

Parameter

Respons