diff options
author | chertus <[email protected]> | 2023-05-12 16:18:22 +0300 |
---|---|---|
committer | chertus <[email protected]> | 2023-05-12 16:18:22 +0300 |
commit | 0ab536455399f2da26b3e92917c0eda5436f0ae8 (patch) | |
tree | 0043b68a210207587d7e5c7c900e13cf0c195ac5 | |
parent | 7b7eb6cedda7fc5a4d6d580909053ecf84ae4c67 (diff) |
minor refactoring
-rw-r--r-- | ydb/core/tx/columnshard/engines/predicate/filter.cpp | 6 | ||||
-rw-r--r-- | ydb/core/tx/columnshard/engines/predicate/filter.h | 2 |
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: |