YQ Connector: move tests from yql to ydb (OSS)

Перенос папки с тестами на Коннектор из папки yql в папку ydb (синхронизируется с github).

1 files changed, 42 insertions, 0 deletions

diff --git a/contrib/clickhouse/src/Processors/Merges/Algorithms/IMergingAlgorithmWithDelayedChunk.cpp b/contrib/clickhouse/src/Processors/Merges/Algorithms/IMergingAlgorithmWithDelayedChunk.cpp
new file mode 100644
index 00000000000..68170924840
--- /dev/null
+++ b/contrib/clickhouse/src/Processors/Merges/Algorithms/IMergingAlgorithmWithDelayedChunk.cpp
@@ -0,0 +1,42 @@
+#include <Processors/Merges/Algorithms/IMergingAlgorithmWithDelayedChunk.h>
+
+
+namespace DB
+{
+
+IMergingAlgorithmWithDelayedChunk::IMergingAlgorithmWithDelayedChunk(Block header_, size_t num_inputs, SortDescription description_)
+    : description(std::move(description_)), header(std::move(header_)), current_inputs(num_inputs), cursors(num_inputs)
+{
+}
+
+void IMergingAlgorithmWithDelayedChunk::initializeQueue(Inputs inputs)
+{
+    current_inputs = std::move(inputs);
+
+    for (size_t source_num = 0; source_num < current_inputs.size(); ++source_num)
+    {
+        if (!current_inputs[source_num].chunk)
+            continue;
+
+        cursors[source_num] = SortCursorImpl(
+            header, current_inputs[source_num].chunk.getColumns(), description, source_num, current_inputs[source_num].permutation);
+    }
+
+    queue = SortingQueue<SortCursor>(cursors);
+}
+
+void IMergingAlgorithmWithDelayedChunk::updateCursor(Input & input, size_t source_num)
+{
+    auto & current_input = current_inputs[source_num];
+
+    /// Extend lifetime of last chunk.
+    last_chunk.swap(current_input.chunk);
+    last_chunk_sort_columns = std::move(cursors[source_num].sort_columns);
+
+    current_input.swap(input);
+    cursors[source_num].reset(current_input.chunk.getColumns(), header, current_input.permutation);
+
+    queue.push(cursors[source_num]);
+}
+
+}