diff options
| author | mpereskokova <mpereskokova@yandex-team.com> | 2023-11-28 11:52:36 +0300 |
|---|---|---|
| committer | mpereskokova <mpereskokova@yandex-team.com> | 2023-11-28 13:03:09 +0300 |
| commit | f9a0d615c4e78fadc0d138af5bcfb5adfc4c0aeb (patch) | |
| tree | 731d26403109fa2b99e07377ef638cfc2e63dee9 | |
| parent | 7badac1554402ad0fc613fcd68c8624af127bb8f (diff) | |
| download | ydb-f9a0d615c4e78fadc0d138af5bcfb5adfc4c0aeb.tar.gz | |
YT-20420: Put is_truncated field in get_query_result
| -rw-r--r-- | yt/yt/client/api/query_tracker_client.cpp | 3 | ||||
| -rw-r--r-- | yt/yt/client/api/query_tracker_client.h | 1 |
2 files changed, 3 insertions, 1 deletions
diff --git a/yt/yt/client/api/query_tracker_client.cpp b/yt/yt/client/api/query_tracker_client.cpp index bf14e1237e..ea77e44726 100644 --- a/yt/yt/client/api/query_tracker_client.cpp +++ b/yt/yt/client/api/query_tracker_client.cpp @@ -52,7 +52,7 @@ void Serialize(const TQuery& query, NYson::IYsonConsumer* consumer) void Serialize(const TQueryResult& queryResult, NYson::IYsonConsumer* consumer) { - static_assert(pfr::tuple_size<TQueryResult>::value == 5); + static_assert(pfr::tuple_size<TQueryResult>::value == 6); BuildYsonFluently(consumer) .BeginMap() .Item("id").Value(queryResult.Id) @@ -62,6 +62,7 @@ void Serialize(const TQueryResult& queryResult, NYson::IYsonConsumer* consumer) .Item("error").Value(queryResult.Error); }) .OptionalItem("schema", queryResult.Schema) + .Item("is_truncated").Value(queryResult.IsTruncated) .Item("data_statistics").Value(queryResult.DataStatistics) .EndMap(); } diff --git a/yt/yt/client/api/query_tracker_client.h b/yt/yt/client/api/query_tracker_client.h index 07d0e53f0f..1850c30711 100644 --- a/yt/yt/client/api/query_tracker_client.h +++ b/yt/yt/client/api/query_tracker_client.h @@ -118,6 +118,7 @@ struct TQueryResult TError Error; NTableClient::TTableSchemaPtr Schema; NChunkClient::NProto::TDataStatistics DataStatistics; + bool IsTruncated; }; void Serialize(const TQueryResult& queryResult, NYson::IYsonConsumer* consumer); |