This is an automated email from the ASF dual-hosted git repository.
eldenmoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new a2d198ea7b7 [Fix](Variant) implement some interface in ColumnNothing
(#40607)
a2d198ea7b7 is described below
commit a2d198ea7b709764c90c4df0cecf17c21371d10f
Author: lihangyu <15605149...@163.com>
AuthorDate: Wed Sep 18 14:33:15 2024 +0800
[Fix](Variant) implement some interface in ColumnNothing (#40607)
IColumnDummy implementation is not suitable for ColumnNothing in
ColumnObject
---
be/src/vec/columns/column_nothing.h | 7 +++++++
regression-test/suites/variant_p0/nested.groovy | 2 +-
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/be/src/vec/columns/column_nothing.h
b/be/src/vec/columns/column_nothing.h
index 8a10eec8b6f..79cb779c7d1 100644
--- a/be/src/vec/columns/column_nothing.h
+++ b/be/src/vec/columns/column_nothing.h
@@ -32,6 +32,13 @@ private:
ColumnNothing(const ColumnNothing&) = default;
+ ColumnPtr permute(const Permutation& perm, size_t limit) const override {
+ return clone_dummy(limit ? std::min(s, limit) : s);
+ }
+ Field operator[](size_t) const override { return {}; }
+ void get(size_t, Field& f) const override { f = {}; }
+ void insert(const Field&) override { ++s; }
+
public:
const char* get_family_name() const override { return "Nothing"; }
MutableColumnPtr clone_dummy(size_t s_) const override { return
ColumnNothing::create(s_); }
diff --git a/regression-test/suites/variant_p0/nested.groovy
b/regression-test/suites/variant_p0/nested.groovy
index a2a3355854f..90728df2532 100644
--- a/regression-test/suites/variant_p0/nested.groovy
+++ b/regression-test/suites/variant_p0/nested.groovy
@@ -162,7 +162,7 @@
parallel_pipeline_task_num=7,parallel_fragment_exec_instance_num=4,profile_level
properties("replication_num" = "1", "disable_auto_compaction"
= "false", "enable_unique_key_merge_on_write" = "true",
"variant_enable_flatten_nested" = "true");
"""
sql """insert into var_nested2 select * from var_nested order by k
limit 1024"""
- qt_sql """select * from var_nested2 order by k limit 10;"""
+ qt_sql """select
/*+SET_VAR(batch_size=4064,broker_load_batch_size=16352,disable_streaming_preaggregations=true,enable_distinct_streaming_aggregation=true,parallel_fragment_exec_instance_num=5,parallel_pipeline_task_num=1,profile_level=1,enable_pipeline_engine=false,enable_parallel_scan=true,parallel_scan_max_scanners_count=48,parallel_scan_min_rows_per_scanner=16384,enable_fold_constant_by_be=true,enable_rewrite_element_at_to_slot=true,runtime_filter_type=12,enable_parallel_res
[...]
qt_sql """select v['nested'] from var_nested2 where k < 10 order by k
limit 10;"""
// explode variant array
order_qt_explode_sql """select count(),cast(vv['xx'] as int) from
var_nested lateral view explode_variant_array(v['nested']) tmp as vv where
vv['xx'] = 10 group by cast(vv['xx'] as int)"""
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
