This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch array-type
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git.
discard aaeca61 [feature-wip][array-type] Support ArrayLiteral in SQL. (#8089)
omit 9253a78 [feature-wip](array-type) Create table with nested array
type. (#8003)
add 0553ce2 [feature](vectorization) support function topn && remove some
unused code (#7793)
add db20e1f [refactor](storage) VGenericIterator to reuse Schema (#7858)
add 5029ef4 [fix] fix ltrim result may incorrect in some case (#7963)
add eeaf672 (fix)[lateral-view] Solve the problem of not recognizing the
lateral view on the view (#7968)
add df2c756 [improvement](log) Add query id info in error log for easy
tracking (#7975)
add c3b010b [refactor] Remove flink/spark connectors (#8004)
add 2e27827 [doc] Added http interface return example to obtain the
specified table structure information (#7955)
add 92b690f [feature-wip](iceberg) Step2: add table creation strict mode
and support refresh iceberg table or db. (#7981)
add 690b3b7 [doc] Translate the Chinese comments (#7982)
add 0b2b328 [doc] remove useless word 'To' in materialized view (#7985)
add 5bd9fdb [Improvement] print log foreground if not use --daemon to
start fe (#7995)
add a4e7c76 [Enhancement] use std::search to replace custom search (#7999)
add 789472a [build] change docker image add perf tools and simdjson
(#8012)
add 0b1b937 [docs] Fixed typo in CREATE TABLE (#8001)
add 7648303 [docs](config) correct mysql jdbc auto-retry url format
(#8009)
add 6b9cb49 [Refactor] remove plugin folder in be since it is useless and
it need fPIC tag to build and we will remove all fPIC tag in the future (#8008)
add 7a73645 [refactor] remove some unused code (#8022)
add ee26cd2 [fix] (grouping set) fix Unexpected exception: bitIndex < 0:
-1 (#7989)
add 6934534 [fix](demo) scala.Function1 used in java about compiling
error:apply$mcVJ$sp(long)
add 64fb8da [feature] (function)(vec) support pmod function (#7977)
add b26e7e3 [feature](function)(vec) support locate function (#7988)
add 1278796 [fix](backup) fix backup job finished with error message
issue (#7997)
add 7d7e3a3 [refactor] Remove snapshot converter and unused Protobuf
Definitions (#8026)
add 18e2071 [fix](be-unit-test) Fix memory problems in agg_test.cpp.
(#8019)
add 8d7a0d9 [docs](routine-load)Update routine-load-manual.md (#8006)
add 969cd0c [fix](fe-ui)Solve the problem that the web UI playground
preview table data, the field is the wrong problem (#8016)
add 64f71dd [fix](be-ut) fix segmentation fault at unaligned address
int128 (#8021)
add aea3e4e [refactor] Remove version hash from BE and related test in BE
(#8027)
add 1ff0df9 [refactor] Remove old schema change rollup backend
decommission code (#8030)
add a390b76 [Improvement] BE could print log foreground when not use
daemon mode (#8031)
add fa7cd94 [typo](docs) fix typos in multi-tenant.md(zh-CN) (#8032)
add 884fddb [fix](compatibility) Fix compatibility issue of PRowBatch and
some tablet sink bugs (#8000)
add f190806 [community] add collaborators in .asf.yaml (#8029)
add 25d6477 [Vectorized][Feature] Support mysql external table insert
into stm (#7979)
add 6ccf9db [feature-wip](statistics) Step1: Statistics collection
framework (#7880)
add a6bf8c1 [Feature](Transaction) Support two phase commit (2PC) for
stream load (#7473)
add bb4881b [fix](planner) fix using clause npe (#7952)
add aee9273 [typo] translate comment in Chinese to English in
SingleNodePlanner (#8038)
add a46af29 [fix](meta) fix bug that FE can't start due to wrong image
reading (#8045)
add 143c408 [Feature][Vectorized] support aggregate function
ndv()/approx_count_distinct() (#8044)
add e6fedff [Refactor][heartbeat] Make get fe heart response by thrift
(#8035)
add 0003822 [feature](vec) add ColumnHLL to support hll type (#7828)
add 264f384 [feature](spark-load) add Hive Bitmap UDFs (#8036)
add d1cb291 [improvement] check simd instructions before start (#8042)
add 53f22bb [fix] fix incorrect serialized_size of TDigest object (#8046)
add 79fd81f [doc] Added be -238 error code description (#8048)
add bef1b55 [feature][fix](vec)(function) Fix multi args function call
the DATETIME type not effective in DATE type and add the alias function (#8050)
add f06c13a [feature](vec)(function) support function `convert_tz()`
(#8060)
add 26289c2 [fix](load)(compaction) Fix NodeChannel coredump bug and
modify some compaction logic (#8072)
add d9535c2 [doc] update alter table docs (#8076)
add 486a058 [community] modify the doc of verifying apache release (#8084)
add 289aacb [improvement] enable check_java_version (#8034)
add f8411f3 [refactor](mysql_table_writer)split into two parts of
vectorized and row mode (#8081)
add f6e2a4f [Vectorized][Function] Support
year/month/week/hour/mintue/day/second floor/ceil function (#8068)
add e0dbf48 [Vectorized] [AggFunction] Support group_concat (#8086)
add 8939b74 Update sql-block.md (#8106)
add 7471873 Add version upgrade instructions (#8057)
add bdd78f2 [Vectorized][HashJoin] Eliminate hashjoin branch prediction
(#8051)
add a162f56 (test) resolve unit test failed problem for
VGenericIteratorsTest
add 936da4f [feature](thread-pool) Support thread pool per disk for
scanners (#7994)
add b9f0b55 [refactor](storage) refactor some interfaces of storage layer
column (#8064)
add b7e07ee [fix](cache) Throws ClassCastException when there are
multiple EXCEPT, INTERSECT and UNION in the local view (#8083)
add 4a16b66 Update commit-format-specification.md (#8121)
add 31399d5 [Bug][Vec] Fix the bug of coredump when vec exec engine with
delete condition (#8109)
add d383821 [refactor] Remove unused code in data dir (#8092)
add 2b1aec8 [docs] Modify the SSB document (#8101)
add 920a6db Fix username@cluster:passwod is modified to cluster:
username:passwod causes authentication failure (#8115)
add 68b24d6 [fix] (vectorization)Fix nullable column compute the hash
value error (#8105)
add bcde1f2 [Function][Vectorized] Support least/greast function (#8107)
add 8892780 [Vectorized][Feature] support agg function
percentile&&percentile_approx (#8066)
add 50864ac [refactor] fix warings when compile with clang (#8069)
add 9cb9781 [chore](storage) add STORAGE_LAYER_VECTORIZED_SWITCH (#8005)
add 9df5b2d [fix](variables) Fix bug that execute showVariablesStmt with
where expression return empty resultset (#8094)
add 1943a5d [docs] fix some document error and adjust some function
document location
add 0f7a253 [fix](rowset-meta) Fix bug that rowset meta is not deleted
(#8118)
add 5cc8cb1 [improvement](txn) Add PreCommitTime for the result of `SHOW
TRANSACTION` stmt (#8124)
add 5f50d9a predicate test bugfix (#8134)
add 694e643 [feature](test) Add regression test framework (#8125)
add 4926c0b [typo] translate the comments of byte_buffer.h (#8127)
add 02531cc [doc]fix start/stop command (#8150)
add 13d217b [community](doc) Refactor the release and verify doc (#8136)
add 56adc7f [Bug][vec] Fix bug of nullable const value convert to
argument cause coredump (#8139)
add b27122d [Docs] add rpc function document (#7984)
add 826738d [docs]Some doc improvements and typo fix (#8153)
add 16bf60e [docs] Update data-model-rollup.md (#8126)
add 409aefd [refactor] add some log when close parquet file (#8144)
add 16020cb [fix](lateral-view) Fix bug that explode_json_array_string
return unstable result (#8152)
add c3348b8 [docs] fix config enable_force_drop_redundant_replica name
not correct in docs (#8154)
add c47368f [fix] (udf) fix check_fn and fn_call function name not same
(#8132)
add 0d5b297 [chore] add aclocal/automake version check (#8055)
add d0ee101 [refactor] (runtime)tidy up the plan_fragment_executor codes
(#8110)
add f13fd13 [fix] (schema change) Fix BE crash after schema change int
column to varchar column(#8073) (#8142)
add 47067e4 [refactor](common) optimize Status implemention: no dynamic
new (#8117)
add 6e8d52f [fix](stream-load) fix bug that stream load may be blocked
with unqualified data (#8176)
add d6aebc0 [improvement] make asan work as much as possible (#8148)
add 87e555c [Feature][Vectorized] support function
json_array/json_object/json_quote (#8158)
add 273ced0 [Build] Fix build fe error caused by Inaccessible
pentaho-aggdesigner-algorithm jar (#8175)
add 802fcbb (#8162)refactor binary dict
new 0d14205 [feature-wip](array-type) Create table with nested array
type. (#8003)
new e1d75ee [feature-wip][array-type] Support ArrayLiteral in SQL. (#8089)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (aaeca61)
\
N -- N -- N refs/heads/array-type (e1d75ee)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 8 +-
.github/workflows/build-extension.yml | 21 -
.gitignore | 3 +
.licenserc.yaml | 2 +
CONTRIBUTING.md | 5 +-
CONTRIBUTING_CN.md | 5 +-
be/CMakeLists.txt | 144 +-
be/src/agent/cgroups_mgr.cpp | 5 +-
be/src/agent/cgroups_mgr.h | 1 -
be/src/agent/task_worker_pool.cpp | 37 +-
be/src/codegen/doris_ir.h | 34 -
be/src/common/config.h | 16 +-
be/src/common/daemon.h | 2 +-
be/src/common/hdfs.h | 31 -
be/src/common/logconfig.cpp | 4 +
be/src/common/logging.h | 32 +-
be/src/common/status.cpp | 62 +-
be/src/common/status.h | 105 +-
be/src/common/utils.h | 2 +
be/src/env/env.h | 12 +-
be/src/env/env_posix.cpp | 36 +-
be/src/env/env_posix.h | 15 +-
be/src/env/env_remote.cpp | 105 +-
be/src/env/env_remote.h | 15 +-
be/src/exec/CMakeLists.txt | 6 -
be/src/exec/aggregation_node.cpp | 454 -------
be/src/exec/aggregation_node.h | 132 --
be/src/exec/aggregation_node_ir.cpp | 50 -
be/src/exec/base_scanner.cpp | 74 +-
be/src/exec/broker_scan_node.h | 2 -
be/src/exec/broker_scanner.h | 4 +-
be/src/exec/csv_scan_node.cpp | 6 +-
be/src/exec/csv_scan_node.h | 2 +-
be/src/exec/data_sink.cpp | 14 +-
be/src/exec/es/es_predicate.cpp | 6 +-
be/src/exec/es/es_predicate.h | 3 +-
be/src/exec/es/es_scroll_parser.cpp | 272 ++--
be/src/exec/es/es_scroll_parser.h | 4 +-
be/src/exec/es_http_scan_node.h | 6 +-
be/src/exec/es_scan_node.h | 2 +-
be/src/exec/exchange_node.h | 12 +-
be/src/exec/exec_node.cpp | 26 +-
be/src/exec/hash_join_node.cpp | 153 ++-
be/src/exec/hash_join_node_ir.cpp | 172 ---
be/src/exec/hash_table.cpp | 14 +-
be/src/exec/hash_table.h | 25 +-
be/src/exec/odbc_connector.cpp | 1 -
be/src/exec/odbc_connector.h | 1 -
be/src/exec/olap_scan_node.cpp | 3 +-
be/src/exec/parquet_reader.cpp | 10 +-
be/src/exec/parquet_scanner.cpp | 36 +-
be/src/exec/parquet_scanner.h | 7 +-
be/src/exec/parquet_writer.cpp | 10 +-
be/src/exec/partitioned_aggregation_node.cc | 228 +++-
be/src/exec/partitioned_aggregation_node.h | 19 +-
be/src/exec/partitioned_aggregation_node_ir.cc | 250 ----
be/src/exec/partitioned_hash_table.h | 67 +-
be/src/exec/partitioned_hash_table.inline.h | 10 +-
be/src/exec/scanner_ir.cpp | 55 -
.../exec/schema_scanner/schema_dummy_scanner.cpp | 2 +-
be/src/exec/schema_scanner/schema_dummy_scanner.h | 2 +-
.../exec/schema_scanner/schema_variables_scanner.h | 1 -
be/src/exec/tablet_sink.cpp | 89 +-
be/src/exec/tablet_sink.h | 42 +-
be/src/exec/text_converter.hpp | 7 +-
be/src/exec/union_node.cpp | 56 +-
be/src/exec/union_node.h | 1 -
be/src/exec/union_node_ir.cpp | 67 -
be/src/exprs/CMakeLists.txt | 2 -
be/src/exprs/agg_fn_evaluator.cpp | 16 +-
be/src/exprs/agg_fn_evaluator.h | 2 +-
be/src/exprs/aggregate_functions.cpp | 51 +-
be/src/exprs/arithmetic_expr.h | 110 +-
be/src/exprs/binary_predicate.h | 40 +-
be/src/exprs/bloomfilter_predicate.h | 3 +-
be/src/exprs/case_expr.h | 28 +-
be/src/exprs/cast_expr.h | 32 +-
be/src/exprs/cast_functions.cpp | 25 +-
be/src/exprs/cast_functions.h | 3 -
be/src/exprs/compound_predicate.cpp | 6 -
be/src/exprs/compound_predicate.h | 12 +-
be/src/exprs/conditional_functions.cpp | 101 +-
be/src/exprs/conditional_functions.h | 104 +-
be/src/exprs/conditional_functions_ir.cpp | 117 --
be/src/exprs/expr.cpp | 26 -
be/src/exprs/expr.h | 2 +-
be/src/exprs/expr_context.cpp | 15 -
be/src/exprs/expr_ir.cpp | 81 --
be/src/exprs/hash_functions.h | 4 +-
be/src/exprs/hybrid_set.h | 12 +-
be/src/exprs/in_predicate.h | 8 +-
be/src/exprs/info_func.cpp | 10 -
be/src/exprs/info_func.h | 6 +-
be/src/exprs/literal.h | 26 +-
be/src/exprs/math_functions.cpp | 163 ---
be/src/exprs/minmax_predicate.h | 4 +-
be/src/exprs/new_agg_fn_evaluator.cc | 2 -
be/src/exprs/new_agg_fn_evaluator.h | 5 +-
be/src/exprs/null_literal.h | 22 +-
be/src/exprs/operators.cpp | 45 -
be/src/exprs/operators.h | 7 -
be/src/exprs/rpc_fn_call.cpp | 6 +
be/src/exprs/scalar_fn_call.cpp | 15 -
be/src/exprs/scalar_fn_call.h | 39 +-
be/src/exprs/slot_ref.h | 37 +-
be/src/exprs/string_functions.h | 16 +-
be/src/exprs/table_function/explode_json_array.cpp | 17 +-
be/src/exprs/table_function/explode_json_array.h | 1 -
be/src/exprs/topn_function.cpp | 40 -
be/src/exprs/tuple_is_null_predicate.h | 12 +-
be/src/exprs/v_string_functions.h | 219 ----
be/src/geo/geo_types.cpp | 136 --
be/src/geo/geo_types.h | 52 -
be/src/geo/wkt_yacc.y | 2 +-
be/src/gutil/atomicops.h | 69 -
be/src/gutil/hash/hash.cc | 14 +-
be/src/gutil/hash/hash.h | 132 +-
be/src/gutil/strings/join.h | 6 -
be/src/gutil/threading/thread_collision_warner.cc | 18 -
be/src/http/CMakeLists.txt | 1 +
be/src/http/action/checksum_action.cpp | 24 +-
be/src/http/action/checksum_action.h | 8 +-
be/src/http/action/compaction_action.cpp | 2 +-
be/src/http/action/health_action.cpp | 6 +-
be/src/http/action/health_action.h | 7 +-
be/src/http/action/monitor_action.cpp | 12 -
be/src/http/action/pprof_actions.cpp | 9 +-
be/src/http/action/snapshot_action.cpp | 5 +-
be/src/http/action/snapshot_action.h | 5 +-
be/src/http/action/stream_load.cpp | 21 +-
be/src/http/action/stream_load_2pc.cpp | 102 ++
.../action/{health_action.h => stream_load_2pc.h} | 16 +-
be/src/http/action/tablet_migration_action.cpp | 9 +-
be/src/http/http_client.h | 13 +-
be/src/http/http_common.h | 4 +
be/src/olap/CMakeLists.txt | 1 -
be/src/olap/base_compaction.cpp | 32 +-
be/src/olap/block_column_predicate.h | 1 -
be/src/olap/bloom_filter_reader.h | 1 -
be/src/olap/byte_buffer.cpp | 2 +-
be/src/olap/byte_buffer.h | 112 +-
be/src/olap/collect_iterator.h | 37 +-
be/src/olap/compaction.cpp | 2 -
be/src/olap/compaction.h | 1 -
be/src/olap/compaction_permit_limiter.h | 2 +
be/src/olap/comparison_predicate.cpp | 248 ++--
be/src/olap/cumulative_compaction.cpp | 8 +-
be/src/olap/cumulative_compaction_policy.h | 19 +-
be/src/olap/data_dir.cpp | 70 +-
be/src/olap/data_dir.h | 8 -
be/src/olap/decimal12.h | 10 +-
be/src/olap/field.h | 2 +-
be/src/olap/fs/block_manager.h | 16 +-
be/src/olap/fs/file_block_manager.h | 8 +-
be/src/olap/fs/remote_block_manager.h | 8 +-
be/src/olap/hll.h | 190 ++-
be/src/olap/lru_cache.h | 16 +-
be/src/olap/memory/typed_column_writer.h | 3 +-
be/src/olap/memtable.cpp | 16 +-
be/src/olap/memtable.h | 33 +-
be/src/olap/olap_common.h | 1 -
be/src/olap/olap_cond.h | 2 +-
be/src/olap/olap_define.h | 3 +-
be/src/olap/olap_meta.cpp | 21 -
be/src/olap/olap_meta.h | 4 -
be/src/olap/olap_server.cpp | 28 +-
be/src/olap/olap_snapshot_converter.cpp | 306 -----
be/src/olap/olap_snapshot_converter.h | 65 -
be/src/olap/push_handler.h | 4 +-
be/src/olap/row_block2.cpp | 25 +-
be/src/olap/row_block2.h | 2 +-
be/src/olap/rowset/alpha_rowset.cpp | 10 +-
be/src/olap/rowset/alpha_rowset.h | 4 +-
be/src/olap/rowset/alpha_rowset_reader.cpp | 4 -
be/src/olap/rowset/alpha_rowset_reader.h | 2 -
be/src/olap/rowset/alpha_rowset_writer.cpp | 3 +-
be/src/olap/rowset/beta_rowset.cpp | 10 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 38 +-
be/src/olap/rowset/beta_rowset_reader.h | 3 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 4 +-
be/src/olap/rowset/column_data.cpp | 10 +-
be/src/olap/rowset/column_data.h | 1 -
be/src/olap/rowset/column_reader.cpp | 3 +-
be/src/olap/rowset/column_reader.h | 19 +-
be/src/olap/rowset/column_writer.cpp | 29 -
be/src/olap/rowset/column_writer.h | 54 +-
be/src/olap/rowset/rowset.cpp | 5 +-
be/src/olap/rowset/rowset.h | 5 +-
be/src/olap/rowset/rowset_converter.cpp | 1 -
be/src/olap/rowset/rowset_factory.h | 5 +-
be/src/olap/rowset/rowset_meta.h | 6 -
be/src/olap/rowset/rowset_reader.h | 2 -
be/src/olap/rowset/rowset_writer.h | 2 +-
be/src/olap/rowset/rowset_writer_context.h | 2 -
be/src/olap/rowset/segment_group.cpp | 19 +-
be/src/olap/rowset/segment_group.h | 5 +-
be/src/olap/rowset/segment_v2/binary_dict_page.cpp | 35 +-
be/src/olap/rowset/segment_v2/binary_dict_page.h | 7 +-
be/src/olap/rowset/segment_v2/binary_plain_page.h | 65 +-
be/src/olap/rowset/segment_v2/bitshuffle_page.h | 60 +-
.../rowset/segment_v2/bloom_filter_index_writer.h | 2 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 16 +-
be/src/olap/rowset/segment_v2/column_reader.h | 55 +-
.../rowset/segment_v2/empty_segment_iterator.h | 2 +-
be/src/olap/rowset/segment_v2/encoding_info.h | 4 +-
be/src/olap/rowset/segment_v2/plain_page.h | 2 +-
be/src/olap/rowset/segment_v2/segment.cpp | 33 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 113 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 28 +-
be/src/olap/schema.cpp | 159 +--
be/src/olap/schema_change.cpp | 19 +-
be/src/olap/schema_change.h | 25 +-
be/src/olap/short_key_index.h | 4 +-
be/src/olap/snapshot_manager.cpp | 2 -
be/src/olap/storage_engine.cpp | 29 +-
be/src/olap/tablet.cpp | 85 +-
be/src/olap/tablet.h | 12 +-
be/src/olap/tablet_manager.cpp | 1 -
be/src/olap/tablet_meta.cpp | 4 +-
be/src/olap/tablet_meta_manager.cpp | 7 +-
be/src/olap/task/engine_alter_tablet_task.cpp | 11 +-
be/src/olap/task/engine_alter_tablet_task.h | 8 +-
be/src/olap/task/engine_checksum_task.cpp | 4 +-
be/src/olap/task/engine_checksum_task.h | 3 +-
be/src/olap/task/engine_clone_task.cpp | 3 +-
be/src/olap/task/engine_publish_version_task.cpp | 13 +-
be/src/olap/txn_manager.cpp | 30 +-
be/src/olap/txn_manager.h | 5 +-
be/src/olap/types.h | 33 +-
be/src/olap/uint24.h | 2 +
be/src/olap/utils.cpp | 2 +-
be/src/plugin/CMakeLists.txt | 28 -
be/src/plugin/plugin.h | 82 --
be/src/plugin/plugin_loader.cpp | 197 ---
be/src/plugin/plugin_loader.h | 108 --
be/src/plugin/plugin_mgr.cpp | 165 ---
be/src/plugin/plugin_mgr.h | 64 -
be/src/plugin/plugin_zip.cpp | 132 --
be/src/plugin/plugin_zip.h | 43 -
be/src/runtime/CMakeLists.txt | 4 -
be/src/runtime/buffered_block_mgr2.h | 4 +-
be/src/runtime/buffered_tuple_stream2.cc | 151 ++-
be/src/runtime/buffered_tuple_stream2_ir.cc | 187 ---
be/src/runtime/buffered_tuple_stream3.cc | 3 +-
be/src/runtime/bufferpool/buffer_pool.h | 4 +-
be/src/runtime/collection_value.cpp | 4 +-
be/src/runtime/descriptors.cpp | 7 +-
be/src/runtime/descriptors.h | 8 +-
be/src/runtime/disk_io_mgr.cc | 2 -
be/src/runtime/disk_io_mgr.h | 1 -
be/src/runtime/exec_env.h | 8 +-
be/src/runtime/exec_env_init.cpp | 25 +-
be/src/runtime/export_sink.h | 2 +-
be/src/runtime/file_result_writer.h | 2 +-
be/src/runtime/fold_constant_executor.h | 17 +-
be/src/runtime/fragment_mgr.cpp | 5 +-
be/src/runtime/load_channel.cpp | 2 +-
be/src/runtime/load_channel_mgr.cpp | 2 +-
be/src/runtime/load_path_mgr.h | 1 -
be/src/runtime/mem_pool.h | 67 +-
be/src/runtime/memory/chunk_allocator.h | 2 +-
be/src/runtime/memory_scratch_sink.h | 1 -
be/src/runtime/message_body_sink.h | 8 +
be/src/runtime/minidump.cpp | 2 +-
be/src/runtime/mysql_table_writer.cpp | 4 +-
be/src/runtime/mysql_table_writer.h | 7 +-
be/src/runtime/plan_fragment_executor.cpp | 31 +-
be/src/runtime/plan_fragment_executor.h | 4 +-
be/src/runtime/raw_value.cpp | 90 ++
be/src/runtime/raw_value_ir.cpp | 114 --
be/src/runtime/result_buffer_mgr.h | 2 +-
be/src/runtime/result_file_sink.h | 14 +-
be/src/runtime/result_sink.h | 15 +-
be/src/runtime/result_writer.h | 2 +-
be/src/runtime/row_batch.cpp | 72 +-
be/src/runtime/row_batch.h | 16 +-
be/src/runtime/small_file_mgr.cpp | 3 +-
be/src/runtime/snapshot_loader.cpp | 19 -
be/src/runtime/snapshot_loader.h | 7 +-
be/src/runtime/stream_load/stream_load_context.cpp | 4 +
be/src/runtime/stream_load/stream_load_context.h | 4 +
.../runtime/stream_load/stream_load_executor.cpp | 91 +-
be/src/runtime/stream_load/stream_load_executor.h | 12 +-
be/src/runtime/stream_load/stream_load_pipe.h | 11 +-
be/src/runtime/string_search.hpp | 95 +-
be/src/runtime/string_value_ir.cpp | 29 -
be/src/runtime/tmp_file_mgr.cc | 9 -
be/src/runtime/tmp_file_mgr.h | 3 -
be/src/runtime/types.cpp | 50 +-
be/src/runtime/types.h | 16 +-
be/src/service/backend_service.h | 35 +-
be/src/service/doris_main.cpp | 199 +++
be/src/service/http_service.cpp | 11 +-
be/src/service/internal_service.h | 6 +-
be/src/udf/CMakeLists.txt | 4 +-
be/src/udf/udf.cpp | 57 +-
be/src/udf/udf.h | 8 +-
be/src/udf/udf_internal.h | 2 +-
be/src/udf/udf_ir.cpp | 83 --
be/src/util/arrow/row_batch.cpp | 24 +-
be/src/util/arrow/row_block.cpp | 2 +-
be/src/util/bfd_parser.cpp | 11 -
be/src/util/blocking_priority_queue.hpp | 14 +-
be/src/util/brpc_client_cache.h | 13 +-
be/src/util/cidr.cpp | 8 +-
be/src/util/counts.h | 8 +-
be/src/util/crc32c.cpp | 2 +-
be/src/util/date_func.h | 2 +-
be/src/util/disk_info.h | 16 -
be/src/util/error_util.cc | 160 +--
be/src/util/error_util.h | 139 --
be/src/util/hash_util.hpp | 4 +-
be/src/util/hash_util_ir.cpp | 39 -
be/src/util/metrics.h | 24 +-
be/src/util/mysql_load_error_hub.cpp | 4 +-
be/src/util/mysql_row_buffer.cpp | 14 +-
be/src/util/priority_thread_pool.hpp | 22 +-
....hpp => priority_work_stealing_thread_pool.hpp} | 109 +-
be/src/util/sse2neon.h | 27 +-
be/src/util/system_metrics.h | 14 +-
be/src/util/tdigest.h | 2 +-
be/src/util/topn_counter.h | 2 +-
be/src/util/tuple_row_zorder_compare.h | 31 +-
be/src/vec/CMakeLists.txt | 10 +
.../vec/aggregate_functions/aggregate_function.h | 39 +-
.../aggregate_function_approx_count_distinct.cpp | 50 +
.../aggregate_function_approx_count_distinct.h | 107 ++
.../aggregate_functions/aggregate_function_avg.cpp | 4 -
.../aggregate_functions/aggregate_function_avg.h | 8 +-
.../aggregate_function_bitmap.h | 18 +-
.../aggregate_function_combinator.h | 2 -
.../aggregate_functions/aggregate_function_count.h | 32 +-
.../aggregate_function_distinct.h | 12 +-
.../aggregate_function_group_concat.cpp | 46 +
.../aggregate_function_group_concat.h | 140 ++
.../aggregate_function_hll_union_agg.h | 38 +-
.../aggregate_function_min_max.h | 27 +-
.../aggregate_function_nothing.h | 4 +-
.../aggregate_functions/aggregate_function_null.h | 20 +-
.../aggregate_function_percentile_approx.cpp | 58 +
.../aggregate_function_percentile_approx.h | 267 ++++
.../aggregate_function_simple_factory.cpp | 15 +-
.../aggregate_function_simple_factory.h | 7 +-
.../aggregate_function_stddev.h | 8 +-
.../aggregate_functions/aggregate_function_sum.h | 24 +-
.../aggregate_function_topn.cpp | 48 +
.../aggregate_functions/aggregate_function_topn.h | 239 ++++
.../aggregate_functions/aggregate_function_uniq.h | 14 +-
.../aggregate_function_window.h | 10 +-
be/src/vec/columns/column.h | 20 +-
be/src/vec/columns/column_complex.h | 54 +-
be/src/vec/columns/column_decimal.h | 11 +
be/src/vec/columns/column_nullable.cpp | 27 +-
be/src/vec/columns/column_nullable.h | 20 +-
be/src/vec/columns/column_string.h | 15 +
be/src/vec/columns/column_vector.h | 100 +-
be/src/vec/columns/columns_number.h | 3 +
be/src/vec/columns/predicate_column.h | 314 ++---
be/src/vec/common/cow.h | 87 +-
be/src/vec/common/string_ref.h | 11 +-
be/src/vec/core/accurate_comparison.h | 47 +-
be/src/vec/core/block.cpp | 51 +-
be/src/vec/core/block.h | 16 +
be/src/vec/core/types.h | 8 +
be/src/vec/data_types/data_type.cpp | 11 +-
be/src/vec/data_types/data_type_bitmap.h | 18 +-
be/src/vec/data_types/data_type_date.h | 5 +-
be/src/vec/data_types/data_type_date_time.cpp | 4 -
be/src/vec/data_types/data_type_date_time.h | 4 +-
be/src/vec/data_types/data_type_decimal.h | 20 +-
be/src/vec/data_types/data_type_hll.cpp | 116 ++
.../{data_type_bitmap.h => data_type_hll.h} | 39 +-
be/src/vec/data_types/data_type_nullable.h | 2 +-
be/src/vec/data_types/data_type_number_base.h | 4 +-
be/src/vec/data_types/data_type_string.h | 4 +-
be/src/vec/exec/join/vhash_join_node.cpp | 280 ++--
be/src/vec/exec/join/vhash_join_node.h | 50 +-
be/src/vec/exec/vaggregation_node.h | 162 ++-
be/src/vec/exec/vanalytic_eval_node.h | 3 +-
be/src/vec/exec/vassert_num_rows_node.h | 6 +-
be/src/vec/exec/vcross_join_node.h | 18 +-
be/src/vec/exec/vempty_set_node.h | 20 +-
be/src/vec/exec/ves_http_scan_node.h | 5 +-
be/src/vec/exec/vexcept_node.h | 3 +-
be/src/vec/exec/vintersect_node.h | 3 +-
be/src/vec/exec/vmysql_scan_node.h | 1 +
be/src/vec/exec/vodbc_scan_node.h | 1 +
be/src/vec/exec/volap_scan_node.cpp | 1 +
be/src/vec/exec/volap_scanner.cpp | 20 +-
be/src/vec/exec/vrepeat_node.h | 1 +
be/src/vec/exec/vschema_scan_node.cpp | 10 +-
be/src/vec/exec/vschema_scan_node.h | 4 +-
be/src/vec/exec/vset_operation_node.h | 9 +-
be/src/vec/exec/vsort_node.h | 27 +-
be/src/vec/exprs/vcase_expr.h | 10 +-
be/src/vec/exprs/vcast_expr.h | 10 +-
be/src/vec/exprs/vectorized_agg_fn.cpp | 6 -
be/src/vec/exprs/vectorized_agg_fn.h | 3 -
be/src/vec/exprs/vectorized_fn_call.h | 10 +-
be/src/vec/exprs/vin_predicate.h | 12 +-
be/src/vec/exprs/vslot_ref.h | 8 +-
be/src/vec/functions/date_time_transforms.h | 22 +-
be/src/vec/functions/function.cpp | 81 +-
be/src/vec/functions/function_case.h | 55 +-
be/src/vec/functions/function_cast.h | 4 +-
be/src/vec/functions/function_coalesce.cpp | 103 +-
be/src/vec/functions/function_conv.cpp | 5 +-
.../src/vec/functions/function_convert_tz.cpp | 11 +-
be/src/vec/functions/function_convert_tz.h | 114 ++
.../function_date_or_datetime_computation.cpp | 25 +-
.../function_date_or_datetime_computation.h | 32 +-
.../function_date_or_datetime_to_something.h | 7 +
.../vec/functions/function_datetime_floor_ceil.cpp | 271 ++++
be/src/vec/functions/function_hash.cpp | 80 +-
be/src/vec/functions/function_json.cpp | 212 ++-
be/src/vec/functions/function_multi_same_args.h | 55 +
be/src/vec/functions/function_rpc.cpp | 33 +-
be/src/vec/functions/function_string.cpp | 49 +-
be/src/vec/functions/function_string.h | 132 +-
be/src/vec/functions/function_totype.h | 18 +-
be/src/vec/functions/functions_comparison.h | 64 -
be/src/vec/functions/hll_cardinality.cpp | 67 +-
be/src/vec/functions/hll_empty.cpp | 13 +-
be/src/vec/functions/hll_hash.cpp | 57 +-
be/src/vec/functions/least_greast.cpp | 127 ++
be/src/vec/functions/modulo.cpp | 35 +-
be/src/vec/functions/random.cpp | 1 -
be/src/vec/functions/simple_function_factory.h | 16 +-
be/src/vec/functions/time_of_function.cpp | 3 +-
be/src/vec/functions/to_time_function.cpp | 2 +-
be/src/vec/io/io_helper.h | 18 +-
be/src/vec/olap/vcollect_iterator.h | 2 -
be/src/vec/olap/vgeneric_iterators.cpp | 61 +-
be/src/vec/runtime/vdata_stream_recvr.h | 4 +-
be/src/vec/sink/result_sink.h | 3 +-
be/src/vec/sink/vmysql_table_sink.cpp | 91 ++
.../export_sink.h => vec/sink/vmysql_table_sink.h} | 61 +-
be/src/vec/sink/vmysql_table_writer.cpp | 211 +++
.../sink/vmysql_table_writer.h} | 48 +-
be/src/vec/sink/vtablet_sink.cpp | 20 -
be/src/vec/sink/vtablet_sink.h | 10 +-
be/src/vec/utils/template_helpers.hpp | 83 ++
be/test/env/env_posix_test.cpp | 17 +-
be/test/exec/hash_table_test.cpp | 3 -
be/test/exec/new_olap_scan_node_test.cpp | 3 +
be/test/exec/olap_common_test.cpp | 1 +
be/test/exec/olap_scan_node_test.cpp | 1 +
be/test/exec/olap_scanner_test.cpp | 1 +
be/test/exprs/string_functions_test.cpp | 56 +-
be/test/exprs/topn_function_test.cpp | 98 +-
be/test/gutil/strings/numbers_test.cpp | 9 +-
be/test/http/http_client_test.cpp | 5 +-
be/test/http/stream_load_test.cpp | 2 +-
be/test/olap/CMakeLists.txt | 1 -
be/test/olap/column_reader_test.cpp | 70 +-
be/test/olap/cumulative_compaction_policy_test.cpp | 2 -
be/test/olap/delete_handler_test.cpp | 2 -
be/test/olap/delta_writer_test.cpp | 23 +-
be/test/olap/in_list_predicate_test.cpp | 5 +-
be/test/olap/null_predicate_test.cpp | 5 +-
be/test/olap/olap_snapshot_converter_test.cpp | 250 ----
be/test/olap/row_cursor_test.cpp | 8 +-
be/test/olap/rowset/rowset_converter_test.cpp | 1 -
.../rowset/segment_v2/binary_dict_page_test.cpp | 24 +-
.../rowset/segment_v2/bitshuffle_page_test.cpp | 4 +-
be/test/olap/rowset/segment_v2/plain_page_test.cpp | 2 +-
be/test/olap/schema_change_test.cpp | 117 +-
be/test/olap/storage_types_test.cpp | 2 +-
be/test/olap/tablet_meta_manager_test.cpp | 1 -
be/test/olap/tablet_mgr_test.cpp | 3 -
be/test/olap/tablet_test.cpp | 1 -
.../data/0/15007/368169781/olap_header.json | 676 ----------
be/test/olap/test_data/header.txt | 197 ---
be/test/olap/test_data/header_without_inc_rs.txt | 2 -
be/test/olap/test_data/rowset.json | 1 -
be/test/olap/test_data/rowset_meta.json | 1 -
be/test/olap/timestamped_version_tracker_test.cpp | 4 +-
be/test/olap/txn_manager_test.cpp | 6 +-
be/test/runtime/result_queue_mgr_test.cpp | 16 +-
be/test/runtime/snapshot_loader_test.cpp | 7 -
be/test/tools/benchmark_tool.cpp | 26 +-
be/test/util/broker_storage_backend_test.cpp | 1 -
be/test/vec/aggregate_functions/agg_test.cpp | 54 +-
be/test/vec/core/CMakeLists.txt | 1 +
be/test/vec/core/column_nullable_test.cpp | 52 +
be/test/vec/exec/vgeneric_iterators_test.cpp | 36 +-
be/test/vec/function/function_math_test.cpp | 22 +
be/test/vec/function/function_string_test.cpp | 46 +-
be/test/vec/function/function_test_util.h | 29 +-
be/test/vec/function/function_time_test.cpp | 58 +
bin/start_be.sh | 3 +-
bin/start_fe.sh | 2 +-
build.sh | 2 +-
docker/Dockerfile | 4 +-
.../public/images/staging-repositories.png | Bin 0 -> 249300 bytes
docs/.vuepress/public/images/staging_repo.png | Bin 392700 -> 0 bytes
docs/.vuepress/sidebar/en.js | 57 +-
docs/.vuepress/sidebar/zh-CN.js | 58 +-
docs/en/administrator-guide/config/be_config.md | 20 +-
docs/en/administrator-guide/config/fe_config.md | 22 +-
.../http-actions/fe/table-schema-action.md | 57 +-
.../load-data/routine-load-manual.md | 4 +
.../load-data/stream-load-manual.md | 22 +
docs/en/administrator-guide/materialized_view.md | 2 +-
.../operation/be-olap-error-code.md | 4 +-
docs/en/benchmark/star-schema-benchmark.md | 28 +-
.../commit-format-specification.md | 2 +-
.../{ => how-to-contribute}/committer-guide.md | 0
.../{ => how-to-contribute}/how-to-contribute.md | 8 +-
.../{ => how-to-contribute}/pull-request.md | 0
docs/en/community/how-to-deploy-to-maven.md | 185 ---
.../release-and-verify/release-complete.md | 198 +++
.../release-and-verify/release-doris-connectors.md | 275 ++++
.../release-and-verify/release-doris-core.md | 324 +++++
.../release-and-verify/release-prepare.md | 342 +++++
.../community/release-and-verify/release-verify.md | 101 ++
docs/en/community/release-process.md | 750 -----------
docs/en/community/{members.md => team.md} | 8 +-
docs/en/community/verify-apache-release.md | 82 --
docs/en/extending-doris/flink-doris-connector.md | 44 +-
docs/en/extending-doris/hive-bitmap-udf.md | 97 ++
docs/en/extending-doris/iceberg-of-doris.md | 67 +-
docs/en/extending-doris/spark-doris-connector.md | 15 +-
...function.md => native-user-defined-function.md} | 4 +-
.../udf/remote-user-defined-function.md | 106 ++
docs/en/getting-started/advance-usage.md | 2 +-
docs/en/getting-started/data-model-rollup.md | 4 +-
.../installing/compilation-with-ldb-toolchain.md | 6 +-
docs/en/installing/compilation.md | 2 +
docs/en/installing/install-deploy.md | 6 +-
docs/en/installing/upgrade.md | 7 +-
.../group_concat.md | 12 +-
.../get_json_double.md | 0
.../get_json_int.md | 0
.../get_json_string.md | 0
.../json_array.md | 0
.../json_object.md | 0
.../json_quote.md | 0
.../sql-functions/math-functions/pmod.md | 54 +
.../sql-statements/Data Definition/ALTER TABLE.md | 5 +-
.../Data Definition/REFRESH DATABASE.md | 45 +
.../Data Definition/REFRESH TABLE.md | 45 +
.../administrator-guide/block-rule/sql-block.md | 2 +-
docs/zh-CN/administrator-guide/config/be_config.md | 20 +-
docs/zh-CN/administrator-guide/config/fe_config.md | 20 +-
.../http-actions/fe/table-schema-action.md | 57 +-
.../load-data/routine-load-manual.md | 4 +
.../load-data/stream-load-manual.md | 22 +
docs/zh-CN/administrator-guide/multi-tenant.md | 4 +-
.../operation/be-olap-error-code.md | 2 +-
docs/zh-CN/benchmark/star-schema-benchmark.md | 16 +
.../commit-format-specification.md | 5 +-
.../{ => how-to-contribute}/committer-guide.md | 0
.../{ => how-to-contribute}/how-to-contribute.md | 10 +-
.../{ => how-to-contribute}/pull-request.md | 0
docs/zh-CN/community/how-to-deploy-to-maven.md | 185 ---
.../release-and-verify/release-complete.md | 194 +++
.../release-and-verify/release-doris-connectors.md | 279 ++++
.../release-and-verify/release-doris-core.md | 323 +++++
.../release-and-verify/release-prepare.md | 343 +++++
.../release-verify.md} | 40 +-
docs/zh-CN/community/release-process.md | 731 -----------
docs/zh-CN/community/{members.md => team.md} | 7 +-
docs/zh-CN/developer-guide/regression-testing.md | 487 +++++++
.../zh-CN/extending-doris/flink-doris-connector.md | 35 +-
docs/zh-CN/extending-doris/hive-bitmap-udf.md | 104 ++
docs/zh-CN/extending-doris/iceberg-of-doris.md | 66 +-
.../zh-CN/extending-doris/spark-doris-connector.md | 12 +-
...function.md => native-user-defined-function.md} | 2 +-
.../udf/remote-user-defined-function.md | 108 ++
docs/zh-CN/faq/error.md | 2 +-
docs/zh-CN/getting-started/advance-usage.md | 4 +-
docs/zh-CN/getting-started/data-model-rollup.md | 2 +-
.../installing/compilation-with-ldb-toolchain.md | 6 +-
docs/zh-CN/installing/compilation.md | 2 +-
docs/zh-CN/installing/install-deploy.md | 6 +-
docs/zh-CN/installing/upgrade.md | 8 +-
.../group_concat.md | 12 +-
.../get_json_double.md | 0
.../get_json_int.md | 0
.../get_json_string.md | 0
.../json_array.md | 0
.../json_object.md | 0
.../json_quote.md | 0
.../group_concat.md => math-functions/pmod.md} | 52 +-
.../sql-statements/Data Definition/ALTER TABLE.md | 3 +
.../sql-statements/Data Definition/CREATE TABLE.md | 2 +-
.../Data Definition/REFRESH DATABASE.md | 46 +
.../Data Definition/REFRESH TABLE.md | 46 +
env.sh | 3 +
extension/flink-doris-connector/build.sh | 80 --
extension/flink-doris-connector/pom.xml | 432 ------
.../apache/doris/flink/backend/BackendClient.java | 220 ----
.../doris/flink/cfg/ConfigurationOptions.java | 65 -
.../doris/flink/cfg/DorisConnectionOptions.java | 80 --
.../doris/flink/cfg/DorisExecutionOptions.java | 128 --
.../org/apache/doris/flink/cfg/DorisOptions.java | 103 --
.../apache/doris/flink/cfg/DorisReadOptions.java | 190 ---
.../java/org/apache/doris/flink/cfg/DorisSink.java | 112 --
.../apache/doris/flink/cfg/DorisStreamOptions.java | 74 --
.../doris/flink/cfg/GenericDorisSinkFunction.java | 70 -
.../flink/datastream/DorisSourceFunction.java | 113 --
.../doris/flink/exception/DorisException.java | 42 -
.../flink/exception/DorisInternalException.java | 29 -
.../doris/flink/exception/StreamLoadException.java | 42 -
.../doris/flink/rest/PartitionDefinition.java | 150 ---
.../org/apache/doris/flink/rest/RestService.java | 641 ---------
.../org/apache/doris/flink/rest/SchemaUtils.java | 39 -
.../apache/doris/flink/rest/models/BackendRow.java | 68 -
.../apache/doris/flink/rest/models/BackendV2.java | 74 --
.../org/apache/doris/flink/rest/models/Field.java | 121 --
.../apache/doris/flink/rest/models/QueryPlan.java | 70 -
.../doris/flink/rest/models/RespContent.java | 100 --
.../org/apache/doris/flink/rest/models/Schema.java | 105 --
.../org/apache/doris/flink/rest/models/Tablet.java | 80 --
.../apache/doris/flink/serialization/Routing.java | 70 -
.../apache/doris/flink/serialization/RowBatch.java | 309 -----
.../flink/table/DorisDynamicOutputFormat.java | 405 ------
.../flink/table/DorisDynamicTableFactory.java | 270 ----
.../doris/flink/table/DorisDynamicTableSink.java | 80 --
.../doris/flink/table/DorisDynamicTableSource.java | 101 --
.../doris/flink/table/DorisRowDataInputFormat.java | 227 ----
.../apache/doris/flink/table/DorisStreamLoad.java | 189 ---
.../doris/flink/table/DorisTableInputSplit.java | 46 -
.../org/apache/doris/flink/util/ErrorMessages.java | 27 -
.../java/org/apache/doris/flink/util/IOUtils.java | 49 -
.../org.apache.flink.table.factories.Factory | 18 -
.../src/main/resources/log4j.properties | 23 -
.../doris/flink/datastream/ScalaValueReader.scala | 222 ----
.../main/thrift/doris/DorisExternalService.thrift | 122 --
.../src/main/thrift/doris/Status.thrift | 66 -
.../src/main/thrift/doris/Types.thrift | 376 ------
.../doris/flink/DorisOutPutFormatExample.java | 84 --
.../org/apache/doris/flink/DorisSinkExample.java | 58 -
.../apache/doris/flink/DorisSourceDataStream.java | 46 -
.../org/apache/doris/flink/DorisSourceExample.java | 64 -
.../apache/doris/flink/DorisSourceSinkExample.java | 64 -
.../apache/doris/flink/DorisStreamSinkExample.java | 236 ----
.../doris/flink/serialization/TestRowBatch.java | 439 -------
extension/spark-doris-connector/build.sh | 79 --
extension/spark-doris-connector/pom.xml | 375 ------
.../doris/spark/CachedDorisStreamLoadClient.java | 63 -
.../org/apache/doris/spark/DorisStreamLoad.java | 225 ----
.../apache/doris/spark/backend/BackendClient.java | 227 ----
.../doris/spark/cfg/ConfigurationOptions.java | 74 --
.../java/org/apache/doris/spark/cfg/Settings.java | 114 --
.../org/apache/doris/spark/cfg/SparkSettings.java | 77 --
.../spark/exception/ConnectedFailedException.java | 28 -
.../doris/spark/exception/DorisException.java | 38 -
.../spark/exception/DorisInternalException.java | 29 -
.../doris/spark/exception/StreamLoadException.java | 38 -
.../doris/spark/rest/PartitionDefinition.java | 155 ---
.../org/apache/doris/spark/rest/RestService.java | 631 ---------
.../apache/doris/spark/rest/models/Backend.java | 40 -
.../apache/doris/spark/rest/models/BackendRow.java | 67 -
.../apache/doris/spark/rest/models/BackendV2.java | 72 -
.../org/apache/doris/spark/rest/models/Field.java | 121 --
.../apache/doris/spark/rest/models/QueryPlan.java | 70 -
.../doris/spark/rest/models/RespContent.java | 96 --
.../org/apache/doris/spark/rest/models/Schema.java | 96 --
.../org/apache/doris/spark/rest/models/Tablet.java | 80 --
.../apache/doris/spark/serialization/Routing.java | 70 -
.../apache/doris/spark/serialization/RowBatch.java | 314 -----
.../org/apache/doris/spark/util/ErrorMessages.java | 27 -
.../java/org/apache/doris/spark/util/IOUtils.java | 51 -
.../scala/org/apache/doris/spark/package.scala | 35 -
.../apache/doris/spark/rdd/AbstractDorisRDD.scala | 68 -
.../doris/spark/rdd/AbstractDorisRDDIterator.scala | 90 --
.../org/apache/doris/spark/rdd/DorisSpark.scala | 36 -
.../org/apache/doris/spark/rdd/ScalaDorisRDD.scala | 49 -
.../apache/doris/spark/rdd/ScalaValueReader.scala | 252 ----
.../org/apache/doris/spark/sql/DorisRelation.scala | 104 --
.../doris/spark/sql/DorisSourceProvider.scala | 150 ---
.../doris/spark/sql/DorisStreamLoadSink.scala | 109 --
.../apache/doris/spark/sql/DorisWriterOption.scala | 41 -
.../org/apache/doris/spark/sql/ScalaDorisRow.scala | 59 -
.../apache/doris/spark/sql/ScalaDorisRowRDD.scala | 53 -
.../doris/spark/sql/ScalaDorisRowValueReader.scala | 50 -
.../org/apache/doris/spark/sql/SchemaUtils.scala | 109 --
.../scala/org/apache/doris/spark/sql/Utils.scala | 155 ---
.../main/thrift/doris/DorisExternalService.thrift | 122 --
.../src/main/thrift/doris/Status.thrift | 66 -
.../src/main/thrift/doris/Types.thrift | 376 ------
.../doris/spark/rest/TestPartitionDefinition.java | 70 -
.../apache/doris/spark/rest/TestRestService.java | 327 -----
.../apache/doris/spark/rest/models/TestSchema.java | 40 -
.../doris/spark/serialization/TestRouting.java | 47 -
.../doris/spark/serialization/TestRowBatch.java | 440 -------
.../apache/doris/spark/sql/TestSchemaUtils.scala | 94 --
.../doris/spark/sql/TestSparkConnector.scala | 118 --
.../org/apache/doris/spark/sql/TestUtils.scala | 120 --
fe/fe-core/src/main/cup/sql_parser.cup | 25 +-
.../java/org/apache/doris/alter/AlterHandler.java | 221 ----
.../main/java/org/apache/doris/alter/AlterJob.java | 360 -----
.../java/org/apache/doris/alter/AlterJobV2.java | 2 +-
.../apache/doris/alter/DecommissionBackendJob.java | 369 ------
.../org/apache/doris/alter/DecommissionType.java | 13 +-
.../doris/alter/MaterializedViewHandler.java | 176 +--
.../java/org/apache/doris/alter/RollupJob.java | 1180 -----------------
.../apache/doris/alter/SchemaChangeHandler.java | 181 +--
.../org/apache/doris/alter/SchemaChangeJob.java | 1385 --------------------
.../java/org/apache/doris/alter/SystemHandler.java | 39 -
.../org/apache/doris/analysis/AnalyzeStmt.java | 30 +-
.../apache/doris/analysis/CreateFunctionStmt.java | 7 +-
.../doris/analysis/DecommissionBackendClause.java | 2 +-
.../java/org/apache/doris/analysis/FromClause.java | 4 +-
.../org/apache/doris/analysis/GroupingInfo.java | 10 +-
.../org/apache/doris/analysis/InlineViewRef.java | 7 +-
.../java/org/apache/doris/analysis/KillStmt.java | 6 +-
.../java/org/apache/doris/analysis/QueryStmt.java | 78 +-
.../org/apache/doris/analysis/RefreshDbStmt.java | 84 ++
.../apache/doris/analysis/RefreshTableStmt.java | 80 ++
.../java/org/apache/doris/analysis/SelectStmt.java | 3 +-
.../java/org/apache/doris/analysis/TableRef.java | 4 +
.../java/org/apache/doris/backup/BackupJob.java | 2 +-
.../java/org/apache/doris/catalog/Catalog.java | 124 +-
.../main/java/org/apache/doris/catalog/Column.java | 9 +
.../java/org/apache/doris/catalog/Database.java | 4 +
.../org/apache/doris/catalog/DatabaseProperty.java | 8 +-
.../java/org/apache/doris/catalog/FunctionSet.java | 221 ++--
.../org/apache/doris/catalog/IcebergProperty.java | 9 +
.../org/apache/doris/catalog/RefreshManager.java | 95 ++
.../main/java/org/apache/doris/catalog/Type.java | 33 +
.../org/apache/doris/clone/TabletSchedCtx.java | 8 +-
.../org/apache/doris/clone/TabletScheduler.java | 15 +
.../main/java/org/apache/doris/common/Config.java | 50 +-
.../org/apache/doris/common/FeMetaVersion.java | 4 +-
.../doris/common/LabelAlreadyUsedException.java | 13 +-
.../java/org/apache/doris/common/Log4jConfig.java | 6 +
.../apache/doris/common/proc/BackendsProcDir.java | 2 +-
.../org/apache/doris/common/proc/TransProcDir.java | 1 +
.../doris/external/iceberg/IcebergCatalogMgr.java | 19 +-
.../iceberg/IcebergTableCreationRecord.java | 15 +-
.../iceberg/IcebergTableCreationRecordMgr.java | 79 +-
.../doris/external/iceberg/util/IcebergUtils.java | 14 +-
.../apache/doris/http/rest/ConnectionAction.java | 2 +-
.../apache/doris/httpv2/rest/ConnectionAction.java | 4 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 58 +
.../doris/httpv2/rest/RestBaseController.java | 8 +-
.../doris/httpv2/util/StatementSubmitter.java | 7 +-
.../org/apache/doris/journal/JournalEntity.java | 15 -
.../doris/journal/local/LocalJournalCursor.java | 13 -
.../java/org/apache/doris/load/LoadChecker.java | 24 +-
.../doris/load/routineload/RoutineLoadManager.java | 52 +-
.../java/org/apache/doris/master/MasterImpl.java | 84 +-
.../java/org/apache/doris/metric/MetricRepo.java | 2 +-
.../org/apache/doris/mysql/nio/AcceptListener.java | 3 +-
.../java/org/apache/doris/persist/EditLog.java | 101 --
.../apache/doris/planner/DistributedPlanner.java | 14 -
.../apache/doris/planner/SingleNodePlanner.java | 7 +-
.../java/org/apache/doris/qe/ConnectContext.java | 5 +
.../java/org/apache/doris/qe/ConnectScheduler.java | 2 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 6 +
.../java/org/apache/doris/qe/QeProcessorImpl.java | 2 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 7 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 20 +-
.../org/apache/doris/qe/cache/CacheAnalyzer.java | 2 +-
.../apache/doris/service/FrontendServiceImpl.java | 133 +-
.../doris/statistics/MetaStatisticsTask.java | 20 +-
.../apache/doris/statistics/SQLStatisticsTask.java | 73 ++
.../SampleSQLStatisticsTask.java} | 40 +-
.../org/apache/doris/statistics/StatisticsJob.java | 79 ++
.../doris/statistics/StatisticsJobManager.java | 73 ++
.../doris/statistics/StatisticsJobScheduler.java | 63 +
.../apache/doris/statistics/StatisticsTask.java | 55 +
.../doris/statistics/StatisticsTaskResult.java | 31 +-
.../doris/statistics/StatisticsTaskScheduler.java | 93 ++
.../apache/doris/statistics/StatsCategoryDesc.java | 14 +-
.../doris/statistics/StatsGranularityDesc.java | 15 +-
.../org/apache/doris/statistics/StatsType.java | 17 +-
.../main/java/org/apache/doris/system/Backend.java | 2 +-
.../java/org/apache/doris/system/HeartbeatMgr.java | 61 +-
.../doris/transaction/DatabaseTransactionMgr.java | 274 +++-
.../doris/transaction/GlobalTransactionMgr.java | 64 +-
.../doris/transaction/PartitionCommitInfo.java | 12 +
.../apache/doris/transaction/TransactionState.java | 19 +-
.../doris/transaction/TransactionStatus.java | 7 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 1 +
.../apache/doris/analysis/GroupByClauseTest.java | 18 +-
.../java/org/apache/doris/catalog/CatalogTest.java | 50 +-
.../java/org/apache/doris/catalog/ColumnTest.java | 33 +-
.../java/org/apache/doris/catalog/FakeEditLog.java | 24 -
.../doris/clone/TabletReplicaTooSlowTest.java | 6 +-
.../org/apache/doris/planner/QueryPlanTest.java | 98 +-
.../doris/planner/TableFunctionPlanTest.java | 16 +-
.../org/apache/doris/qe/PartitionCacheTest.java | 21 +
.../java/org/apache/doris/qe/StmtExecutorTest.java | 12 +-
.../org/apache/doris/system/HeartbeatMgrTest.java | 53 +-
.../transaction/DatabaseTransactionMgrTest.java | 9 +-
.../doris/transaction/TransactionStateTest.java | 2 +-
fe/hive-udf/pom.xml | 130 ++
.../org/apache/doris/common/BitmapValueUtil.java | 43 +
.../java/org/apache/doris/udf/BitmapAndUDF.java | 75 ++
.../java/org/apache/doris/udf/BitmapCountUDF.java | 70 +
.../java/org/apache/doris/udf/BitmapOrUDF.java | 76 ++
.../java/org/apache/doris/udf/BitmapUnionUDAF.java | 132 ++
.../java/org/apache/doris/udf/BitmapXorUDF.java | 76 ++
.../java/org/apache/doris/udf/ToBitmapUDAF.java | 143 ++
fe/pom.xml | 1 +
gensrc/proto/olap_file.proto | 90 --
gensrc/script/doris_builtins_functions.py | 186 +--
gensrc/thrift/FrontendService.thrift | 19 +
gensrc/thrift/MetaStoreService.thrift | 157 ---
regression-test/conf/logback.xml | 43 +
.../conf/regression-conf.groovy | 35 +-
.../data/correctness/test_select_constant.out | 4 +
regression-test/data/demo/qt_action.out | 15 +
regression-test/data/demo/streamload_input.csv | 3 +
.../framework/README | 2 +-
.../framework}/checkstyle-apache-header.txt | 0
{fe => regression-test/framework}/checkstyle.xml | 0
regression-test/framework/pom.xml | 219 ++++
.../org/apache/doris/regression/Config.groovy | 259 ++++
.../apache/doris/regression/ConfigOptions.groovy | 200 +++
.../apache/doris/regression/RegressionTest.groovy | 189 +++
.../doris/regression/action/ExplainAction.groovy | 144 ++
.../regression/action/StreamLoadAction.groovy | 297 +++++
.../doris/regression/action/SuiteAction.groovy | 5 +-
.../doris/regression/action/TestAction.groovy | 151 +++
.../org/apache/doris/regression/suite/Suite.groovy | 196 +++
.../doris/regression/suite/SuiteContext.groovy | 107 ++
.../doris/regression/util/BytesInputStream.groovy | 66 +
.../doris/regression/util/CloseableIterator.groovy | 8 +-
.../apache/doris/regression/util/DataUtils.groovy | 47 +
.../apache/doris/regression/util/FileUtils.groovy | 19 +-
.../apache/doris/regression/util/JdbcUtils.groovy | 87 ++
.../doris/regression/util/OutputUtils.groovy | 275 ++++
.../apache/doris/regression/util/Recorder.groovy | 22 +-
.../doris/regression/util/ReusableIterator.groovy | 54 +-
.../apache/doris/regression/util/SuiteInfo.groovy | 16 +-
.../suites/correctness/test_select_constant.groovy | 1 +
regression-test/suites/demo/explain_action.groovy | 31 +
regression-test/suites/demo/qt_action.groovy | 26 +
regression-test/suites/demo/sql_action.groovy | 81 ++
.../suites/demo/streamLoad_action.groovy | 59 +
regression-test/suites/demo/test_action.groovy | 65 +
.../performance/test_streamload_perfomance.groovy | 27 +
run-regression-test.sh | 176 +++
samples/doris-demo/pom.xml | 1 +
.../demo/hdfs/MyForeachPartitionFunction.java | 6 +-
samples/doris-demo/udf-demo/pom.xml | 113 ++
.../java/org/apache/doris/udf/Application.java | 22 +-
.../java/org/apache/doris/udf/FunctionGrpc.java | 102 ++
.../src/main}/proto/function_service.proto | 0
.../udf-demo/src/main}/proto/types.proto | 0
thirdparty/CHANGELOG.md | 4 +
thirdparty/build-thirdparty.sh | 25 +
thirdparty/download-thirdparty.sh | 10 +-
thirdparty/vars.sh | 9 +-
849 files changed, 18180 insertions(+), 30834 deletions(-)
delete mode 100644 be/src/codegen/doris_ir.h
delete mode 100644 be/src/common/hdfs.h
delete mode 100644 be/src/exec/aggregation_node.cpp
delete mode 100644 be/src/exec/aggregation_node.h
delete mode 100644 be/src/exec/aggregation_node_ir.cpp
delete mode 100644 be/src/exec/hash_join_node_ir.cpp
delete mode 100644 be/src/exec/partitioned_aggregation_node_ir.cc
delete mode 100644 be/src/exec/scanner_ir.cpp
delete mode 100644 be/src/exec/union_node_ir.cpp
delete mode 100644 be/src/exprs/conditional_functions_ir.cpp
delete mode 100644 be/src/exprs/expr_ir.cpp
delete mode 100644 be/src/exprs/v_string_functions.h
create mode 100644 be/src/http/action/stream_load_2pc.cpp
copy be/src/http/action/{health_action.h => stream_load_2pc.h} (74%)
delete mode 100644 be/src/olap/olap_snapshot_converter.cpp
delete mode 100644 be/src/olap/olap_snapshot_converter.h
delete mode 100644 be/src/plugin/CMakeLists.txt
delete mode 100644 be/src/plugin/plugin.h
delete mode 100644 be/src/plugin/plugin_loader.cpp
delete mode 100644 be/src/plugin/plugin_loader.h
delete mode 100644 be/src/plugin/plugin_mgr.cpp
delete mode 100644 be/src/plugin/plugin_mgr.h
delete mode 100644 be/src/plugin/plugin_zip.cpp
delete mode 100644 be/src/plugin/plugin_zip.h
delete mode 100644 be/src/runtime/buffered_tuple_stream2_ir.cc
delete mode 100644 be/src/runtime/raw_value_ir.cpp
delete mode 100644 be/src/runtime/string_value_ir.cpp
delete mode 100644 be/src/udf/udf_ir.cpp
delete mode 100644 be/src/util/hash_util_ir.cpp
copy be/src/util/{priority_thread_pool.hpp =>
priority_work_stealing_thread_pool.hpp} (57%)
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_approx_count_distinct.cpp
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_approx_count_distinct.h
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_group_concat.cpp
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_group_concat.h
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_percentile_approx.cpp
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_percentile_approx.h
create mode 100644 be/src/vec/aggregate_functions/aggregate_function_topn.cpp
create mode 100644 be/src/vec/aggregate_functions/aggregate_function_topn.h
create mode 100644 be/src/vec/data_types/data_type_hll.cpp
copy be/src/vec/data_types/{data_type_bitmap.h => data_type_hll.h} (75%)
copy
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
=> be/src/vec/functions/function_convert_tz.cpp (77%)
create mode 100644 be/src/vec/functions/function_convert_tz.h
create mode 100644 be/src/vec/functions/function_datetime_floor_ceil.cpp
create mode 100644 be/src/vec/functions/function_multi_same_args.h
create mode 100644 be/src/vec/functions/least_greast.cpp
create mode 100644 be/src/vec/sink/vmysql_table_sink.cpp
copy be/src/{runtime/export_sink.h => vec/sink/vmysql_table_sink.h} (51%)
create mode 100644 be/src/vec/sink/vmysql_table_writer.cpp
copy be/src/{runtime/mysql_table_writer.h => vec/sink/vmysql_table_writer.h}
(64%)
create mode 100644 be/src/vec/utils/template_helpers.hpp
delete mode 100644 be/test/olap/olap_snapshot_converter_test.cpp
delete mode 100644
be/test/olap/test_data/converter_test_data/data/0/15007/368169781/olap_header.json
delete mode 100644 be/test/olap/test_data/header.txt
create mode 100644 be/test/vec/core/column_nullable_test.cpp
create mode 100644 docs/.vuepress/public/images/staging-repositories.png
delete mode 100644 docs/.vuepress/public/images/staging_repo.png
rename docs/en/community/{ =>
how-to-contribute}/commit-format-specification.md (99%)
rename docs/en/community/{ => how-to-contribute}/committer-guide.md (100%)
rename docs/en/community/{ => how-to-contribute}/how-to-contribute.md (88%)
rename docs/en/community/{ => how-to-contribute}/pull-request.md (100%)
delete mode 100644 docs/en/community/how-to-deploy-to-maven.md
create mode 100644 docs/en/community/release-and-verify/release-complete.md
create mode 100644
docs/en/community/release-and-verify/release-doris-connectors.md
create mode 100644 docs/en/community/release-and-verify/release-doris-core.md
create mode 100644 docs/en/community/release-and-verify/release-prepare.md
create mode 100644 docs/en/community/release-and-verify/release-verify.md
delete mode 100644 docs/en/community/release-process.md
rename docs/en/community/{members.md => team.md} (97%)
delete mode 100644 docs/en/community/verify-apache-release.md
create mode 100644 docs/en/extending-doris/hive-bitmap-udf.md
rename docs/en/extending-doris/udf/{user-defined-function.md =>
native-user-defined-function.md} (99%)
create mode 100644 docs/en/extending-doris/udf/remote-user-defined-function.md
rename docs/en/sql-reference/sql-functions/{string-functions =>
aggregate-functions}/group_concat.md (86%)
rename docs/en/sql-reference/sql-functions/{string-functions =>
json-functions}/get_json_double.md (100%)
rename docs/en/sql-reference/sql-functions/{string-functions =>
json-functions}/get_json_int.md (100%)
rename docs/en/sql-reference/sql-functions/{string-functions =>
json-functions}/get_json_string.md (100%)
rename docs/en/sql-reference/sql-functions/{string-functions =>
json-functions}/json_array.md (100%)
rename docs/en/sql-reference/sql-functions/{string-functions =>
json-functions}/json_object.md (100%)
rename docs/en/sql-reference/sql-functions/{string-functions =>
json-functions}/json_quote.md (100%)
create mode 100644 docs/en/sql-reference/sql-functions/math-functions/pmod.md
create mode 100644 docs/en/sql-reference/sql-statements/Data
Definition/REFRESH DATABASE.md
create mode 100644 docs/en/sql-reference/sql-statements/Data
Definition/REFRESH TABLE.md
rename docs/zh-CN/community/{ =>
how-to-contribute}/commit-format-specification.md (98%)
rename docs/zh-CN/community/{ => how-to-contribute}/committer-guide.md (100%)
rename docs/zh-CN/community/{ => how-to-contribute}/how-to-contribute.md (86%)
rename docs/zh-CN/community/{ => how-to-contribute}/pull-request.md (100%)
delete mode 100644 docs/zh-CN/community/how-to-deploy-to-maven.md
create mode 100644 docs/zh-CN/community/release-and-verify/release-complete.md
create mode 100644
docs/zh-CN/community/release-and-verify/release-doris-connectors.md
create mode 100644
docs/zh-CN/community/release-and-verify/release-doris-core.md
create mode 100644 docs/zh-CN/community/release-and-verify/release-prepare.md
rename docs/zh-CN/community/{verify-apache-release.md =>
release-and-verify/release-verify.md} (61%)
delete mode 100644 docs/zh-CN/community/release-process.md
rename docs/zh-CN/community/{members.md => team.md} (97%)
create mode 100644 docs/zh-CN/developer-guide/regression-testing.md
create mode 100644 docs/zh-CN/extending-doris/hive-bitmap-udf.md
rename docs/zh-CN/extending-doris/udf/{user-defined-function.md =>
native-user-defined-function.md} (99%)
create mode 100644
docs/zh-CN/extending-doris/udf/remote-user-defined-function.md
copy docs/zh-CN/sql-reference/sql-functions/{string-functions =>
aggregate-functions}/group_concat.md (86%)
rename docs/zh-CN/sql-reference/sql-functions/{string-functions =>
json-functions}/get_json_double.md (100%)
rename docs/zh-CN/sql-reference/sql-functions/{string-functions =>
json-functions}/get_json_int.md (100%)
rename docs/zh-CN/sql-reference/sql-functions/{string-functions =>
json-functions}/get_json_string.md (100%)
rename docs/zh-CN/sql-reference/sql-functions/{string-functions =>
json-functions}/json_array.md (100%)
rename docs/zh-CN/sql-reference/sql-functions/{string-functions =>
json-functions}/json_object.md (100%)
rename docs/zh-CN/sql-reference/sql-functions/{string-functions =>
json-functions}/json_quote.md (100%)
rename
docs/zh-CN/sql-reference/sql-functions/{string-functions/group_concat.md =>
math-functions/pmod.md} (50%)
create mode 100644 docs/zh-CN/sql-reference/sql-statements/Data
Definition/REFRESH DATABASE.md
create mode 100644 docs/zh-CN/sql-reference/sql-statements/Data
Definition/REFRESH TABLE.md
delete mode 100644 extension/flink-doris-connector/build.sh
delete mode 100644 extension/flink-doris-connector/pom.xml
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisSink.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/GenericDorisSinkFunction.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisException.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendRow.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisStreamLoad.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/util/ErrorMessages.java
delete mode 100644
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/util/IOUtils.java
delete mode 100644
extension/flink-doris-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644
extension/flink-doris-connector/src/main/resources/log4j.properties
delete mode 100644
extension/flink-doris-connector/src/main/scala/org/apache/doris/flink/datastream/ScalaValueReader.scala
delete mode 100644
extension/flink-doris-connector/src/main/thrift/doris/DorisExternalService.thrift
delete mode 100644
extension/flink-doris-connector/src/main/thrift/doris/Status.thrift
delete mode 100644
extension/flink-doris-connector/src/main/thrift/doris/Types.thrift
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisOutPutFormatExample.java
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSinkExample.java
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceDataStream.java
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceExample.java
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisSourceSinkExample.java
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisStreamSinkExample.java
delete mode 100644
extension/flink-doris-connector/src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java
delete mode 100755 extension/spark-doris-connector/build.sh
delete mode 100644 extension/spark-doris-connector/pom.xml
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/CachedDorisStreamLoadClient.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/DorisStreamLoad.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/ConfigurationOptions.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/Settings.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/SparkSettings.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/exception/ConnectedFailedException.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/exception/DorisException.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/exception/DorisInternalException.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/exception/StreamLoadException.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Backend.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/BackendRow.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/BackendV2.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Field.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/RespContent.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Schema.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Tablet.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/Routing.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/util/ErrorMessages.java
delete mode 100644
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/util/IOUtils.java
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/package.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/rdd/AbstractDorisRDD.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/rdd/AbstractDorisRDDIterator.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/rdd/DorisSpark.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/rdd/ScalaDorisRDD.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/rdd/ScalaValueReader.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisStreamLoadSink.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisWriterOption.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/ScalaDorisRow.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/ScalaDorisRowRDD.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/ScalaDorisRowValueReader.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
delete mode 100644
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala
delete mode 100644
extension/spark-doris-connector/src/main/thrift/doris/DorisExternalService.thrift
delete mode 100644
extension/spark-doris-connector/src/main/thrift/doris/Status.thrift
delete mode 100644
extension/spark-doris-connector/src/main/thrift/doris/Types.thrift
delete mode 100644
extension/spark-doris-connector/src/test/java/org/apache/doris/spark/rest/TestPartitionDefinition.java
delete mode 100644
extension/spark-doris-connector/src/test/java/org/apache/doris/spark/rest/TestRestService.java
delete mode 100644
extension/spark-doris-connector/src/test/java/org/apache/doris/spark/rest/models/TestSchema.java
delete mode 100644
extension/spark-doris-connector/src/test/java/org/apache/doris/spark/serialization/TestRouting.java
delete mode 100644
extension/spark-doris-connector/src/test/java/org/apache/doris/spark/serialization/TestRowBatch.java
delete mode 100644
extension/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala
delete mode 100644
extension/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSparkConnector.scala
delete mode 100644
extension/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestUtils.scala
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/alter/AlterJob.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/alter/DecommissionBackendJob.java
rename
extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisWriterOptionKeys.scala
=> fe/fe-core/src/main/java/org/apache/doris/alter/DecommissionType.java (74%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeJob.java
rename be/src/exec/partitioned_hash_table_ir.cc =>
fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyzeStmt.java (65%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/RefreshDbStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/RefreshTableStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/RefreshManager.java
rename
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java
=>
fe/fe-core/src/main/java/org/apache/doris/statistics/MetaStatisticsTask.java
(62%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/SQLStatisticsTask.java
copy
fe/fe-core/src/main/java/org/apache/doris/{analysis/DecommissionBackendClause.java
=> statistics/SampleSQLStatisticsTask.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJobManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJobScheduler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTask.java
rename
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Backend.java
=>
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTaskResult.java
(59%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTaskScheduler.java
copy
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java
=> fe/fe-core/src/main/java/org/apache/doris/statistics/StatsCategoryDesc.java
(77%)
copy
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
=>
fe/fe-core/src/main/java/org/apache/doris/statistics/StatsGranularityDesc.java
(73%)
rename
extension/spark-doris-connector/src/test/java/org/apache/doris/spark/sql/ExpectedExceptionTest.java
=> fe/fe-core/src/main/java/org/apache/doris/statistics/StatsType.java (79%)
create mode 100644 fe/hive-udf/pom.xml
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/common/BitmapValueUtil.java
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapAndUDF.java
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapCountUDF.java
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapOrUDF.java
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapUnionUDAF.java
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapXorUDF.java
create mode 100644
fe/hive-udf/src/main/java/org/apache/doris/udf/ToBitmapUDAF.java
delete mode 100644 gensrc/thrift/MetaStoreService.thrift
create mode 100644 regression-test/conf/logback.xml
copy be/src/exec/schema_scanner/schema_dummy_scanner.h =>
regression-test/conf/regression-conf.groovy (55%)
create mode 100644 regression-test/data/correctness/test_select_constant.out
create mode 100644 regression-test/data/demo/qt_action.out
create mode 100644 regression-test/data/demo/streamload_input.csv
rename
extension/spark-doris-connector/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister
=> regression-test/framework/README (94%)
copy {fe => regression-test/framework}/checkstyle-apache-header.txt (100%)
copy {fe => regression-test/framework}/checkstyle.xml (100%)
create mode 100644 regression-test/framework/pom.xml
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/Config.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/ConfigOptions.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/RegressionTest.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/action/ExplainAction.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy
rename
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java
=>
regression-test/framework/src/main/groovy/org/apache/doris/regression/action/SuiteAction.groovy
(88%)
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/action/TestAction.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/SuiteContext.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/BytesInputStream.groovy
rename
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/exception/ShouldNeverHappenException.java
=>
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/CloseableIterator.groovy
(83%)
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/DataUtils.groovy
rename
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java
=>
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/FileUtils.groovy
(69%)
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/JdbcUtils.groovy
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/OutputUtils.groovy
rename
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java
=>
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/Recorder.groovy
(64%)
rename
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/PropertiesSettings.java
=>
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/ReusableIterator.groovy
(51%)
rename
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
=>
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/SuiteInfo.groovy
(71%)
create mode 100644
regression-test/suites/correctness/test_select_constant.groovy
create mode 100644 regression-test/suites/demo/explain_action.groovy
create mode 100644 regression-test/suites/demo/qt_action.groovy
create mode 100644 regression-test/suites/demo/sql_action.groovy
create mode 100644 regression-test/suites/demo/streamLoad_action.groovy
create mode 100644 regression-test/suites/demo/test_action.groovy
create mode 100644
regression-test/suites/performance/test_streamload_perfomance.groovy
create mode 100755 run-regression-test.sh
create mode 100644 samples/doris-demo/udf-demo/pom.xml
rename
extension/spark-doris-connector/src/main/java/org/apache/doris/spark/exception/IllegalArgumentException.java
=>
samples/doris-demo/udf-demo/src/main/java/org/apache/doris/udf/Application.java
(68%)
create mode 100644
samples/doris-demo/udf-demo/src/main/java/org/apache/doris/udf/FunctionGrpc.java
copy {gensrc =>
samples/doris-demo/udf-demo/src/main}/proto/function_service.proto (100%)
copy {gensrc => samples/doris-demo/udf-demo/src/main}/proto/types.proto (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
