全部產品
Search
文件中心

Tablestore:GetStreamRecord

更新時間:Jul 24, 2024

調用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的更新記錄