Tablestore:Ambil indeks Lastpoint

1. Buat indeks pencarian

Kode sampel berikut memberikan contoh cara membuat indeks pencarian untuk indeks Lastpoint. Untuk informasi tentang skenario sampel dan data, lihat Lampiran.

private static void createSearchIndex(SyncClient client) {
    CreateSearchIndexRequest createSearchIndexRequest = new CreateSearchIndexRequest();
    createSearchIndexRequest.setTableName("");
    createSearchIndexRequest.setIndexName("");
    IndexSchema indexSchema = new IndexSchema();
    indexSchema.setFieldSchemas(Arrays.asList(
            new FieldSchema("_#h", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("_m_name", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("_data_source", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("_tags", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true).setIsArray(true),
            new FieldSchema("_time", FieldType.LONG).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("gps", FieldType.GEO_POINT).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("speed", FieldType.DOUBLE).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("status", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("total_mileage", FieldType.DOUBLE).setIndex(true).setEnableSortAndAgg(true),
            new FieldSchema("remaining_mileage", FieldType.DOUBLE).setIndex(true).setEnableSortAndAgg(true)
    ));
    createSearchIndexRequest.setIndexSchema(indexSchema);
    client.createSearchIndex(createSearchIndexRequest);
}

2. Ambil data menggunakan indeks pencarian

Kode sampel berikut memberikan contoh cara menggunakan fitur kueri rentang indeks pencarian.

Dalam contoh ini, indeks pencarian digunakan untuk mengambil baris di mana nilai bidang speed lebih besar dari 20,0 dalam indeks Lastpoint.

private static void rangeQuery(SyncClient client) {
    SearchQuery searchQuery = new SearchQuery();
    RangeQuery rangeQuery = new RangeQuery(); // Setel jenis kueri ke RangeQuery.
    rangeQuery.setFieldName("speed");  // Tentukan bidang yang sesuai.
    rangeQuery.greaterThan(ColumnValue.fromDouble(20.0));  // Tentukan kondisi kueri untuk bidang tersebut. Hanya baris di mana nilai bidang lebih besar dari 20.0 yang memenuhi kondisi kueri.
    searchQuery.setGetTotalCount(true);
    searchQuery.setQuery(rangeQuery);
    // Tentukan bahwa baris yang memenuhi kondisi kueri diurutkan berdasarkan kolom speed secara menurun.
    FieldSort fieldSort = new FieldSort("speed");
    fieldSort.setOrder(SortOrder.DESC);
    searchQuery.setSort(new Sort(Arrays.asList((Sort.Sorter)fieldSort)));
    searchQuery.setGetTotalCount(true); // Tentukan bahwa jumlah total baris yang memenuhi kondisi kueri dikembalikan.

    SearchRequest searchRequest = new SearchRequest("", "", searchQuery);
    // Anda dapat mengonfigurasi parameter columnsToGet untuk menentukan kolom yang ingin Anda kembalikan atau tentukan bahwa semua kolom dikembalikan. Jika Anda tidak mengonfigurasi parameter ini, hanya kolom kunci utama yang dikembalikan.
    SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
    columnsToGet.setReturnAll(true); // Tentukan bahwa semua kolom dikembalikan.
    searchRequest.setColumnsToGet(columnsToGet);

    SearchResponse resp = client.search(searchRequest);
    System.out.println("TotalCount: " + resp.getTotalCount()); // Cetak jumlah total baris yang cocok, bukan jumlah baris yang dikembalikan.
    System.out.println("Row: " + resp.getRows());
}

FAQ

• Apa yang harus saya lakukan jika tidak ada data yang ditemukan saat memanggil operasi Pencarian?

• Bagaimana cara meningkatkan nilai parameter limit menjadi 1.000 saat saya memanggil operasi Pencarian fitur indeks pencarian untuk menanyakan data?

• Mengapa token menjadi tidak valid ketika paginasi digunakan dalam kueri berbasis indeks pencarian?