summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorchertus <[email protected]>2023-05-12 16:18:22 +0300
committerchertus <[email protected]>2023-05-12 16:18:22 +0300
commit0ab536455399f2da26b3e92917c0eda5436f0ae8 (patch)
tree0043b68a210207587d7e5c7c900e13cf0c195ac5
parent7b7eb6cedda7fc5a4d6d580909053ecf84ae4c67 (diff)
minor refactoring
-rw-r--r--ydb/core/tx/columnshard/engines/predicate/filter.cpp6
-rw-r--r--ydb/core/tx/columnshard/engines/predicate/filter.h2
2 files changed, 4 insertions, 4 deletions
diff --git a/ydb/core/tx/columnshard/engines/predicate/filter.cpp b/ydb/core/tx/columnshard/engines/predicate/filter.cpp
index 4efd14a7996..89bcdb2bb3f 100644
--- a/ydb/core/tx/columnshard/engines/predicate/filter.cpp
+++ b/ydb/core/tx/columnshard/engines/predicate/filter.cpp
@@ -23,7 +23,7 @@ bool TPKRangesFilter::Add(std::shared_ptr<NOlap::TPredicate> f, std::shared_ptr<
if (!fromContainer || !toContainer) {
return false;
}
- if (SortedRanges.size() && NotFakeRanges) {
+ if (SortedRanges.size() && !FakeRanges) {
if (ReverseFlag) {
if (fromContainer->CrossRanges(SortedRanges.front().GetPredicateTo())) {
AFL_ERROR(NKikimrServices::TX_COLUMNSHARD_SCAN)("event", "add_range_filter")("problem", "not sorted sequence");
@@ -40,8 +40,8 @@ bool TPKRangesFilter::Add(std::shared_ptr<NOlap::TPredicate> f, std::shared_ptr<
if (!pkRangeFilter) {
return false;
}
- if (!NotFakeRanges) {
- NotFakeRanges = true;
+ if (FakeRanges) {
+ FakeRanges = false;
SortedRanges.clear();
}
if (ReverseFlag) {
diff --git a/ydb/core/tx/columnshard/engines/predicate/filter.h b/ydb/core/tx/columnshard/engines/predicate/filter.h
index 399c32c7af2..1cfac10f675 100644
--- a/ydb/core/tx/columnshard/engines/predicate/filter.h
+++ b/ydb/core/tx/columnshard/engines/predicate/filter.h
@@ -6,7 +6,7 @@ namespace NKikimr::NOlap {
class TPKRangesFilter {
private:
- bool NotFakeRanges = false;
+ bool FakeRanges = true;
std::deque<TPKRangeFilter> SortedRanges;
bool ReverseFlag = false;
public: