From 6233023d3716a221d8710e0d5a259d5c81eb3aee Mon Sep 17 00:00:00 2001 From: wshwsh12 <793703860@qq.com> Date: Thu, 25 Sep 2025 14:55:22 +0800 Subject: [PATCH] support return version --- dbms/src/Storages/Tantivy/TantivyInputStream.h | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/dbms/src/Storages/Tantivy/TantivyInputStream.h b/dbms/src/Storages/Tantivy/TantivyInputStream.h index 97f94cf7fca..4f365a3dfe8 100644 --- a/dbms/src/Storages/Tantivy/TantivyInputStream.h +++ b/dbms/src/Storages/Tantivy/TantivyInputStream.h @@ -50,6 +50,8 @@ class TantivyInputStream : public IProfilingBlockInputStream { static constexpr auto NAME = "TantivyInputStream"; + static constexpr auto version_column_name = "column_-1024"; + public: TantivyInputStream( LoggerPtr log_, @@ -142,6 +144,15 @@ class TantivyInputStream : public IProfilingBlockInputStream } if (idx == -1) { + if (name_and_type.name == version_column_name) + { + auto col = res.getByName(name_and_type.name).column->assumeMutable(); + for (auto & doc : documents) + { + col->insert(Field(doc.version)); + } + continue; + } for (size_t j = 0; j < documents.size(); j++) { // Insert default value for missing fields