Consulta os dados incrementais de um shard.
Sintaxe da 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 de shard usado para ler 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 da 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 stream lida no shard atual. |
|
next_shard_iterator/@parmname |
string |
Iterador de shard a ser usado na próxima solicitação GetStreamRecord para continuar a leitura no shard atual. |
|
consumed/@parmname |
Número de unidades de capacidade de leitura (CUs) consumidas, arredondado para cima conforme a fórmula: CUs de leitura = tamanho total de todas as linhas lidas / 4 KB. Para mais informações sobre como calcular o tamanho total dos dados nas linhas efetivamente lidas, consulte Uso de armazenamento. |
|
|
may_more_record/@parmname |
bool |
Indica se há mais registros disponíveis para leitura no shard. Use este parâmetro para determinar se o cliente precisa fazer novas solicitações de leitura ou processamento. |
Usar SDKs do Tablestore
Tablestore SDK for Java: GetStreamRecord