This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 970efdc1cb [Feature](Nereids) support advanced materialized view
(#19650)
add 9f8de89659 [refactor](exec) replace the single pointer with an array
of 'conjuncts' in ExecNode (#19758)
No new revisions were added by this update.
Summary of changes:
be/src/exec/data_sink.cpp | 6 +-
be/src/exec/exec_node.cpp | 27 ++-
be/src/exec/exec_node.h | 9 +-
be/src/exec/scan_node.cpp | 24 ---
be/src/exec/scan_node.h | 4 -
be/src/exec/table_connector.cpp | 18 +-
be/src/exec/table_connector.h | 11 +-
be/src/exec/tablet_info.cpp | 4 +-
be/src/exec/tablet_info.h | 7 +-
be/src/exprs/runtime_filter.cpp | 113 +++++-----
be/src/exprs/runtime_filter.h | 10 +-
be/src/exprs/runtime_filter_slots.h | 8 +-
be/src/exprs/runtime_filter_slots_cross.h | 6 +-
be/src/olap/iterators.h | 3 +-
be/src/olap/push_handler.cpp | 30 ++-
be/src/olap/push_handler.h | 10 +-
be/src/olap/reader.cpp | 6 +-
be/src/olap/reader.h | 5 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 4 +-
be/src/olap/rowset/rowset_reader_context.h | 6 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 111 ++++------
be/src/olap/rowset/segment_v2/segment_iterator.h | 11 +-
be/src/olap/schema_change.cpp | 11 +-
be/src/runtime/fold_constant_executor.cpp | 6 +-
be/src/service/point_query_executor.cpp | 5 +-
be/src/service/point_query_executor.h | 9 +-
be/src/vec/common/sort/vsort_exec_exprs.cpp | 15 +-
be/src/vec/common/sort/vsort_exec_exprs.h | 22 +-
be/src/vec/core/sort_cursor.h | 4 +-
be/src/vec/exec/format/generic_reader.h | 2 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 53 +++--
be/src/vec/exec/format/orc/vorc_reader.h | 12 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 63 +++---
.../exec/format/parquet/vparquet_group_reader.h | 29 ++-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 34 +--
be/src/vec/exec/format/parquet/vparquet_reader.h | 12 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 14 +-
be/src/vec/exec/format/table/iceberg_reader.h | 8 +-
.../vec/exec/join/process_hash_table_probe_impl.h | 17 +-
be/src/vec/exec/join/vhash_join_node.cpp | 40 ++--
be/src/vec/exec/join/vhash_join_node.h | 10 +-
be/src/vec/exec/join/vjoin_node_base.cpp | 11 +-
be/src/vec/exec/join/vjoin_node_base.h | 6 +-
be/src/vec/exec/join/vnested_loop_join_node.cpp | 99 +++------
be/src/vec/exec/join/vnested_loop_join_node.h | 4 +-
be/src/vec/exec/scan/new_es_scan_node.cpp | 2 +-
be/src/vec/exec/scan/new_es_scanner.cpp | 4 +-
be/src/vec/exec/scan/new_es_scanner.h | 2 +-
be/src/vec/exec/scan/new_file_scan_node.cpp | 4 +-
be/src/vec/exec/scan/new_jdbc_scan_node.cpp | 2 +-
be/src/vec/exec/scan/new_jdbc_scanner.cpp | 7 +-
be/src/vec/exec/scan/new_jdbc_scanner.h | 2 +-
be/src/vec/exec/scan/new_odbc_scan_node.cpp | 2 +-
be/src/vec/exec/scan/new_odbc_scanner.cpp | 7 +-
be/src/vec/exec/scan/new_odbc_scanner.h | 2 +-
be/src/vec/exec/scan/new_olap_scan_node.cpp | 14 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 34 +--
be/src/vec/exec/scan/vfile_scanner.cpp | 128 ++++++-----
be/src/vec/exec/scan/vfile_scanner.h | 18 +-
be/src/vec/exec/scan/vmeta_scan_node.cpp | 2 +-
be/src/vec/exec/scan/vmeta_scanner.cpp | 4 +-
be/src/vec/exec/scan/vmeta_scanner.h | 2 +-
be/src/vec/exec/scan/vscan_node.cpp | 236 +++++++++------------
be/src/vec/exec/scan/vscan_node.h | 28 +--
be/src/vec/exec/scan/vscanner.cpp | 31 +--
be/src/vec/exec/scan/vscanner.h | 23 +-
be/src/vec/exec/vaggregation_node.cpp | 17 +-
be/src/vec/exec/vaggregation_node.h | 6 +-
be/src/vec/exec/vanalytic_eval_node.cpp | 22 +-
be/src/vec/exec/vanalytic_eval_node.h | 14 +-
be/src/vec/exec/vdata_gen_scan_node.cpp | 2 +-
be/src/vec/exec/vjdbc_connector.cpp | 3 +-
be/src/vec/exec/vjdbc_connector.h | 3 +-
be/src/vec/exec/vpartition_sort_node.cpp | 4 +-
be/src/vec/exec/vpartition_sort_node.h | 2 +-
be/src/vec/exec/vrepeat_node.cpp | 4 +-
be/src/vec/exec/vrepeat_node.h | 4 +-
be/src/vec/exec/vschema_scan_node.cpp | 2 +-
be/src/vec/exec/vselect_node.cpp | 3 +-
be/src/vec/exec/vset_operation_node.cpp | 9 +-
be/src/vec/exec/vset_operation_node.h | 2 +-
be/src/vec/exec/vtable_function_node.cpp | 11 +-
be/src/vec/exec/vtable_function_node.h | 2 +-
be/src/vec/exec/vunion_node.cpp | 18 +-
be/src/vec/exec/vunion_node.h | 8 +-
be/src/vec/exprs/lambda_function/lambda_function.h | 2 +-
.../lambda_function/varray_filter_function.cpp | 2 +-
.../exprs/lambda_function/varray_map_function.cpp | 2 +-
be/src/vec/exprs/table_function/table_function.h | 4 +-
be/src/vec/exprs/table_function/vexplode.cpp | 8 +-
.../vec/exprs/table_function/vexplode_bitmap.cpp | 8 +-
.../exprs/table_function/vexplode_json_array.cpp | 8 +-
.../vec/exprs/table_function/vexplode_numbers.cpp | 8 +-
be/src/vec/exprs/table_function/vexplode_split.cpp | 12 +-
be/src/vec/exprs/varray_literal.cpp | 4 +-
be/src/vec/exprs/vbitmap_predicate.h | 4 +-
be/src/vec/exprs/vbloom_predicate.h | 4 +-
be/src/vec/exprs/vcase_expr.cpp | 2 +-
be/src/vec/exprs/vcase_expr.h | 5 +-
be/src/vec/exprs/vcast_expr.cpp | 2 +-
be/src/vec/exprs/vcast_expr.h | 4 +-
be/src/vec/exprs/vcolumn_ref.h | 4 +-
be/src/vec/exprs/vcompound_pred.h | 10 +-
be/src/vec/exprs/vdirect_in_predicate.h | 4 +-
be/src/vec/exprs/vectorized_agg_fn.cpp | 6 +-
be/src/vec/exprs/vectorized_agg_fn.h | 6 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 2 +-
be/src/vec/exprs/vectorized_fn_call.h | 4 +-
be/src/vec/exprs/vexpr.cpp | 140 ++++++------
be/src/vec/exprs/vexpr.h | 49 ++---
be/src/vec/exprs/vexpr_context.cpp | 86 ++++++--
be/src/vec/exprs/vexpr_context.h | 69 +++++-
.../vexpr_fwd.h} | 16 +-
be/src/vec/exprs/vin_predicate.h | 4 +-
be/src/vec/exprs/vinfo_func.h | 4 +-
be/src/vec/exprs/vlambda_function_call_expr.h | 6 +-
be/src/vec/exprs/vlambda_function_expr.h | 4 +-
be/src/vec/exprs/vliteral.h | 4 +-
be/src/vec/exprs/vmap_literal.cpp | 6 +-
be/src/vec/exprs/vmap_literal.h | 1 -
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 2 +-
be/src/vec/exprs/vruntimefilter_wrapper.h | 12 +-
be/src/vec/exprs/vschema_change_expr.h | 5 +-
be/src/vec/exprs/vslot_ref.h | 4 +-
be/src/vec/exprs/vstruct_literal.cpp | 4 +-
be/src/vec/exprs/vtuple_is_null_predicate.h | 4 +-
be/src/vec/olap/vcollect_iterator.cpp | 11 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 2 +-
be/src/vec/runtime/vdata_stream_recvr.h | 4 +-
be/src/vec/runtime/vfile_result_writer.cpp | 13 +-
be/src/vec/runtime/vfile_result_writer.h | 7 +-
be/src/vec/runtime/vorc_writer.cpp | 2 +-
be/src/vec/runtime/vorc_writer.h | 4 +-
be/src/vec/runtime/vparquet_writer.cpp | 2 +-
be/src/vec/runtime/vparquet_writer.h | 10 +-
be/src/vec/runtime/vsorted_run_merger.cpp | 2 +-
be/src/vec/runtime/vsorted_run_merger.h | 11 +-
be/src/vec/sink/vdata_stream_sender.cpp | 4 +-
be/src/vec/sink/vdata_stream_sender.h | 2 +-
be/src/vec/sink/vmemory_scratch_sink.cpp | 7 +-
be/src/vec/sink/vmemory_scratch_sink.h | 9 +-
be/src/vec/sink/vmysql_result_writer.cpp | 6 +-
be/src/vec/sink/vmysql_result_writer.h | 7 +-
be/src/vec/sink/vmysql_table_writer.cpp | 2 +-
be/src/vec/sink/vmysql_table_writer.h | 6 +-
be/src/vec/sink/vresult_file_sink.cpp | 3 +-
be/src/vec/sink/vresult_file_sink.h | 2 +-
be/src/vec/sink/vresult_sink.cpp | 5 +-
be/src/vec/sink/vresult_sink.h | 4 +-
be/src/vec/sink/vtable_sink.cpp | 2 +-
be/src/vec/sink/vtable_sink.h | 4 +-
be/src/vec/sink/vtablet_sink.cpp | 2 +-
be/src/vec/sink/vtablet_sink.h | 14 +-
be/src/vec/utils/util.hpp | 29 ---
be/test/exprs/mock_vexpr.h | 2 +-
.../serde/data_type_serde_mysql_test.cpp | 6 +-
be/test/vec/exec/parquet/parquet_reader_test.cpp | 4 +-
be/test/vec/exprs/vexpr_test.cpp | 8 +-
be/test/vec/function/table_function_test.cpp | 22 +-
.../apache/doris/analysis/CompoundPredicate.java | 2 +-
.../main/java/org/apache/doris/analysis/Expr.java | 2 +-
.../doris/load/loadv2/LoadingTaskPlanner.java | 1 -
.../glue/translator/PhysicalPlanTranslator.java | 1 -
.../org/apache/doris/planner/FileLoadScanNode.java | 6 +-
.../org/apache/doris/planner/HashJoinNode.java | 23 +-
.../org/apache/doris/planner/JoinNodeBase.java | 4 -
.../apache/doris/planner/NestedLoopJoinNode.java | 20 +-
.../org/apache/doris/planner/OlapScanNode.java | 12 +-
.../org/apache/doris/planner/OriginalPlanner.java | 5 -
.../java/org/apache/doris/planner/PlanNode.java | 41 +---
.../apache/doris/planner/SingleNodePlanner.java | 14 +-
.../apache/doris/planner/StreamLoadPlanner.java | 1 -
gensrc/thrift/PlanNodes.thrift | 3 +
.../suites/query_p0/join/test_join.groovy | 7 +-
174 files changed, 1160 insertions(+), 1344 deletions(-)
copy be/src/vec/{core/columns_with_type_and_name.h => exprs/vexpr_fwd.h} (75%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
