调用ParallelScan接口并发扫描数据。
请求消息结构
message ParallelScanRequest {
optional string table_name = 1;
optional string index_name = 2;
optional ColumnsToGet columns_to_get = 3;
optional bytes session_id = 4;
optional ScanQuery scan_query = 5;
optional int32 timeout_ms = 6;
}
名称 | 类型 | 是否必选 | 描述 |
table_name | string | 是 | 数据表名称。 |
index_name | string | 是 | 多元索引名称。 |
columns_to_get | 否 | 要返回的列。 | |
session_id | bytes | 否 | Session ID,用于保证获取到的结果集是稳定的,由protobuf编码。 |
scan_query | 是 | 扫描查询配置。 | |
timeout_ms | int32 | 否 | 扫描数据的超时时间。单位为毫秒。 |
响应消息结构
message ParallelScanResponse {
repeated bytes rows = 1;
optional bytes next_token = 2;
}
名称 | 类型 | 是否必选 | 描述 |
rows | bytes | 否 | 返回的行数据,由Plainbuffer编码,详见Plainbuffer。 |
next_token | bytes | 否 | 下次数据扫描的起点位置。 |
使用SDK
您可以使用如下语言的SDK并发导出数据。