使用虚拟列功能时,您可以通过修改多元索引Schema或者新建多元索引来实现新字段新数据类型的查询功能,而无需修改表格存储的存储结构及数据。

前提条件

  • 已初始化Client。具体操作,请参见初始化OTSClient

  • 已创建数据表,并且数据表的最大版本数(max Versions)必须为1,数据生命周期(Time to Live)必须满足如下条件中的任意一个。具体操作,请参见创建数据表

    • 数据表的数据生命周期为-1(数据永不过期)。

    • 数据表的数据生命周期不为-1时,数据表为禁止更新状态(即是否允许更新)。

注意事项

  • 虚拟列支持不同类型到字符串类型的相互转换,转换规则请参见下表。
    数据表中字段类型虚拟列字段类型
    StringKeyword(含数组)
    StringText(含数组)
    StringLong(含数组)
    StringDouble(含数组)
    StringGeo-point(含数组)
    LongKeyword
    LongText
    DoubleKeyword
    DoubleText
  • 虚拟列目前仅支持用在查询语句中,不能用在ColumnsToGet返回列值,如果需要返回列值,可以指定返回该虚拟列的原始列。

参数

更多信息,请参见创建多元索引

示例

  1. 创建多元索引时指定虚拟列。

    以下示例用于创建一个多元索引,多元索引包含Col_KeywordCol_Long两列,同时创建虚拟列Col_Keyword_Virtual_LongCol_Long_Virtual_Keyword。虚拟列Col_Keyword_Virtual_Long映射为数据表中Col_Keyword列,虚拟列Col_Long_Virtual_Keyword映射为数据表中Col_Long列。

    private static void createSearchIndex(SyncClient client) {
        CreateSearchIndexRequest request = new CreateSearchIndexRequest();
        //设置数据表名称。
        request.setTableName("<TABLE_NAME>"); 
        //设置多元索引名称。
        request.setIndexName("<SEARCH_INDEX_NAME>"); 
        IndexSchema indexSchema = new IndexSchema();
        indexSchema.setFieldSchemas(Arrays.asList(
            //设置字段名和类型。
            new FieldSchema("Col_Keyword", FieldType.KEYWORD), 
            //设置字段名和类型。
            new FieldSchema("Col_Keyword_Virtual_Long", FieldType.LONG) 
                 //设置字段是否为虚拟列。
                .setVirtualField(true) 
                 //虚拟列对应的数据表中字段。
                .setSourceFieldName("Col_Keyword"), 
            new FieldSchema("Col_Long", FieldType.LONG),
            new FieldSchema("Col_Long_Virtual_Keyword", FieldType.KEYWORD)
                .setVirtualField(true)
                .setSourceFieldName("Col_Long")));
        request.setIndexSchema(indexSchema);
        //调用client创建多元索引。
        client.createSearchIndex(request); 
    }
  2. 使用虚拟列查询数据。

    以下示例用于查询表中Col_Long_Virtual_Keyword列的值能够匹配"1000"的数据,返回匹配到的总行数和一些匹配成功的行。

    private static void query(SyncClient client) {
        SearchQuery searchQuery = new SearchQuery();
        TermsQuery termsQuery = new TermsQuery(); //设置查询类型为TermsQuery。
        termsQuery.setFieldName("Col_Long_Virtual_Keyword"); //设置要匹配的字段。
        termsQuery.addTerm(ColumnValue.fromString("1000")); //设置要匹配的值。
        searchQuery.setQuery(termsQuery);
        searchQuery.setGetTotalCount(true); //设置返回匹配的总行数。
        SearchRequest searchRequest = new SearchRequest("<TABLE_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);
        SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
        columnsToGet.setReturnAll(true); //设置返回所有列,不支持返回虚拟列。
        searchRequest.setColumnsToGet(columnsToGet);
    
        SearchResponse resp = client.search(searchRequest);
        System.out.println("TotalCount: " + resp.getTotalCount()); //匹配到的总行数,非返回行数。
        System.out.println("Row: " + resp.getRows());
    }

相关文档