aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.com>2023-06-22 12:04:52 +0300
committerivanmorozov <ivanmorozov@yandex-team.com>2023-06-22 12:04:52 +0300
commitd7d69ab087c2d0a9b644b74dcfa3fa69c0ef215b (patch)
tree27ffd690f098b9ed3dc180e10c55cfaa1d513a97
parent3e8f055bf0be40220e5bec2a8380b9889d57f3ec (diff)
downloadydb-d7d69ab087c2d0a9b644b74dcfa3fa69c0ef215b.tar.gz
special non-sorting mode reading
-rw-r--r--ydb/core/tx/columnshard/engines/reader/read_metadata.cpp5
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());
}
}