aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.com>2023-02-01 13:04:03 +0300
committerivanmorozov <ivanmorozov@yandex-team.com>2023-02-01 13:04:03 +0300
commite586e630d0fa60533135bae70fce3613feab9a85 (patch)
tree08957cd3ed3883b85532fad940b39f92b2ce2d14
parent0a953ae6cfcc600db9eefde4b859a29b3e8dac1a (diff)
downloadydb-e586e630d0fa60533135bae70fce3613feab9a85.tar.gz
correction
-rw-r--r--ydb/core/tx/columnshard/engines/indexed_read_data.cpp13
1 files changed, 7 insertions, 6 deletions
diff --git a/ydb/core/tx/columnshard/engines/indexed_read_data.cpp b/ydb/core/tx/columnshard/engines/indexed_read_data.cpp
index 323bd54bb4..fc9723a506 100644
--- a/ydb/core/tx/columnshard/engines/indexed_read_data.cpp
+++ b/ydb/core/tx/columnshard/engines/indexed_read_data.cpp
@@ -49,13 +49,14 @@ std::vector<std::shared_ptr<arrow::RecordBatch>> SpecialMergeSorted(const std::v
#if 1 // Optimization [remove portion's dups]
if (batches.size() == 1) {
- if (NArrow::IsSortedAndUnique(batches[0], description->ReplaceKey)) {
+ Y_UNUSED(size);
+// if (NArrow::IsSortedAndUnique(batches[0], description->ReplaceKey)) {
std::vector<std::shared_ptr<arrow::RecordBatch>> out;
SliceBatch(batches[0], maxRowsInBatch, out);
return out;
- } else {
- return NArrow::MergeSortedBatches(batches, description, size);
- }
+// } else {
+// return NArrow::MergeSortedBatches(batches, description, size);
+// }
}
#endif
@@ -104,11 +105,11 @@ std::vector<std::shared_ptr<arrow::RecordBatch>> SpecialMergeSorted(const std::v
// The core of optimization: do not merge slice if it's alone in its key range
if (slices.size() == 1) {
- if (NArrow::IsSortedAndUnique(slices[0], description->ReplaceKey)) {
+// if (NArrow::IsSortedAndUnique(slices[0], description->ReplaceKey)) {
// Split big batch into smaller batches if needed
SliceBatch(slices[0], maxRowsInBatch, out);
continue;
- }
+// }
}
auto merged = NArrow::MergeSortedBatches(slices, description, maxRowsInBatch);