GetStreamRecord

调用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

下次读取此Sharditerator。

consumed

ConsumedCapacity

读取Stream数据时CU的计算是根据读取所有行总大小除以4 KB向上取整。关于行的数据大小计算方式的更多信息,请参见数据存储

may_more_record

bool

指示是否可能还有更多的记录可供读取,以便客户端可以做出进一步的数据读取或处理决策。

使用SDK

Java SDK:获取Shard的更新记录