This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch dev_join
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 45d1d16f3e9 update dev_join to pre calculate bucket num (#25663)
omit dbd3454abe4 support batch size (#25629)
omit c3089031635 update rf
omit 032555667fb merge block to single block on join/set node
add b0e0a0569a3 [Fix](row store) Real default value should be used instead
of default… (#25230)
add 6f6264693ff [fix](Nereids) can't choosing best plan for join that
could only broadcast (#25511)
add ef9cbc4c64e [enhancement](priv) Clarify ccr releated
FrontendServiceImpl call privs (#25530)
add 64aeeb971b5 [Fix](partial-update) Correct the alignment process when
the table has sequence column and add cases (#25346)
add 6cb947f72b2 [refactor](unused code) delete unused method from field.h
(#25554)
add d2400d1d7bf [feature](profile) profilev2 distinguish Sink and Operator
in pipelineX (#25491)
add db16a149704 [fix](backup) fix backup fail on s3 (#25496)
add 76abbfc5556 [fix](mvn source) fix audit compile java-cup and
cup-maven-plugin not found (#25564)
add 0ec537edef4 [fix](column-id) fix null conn ctx in column id flusher
and parser for `database` field in corresponding show stmt (#25393)
add 8a8e6edba98 [enhancement](stats) Unify sample algorithm between olap
table and external table (#25472)
add 62d06584f1e [feature](fe) add function 'BitmapAgg' in nereids (#25508)
add 0533911275b [Enhance](regression)change external default docker list
(#25573)
add c77590414ea [fix](pipeline)fix case (#25567)
add 80e5e722024 [fix](scanner) coredump caused by
'prune_predicates_by_zone_map' (#25555)
add e4a83a22d14 [opt](error msg) Make data codec error clearly when load
csv data can't display (#25540)
add 85e83b9c6c5 [fix](auth)fix not check udf auth in nereids (#25541)
add ea97f2d6e51 [refactor](nereids)make enable_stats session var (#25550)
add 9e07291e65a [fix](stats) internal stats table tablet replica num not
update as expected (#25563)
add 2ddd2e50797 [feature](Nereids) add map_agg function (#25246)
add 46158a6555a [tpcds-tools](nereids) remove cascades specific control
for global config (#25595)
add 9c9fc84f399 [feature](merge-cloud) Abstract BaseTablet for CloudTablet
(#24929)
add 2a442972a82 [Fix](merge-on-write) Fix some bugs about sequence column
(#24915)
add c21eb315b06 [feature](thrift api) support expr in MemoryScratchSink
and make arrow::Schema recalculate with block info (#24603)
add 32fc8a17998 [chore](compaction) Do not print the stack trace when the
compaction task already exists (#25597)
add 11fecafb749 [fix](move-memtable) fallback if target table contains
inverted index (#25498)
add dbf57876823 [fix](be) Make DorisCallOnce's function exception-safe
(#25579)
add 5b814e6e653 [cases](regression-test) Add create and drop S3 repository
test (#25568)
add 45178f5664d [improvement](disk balance) impr disk rebalancer sched
with partition rebalancer (#25549)
add 63c89df4741 [enhencement](RowsetWriter) Don't delete files when beta
rowset writer destructed (#25578)
add 8d65a627058 [Fix](show-frontends-disk)Fix NPE and macOS compatibility
(#25565)
add 4752b800b2d [typo](doc)update config (#25425)
add fcf7bdc9e0e [typo](docs) Rename Import Advanced to CN Version (#25374)
add b45f501e511 [improvement](nereids) Support aggregate functions without
from clause (#25500)
add ed713c2e2d6 [FIX](func) fix count distinct do not support
arr/map/struct (#25483)
add 3d1206d3259 [date](fix) modify push-down predicate for datev1 type
(#25571)
add e77b98be883 [fix](months_diff) fix wrong result of months_diff (#25577)
add 159be51ea6a [bugfix](schema_change) Fix the coredump when doubly write
during schema change (#22557)
add 23535824934 [enhancement](load) support for broker load, routine load,
mysql load and add docs (#25528)
add d0d9c4267dd [fix](move-memtable) fix use-after-free in load stream
stub (#25618)
add 68eaba7220f [DOC](fix) fix hyperlink to create tpch table (#25561)
add 4d2e7d7c86b [improvement](statistics)Set min max to NULL when collect
stats with sample (#25593)
add 54780c62e0d [improvement](executor)Using cgroup to implement cpu hard
limit (#25489)
add 7385602b190 [bug](rf) fix only min/max rf return error when has remote
target (#25588)
add b0e70bd02bc [fix](pipelineX) fix error set delta_urls (#25631)
add fa5dd61563f [feature](pipelineX) operator id use negative numbers
(#25529)
add b964ab76b33 [refactor](shuffle) Simplify hash partitioning strategy
(#25596)
add 8b5fd616321 [pipelineX](profile) Add pending finish dependency timer
(#25635)
add a42536efc11 [feature](pipelineX) release dependency when task close
(#25633)
add 9ea8efe5fae [coverage](fe)add jacoco coverage option on start_fe.sh
(#25598)
add 32fe78511a8 [typo](doc) update spark connector two phase commit option
doc (#24458)
add 4006c7cd1f2 [regression-test](test) enable some cases (#25183)
add 0510d548c65 [FeMeta](function) write function nullable mode info
(#25535)
new 2e0778a3d87 merge block to single block on join/set node
new d15c3f064a2 update rf
new a0d727cccac support batch size (#25629)
new 16a2f7d0907 update dev_join to pre calculate bucket num (#25663)
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 (45d1d16f3e9)
\
N -- N -- N refs/heads/dev_join (16a2f7d0907)
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 4 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:
be/CMakeLists.txt | 3 +
be/src/agent/cgroup_cpu_ctl.cpp | 25 ++-
be/src/agent/cgroup_cpu_ctl.h | 23 +-
be/src/agent/task_worker_pool.cpp | 19 +-
be/src/cloud/CMakeLists.txt | 24 ++
.../task_group_manager.h => cloud/config.cpp} | 28 +--
.../task_group_manager.h => cloud/config.h} | 28 +--
be/src/common/status.h | 13 ++
be/src/exec/data_sink.cpp | 21 +-
be/src/exec/data_sink.h | 4 +
be/src/exec/rowid_fetcher.cpp | 5 +-
be/src/exec/tablet_info.cpp | 69 +++---
be/src/exprs/bloom_filter_func.h | 5 -
be/src/exprs/runtime_filter.cpp | 19 +-
be/src/exprs/runtime_filter.h | 4 +-
be/src/exprs/runtime_filter_slots_cross.h | 5 +-
be/src/http/action/compaction_action.cpp | 12 +-
be/src/olap/base_compaction.cpp | 12 +-
be/src/olap/base_tablet.cpp | 47 ++--
be/src/olap/base_tablet.h | 137 ++++--------
be/src/olap/compaction.cpp | 20 +-
be/src/olap/comparison_predicate.h | 2 +
be/src/olap/cumulative_compaction.cpp | 10 +-
be/src/olap/cumulative_compaction_policy.cpp | 4 +-
.../cumulative_compaction_time_series_policy.cpp | 2 +-
be/src/olap/data_dir.cpp | 15 --
be/src/olap/data_dir.h | 9 -
be/src/olap/delta_writer.cpp | 15 +-
be/src/olap/delta_writer.h | 2 -
be/src/olap/field.h | 68 ------
be/src/olap/full_compaction.cpp | 2 +-
be/src/olap/merger.cpp | 45 ++--
be/src/olap/olap_server.cpp | 12 +-
be/src/olap/push_handler.cpp | 30 +--
be/src/olap/reader.cpp | 6 +-
be/src/olap/reader.h | 9 +-
be/src/olap/row_cursor.cpp | 28 ---
be/src/olap/row_cursor.h | 3 -
be/src/olap/rowset/beta_rowset_writer.cpp | 25 ++-
.../rowset/rowset_fwd.h} | 31 +--
be/src/olap/rowset/rowset_meta.cpp | 154 +++++++++++++
be/src/olap/rowset/rowset_meta.h | 152 ++-----------
be/src/olap/rowset/rowset_meta_manager.cpp | 3 +-
be/src/olap/rowset/rowset_meta_manager.h | 3 +-
be/src/olap/rowset/rowset_reader.h | 6 +-
be/src/olap/rowset/rowset_writer_context.h | 2 +-
be/src/olap/rowset/segcompaction.cpp | 5 +-
be/src/olap/rowset/segment_creator.cpp | 2 +-
be/src/olap/rowset/segment_v2/segment.cpp | 38 +++-
be/src/olap/rowset/segment_v2/segment.h | 4 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 15 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 2 +-
be/src/olap/rowset/segment_v2/segment_writer.cpp | 40 ++--
be/src/olap/rowset/segment_v2/segment_writer.h | 8 +-
be/src/olap/rowset/vertical_beta_rowset_writer.cpp | 12 +-
be/src/olap/rowset_builder.cpp | 212 +++++++++++-------
be/src/olap/rowset_builder.h | 32 ++-
be/src/olap/schema_change.cpp | 47 ++--
be/src/olap/single_replica_compaction.cpp | 21 +-
be/src/olap/snapshot_manager.cpp | 2 +-
be/src/olap/tablet.cpp | 156 ++++++++-----
be/src/olap/tablet.h | 78 ++-----
.../task_group_manager.h => olap/tablet_fwd.h} | 34 +--
be/src/olap/tablet_manager.cpp | 32 +--
be/src/olap/tablet_manager.h | 3 -
be/src/olap/tablet_meta.cpp | 27 +--
be/src/olap/tablet_meta.h | 7 -
be/src/olap/tablet_schema.cpp | 5 +-
be/src/olap/tablet_schema.h | 4 +
be/src/olap/task/engine_batch_load_task.cpp | 4 +-
be/src/olap/task/engine_checksum_task.cpp | 2 +-
be/src/olap/task/engine_clone_task.cpp | 10 +-
be/src/olap/task/engine_publish_version_task.cpp | 4 +-
be/src/olap/task/engine_storage_migration_task.cpp | 4 +-
be/src/olap/task/index_builder.cpp | 2 +-
be/src/olap/txn_manager.cpp | 18 +-
be/src/olap/txn_manager.h | 6 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 123 ++++-------
be/src/pipeline/exec/exchange_sink_operator.h | 24 +-
be/src/pipeline/exec/join_probe_operator.cpp | 2 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 5 +-
be/src/pipeline/exec/olap_table_sink_operator.h | 2 +
be/src/pipeline/exec/result_file_sink_operator.cpp | 1 +
be/src/pipeline/exec/scan_operator.cpp | 6 -
be/src/pipeline/pipeline_fragment_context.cpp | 23 +-
be/src/pipeline/pipeline_fragment_context.h | 1 +
be/src/pipeline/pipeline_task.h | 3 +
be/src/pipeline/pipeline_x/operator.cpp | 20 +-
be/src/pipeline/pipeline_x/operator.h | 11 +-
.../pipeline_x/pipeline_x_fragment_context.h | 9 +-
be/src/pipeline/pipeline_x/pipeline_x_task.h | 5 +
be/src/pipeline/task_scheduler.cpp | 14 +-
be/src/pipeline/task_scheduler.h | 6 +-
be/src/runtime/descriptors.cpp | 7 +-
be/src/runtime/descriptors.h | 6 +
be/src/runtime/exec_env.cpp | 14 ++
be/src/runtime/exec_env.h | 18 +-
be/src/runtime/exec_env_init.cpp | 30 +--
be/src/runtime/fragment_mgr.cpp | 28 ++-
be/src/runtime/load_stream_writer.cpp | 4 +-
be/src/runtime/primitive_type.cpp | 6 +
be/src/runtime/query_context.h | 15 ++
be/src/runtime/task_group/task_group.cpp | 11 +-
be/src/runtime/task_group/task_group.h | 3 +-
be/src/runtime/task_group/task_group_manager.cpp | 72 ++++++
be/src/runtime/task_group/task_group_manager.h | 26 +++
be/src/service/backend_service.cpp | 4 +-
be/src/service/point_query_executor.cpp | 10 +-
be/src/service/point_query_executor.h | 3 +
be/src/util/arrow/block_convertor.cpp | 2 +
be/src/util/arrow/row_batch.cpp | 18 ++
be/src/util/arrow/row_batch.h | 4 +
be/src/util/once.h | 3 +-
be/src/vec/columns/column.h | 5 +-
be/src/vec/columns/column_array.cpp | 15 +-
be/src/vec/columns/column_array.h | 5 +-
be/src/vec/columns/column_const.cpp | 9 +-
be/src/vec/columns/column_const.h | 7 +-
be/src/vec/columns/column_decimal.cpp | 7 +-
be/src/vec/columns/column_decimal.h | 9 +-
be/src/vec/columns/column_map.cpp | 8 +-
be/src/vec/columns/column_map.h | 5 +-
be/src/vec/columns/column_nullable.cpp | 12 +-
be/src/vec/columns/column_nullable.h | 5 +-
be/src/vec/columns/column_string.cpp | 5 +-
be/src/vec/columns/column_string.h | 5 +-
be/src/vec/columns/column_struct.cpp | 7 +-
be/src/vec/columns/column_struct.h | 5 +-
be/src/vec/columns/column_vector.cpp | 5 +-
be/src/vec/columns/column_vector.h | 7 +-
be/src/vec/columns/predicate_column.h | 12 -
be/src/vec/common/hash_table/hash_map_context.h | 8 +-
be/src/vec/data_types/data_type.h | 2 +-
be/src/vec/data_types/data_type_agg_state.h | 6 +-
be/src/vec/data_types/data_type_array.h | 8 +-
be/src/vec/data_types/data_type_bitmap.h | 4 +-
be/src/vec/data_types/data_type_date.h | 4 +-
be/src/vec/data_types/data_type_date_time.h | 4 +-
be/src/vec/data_types/data_type_decimal.h | 22 +-
.../vec/data_types/data_type_fixed_length_object.h | 4 +-
be/src/vec/data_types/data_type_hll.h | 2 +-
be/src/vec/data_types/data_type_jsonb.h | 4 +-
be/src/vec/data_types/data_type_map.h | 7 +-
be/src/vec/data_types/data_type_nothing.h | 4 +-
be/src/vec/data_types/data_type_nullable.h | 6 +-
be/src/vec/data_types/data_type_number_base.h | 34 +--
be/src/vec/data_types/data_type_object.h | 5 +-
be/src/vec/data_types/data_type_quantilestate.h | 4 +-
be/src/vec/data_types/data_type_string.h | 4 +-
be/src/vec/data_types/data_type_struct.h | 11 +-
be/src/vec/data_types/data_type_time.h | 8 +-
be/src/vec/data_types/data_type_time_v2.h | 8 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 8 +-
be/src/vec/exec/jni_connector.cpp | 2 +-
be/src/vec/exec/join/vnested_loop_join_node.cpp | 10 +-
be/src/vec/exec/scan/new_olap_scan_node.cpp | 12 +-
be/src/vec/exec/scan/new_olap_scanner.cpp | 7 +-
be/src/vec/exec/scan/new_olap_scanner.h | 4 +-
be/src/vec/exec/scan/pip_scanner_context.h | 10 +-
be/src/vec/exec/scan/scanner_context.cpp | 4 +
be/src/vec/exec/scan/scanner_context.h | 5 +
be/src/vec/exec/scan/scanner_scheduler.cpp | 16 +-
be/src/vec/exec/scan/scanner_scheduler.h | 60 +++++
be/src/vec/exec/scan/vscan_node.cpp | 6 -
be/src/vec/exprs/vectorized_agg_fn.cpp | 5 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 2 +-
be/src/vec/jsonb/serialize.cpp | 22 +-
be/src/vec/jsonb/serialize.h | 4 +-
be/src/vec/olap/block_reader.cpp | 13 +-
be/src/vec/olap/block_reader.h | 8 +-
be/src/vec/olap/olap_data_convertor.cpp | 3 +-
be/src/vec/olap/vertical_block_reader.cpp | 14 +-
be/src/vec/olap/vertical_block_reader.h | 8 +-
be/src/vec/runtime/partitioner.cpp | 70 ++++++
be/src/vec/runtime/partitioner.h | 105 +++++++++
be/src/vec/runtime/vdatetime_value.h | 26 ++-
be/src/vec/sink/load_stream_stub.cpp | 24 +-
be/src/vec/sink/load_stream_stub.h | 71 +++---
be/src/vec/sink/vdata_stream_sender.cpp | 89 ++------
be/src/vec/sink/vdata_stream_sender.h | 25 +--
be/src/vec/sink/vmemory_scratch_sink.cpp | 17 +-
be/src/vec/sink/vtablet_sink_v2.cpp | 2 +-
be/test/olap/cumulative_compaction_policy_test.cpp | 1 +
...mulative_compaction_time_series_policy_test.cpp | 1 +
be/test/olap/delete_handler_test.cpp | 64 +-----
be/test/olap/memtable_memory_limiter_test.cpp | 1 +
be/test/olap/ordered_data_compaction_test.cpp | 1 +
be/test/olap/rowid_conversion_test.cpp | 1 +
be/test/olap/rowset/rowset_meta_test.cpp | 1 +
be/test/olap/tablet_test.cpp | 1 +
be/test/olap/timestamped_version_tracker_test.cpp | 1 +
be/test/runtime/load_stream_test.cpp | 1 +
be/test/vec/columns/column_hash_func_test.cpp | 26 +--
be/test/vec/exec/vwal_scanner_test.cpp | 1 +
be/test/vec/jsonb/serialize_test.cpp | 9 +-
be/test/vec/olap/vertical_compaction_test.cpp | 1 +
bin/start_fe.sh | 13 +-
docker/thirdparties/run-thirdparties-docker.sh | 2 +-
docs/dev.json | 6 +-
docs/en/docs/admin-manual/config/fe-config.md | 8 +-
.../import/import-way/stream-load-manual.md | 8 +
.../update-delete/sequence-column-manual.md | 2 +-
docs/en/docs/ecosystem/spark-doris-connector.md | 1 +
.../Load/BROKER-LOAD.md | 8 +
.../Load/CREATE-ROUTINE-LOAD.md | 6 +
.../Load/MYSQL-LOAD.md | 4 +
.../Load/STREAM-LOAD.md | 4 +
.../SHOW-CONVERT-LIGHR-SCHEMA-CHANGE-PROCESS.md | 4 +-
docs/sidebars.json | 3 +-
docs/zh-CN/docs/admin-manual/config/fe-config.md | 8 +-
docs/zh-CN/docs/benchmark/tpch.md | 2 +-
.../import/import-advanced/min-load-replica-num.md | 4 +-
.../import/import-way/stream-load-manual.md | 8 +
.../update-delete/sequence-column-manual.md | 2 +-
docs/zh-CN/docs/ecosystem/spark-doris-connector.md | 1 +
.../Load/BROKER-LOAD.md | 8 +
.../Load/CREATE-ROUTINE-LOAD.md | 6 +
.../Load/MYSQL-LOAD.md | 4 +
.../Load/STREAM-LOAD.md | 4 +
.../SHOW-CONVERT-LIGHT-SCHEMA-CHANGE-PROCESS.md | 4 +-
.../main/java/org/apache/doris/common/Config.java | 6 -
.../org/apache/doris/common/FeMetaVersion.java | 4 +-
.../java/org/apache/doris/common/io/DiskUtils.java | 97 +++++---
fe/fe-core/src/main/cup/sql_parser.cup | 2 +-
.../doris/alter/AlterLightSchChangeHelper.java | 12 +-
.../apache/doris/alter/SchemaChangeHandler.java | 5 +
.../doris/analysis/AlterColumnStatsStmt.java | 3 +-
.../apache/doris/analysis/AlterTableStatsStmt.java | 3 +-
.../org/apache/doris/analysis/AnalyzeTblStmt.java | 3 +-
.../doris/analysis/CreateRoutineLoadStmt.java | 20 ++
.../org/apache/doris/analysis/DataDescription.java | 19 +-
.../org/apache/doris/analysis/DropStatsStmt.java | 3 +-
.../apache/doris/analysis/FunctionCallExpr.java | 5 +-
.../java/org/apache/doris/analysis/LoadStmt.java | 4 +
.../apache/doris/analysis/NativeInsertStmt.java | 19 ++
.../org/apache/doris/analysis/ShowAnalyzeStmt.java | 3 +-
.../doris/analysis/ShowAnalyzeTaskStatus.java | 4 +-
.../org/apache/doris/analysis/SlotDescriptor.java | 6 +-
.../java/org/apache/doris/backup/BackupJob.java | 6 +-
.../java/org/apache/doris/backup/RestoreJob.java | 6 +-
.../doris/catalog/BuiltinAggregateFunctions.java | 4 +
.../main/java/org/apache/doris/catalog/Column.java | 2 +-
.../java/org/apache/doris/catalog/Function.java | 5 +
.../org/apache/doris/catalog/FunctionRegistry.java | 4 +-
.../doris/catalog/InternalSchemaInitializer.java | 4 +-
.../org/apache/doris/clone/DiskRebalancer.java | 14 +-
.../apache/doris/clone/PartitionRebalancer.java | 12 +
.../org/apache/doris/clone/TabletScheduler.java | 4 +
.../doris/common/util/ProfileStatistics.java | 122 +++++++++--
.../apache/doris/common/util/RuntimeProfile.java | 4 +-
.../datasource/property/PropertyConverter.java | 16 +-
.../org/apache/doris/fs/remote/S3FileSystem.java | 9 +-
.../apache/doris/load/loadv2/MysqlLoadManager.java | 12 +
.../doris/load/routineload/RoutineLoadJob.java | 7 +-
.../doris/nereids/jobs/executor/Analyzer.java | 4 +-
.../doris/nereids/minidump/MinidumpUtils.java | 4 +-
.../nereids/properties/RequestPropertyDeriver.java | 8 +-
.../org/apache/doris/nereids/rules/RuleType.java | 1 +
.../doris/nereids/rules/analysis/BindSink.java | 24 +-
.../nereids/rules/analysis/CheckAnalysis.java | 1 -
.../analysis/OneRowRelationExtractAggregate.java | 68 ++++++
.../rules/analysis/ProjectToGlobalAggregate.java | 35 +--
.../rules/SimplifyComparisonPredicate.java | 10 -
.../doris/nereids/rules/rewrite/ColumnPruning.java | 3 +
.../doris/nereids/stats/StatsCalculator.java | 13 +-
.../trees/expressions/functions/agg/BitmapAgg.java | 66 ++++++
.../trees/expressions/functions/agg/MapAgg.java | 72 ++++++
.../visitor/AggregateFunctionVisitor.java | 11 +
.../expressions/visitor/ExpressionVisitors.java} | 45 +---
.../trees/plans/logical/LogicalOneRowRelation.java | 4 -
.../org/apache/doris/nereids/util/JoinUtils.java | 13 ++
.../doris/planner/external/LoadScanProvider.java | 14 +-
.../java/org/apache/doris/qe/SessionVariable.java | 7 +
.../resource/workloadgroup/WorkloadGroupMgr.java | 78 +------
.../apache/doris/service/FrontendServiceImpl.java | 92 +++++---
.../apache/doris/statistics/BaseAnalysisTask.java | 26 +++
.../apache/doris/statistics/HMSAnalysisTask.java | 12 +-
.../apache/doris/statistics/OlapAnalysisTask.java | 34 +--
.../datasource/property/PropertyConverterTest.java | 2 +-
.../rules/SimplifyComparisonPredicateTest.java | 8 -
fe_plugins/pom.xml | 2 +-
gensrc/proto/descriptors.proto | 1 +
gensrc/proto/internal_service.proto | 2 +
gensrc/thrift/Descriptors.thrift | 2 +
.../test_compaction_uniq_keys_row_store.out | 8 +-
.../stream_load/csv_with_none_utf8_data.csv | 4 +
.../data/nereids_function_p0/agg_function/agg.out | 49 +++++
.../data/nereids_function_p0/scalar_function/M.out | 48 ++++
.../insert_into_table/partial_update_seq_col.out} | 9 +-
.../data/nereids_p0/join/test_join_13.out | 3 +
.../select_no_from/sql/projectAggFuncs.out | 4 +
.../nereids_p0/system/test_query_sys_tables.out | 2 +-
.../data/point_query_p0/test_point_query.out | 57 +++--
.../data/point_query_p0/test_rowstore.out | 7 +
.../select_no_from/sql/projectAggFuncs.out | 4 +
.../data/query_p0/system/test_query_sys_tables.out | 2 +-
...t_partial_update_insert_light_schema_change.out | 4 -
.../test_partial_update_insert_schema_change.out | 4 -
....out => test_partial_update_insert_seq_col.out} | 9 +-
.../test_partial_update_parallel.out | 21 ++
.../partial_update/test_partial_update_seq_col.out | 5 +
.../pipeline/p0/conf/regression-conf.groovy | 2 +-
.../test_create_and_drop_repository.groovy | 84 +++++++
.../hive/test_hive_sample_statistic.groovy | 99 ---------
.../hive/test_hive_statistic.groovy | 34 +--
.../hive/test_hive_statistic_sample.groovy | 40 ++--
.../suites/javaudf_p0/test_javaudf_auth.groovy | 69 ++++++
.../test_csv_with_none_utf8_data.groovy | 73 +++++++
.../nereids_function_p0/agg_function/agg.groovy | 20 ++
.../nereids_function_p0/scalar_function/M.groovy | 27 +++
.../suites/nereids_p0/delete/delete_cte.groovy | 1 -
.../suites/nereids_p0/delete/delete_using.groovy | 1 -
.../insert_into_table/complex_insert.groovy | 3 +-
.../partial_update_seq_col.groovy | 115 ++++++++++
.../suites/nereids_p0/join/test_join_13.groovy | 2 +
.../select_no_from/sql/projectAggFuncs.sql | 19 +-
.../nereids_p0/system/test_query_sys_tables.groovy | 8 +-
.../nereids_syntax_p0/one_row_relation.groovy | 7 -
.../suites/point_query_p0/test_point_query.groovy | 8 +-
.../suites/point_query_p0/test_rowstore.groovy | 49 +++++
.../select_no_from/sql/projectAggFuncs.sql | 18 +-
...test_count_distinct_with_collection_type.groovy | 67 ++++++
.../query_p0/system/test_query_sys_tables.groovy | 8 +-
.../suites/schema_change/ddl/lineorder_create.sql | 24 ++
.../suites/schema_change/ddl/lineorder_delete.sql | 1 +
.../test_double_write_when_schema_change.groovy | 99 +++++++++
.../suites/show_p0/test_show_backends.groovy | 16 +-
...artial_update_insert_light_schema_change.groovy | 20 +-
...test_partial_update_insert_schema_change.groovy | 20 +-
.../test_partial_update_insert_seq_col.groovy | 114 ++++++++++
.../test_partial_update_parallel.groovy | 243 ++++++++++++++++++++-
.../test_partial_update_seq_col.groovy | 31 +++
tools/tpcds-tools/conf/opt/opt_sf100.sql | 2 -
tools/tpcds-tools/queries/sf100/query72.sql | 2 +
334 files changed, 4154 insertions(+), 2233 deletions(-)
create mode 100644 be/src/cloud/CMakeLists.txt
copy be/src/{runtime/task_group/task_group_manager.h => cloud/config.cpp} (57%)
copy be/src/{runtime/task_group/task_group_manager.h => cloud/config.h} (58%)
copy be/src/{runtime/task_group/task_group_manager.h =>
olap/rowset/rowset_fwd.h} (58%)
create mode 100644 be/src/olap/rowset/rowset_meta.cpp
copy be/src/{runtime/task_group/task_group_manager.h => olap/tablet_fwd.h}
(58%)
create mode 100644 be/src/vec/runtime/partitioner.cpp
create mode 100644 be/src/vec/runtime/partitioner.h
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/OneRowRelationExtractAggregate.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/BitmapAgg.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MapAgg.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/{rules/analysis/ProjectToGlobalAggregate.java
=> trees/expressions/visitor/ExpressionVisitors.java} (55%)
create mode 100644
regression-test/data/load_p0/stream_load/csv_with_none_utf8_data.csv
copy
regression-test/data/{unique_with_mow_p0/partial_update/test_partial_update_seq_col.out
=> nereids_p0/insert_into_table/partial_update_seq_col.out} (82%)
create mode 100644
regression-test/data/nereids_p0/select_no_from/sql/projectAggFuncs.out
create mode 100644 regression-test/data/point_query_p0/test_rowstore.out
create mode 100644
regression-test/data/query_p0/select_no_from/sql/projectAggFuncs.out
copy
regression-test/data/unique_with_mow_p0/partial_update/{test_partial_update_seq_col.out
=> test_partial_update_insert_seq_col.out} (82%)
create mode 100644
regression-test/suites/backup_restore/test_create_and_drop_repository.groovy
delete mode 100644
regression-test/suites/external_table_p2/hive/test_hive_sample_statistic.groovy
create mode 100644 regression-test/suites/javaudf_p0/test_javaudf_auth.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_csv_with_none_utf8_data.groovy
create mode 100644
regression-test/suites/nereids_p0/insert_into_table/partial_update_seq_col.groovy
create mode 100644 regression-test/suites/point_query_p0/test_rowstore.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/aggregate_functions/test_count_distinct_with_collection_type.groovy
create mode 100644
regression-test/suites/schema_change/ddl/lineorder_create.sql
create mode 100644
regression-test/suites/schema_change/ddl/lineorder_delete.sql
create mode 100644
regression-test/suites/schema_change/test_double_write_when_schema_change.groovy
create mode 100644
regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_insert_seq_col.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
