diff options
author | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-02-01 13:04:03 +0300 |
---|---|---|
committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-02-01 13:04:03 +0300 |
commit | e586e630d0fa60533135bae70fce3613feab9a85 (patch) | |
tree | 08957cd3ed3883b85532fad940b39f92b2ce2d14 | |
parent | 0a953ae6cfcc600db9eefde4b859a29b3e8dac1a (diff) | |
download | ydb-e586e630d0fa60533135bae70fce3613feab9a85.tar.gz |
correction
-rw-r--r-- | ydb/core/tx/columnshard/engines/indexed_read_data.cpp | 13 |
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); |