diff options
author | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-06-22 12:04:52 +0300 |
---|---|---|
committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-06-22 12:04:52 +0300 |
commit | d7d69ab087c2d0a9b644b74dcfa3fa69c0ef215b (patch) | |
tree | 27ffd690f098b9ed3dc180e10c55cfaa1d513a97 | |
parent | 3e8f055bf0be40220e5bec2a8380b9889d57f3ec (diff) | |
download | ydb-d7d69ab087c2d0a9b644b74dcfa3fa69c0ef215b.tar.gz |
special non-sorting mode reading
-rw-r--r-- | ydb/core/tx/columnshard/engines/reader/read_metadata.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/tx/columnshard/engines/reader/read_metadata.cpp b/ydb/core/tx/columnshard/engines/reader/read_metadata.cpp index 994e5056d3..1870d35285 100644 --- a/ydb/core/tx/columnshard/engines/reader/read_metadata.cpp +++ b/ydb/core/tx/columnshard/engines/reader/read_metadata.cpp @@ -1,6 +1,7 @@ #include "read_metadata.h" #include "order_control/default.h" #include "order_control/pk_with_limit.h" +#include "order_control/not_sorted.h" #include <ydb/core/tx/columnshard/hooks/abstract/abstract.h> #include <ydb/core/tx/columnshard/columnshard__index_scan.h> #include <ydb/core/tx/columnshard/columnshard__stats_scan.h> @@ -219,8 +220,10 @@ NIndexedReader::IOrderPolicy::TPtr TReadMetadata::DoBuildSortingPolicy() const { return std::make_shared<NIndexedReader::TAnySorting>(this->shared_from_this()); } return std::make_shared<NIndexedReader::TPKSortingWithLimit>(this->shared_from_this()); - } else { + } else if (IsSorted()) { return std::make_shared<NIndexedReader::TAnySorting>(this->shared_from_this()); + } else { + return std::make_shared<NIndexedReader::TNonSorting>(this->shared_from_this()); } } |