Baca data indeks Lastpoint - Tablestore SDK untuk Java - Tablestore

Gunakan Tablestore SDK untuk Java untuk membaca titik data terbaru dari setiap deret waktu dalam indeks Lastpoint berdasarkan rentang kunci primer.

Prasyarat

Instal Tablestore SDK untuk Java dan inisialisasi klien. Indeks Lastpoint memerlukan versi 5.17.1 atau lebih baru. Disarankan untuk menggunakan versi terbaru.

Deskripsi

Indeks Lastpoint dapat dibaca sebagai tabel data. Panggil metode getRange dan tentukan rentang kunci primer untuk membaca titik data terbaru dalam rentang tersebut. Untuk tabel deret waktu yang menggunakan pengenal deret waktu bawaan, indeks Lastpoint mencakup kolom kunci primer _#h, _m_name, _data_source, dan _tags dalam urutan ini.

public GetRangeResponse getRange(GetRangeRequest getRangeRequest) throws TableStoreException, ClientException

Contoh berikut mengatur nilai awal keempat kolom kunci primer ke INF_MIN dan nilai akhir ke INF_MAX, lalu membaca seluruh data dari example_lastpoint_index secara bertahap melalui beberapa halaman.

RangeRowQueryCriteria criteria =
        new RangeRowQueryCriteria("example_lastpoint_index");

PrimaryKey startPrimaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("_#h", PrimaryKeyValue.INF_MIN)
        .addPrimaryKeyColumn("_m_name", PrimaryKeyValue.INF_MIN)
        .addPrimaryKeyColumn("_data_source", PrimaryKeyValue.INF_MIN)
        .addPrimaryKeyColumn("_tags", PrimaryKeyValue.INF_MIN)
        .build();
PrimaryKey endPrimaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("_#h", PrimaryKeyValue.INF_MAX)
        .addPrimaryKeyColumn("_m_name", PrimaryKeyValue.INF_MAX)
        .addPrimaryKeyColumn("_data_source", PrimaryKeyValue.INF_MAX)
        .addPrimaryKeyColumn("_tags", PrimaryKeyValue.INF_MAX)
        .build();

criteria.setInclusiveStartPrimaryKey(startPrimaryKey);
criteria.setExclusiveEndPrimaryKey(endPrimaryKey);
criteria.setMaxVersions(1);

while (true) {
    GetRangeResponse response =
            client.getRange(new GetRangeRequest(criteria));
    response.getRows().forEach(System.out::println);

    if (response.getNextStartPrimaryKey() == null) {
        break;
    }
    criteria.setInclusiveStartPrimaryKey(
            response.getNextStartPrimaryKey());
}

Parameter

GetRangeRequest mencakup parameter berikut.

Nama	Type	Deskripsi
rangeRowQueryCriteria (wajib)	`RangeRowQueryCriteria`	Kriteria pembacaan rentang.

Kriteria pembacaan rentang

rangeRowQueryCriteria mencakup parameter berikut.

Nama	Tipe	Deskripsi
tableName (wajib)	`String`	Nama indeks Lastpoint.
inclusiveStartPrimaryKey (wajib)	`PrimaryKey`	Kunci primer awal inklusif. Tentukan semua kolom kunci primer sesuai urutan yang ditentukan dalam indeks.
exclusiveEndPrimaryKey (wajib)	`PrimaryKey`	Kunci primer akhir eksklusif. Tentukan semua kolom kunci primer sesuai urutan yang ditentukan dalam indeks.
maxVersions (wajib)	`int`	Jumlah maksimum versi yang dikembalikan untuk setiap kolom. Indeks Lastpoint hanya menyimpan nilai terbaru dari setiap bidang. Atur parameter ini ke `1`.
columnsToGet (opsional)	`Set<String>`	Kolom atribut yang akan dikembalikan. Jika parameter ini tidak ditentukan, semua kolom atribut akan dikembalikan.
direction (opsional)	`Direction`	Arah pembacaan. Nilai yang valid: `FORWARD` dan `BACKWARD`. Nilai default: `FORWARD`.
limit (opsional)	`int`	Jumlah maksimum baris yang dikembalikan dalam satu permintaan. Nilainya harus lebih besar dari `0`. Jika parameter ini tidak ditentukan, nilai default SDK `-1` akan digunakan.

Respons

GetRangeResponse mencakup bidang spesifik operasi berikut.

Bidang	Tipe	Deskripsi
`rows`	`List<Row>`	Panggil `getRows()` untuk mendapatkan baris Lastpoint yang dikembalikan oleh permintaan.
`nextStartPrimaryKey`	`PrimaryKey`	Panggil `getNextStartPrimaryKey()` untuk mendapatkan kunci primer awal untuk permintaan berikutnya. Nilai `null` menunjukkan bahwa seluruh data dalam rentang yang ditentukan telah dikembalikan.

Skema baris Lastpoint

Untuk tabel deret waktu yang menggunakan pengenal deret waktu bawaan, setiap baris Lastpoint mencakup bidang berikut.

Bidang	Type	Deskripsi
`_#h`	`String`	Kunci partisi yang dihasilkan sistem untuk deret waktu.
`_m_name`	`String`	Nama ukuran.
`_data_source`	`String`	Sumber data.
`_tags`	`String`	Tag deret waktu.
`_time`	`long`	Timestamp dari titik data terbaru, dalam mikrodetik.
Bidang data	`ColumnValue`	Bidang data beserta nilainya pada titik data terbaru.