Tablestore:Mengurutkan dan membagi hasil menjadi halaman

Permintaan kueri

Tipe request adalah SearchRequest. Tabel berikut menjelaskan parameter-parameternya.

Konfigurasi kueri

Tipe request.searchQuery adalah SearchQuery. Tabel berikut hanya menjelaskan parameter yang terkait dengan pengurutan dan paginasi.

Konfigurasi pengurutan

Tipe request.searchQuery.sort adalah Sort. Tabel berikut menjelaskan parameternya.

Pengurutan berdasarkan skor relevansi

ScoreSort mengurutkan baris berdasarkan skor relevansi yang dihitung menggunakan algoritma BM25. Tabel berikut menjelaskan parameternya.

Untuk mengurutkan berdasarkan skor relevansi, konfigurasikan secara eksplisit ScoreSort. Jika tidak, index sort yang digunakan.

Pengurutan berdasarkan primary key

PrimaryKeySort mengurutkan baris berdasarkan primary key. Tabel berikut menjelaskan parameternya.

Pengurutan berdasarkan bidang

FieldSort mengurutkan baris berdasarkan nilai bidang. Tabel berikut menjelaskan parameternya.

Filter Nested

Tipe FieldSort.nestedFilter adalah NestedFilter. Tabel berikut menjelaskan parameternya.

Pengurutan berdasarkan jarak geografis

GeoDistanceSort mengurutkan baris berdasarkan jarak antara bidang titik geografis dan titik target. Tabel berikut menjelaskan parameternya.

Kolom yang dikembalikan

Tipe request.columnsToGet adalah SearchRequest.ColumnsToGet. Apakah kolom yang dikembalikan harus dibaca dari tabel data memengaruhi nilai limit maksimum.

Konfigurasi index sort

Contoh berikut mengonfigurasi bidang score sebagai bidang index sort saat membuat indeks pencarian. Jika sort tidak dikonfigurasi untuk kueri, hasil dikembalikan dalam urutan ascending berdasarkan score.

FieldSchema score = new FieldSchema("score", FieldType.LONG)
        .setEnableSortAndAgg(true);

IndexSchema indexSchema = new IndexSchema();
indexSchema.setFieldSchemas(Collections.singletonList(score));
indexSchema.setIndexSort(new Sort(
        Collections.<Sort.Sorter>singletonList(
                new FieldSort("score", SortOrder.ASC))));

Urutkan berdasarkan skor relevansi

Contoh berikut mengembalikan hasil dalam urutan descending berdasarkan skor relevansi BM25.

TermQuery termQuery = new TermQuery();
termQuery.setFieldName("category");
termQuery.setTerm(ColumnValue.fromString("book"));

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(termQuery);
searchQuery.setSort(new Sort(
        Collections.<Sort.Sorter>singletonList(new ScoreSort())));

Menangani nilai bidang yang tidak tersedia

Contoh berikut mengurutkan baris berdasarkan bidang score secara descending. Jika suatu baris tidak berisi bidang tersebut, nilai score_backup yang digunakan. Jika kedua bidang tidak tersedia, baris tersebut ditempatkan di akhir.

FieldSort fieldSort = new FieldSort("score", SortOrder.DESC);
fieldSort.setMissingFields(Collections.singletonList("score_backup"));
fieldSort.setMissingValue(FieldSort.LAST_WHEN_MISSING);

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(new MatchAllQuery());
searchQuery.setSort(new Sort(
        Collections.<Sort.Sorter>singletonList(fieldSort)));

Mengurutkan bidang bernilai ganda dan Nested

Saat mengurutkan array atau bidang bernilai ganda lainnya, gunakan mode untuk menentukan nilai yang berpartisipasi dalam pengurutan. Contoh berikut mengurutkan baris secara descending berdasarkan nilai maksimum dalam array scores.

FieldSort fieldSort = new FieldSort("scores", SortOrder.DESC);
fieldSort.setMode(SortMode.MAX);

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(new MatchAllQuery());
searchQuery.setSort(new Sort(
        Collections.<Sort.Sorter>singletonList(fieldSort)));

Saat mengurutkan subfield Nested, konfigurasikan juga path Nested dan pilih baris anak yang berpartisipasi dalam pengurutan. Contoh berikut hanya menggunakan baris anak di mana items.age bernilai 1 dan mengurutkan baris secara ascending berdasarkan nilai minimum dari items.name.

TermQuery ageQuery = new TermQuery();
ageQuery.setFieldName("items.age");
ageQuery.setTerm(ColumnValue.fromLong(1));

FieldSort fieldSort = new FieldSort("items.name", SortOrder.ASC);
fieldSort.setMode(SortMode.MIN);
fieldSort.setNestedFilter(new NestedFilter("items", ageQuery));

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(new MatchAllQuery());
searchQuery.setSort(new Sort(
        Collections.<Sort.Sorter>singletonList(fieldSort)));

Mengurutkan berdasarkan jarak geografis

Contoh berikut mengembalikan baris dari terdekat ke terjauh berdasarkan jarak bola antara bidang location dan 30.23,120.19.

GeoDistanceSort geoSort = new GeoDistanceSort(
        "location", Collections.singletonList("30.23,120.19"));
geoSort.setOrder(SortOrder.ASC);
geoSort.setDistanceType(GeoDistanceType.ARC);

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(new MatchAllQuery());
searchQuery.setSort(new Sort(
        Collections.<Sort.Sorter>singletonList(geoSort)));

Paginasi menggunakan limit dan offset

Contoh berikut melewati 100 baris pertama dan mengembalikan 100 baris berikutnya. Saat menggunakan metode ini, jumlah limit dan offset tidak boleh melebihi 100.000.

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(new MatchAllQuery());
searchQuery.setLimit(100);
searchQuery.setOffset(100);

Paginasi menggunakan token

Contoh berikut membaca semua hasil dalam loop. Token bernilai null untuk kueri pertama. Setiap kueri berikutnya langsung menggunakan nextToken dari respons sebelumnya. Setelah setToken dipanggil, SDK membersihkan sort karena token berisi kondisi pengurutan dari halaman sebelumnya.

List<Row> rows = new ArrayList<Row>();
byte[] nextToken = null;
do {
    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setQuery(new MatchAllQuery());
    searchQuery.setLimit(100);
    searchQuery.setToken(nextToken);

    SearchRequest request =
            new SearchRequest("example_table", "example_index", searchQuery);
    SearchResponse response = client.search(request);
    rows.addAll(response.getRows());
    nextToken = response.getNextToken();
} while (nextToken != null);

Untuk kueri berurutan dalam proses yang sama, teruskan nextToken langsung sebagai array byte. Gunakan encoding Base64 hanya ketika token harus disimpan atau ditransfer antar proses atau antara frontend dan backend. Jangan mengonversi token menggunakan new String(nextToken), karena akan merusak token.

String encodedToken = Base64.getEncoder().encodeToString(nextToken);
byte[] decodedToken = Base64.getDecoder().decode(encodedToken);