如何通過.NET SDK並發匯出資料 -

當使用情境中不關心整個結果集的順序時，您可以使用並發匯出資料功能以更快的速度將命中的資料全部返回。

前提條件

已初始化OTSClient。具體操作，請參見初始化OTSClient。
已建立資料表並寫入資料。具體操作，請參見建立資料表和寫入資料。
已在資料表上建立多元索引。具體操作，請參見建立多元索引。

參數

參數		說明
TableName		資料表名稱。
IndexName		多元索引名稱。
ScanQuery	Query	多元索引的查詢語句。支援精確查詢、模糊查詢、範圍查詢、地理位置查詢、巢狀查詢等，功能和Search介面一致。
	Limit	掃描資料時一次能返回的資料行數。
	MaxParallel	最大並發數。請求支援的最大並發數由使用者資料量決定。資料量越大，支援的並發數越多，每次任務前可以通過ComputeSplits API進行擷取。
	CurrentParallelId	當前並發ID。取值範圍為[0, MaxParallel)。
	Token	用於翻頁功能。ParallelScan請求結果中有下一次進行翻頁的Token，使用該Token可以接著上一次的結果繼續讀取資料。
	AliveTime	ParallelScan的當前任務有效時間，也是Token的有效時間。預設值為60，建議使用預設值，單位為秒。如果在有效時間內沒有發起下一次請求，則不能繼續讀取資料。持續發起請求會重新整理Token有效時間。說明動態修改schema中的切換索引、服務端單台機器故障、服務端負載平衡等均會導致Session提前到期，此時需要重新建立Session。
ColumnsToGet		指定分組結果中需要返回的列名，可以通過將列名加入Columns來實現。如果需要返回多元索引中的所有列，則可以使用更簡潔的ReturnAllFromIndex實現。重要此處不能使用ReturnAll。
SessionId		本次並發掃描資料任務的SessionId。建立Session可以通過ComputeSplits API來建立，同時獲得本次任務支援的最大並發數。

樣本

以下樣本用於單並發掃描資料。

/// <summary>
/// ParallelScan單並發掃描資料。
/// </summary>
public class ParallelScan
{
    public static void ParallelScanwithSingleThread(OTSClient otsClient)
    {
        SearchIndexSplitsOptions options = new SearchIndexSplitsOptions
        {
            IndexName = IndexName
        };

        ComputeSplitsRequest computeSplitsRequest = new ComputeSplitsRequest
        {
            TableName = TableName,
            SplitOptions = options
        };

        ComputeSplitsResponse computeSplitsResponse = otsClient.ComputeSplits(computeSplitsRequest);

        MatchAllQuery matchAllQuery = new MatchAllQuery();

        ScanQuery scanQuery = new ScanQuery();
        scanQuery.AliveTime = 60;
        scanQuery.Query = matchAllQuery;
        scanQuery.MaxParallel = computeSplitsResponse.SplitsSize;
        scanQuery.Limit = 10;

        ParallelScanRequest parallelScanRequest = new ParallelScanRequest();
        parallelScanRequest.TableName = TableName;
        parallelScanRequest.IndexName = IndexName;
        parallelScanRequest.ScanQuery = scanQuery;
        parallelScanRequest.ColumnToGet = new ColumnsToGet { ReturnAllFromIndex = true };
        parallelScanRequest.SessionId = computeSplitsResponse.SessionId;

        int total = 0;
        List<Row> result = new List<Row>();

        ParallelScanResponse parallelScanResponse = otsClient.ParallelScan(parallelScanRequest);

        while (parallelScanResponse.NextToken != null)
        {
            List<Row> rows = new List<Row>(parallelScanResponse.Rows);

            total += rows.Count;
            result.AddRange(rows);

            parallelScanRequest.ScanQuery.Token = parallelScanResponse.NextToken;

            parallelScanResponse = otsClient.ParallelScan(parallelScanRequest);
        }

        foreach (Row row in result)
        {
            Console.WriteLine(JsonConvert.SerializeObject(row));
        }
        Console.WriteLine("Total Row Count: {0}", total);
    }
}