调用 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 |
否 |
会话 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支持并发扫描数据:
该文章对您有帮助吗?