调用GetStreamRecord接口读取当前Shard的增量内容。
请求消息结构
message GetStreamRecordRequest {
required string shard_iterator = 1;
optional int32 limit = 2;
optional string table_name = 3;
}名称 | 类型 | 是否必选 | 描述 |
shard_iterator | string | 是 | 当前Shard读取的iterator。 |
limit | int32 | 否 | 本次读取的最大个数。 |
table_name | string | 否 | 数据表名称。 |
响应消息结构
message GetStreamRecordResponse {
repeated StreamRecord stream_records = 1;
optional raw_string next_shard_iterator = 2;
optional ConsumedCapacity consumed = 3;
optional bool may_more_record = 4;
}名称 | 类型 | 描述 |
StreamRecord | repeated StreamRecord | 读取当前Shard记录的record entry。 |
next_shard_iterator | string | 下次读取此Shard的iterator。 |
consumed | ConsumedCapacity | 读取Stream数据时CU的计算是根据读取所有行总大小除以4 KB向上取整。关于行的数据大小计算方式的更多信息，请参见数据存储。 |
may_more_record | bool | 指示是否可能还有更多的记录可供读取，以便客户端可以做出进一步的数据读取或处理决策。 |
使用SDK
Java SDK：获取Shard的更新记录