diff options
| author | pavelvelikhov <pavelvelikhov@yandex-team.com> | 2023-10-16 14:02:52 +0300 |
|---|---|---|
| committer | pavelvelikhov <pavelvelikhov@yandex-team.com> | 2023-10-16 14:33:57 +0300 |
| commit | d76cb10c07a81f39ba344f96533a49f22cea79d9 (patch) | |
| tree | 94ae28ddd69bb5ac2c4f9be27a3e5c1847ab2814 | |
| parent | 98d6cc064d609c73b9ecd820ff7b21f5200baa85 (diff) | |
| download | ydb-d76cb10c07a81f39ba344f96533a49f22cea79d9.tar.gz | |
Added row count and table size to query replay
Added row count and table size to query replay
| -rw-r--r-- | ydb/core/kqp/provider/yql_kikimr_gateway.h | 5 | ||||
| -rw-r--r-- | ydb/core/protos/kqp.proto | 2 |
2 files changed, 7 insertions, 0 deletions
diff --git a/ydb/core/kqp/provider/yql_kikimr_gateway.h b/ydb/core/kqp/provider/yql_kikimr_gateway.h index 25a17a4b2d..e6707c99f4 100644 --- a/ydb/core/kqp/provider/yql_kikimr_gateway.h +++ b/ydb/core/kqp/provider/yql_kikimr_gateway.h @@ -427,7 +427,10 @@ struct TKikimrTableMetadata : public TThrRefBase { , SysView(message->GetSysView()) , SchemaVersion(message->GetSchemaVersion()) , Kind(static_cast<EKikimrTableKind>(message->GetKind())) + , RecordsCount(message->GetRecordsCount()) + , DataSize(message->GetDataSize()) , KeyColumnNames(message->GetKeyColunmNames().begin(), message->GetKeyColunmNames().end()) + { for(auto& attr: message->GetAttributes()) { Attributes.emplace(attr.GetKey(), attr.GetValue()); @@ -491,6 +494,8 @@ struct TKikimrTableMetadata : public TThrRefBase { PathId.ToMessage(message->MutablePathId()); message->SetSchemaVersion(SchemaVersion); message->SetKind(static_cast<ui32>(Kind)); + message->SetRecordsCount(RecordsCount); + message->SetDataSize(DataSize); for(auto& [key, value] : Attributes) { message->AddAttributes()->SetKey(key); message->AddAttributes()->SetValue(value); diff --git a/ydb/core/protos/kqp.proto b/ydb/core/protos/kqp.proto index 222068c7bd..97da279a9e 100644 --- a/ydb/core/protos/kqp.proto +++ b/ydb/core/protos/kqp.proto @@ -163,6 +163,8 @@ message TKqpTableMetadataProto { repeated string KeyColunmNames = 10; repeated TIndexDescriptionProto Indexes = 11; repeated TKqpTableMetadataProto SecondaryGlobalIndexMetadata = 12; + optional uint64 RecordsCount = 13; + optional uint64 DataSize = 14; } message TRlPath { |