Interroge les données incrémentielles d'un shard.
Syntaxe de la requête
message GetStreamRecordRequest {
required string shard_iterator = 1;
optional int32 limit = 2;
optional string table_name = 3;
}|
Paramètre |
Type |
Obligatoire |
Description |
|
shard_iterator/@parmname |
string |
Oui |
L'itérateur de shard utilisé pour lire les données incrémentielles du shard. |
|
limit/@parmname |
int32 |
Non |
Le nombre maximal d'enregistrements à renvoyer. |
|
table_name/@parmname |
string |
Non |
Le nom de la table de données. |
Syntaxe de la réponse
message GetStreamRecordResponse {
repeated StreamRecord stream_records = 1;
optional raw_string next_shard_iterator = 2;
optional ConsumedCapacity consumed = 3;
optional bool may_more_record = 4;
}|
Paramètre |
Type |
Description |
|
StreamRecord/@parmname |
repeated StreamRecord |
Une entrée d'enregistrement de flux lue à partir du shard actuel. |
|
next_shard_iterator/@parmname |
string |
L'itérateur de shard à utiliser dans la prochaine requête GetStreamRecord pour poursuivre la lecture à partir du shard actuel. |
|
consumed/@parmname |
Le nombre d'unités de capacité de lecture (CU) consommées, arrondi vers le haut selon la formule : CU de lecture = taille totale de toutes les lignes lues / 4 Ko. Pour plus d'informations sur le calcul de la taille totale des données dans toutes les lignes réellement lues, consultez Utilisation du stockage. |
|
|
may_more_record/@parmname |
bool |
Indique si d'autres enregistrements sont disponibles à la lecture depuis le shard. Utilisez ce paramètre pour déterminer si le client doit effectuer d'autres requêtes de lecture ou de traitement. |
Utiliser les SDK Tablestore
SDK Tablestore pour Java : GetStreamRecord