Consulta os dados incrementais de um shard.
Sintaxe de solicitação
message GetStreamRecordRequest {
required string shard_iterator = 1;
optional int32 limit = 2;
optional string table_name = 3;
}|
Parâmetro |
Tipo |
Obrigatório |
Descrição |
|
shard_iterator/@parmname |
string |
Sim |
Iterador do shard usado para ler os dados incrementais do shard. |
|
limit/@parmname |
int32 |
Não |
Número máximo de registros a retornar. |
|
table_name/@parmname |
string |
Não |
Nome da tabela de dados. |
Sintaxe de resposta
message GetStreamRecordResponse {
repeated StreamRecord stream_records = 1;
optional raw_string next_shard_iterator = 2;
optional ConsumedCapacity consumed = 3;
optional bool may_more_record = 4;
}|
Parâmetro |
Tipo |
Descrição |
|
StreamRecord/@parmname |
repeated StreamRecord |
Entrada de registro de fluxo lida no shard atual. |
|
next_shard_iterator/@parmname |
string |
Iterador do shard usado na próxima solicitação GetStreamRecord para continuar a leitura do shard atual. |
|
consumed/@parmname |
Quantidade de unidades de capacidade de leitura (CUs) consumidas, arredondada para cima de acordo com a fórmula: CUs de leitura = tamanho total de todas as linhas lidas / 4 KB. Para saber como calcular o tamanho total dos dados em todas as linhas lidas, consulte Storage usage. |
|
|
may_more_record/@parmname |
bool |
Indica se há mais registros disponíveis para leitura no shard. Use este parâmetro para verificar se o cliente precisa enviar novas solicitações de leitura ou processamento. |
Usar Tablestore SDKs
Tablestore SDK for Java: GetStreamRecord