File tree 2 files changed +4
-2
lines changed
ydb/core/tx/columnshard/engines/reader 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -87,7 +87,8 @@ std::shared_ptr<TFetchingScript> TSpecialReadContext::BuildColumnsFetchingPlan(c
87
87
88
88
NCommon::TFetchingScriptBuilder acc (*this );
89
89
if (!!IndexChecker && useIndexes && exclusiveSource) {
90
- acc.AddStep (std::make_shared<TIndexBlobsFetchingStep>(std::make_shared<TIndexesSet>(IndexChecker->GetIndexIds ())));
90
+ acc.AddStep (std::make_shared<TIndexBlobsFetchingStep>(
91
+ std::make_shared<TIndexesSet>(NIndexes::TIndexDataAddress::ExtractIndexIds (IndexChecker->GetIndexIds ()))));
91
92
acc.AddStep (std::make_shared<TApplyIndexStep>(IndexChecker));
92
93
}
93
94
bool hasFilterSharding = false ;
Original file line number Diff line number Diff line change @@ -63,7 +63,8 @@ std::shared_ptr<TFetchingScript> TSpecialReadContext::BuildColumnsFetchingPlan(c
63
63
64
64
NCommon::TFetchingScriptBuilder acc (*this );
65
65
if (!!IndexChecker && useIndexes) {
66
- acc.AddStep (std::make_shared<TIndexBlobsFetchingStep>(std::make_shared<TIndexesSet>(IndexChecker->GetIndexIds ())));
66
+ acc.AddStep (std::make_shared<TIndexBlobsFetchingStep>(
67
+ std::make_shared<TIndexesSet>(NIndexes::TIndexDataAddress::ExtractIndexIds (IndexChecker->GetIndexIds ()))));
67
68
acc.AddStep (std::make_shared<TApplyIndexStep>(IndexChecker));
68
69
}
69
70
if (needFilterSharding && !GetShardingColumns ()->IsEmpty ()) {
You can’t perform that action at this time.
0 commit comments