国产高清在线二区,337p日本大胆精品,久久精品无码一区二区三区

表格存儲(chǔ)提供了BulkExport接口用于在大數(shù)據(jù)場(chǎng)景下批量讀取數(shù)據(jù)表中的數(shù)據(jù)。數(shù)據(jù)寫(xiě)入到數(shù)據(jù)表后，您可以根據(jù)指定條件進(jìn)行數(shù)據(jù)讀取。

前提條件

已初始化OTSClient。具體操作，請(qǐng)參見(jiàn)初始化OTSClient。
已創(chuàng)建數(shù)據(jù)表并寫(xiě)入數(shù)據(jù)。

參數(shù)

參數(shù)	說(shuō)明
tableName	數(shù)據(jù)表名稱(chēng)。
inclusiveStartPrimaryKey	本次批量讀取的起始主鍵和結(jié)束主鍵，起始主鍵和結(jié)束主鍵需要是有效的主鍵或者是由INF_MIN和INF_MAX類(lèi)型組成的虛擬點(diǎn)，虛擬點(diǎn)的列數(shù)必須與主鍵相同。其中INF_MIN表示無(wú)限小，任何類(lèi)型的值都比它大；INF_MAX表示無(wú)限大，任何類(lèi)型的值都比它小。 inclusiveStartPrimaryKey表示起始主鍵，如果該行存在，則返回結(jié)果中一定會(huì)包含此行。 exclusiveEndPrimaryKey表示結(jié)束主鍵，無(wú)論該行是否存在，返回結(jié)果中都不會(huì)包含此行。數(shù)據(jù)表中的行按主鍵從小到大排序，讀取范圍是一個(gè)左閉右開(kāi)的區(qū)間，正序讀取時(shí)，返回的是大于等于起始主鍵且小于結(jié)束主鍵的所有的行。
exclusiveEndPrimaryKey
columnsToGet	讀取的列集合，列名可以是主鍵列或?qū)傩粤小? 如果不設(shè)置返回的列名，則返回整行數(shù)據(jù)。如果設(shè)置了返回的列名，當(dāng)某行中指定的列均不存在時(shí)，則不返回該行，即返回值為null；當(dāng)某行中存在部分指定的列時(shí)，則返回該行且只返回存在的列。說(shuō)明查詢一行數(shù)據(jù)時(shí)，默認(rèn)返回此行所有列的數(shù)據(jù)。如果需要只返回特定列，可以通過(guò)設(shè)置columnsToGet參數(shù)限制。如果將col0和col1加入到columnsToGet中，則只返回col0和col1列的值。如果某行數(shù)據(jù)的主鍵屬于讀取范圍，但是該行數(shù)據(jù)不包含指定返回的列，則返回結(jié)果中不包含該行數(shù)據(jù)。當(dāng)columnsToGet和filter同時(shí)使用時(shí)，執(zhí)行順序是先獲取columnsToGet指定的列，再在返回的列中進(jìn)行條件過(guò)濾。
filter	使用過(guò)濾器，在服務(wù)端對(duì)讀取結(jié)果再進(jìn)行一次過(guò)濾，只返回符合過(guò)濾器中條件的數(shù)據(jù)行。更多信息，請(qǐng)參見(jiàn)過(guò)濾器。說(shuō)明當(dāng)columnsToGet和filter同時(shí)使用時(shí)，執(zhí)行順序是先獲取columnsToGet指定的列，再在返回的列中進(jìn)行條件過(guò)濾。
dataBlockType	此次讀取請(qǐng)求的返回?cái)?shù)據(jù)的格式類(lèi)型。可選項(xiàng)包括PlainBuffer和SimpleRowMatrix。

示例

以下示例用于批量讀取指定范圍內(nèi)的數(shù)據(jù)。

private static void bulkExport(SyncClient client, String start, String end){
    // 構(gòu)造起始主鍵。
    PrimaryKeyBuilder startPrimaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    startPrimaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(String.valueOf(start)));
    PrimaryKey startPrimaryKey = startPrimaryKeyBuilder.build();

    // 構(gòu)造結(jié)束主鍵。
    PrimaryKeyBuilder endPrimaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    endPrimaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(String.valueOf(end)));
    PrimaryKey endPrimaryKey = endPrimaryKeyBuilder.build();

    // 創(chuàng)建bulkExportRequest。
    BulkExportRequest bulkExportRequest = new BulkExportRequest();
    // 創(chuàng)建bulkExportQueryCriteria。
    BulkExportQueryCriteria bulkExportQueryCriteria = new BulkExportQueryCriteria("<TABLE_NAME>");

    bulkExportQueryCriteria.setInclusiveStartPrimaryKey(startPrimaryKey);
    bulkExportQueryCriteria.setExclusiveEndPrimaryKey(endPrimaryKey);
    //使用DBT_PLAIN_BUFFER編碼方式。
    bulkExportQueryCriteria.setDataBlockType(DataBlockType.DBT_PLAIN_BUFFER);
    //如果需要使用DBT_SIMPLE_ROW_MATRIX編碼方式時(shí)，請(qǐng)使用以下代碼配置。
    // bulkExportQueryCriteria.setDataBlockType(DataBlockType.DBT_SIMPLE_ROW_MATRIX);
    bulkExportQueryCriteria.addColumnsToGet("pk");
    bulkExportQueryCriteria.addColumnsToGet("DC1");
    bulkExportQueryCriteria.addColumnsToGet("DC2");

    bulkExportRequest.setBulkExportQueryCriteria(bulkExportQueryCriteria);
    // 獲取bulkExportResponse。
    BulkExportResponse bulkExportResponse = client.bulkExport(bulkExportRequest);
    
    // 如果設(shè)置DataBlockType為DBT_SIMPLE_ROW_MATRIX，則需要使用以下代碼進(jìn)行結(jié)果打印。
    //{
    //    SimpleRowMatrixBlockParser parser = new SimpleRowMatrixBlockParser(bulkExportResponse.getRows());
    //    List<Row> rows = parser.getRows();
    //    for (int i = 0; i < rows.size(); i++){
    //        System.out.println(rows.get(i));
    //    }
    //}

    // 設(shè)置DataBlockType為DBT_PLAIN_BUFFER并打印結(jié)果。
    {
        PlainBufferBlockParser parser = new PlainBufferBlockParser(bulkExportResponse.getRows());
        List<Row> rows = parser.getRows();
        for (int i = 0; i < rows.size(); i++){
            System.out.println(rows.get(i));
        }
    }
}

日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

離線批量讀取數(shù)據(jù)

前提條件

參數(shù)

示例

相關(guān)文檔