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 1520a4af6d [refactor](resource) use resource to create external
catalog (#14978)
add e9a201e0ec [refactor](non-vec) delete some non-vec exec node (#15239)
No new revisions were added by this update.
Summary of changes:
be/src/exec/CMakeLists.txt | 41 +-
be/src/exec/analytic_eval_node.cpp | 939 ----------
be/src/exec/analytic_eval_node.h | 334 ----
be/src/exec/assert_num_rows_node.cpp | 116 --
be/src/exec/assert_num_rows_node.h | 43 -
be/src/exec/blocking_join_node.cpp | 210 ---
be/src/exec/blocking_join_node.h | 133 --
be/src/exec/broker_scan_node.cpp | 418 -----
be/src/exec/broker_scan_node.h | 129 --
be/src/exec/broker_scanner.cpp | 520 ------
be/src/exec/broker_scanner.h | 127 --
be/src/exec/cross_join_node.cpp | 197 ---
be/src/exec/cross_join_node.h | 72 -
be/src/exec/csv_scan_node.cpp | 629 -------
be/src/exec/csv_scan_node.h | 131 --
be/src/exec/csv_scanner.cpp | 93 -
be/src/exec/csv_scanner.h | 45 -
be/src/exec/data_sink.cpp | 37 +-
be/src/exec/empty_set_node.cpp | 33 -
be/src/exec/empty_set_node.h | 35 -
be/src/exec/es_http_scan_node.cpp | 484 -----
be/src/exec/es_http_scan_node.h | 118 --
be/src/exec/es_http_scanner.cpp | 115 --
be/src/exec/es_http_scanner.h | 96 -
be/src/exec/except_node.cpp | 114 --
be/src/exec/except_node.h | 43 -
be/src/exec/exchange_node.cpp | 257 ---
be/src/exec/exchange_node.h | 117 --
be/src/exec/exec_node.cpp | 76 +-
be/src/exec/hash_join_node.cpp | 802 ---------
be/src/exec/hash_join_node.h | 182 --
be/src/exec/intersect_node.cpp | 112 --
be/src/exec/intersect_node.h | 44 -
be/src/exec/json_scanner.cpp | 843 ---------
be/src/exec/json_scanner.h | 202 ---
be/src/exec/merge_node.cpp | 260 ---
be/src/exec/merge_node.h | 92 -
be/src/exec/mysql_scan_node.cpp | 263 ---
be/src/exec/mysql_scan_node.h | 94 -
be/src/exec/odbc_scan_node.cpp | 255 ---
be/src/exec/odbc_scan_node.h | 101 --
be/src/exec/olap_scan_node.cpp | 1853 --------------------
be/src/exec/olap_scan_node.h | 350 ----
be/src/exec/olap_scanner.cpp | 675 -------
be/src/exec/olap_scanner.h | 163 --
be/src/exec/orc_scanner.cpp | 431 -----
be/src/exec/orc_scanner.h | 70 -
be/src/exec/parquet_scanner.cpp | 140 --
be/src/exec/parquet_scanner.h | 85 -
be/src/exec/parquet_writer.cpp | 583 ------
be/src/exec/parquet_writer.h | 138 --
be/src/exec/partitioned_aggregation_node.cc | 1654 -----------------
be/src/exec/partitioned_aggregation_node.h | 696 --------
be/src/exec/partitioned_hash_table.cc | 593 -------
be/src/exec/partitioned_hash_table.h | 956 ----------
be/src/exec/partitioned_hash_table.inline.h | 406 -----
be/src/exec/repeat_node.cpp | 217 ---
be/src/exec/repeat_node.h | 71 -
be/src/exec/schema_scan_node.cpp | 336 ----
be/src/exec/schema_scan_node.h | 90 -
be/src/exec/select_node.cpp | 143 --
be/src/exec/select_node.h | 57 -
be/src/exec/set_operation_node.cpp | 165 --
be/src/exec/set_operation_node.h | 106 --
be/src/exec/sort_exec_exprs.cpp | 79 -
be/src/exec/sort_exec_exprs.h | 91 -
be/src/exec/spill_sort_node.cc | 171 --
be/src/exec/spill_sort_node.h | 75 -
be/src/exec/table_function_node.cpp | 384 ----
be/src/exec/table_function_node.h | 98 --
be/src/exec/topn_node.cpp | 245 ---
be/src/exec/topn_node.h | 113 --
be/src/exec/union_node.cpp | 345 ----
be/src/exec/union_node.h | 159 --
be/src/olap/push_handler.cpp | 8 +-
be/src/runtime/CMakeLists.txt | 8 -
be/src/runtime/data_stream_mgr.cpp | 213 ---
be/src/runtime/data_stream_mgr.h | 137 --
be/src/runtime/data_stream_recvr.cc | 531 ------
be/src/runtime/data_stream_recvr.h | 202 ---
be/src/runtime/data_stream_sender.cpp | 701 --------
be/src/runtime/data_stream_sender.h | 282 ---
be/src/runtime/exec_env.h | 2 -
be/src/runtime/exec_env_init.cpp | 3 -
be/src/runtime/file_result_writer.cpp | 506 ------
be/src/runtime/file_result_writer.h | 201 ---
be/src/runtime/plan_fragment_executor.cpp | 12 +-
be/src/runtime/result_file_sink.cpp | 203 ---
be/src/runtime/result_file_sink.h | 80 -
be/src/runtime/result_sink.cpp | 132 --
be/src/runtime/result_sink.h | 75 -
be/src/runtime/sorted_run_merger.cc | 341 ----
be/src/runtime/sorted_run_merger.h | 128 --
be/src/runtime/spill_sorter.cc | 1323 --------------
be/src/runtime/spill_sorter.h | 215 ---
be/src/service/backend_service.cpp | 1 -
be/src/service/internal_service.cpp | 49 +-
be/src/util/CMakeLists.txt | 1 -
be/src/util/tuple_row_compare.cpp | 22 -
be/src/util/tuple_row_compare.h | 144 --
be/src/util/tuple_row_zorder_compare.h | 1 -
be/src/{exec => vec/exec/scan}/mysql_scanner.cpp | 4 +-
be/src/{exec => vec/exec/scan}/mysql_scanner.h | 4 +-
be/src/vec/exec/vbroker_scanner.cpp | 359 +++-
be/src/vec/exec/vbroker_scanner.h | 60 +-
be/src/vec/exec/vjson_scanner.cpp | 518 +++++-
be/src/vec/exec/vjson_scanner.h | 95 +-
be/src/vec/exec/vmysql_scan_node.h | 2 +-
be/src/vec/exec/vtable_function_node.cpp | 100 +-
be/src/vec/exec/vtable_function_node.h | 56 +-
be/src/vec/runtime/vfile_result_writer.h | 1 -
be/src/vec/runtime/vparquet_writer.cpp | 170 +-
be/src/vec/runtime/vparquet_writer.h | 41 +-
be/src/vec/runtime/vsorted_run_merger.h | 2 -
be/src/vec/sink/vresult_file_sink.cpp | 1 -
be/src/vec/sink/vresult_file_sink.h | 2 +-
be/src/vec/sink/vresult_sink.cpp | 1 -
be/src/vec/sink/vresult_sink.h | 69 +
be/test/CMakeLists.txt | 56 -
be/test/exec/broker_reader_test.cpp | 79 -
be/test/exec/broker_scan_node_test.cpp | 487 -----
be/test/exec/broker_scanner_test.cpp | 742 --------
be/test/exec/buffered_reader_test.cpp | 182 --
be/test/exec/csv_scan_bench_test.cpp | 325 ----
be/test/exec/csv_scan_node_test.cpp | 408 -----
be/test/exec/csv_scanner_test.cpp | 87 -
be/test/exec/es_http_scan_node_test.cpp | 143 --
be/test/exec/es_predicate_test.cpp | 173 --
be/test/exec/es_query_builder_test.cpp | 624 -------
be/test/exec/es_scan_reader_test.cpp | 247 ---
be/test/exec/hash_table_test.cpp | 380 ----
be/test/exec/hdfs_file_reader_test.cpp | 45 -
be/test/exec/json_scanner_test.cpp | 630 -------
be/test/exec/json_scanner_with_jsonpath_test.cpp | 418 -----
be/test/exec/multi_bytes_separator_test.cpp | 109 --
be/test/exec/mysql_scan_node_test.cpp | 280 ---
be/test/exec/mysql_scanner_test.cpp | 116 --
be/test/exec/new_olap_scan_node_test.cpp | 388 ----
be/test/exec/olap_common_test.cpp | 779 --------
be/test/exec/olap_scan_node_test.cpp | 431 -----
be/test/exec/olap_scanner_test.cpp | 82 -
be/test/exec/orc_scanner_test.cpp | 897 ----------
be/test/exec/parquet_scanner_test.cpp | 557 ------
be/test/exec/plain_text_line_reader_bzip_test.cpp | 232 ---
be/test/exec/plain_text_line_reader_gzip_test.cpp | 268 ---
.../exec/plain_text_line_reader_lz4frame_test.cpp | 232 ---
be/test/exec/plain_text_line_reader_lzop_test.cpp | 290 ---
.../plain_text_line_reader_uncompressed_test.cpp | 293 ----
be/test/exec/s3_reader_test.cpp | 121 --
be/test/exec/schema_scan_node_test.cpp | 230 ---
.../schema_scanner/schema_authors_scanner_test.cpp | 98 --
.../schema_charsets_scanner_test.cpp | 98 --
.../schema_collations_scanner_test.cpp | 98 --
.../schema_scanner/schema_columns_scanner_test.cpp | 204 ---
.../schema_create_table_scanner_test.cpp | 204 ---
.../schema_scanner/schema_engines_scanner_test.cpp | 98 --
.../schema_open_tables_scanner_test.cpp | 204 ---
.../schema_schemata_scanner_test.cpp | 170 --
.../schema_table_names_scanner_test.cpp | 187 --
.../schema_scanner/schema_tables_scanner_test.cpp | 204 ---
.../schema_variables_scanner_test.cpp | 99 --
be/test/exec/schema_scanner_test.cpp | 109 --
be/test/exec/set_executor_test.cpp | 113 --
be/test/exec/tablet_info_test.cpp | 833 ---------
be/test/exec/tablet_sink_test.cpp | 982 -----------
be/test/exec/unix_odbc_test.cpp | 18 -
be/test/runtime/buffered_tuple_stream_test.cpp | 265 ---
be/test/runtime/memory_scratch_sink_test.cpp | 240 ---
be/test/runtime/sorter_test.cpp | 345 ----
be/test/util/arrow/arrow_row_batch_test.cpp | 93 -
be/test/util/arrow/arrow_row_block_test.cpp | 92 -
be/test/util/arrow/arrow_work_flow_test.cpp | 333 ----
be/test/util/tuple_row_zorder_compare_test.cpp | 1 -
be/test/vec/exec/vjson_scanner_test.cpp | 1 -
be/test/vec/exec/vorc_scanner_test.cpp | 1 -
be/test/vec/exec/vtablet_sink_test.cpp | 225 ++-
176 files changed, 1698 insertions(+), 41644 deletions(-)
delete mode 100644 be/src/exec/analytic_eval_node.cpp
delete mode 100644 be/src/exec/analytic_eval_node.h
delete mode 100644 be/src/exec/assert_num_rows_node.cpp
delete mode 100644 be/src/exec/assert_num_rows_node.h
delete mode 100644 be/src/exec/blocking_join_node.cpp
delete mode 100644 be/src/exec/blocking_join_node.h
delete mode 100644 be/src/exec/broker_scan_node.cpp
delete mode 100644 be/src/exec/broker_scan_node.h
delete mode 100644 be/src/exec/broker_scanner.cpp
delete mode 100644 be/src/exec/broker_scanner.h
delete mode 100644 be/src/exec/cross_join_node.cpp
delete mode 100644 be/src/exec/cross_join_node.h
delete mode 100644 be/src/exec/csv_scan_node.cpp
delete mode 100644 be/src/exec/csv_scan_node.h
delete mode 100644 be/src/exec/csv_scanner.cpp
delete mode 100644 be/src/exec/csv_scanner.h
delete mode 100644 be/src/exec/empty_set_node.cpp
delete mode 100644 be/src/exec/empty_set_node.h
delete mode 100644 be/src/exec/es_http_scan_node.cpp
delete mode 100644 be/src/exec/es_http_scan_node.h
delete mode 100644 be/src/exec/es_http_scanner.cpp
delete mode 100644 be/src/exec/es_http_scanner.h
delete mode 100644 be/src/exec/except_node.cpp
delete mode 100644 be/src/exec/except_node.h
delete mode 100644 be/src/exec/exchange_node.cpp
delete mode 100644 be/src/exec/exchange_node.h
delete mode 100644 be/src/exec/hash_join_node.cpp
delete mode 100644 be/src/exec/hash_join_node.h
delete mode 100644 be/src/exec/intersect_node.cpp
delete mode 100644 be/src/exec/intersect_node.h
delete mode 100644 be/src/exec/json_scanner.cpp
delete mode 100644 be/src/exec/json_scanner.h
delete mode 100644 be/src/exec/merge_node.cpp
delete mode 100644 be/src/exec/merge_node.h
delete mode 100644 be/src/exec/mysql_scan_node.cpp
delete mode 100644 be/src/exec/mysql_scan_node.h
delete mode 100644 be/src/exec/odbc_scan_node.cpp
delete mode 100644 be/src/exec/odbc_scan_node.h
delete mode 100644 be/src/exec/olap_scan_node.cpp
delete mode 100644 be/src/exec/olap_scan_node.h
delete mode 100644 be/src/exec/olap_scanner.cpp
delete mode 100644 be/src/exec/olap_scanner.h
delete mode 100644 be/src/exec/orc_scanner.cpp
delete mode 100644 be/src/exec/orc_scanner.h
delete mode 100644 be/src/exec/parquet_scanner.cpp
delete mode 100644 be/src/exec/parquet_scanner.h
delete mode 100644 be/src/exec/parquet_writer.cpp
delete mode 100644 be/src/exec/parquet_writer.h
delete mode 100644 be/src/exec/partitioned_aggregation_node.cc
delete mode 100644 be/src/exec/partitioned_aggregation_node.h
delete mode 100644 be/src/exec/partitioned_hash_table.cc
delete mode 100644 be/src/exec/partitioned_hash_table.h
delete mode 100644 be/src/exec/partitioned_hash_table.inline.h
delete mode 100644 be/src/exec/repeat_node.cpp
delete mode 100644 be/src/exec/repeat_node.h
delete mode 100644 be/src/exec/schema_scan_node.cpp
delete mode 100644 be/src/exec/schema_scan_node.h
delete mode 100644 be/src/exec/select_node.cpp
delete mode 100644 be/src/exec/select_node.h
delete mode 100644 be/src/exec/set_operation_node.cpp
delete mode 100644 be/src/exec/set_operation_node.h
delete mode 100644 be/src/exec/sort_exec_exprs.cpp
delete mode 100644 be/src/exec/sort_exec_exprs.h
delete mode 100644 be/src/exec/spill_sort_node.cc
delete mode 100644 be/src/exec/spill_sort_node.h
delete mode 100644 be/src/exec/table_function_node.cpp
delete mode 100644 be/src/exec/table_function_node.h
delete mode 100644 be/src/exec/topn_node.cpp
delete mode 100644 be/src/exec/topn_node.h
delete mode 100644 be/src/exec/union_node.cpp
delete mode 100644 be/src/exec/union_node.h
delete mode 100644 be/src/runtime/data_stream_mgr.cpp
delete mode 100644 be/src/runtime/data_stream_mgr.h
delete mode 100644 be/src/runtime/data_stream_recvr.cc
delete mode 100644 be/src/runtime/data_stream_recvr.h
delete mode 100644 be/src/runtime/data_stream_sender.cpp
delete mode 100644 be/src/runtime/data_stream_sender.h
delete mode 100644 be/src/runtime/file_result_writer.cpp
delete mode 100644 be/src/runtime/file_result_writer.h
delete mode 100644 be/src/runtime/result_file_sink.cpp
delete mode 100644 be/src/runtime/result_file_sink.h
delete mode 100644 be/src/runtime/result_sink.cpp
delete mode 100644 be/src/runtime/result_sink.h
delete mode 100644 be/src/runtime/sorted_run_merger.cc
delete mode 100644 be/src/runtime/sorted_run_merger.h
delete mode 100644 be/src/runtime/spill_sorter.cc
delete mode 100644 be/src/runtime/spill_sorter.h
delete mode 100644 be/src/util/tuple_row_compare.cpp
delete mode 100644 be/src/util/tuple_row_compare.h
rename be/src/{exec => vec/exec/scan}/mysql_scanner.cpp (98%)
rename be/src/{exec => vec/exec/scan}/mysql_scanner.h (96%)
delete mode 100644 be/test/exec/broker_reader_test.cpp
delete mode 100644 be/test/exec/broker_scan_node_test.cpp
delete mode 100644 be/test/exec/broker_scanner_test.cpp
delete mode 100644 be/test/exec/buffered_reader_test.cpp
delete mode 100644 be/test/exec/csv_scan_bench_test.cpp
delete mode 100644 be/test/exec/csv_scan_node_test.cpp
delete mode 100644 be/test/exec/csv_scanner_test.cpp
delete mode 100644 be/test/exec/es_http_scan_node_test.cpp
delete mode 100644 be/test/exec/es_predicate_test.cpp
delete mode 100644 be/test/exec/es_query_builder_test.cpp
delete mode 100644 be/test/exec/es_scan_reader_test.cpp
delete mode 100644 be/test/exec/hash_table_test.cpp
delete mode 100644 be/test/exec/hdfs_file_reader_test.cpp
delete mode 100644 be/test/exec/json_scanner_test.cpp
delete mode 100644 be/test/exec/json_scanner_with_jsonpath_test.cpp
delete mode 100644 be/test/exec/multi_bytes_separator_test.cpp
delete mode 100644 be/test/exec/mysql_scan_node_test.cpp
delete mode 100644 be/test/exec/mysql_scanner_test.cpp
delete mode 100644 be/test/exec/new_olap_scan_node_test.cpp
delete mode 100644 be/test/exec/olap_common_test.cpp
delete mode 100644 be/test/exec/olap_scan_node_test.cpp
delete mode 100644 be/test/exec/olap_scanner_test.cpp
delete mode 100644 be/test/exec/orc_scanner_test.cpp
delete mode 100644 be/test/exec/parquet_scanner_test.cpp
delete mode 100644 be/test/exec/plain_text_line_reader_bzip_test.cpp
delete mode 100644 be/test/exec/plain_text_line_reader_gzip_test.cpp
delete mode 100644 be/test/exec/plain_text_line_reader_lz4frame_test.cpp
delete mode 100644 be/test/exec/plain_text_line_reader_lzop_test.cpp
delete mode 100644 be/test/exec/plain_text_line_reader_uncompressed_test.cpp
delete mode 100644 be/test/exec/s3_reader_test.cpp
delete mode 100644 be/test/exec/schema_scan_node_test.cpp
delete mode 100644 be/test/exec/schema_scanner/schema_authors_scanner_test.cpp
delete mode 100644 be/test/exec/schema_scanner/schema_charsets_scanner_test.cpp
delete mode 100644
be/test/exec/schema_scanner/schema_collations_scanner_test.cpp
delete mode 100644 be/test/exec/schema_scanner/schema_columns_scanner_test.cpp
delete mode 100644
be/test/exec/schema_scanner/schema_create_table_scanner_test.cpp
delete mode 100644 be/test/exec/schema_scanner/schema_engines_scanner_test.cpp
delete mode 100644
be/test/exec/schema_scanner/schema_open_tables_scanner_test.cpp
delete mode 100644 be/test/exec/schema_scanner/schema_schemata_scanner_test.cpp
delete mode 100644
be/test/exec/schema_scanner/schema_table_names_scanner_test.cpp
delete mode 100644 be/test/exec/schema_scanner/schema_tables_scanner_test.cpp
delete mode 100644
be/test/exec/schema_scanner/schema_variables_scanner_test.cpp
delete mode 100644 be/test/exec/schema_scanner_test.cpp
delete mode 100644 be/test/exec/set_executor_test.cpp
delete mode 100644 be/test/exec/tablet_info_test.cpp
delete mode 100644 be/test/exec/tablet_sink_test.cpp
delete mode 100644 be/test/exec/unix_odbc_test.cpp
delete mode 100644 be/test/runtime/buffered_tuple_stream_test.cpp
delete mode 100644 be/test/runtime/memory_scratch_sink_test.cpp
delete mode 100644 be/test/runtime/sorter_test.cpp
delete mode 100644 be/test/util/arrow/arrow_row_batch_test.cpp
delete mode 100644 be/test/util/arrow/arrow_row_block_test.cpp
delete mode 100644 be/test/util/arrow/arrow_work_flow_test.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
