File tree Expand file tree Collapse file tree 1 file changed +2
-24
lines changed
ydb/core/sys_view/resource_pool_classifiers Expand file tree Collapse file tree 1 file changed +2
-24
lines changed Original file line number Diff line number Diff line change @@ -39,17 +39,7 @@ class TResourcePoolClassifiersScan : public TScanActorBase<TResourcePoolClassifi
39
39
, UserToken(std::move(userToken))
40
40
, Database(database)
41
41
, Reverse(reverse)
42
- {
43
- const auto & cellsFrom = TableRange.From .GetCells ();
44
- if (cellsFrom.size () == 1 && !cellsFrom[0 ].IsNull ()) {
45
- From = TString{cellsFrom[0 ].Data (), cellsFrom[0 ].Size ()};
46
- }
47
-
48
- const auto & cellsTo = TableRange.To .GetCells ();
49
- if (cellsTo.size () == 1 && !cellsTo[0 ].IsNull ()) {
50
- To = TString{cellsTo[0 ].Data (), cellsTo[0 ].Size ()};
51
- }
52
- }
42
+ {}
53
43
54
44
STFUNC (StateScan) {
55
45
try {
@@ -138,7 +128,7 @@ class TResourcePoolClassifiersScan : public TScanActorBase<TResourcePoolClassifi
138
128
batch->Finished = true ;
139
129
// It's a mandatory condition to keep sorted PK here
140
130
for (const auto & [name, config] : std::map (resourcePoolsIt->second .begin (), resourcePoolsIt->second .end ())) {
141
- if (!IsInRange ( name)) {
131
+ if (!StringKeyIsInTableRange ({ name} )) {
142
132
continue ;
143
133
}
144
134
TVector<TCell> cells;
@@ -160,19 +150,7 @@ class TResourcePoolClassifiersScan : public TScanActorBase<TResourcePoolClassifi
160
150
SendBatch (std::move (batch));
161
151
}
162
152
163
- bool IsInRange (const TString& name) const {
164
- if ((From && name < From) || (!TableRange.FromInclusive && From && name == From)) {
165
- return false ;
166
- }
167
- if ((To && To < name) || (!TableRange.ToInclusive && To && name == To)) {
168
- return false ;
169
- }
170
- return true ;
171
- }
172
-
173
153
private:
174
- TMaybe<TString> From;
175
- TMaybe<TString> To;
176
154
const TIntrusiveConstPtr<NACLib::TUserToken> UserToken;
177
155
TString Database;
178
156
const bool Reverse;
You can’t perform that action at this time.
0 commit comments