1. 創(chuàng)建多元索引

以下示例用于為Lastpoint索引創(chuàng)建一個多元索引。示例場景及數(shù)據(jù)請參見附錄。

private static void createSearchIndex(SyncClient client) {
    CreateSearchIndexRequest createSearchIndexRequest = new CreateSearchIndexRequest();
    createSearchIndexRequest.setTableName("<LASTPOINT_INDEX_NAME>");
    createSearchIndexRequest.setIndexName("<SEARCH_INDEX_NAME>");
    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. 通過多元索引檢索數(shù)據(jù)

此處以范圍查詢?yōu)槔榻B多元索引查詢功能的使用。

以下示例用于通過多元索引檢索Lastpoint索引中speed值大于20.0的行數(shù)據(jù)。

private static void rangeQuery(SyncClient client) {
    SearchQuery searchQuery = new SearchQuery();
    RangeQuery rangeQuery = new RangeQuery(); //設(shè)置查詢類型為RangeQuery。
    rangeQuery.setFieldName("speed");  //設(shè)置要匹配的字段。
    rangeQuery.greaterThan(ColumnValue.fromDouble(20.0));  //設(shè)置該字段的范圍條件為大于20.0。
    searchQuery.setGetTotalCount(true);
    searchQuery.setQuery(rangeQuery);
    //設(shè)置按照speed列逆序排序。
    FieldSort fieldSort = new FieldSort("speed");
    fieldSort.setOrder(SortOrder.DESC);
    searchQuery.setSort(new Sort(Arrays.asList((Sort.Sorter)fieldSort)));
    searchQuery.setGetTotalCount(true); //設(shè)置返回匹配的總行數(shù)。

    SearchRequest searchRequest = new SearchRequest("<LASTPOINT_INDEX_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);
    //通過設(shè)置columnsToGet參數(shù)可以指定返回的列或返回所有列，如果不設(shè)置此參數(shù)，則默認只返回主鍵列。
    SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
    columnsToGet.setReturnAll(true); //設(shè)置為返回所有列。
    searchRequest.setColumnsToGet(columnsToGet);

    SearchResponse resp = client.search(searchRequest);
    System.out.println("TotalCount: " + resp.getTotalCount()); //打印匹配到的總行數(shù)，非返回行數(shù)。
    System.out.println("Row: " + resp.getRows());
}