Skip to content

Commit c1bd94c

Browse files
Added metadata flag to track if stats for optimizer were loaded (#7188)
1 parent 9908fdd commit c1bd94c

File tree

3 files changed

+5
-0
lines changed

3 files changed

+5
-0
lines changed

ydb/core/kqp/gateway/kqp_metadata_loader.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -891,6 +891,7 @@ NThreading::TFuture<TTableMetadataResult> TKqpTableMetadataLoader::LoadTableMeta
891891
auto s = std::get<NKikimr::NStat::TStatSimple>(resp.Statistics);
892892
result.Metadata->RecordsCount = s.RowCount;
893893
result.Metadata->DataSize = s.BytesSize;
894+
result.Metadata->StatsLoaded = true;
894895
}
895896
promise.SetValue(result);
896897
});

ydb/core/kqp/provider/yql_kikimr_gateway.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -416,6 +416,7 @@ struct TKikimrTableMetadata : public TThrRefBase {
416416
ui64 DataSize = 0;
417417
ui64 MemorySize = 0;
418418
ui32 ShardsCount = 0;
419+
bool StatsLoaded = false;
419420

420421
TInstant LastAccessTime;
421422
TInstant LastUpdateTime;
@@ -452,6 +453,7 @@ struct TKikimrTableMetadata : public TThrRefBase {
452453
, Kind(static_cast<EKikimrTableKind>(message->GetKind()))
453454
, RecordsCount(message->GetRecordsCount())
454455
, DataSize(message->GetDataSize())
456+
, StatsLoaded(message->GetStatsLoaded())
455457
, KeyColumnNames(message->GetKeyColunmNames().begin(), message->GetKeyColunmNames().end())
456458

457459
{
@@ -519,6 +521,7 @@ struct TKikimrTableMetadata : public TThrRefBase {
519521
message->SetKind(static_cast<ui32>(Kind));
520522
message->SetRecordsCount(RecordsCount);
521523
message->SetDataSize(DataSize);
524+
message->SetStatsLoaded(StatsLoaded);
522525
for(auto& [key, value] : Attributes) {
523526
message->AddAttributes()->SetKey(key);
524527
message->AddAttributes()->SetValue(value);

ydb/core/protos/kqp.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,7 @@ message TKqpTableMetadataProto {
169169
repeated TKqpTableMetadataProto SecondaryGlobalIndexMetadata = 12;
170170
optional uint64 RecordsCount = 13;
171171
optional uint64 DataSize = 14;
172+
optional bool StatsLoaded = 15;
172173
}
173174

174175
message TRlPath {

0 commit comments

Comments
 (0)