This is an automated email from the ASF dual-hosted git repository.
BiteTheDDDDt pushed a change to branch dev_runtime_partition_prune
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 6be29ffaf96 : This is a combination of 16 commits.
add afe30f383fe [fix](view) Prevent invalid alias rewrite in view
definitions (#63353)
add d527c14d90f [refactor](fe) Add typed filesystem properties for S3
(#63252)
add a0685f450d3 [doc](be) Document JSONB path compatibility (#63364)
add 5d82f600b20 [fix](nereids) Fix pre-aggregation context leakage across
join branches (#63357)
add f4ce70ed503 [fix](be) Remove pure attribute from assert_cast (#63417)
add 06f55c0ac14 [Enhancement](CI) Auto refresh AI Review credential
(#63431)
add 820f51b474a [refactor](fe) Refine volatile expression handling (#63403)
add a70c212956c [fix](uniform function) fix constant argument handling
and use ColumnView
(#63076)
add bad5649d6d5 [improvement](be) Optimize nested loop join
materialization (#62956)
add 3d7b76454c6 [fix](be) Remove unsafe JsonbWriter key overload (#63355)
add ec722fd6a12 [fix](be) Avoid signaling unbuilt shared hash table
(#63345)
add d449371b20a [fix](agg)Adjust agg strategy when table satisfy distinct
key distribution (#61248)
add 9b3b9d2c5fc [doc](security) Add threat model for scans (#63447)
add b6d8ef45d7c [chore](be) Document lightweight JSONB validation (#63359)
add 8a8999cf3a5 [refactor](storage) drop StorageField wrapper and clean up
related dead code (#63233)
add c02047ee370 [fix](test) Fix flaky partition_curd_union_rewrite test in
cloud mode (#62766)
add dc5d1398b33 [chore](be) Reject broadcast joins that finalize build
side (#63445)
add b307a23967f [refine](be) remove unsafe PURE annotations (#63440)
add 12f02ebf090 [opt](be) Batch row_id reads in seek_and_read_by_rowid to
reduce column iterator overhead (#63436)
add 4ab7cc02461 [fix](function) support TIMESTAMPDIFF MICROSECOND in
nereids (#63365)
add 974f9bdc89b [opt](sort) avoid copying whole blocks during merge
(#63429)
add 70ca0872d61 [fix](cloud) show proc should display partition cached
version (#60807)
add 58a24298999 [fix](cloud) avoid false tablet diagnosis alarms in cloud
mode (#60805)
add e4238ac87cc [fix](cloud) Fill schema change version holes before
running (#63443)
add f852097a4ff [opt](storage) disable dict encoding in row store columns
(#63438)
add 3da4d2b4669 [fix](test) replace removed JMockit with Mockito in
CloudProcVersionD… (#63473)
add ac34f069c25 [test](be) add JsonbSerializeUtil::block_to_jsonb
golden-file UT covering all row-store-supported types (#63448)
add fb38a5df891 [fix](be) Compare JSON numeric values by value (#63396)
add ad4b8b87bdf [fix](ci) harden GitHub Actions workflows against
injection and module shadowing (#63486)
add 2eff9ea9894 [fix](fe) Allow show tablet without selected database
(#63280)
add cc2224b5444 [fix](streaming-job) keep isCanceled set when cancel runs
on terminal task (#63427)
add d7d516ff7b6 [fix](streaming-job) Avoid NPE on cross-table DML during
snapshot chunk read (#63435)
add 90ec8ade9ba [opt](function) speed up md5 with AVX2 batch path (#63484)
add cbe23a31d8d [fix](job) fix NPE in routine load Kafka meta request
(#63180)
add caa02b47113 [refactor](be) Rename runtime filter expression wrapper
(#63489)
add 85767429400 [Chore](be) Reject right anti hash mark join plans (#63482)
add 1b5fa615aa7 [chore](url) delete useless code for function url (#63250)
add 895102b3d04 [Chore](be) Stop spill hash join repartition on cancel
(#63456)
add 1e75bfc1f4e [feature](be/fe) Add exponential_moving_average aggregate
function (#63499)
add d5fb1e54964 [fix](be) Fix NOT_IMPLEMENTED_ERROR for length() on
dict-encoded varchar columns (#63498)
add 4938d638e3f [opt](exec) skip result serialization for dry run queries
(#63356)
add dcee5052615 [refactor](be) Enforce COW ownership for assume_mutable
(#63001)
add 9a58cde5977 [doc](security) Add SECURITY.md threat model entry point
(#63553)
add 121193a6d2f [fix](test)(dynamic-partition) fix some unstable test
cases and dynamic-partition logic (#63551)
add 28b3da8e0c6 [fix](cloud) skip stale tablet cache check for STOP_TOKEN
(#63520)
add 962b88fe624 [fix](fe) avoid concurrent tablet stat iteration failures
(#63298)
add a5b43fb2a4a [followup](BE) rename assume_mutable to assert_mutable
(#63557)
add 68d4eb308e5 Update codeowners (#63552)
add 3bdcb38f23a [fix](parquet) Fix wrong condition (#63509)
add 944b0fa5bcb [fix](catalog) Mask sensitive properties in show create
catalog (#63234)
add 73b32d29744 [refine](array) introduce ColumnArrayView to unify array
column access in array functions (#63386)
add bf1faf73f0d Fix meta tool build on master (#63540)
add 60d1b99b191 [feat](txn) Add txn write amplification brpc metrics for
sub txn load (#63545)
add 5cc48ea03a7 [bug](iceberg) fix iceberg sink writer with spill report
error (#62899)
add 01bf2d9985e [fix](auth)Fix arrow flight client ip auth (#63506)
add 942734e94dc [fix](workload) enforce explicit compute group form for
workload DDLs (#63505)
add fac0cbbc403 [chore](build) Ignore local IDE metadata files (#63572)
add 440a6d3b57e [fix](test) stabilize internal copy recycler case (#63340)
add 5667e9de714 [fix](topn_to_max)Remove the topnToMax optimizer rewrite
that converted TOPN into MAX. (#63519)
add 03b7afda992 [fix](inverted index) Split bound multi-segment readers
(#63138)
add 892d0b7fa72 [refactor](be) Remove redundant remaining conjunct roots
(#63525)
add 34846980fcc [fix](filecache) clean empty v3 cache dirs (#63344)
add f6a4f022923 [chore](beut) fix beut use assume_mutable (#63598)
add 0c0dba31038 [chore](regression-test) make test_point_query_ck
nonConcurrent (#63587)
add e7141280927 [feature](runtime-filter) Add runtime filter partition
pruning
add 628f8bc1052 [fix](runtime-filter) Fix projection cache lifetime
add 085682035ee [chore](runtime-filter) Remove unused partition tablet
mapping
add c33d49a9a55 [fix](fe) Centralize RF partition pruning classification
add 7ebc576bf03 update
add 0dc5621cd88 update
add 475ba092677 fix
add a64ff68f887 update
add 64899496e96 update
add 3d7e57a398c [test](runtime-filter) Add partition pruner type coverage
add 58f39952c6e [refactor](be) Simplify runtime filter partition pruner
state
add aea4c454412 [fix](be) Preserve open RF pruning boundaries
add 0ce8b53d528 [improvement](be) Unify RF partition pruning target
handling
add b9f95bbd743 [improvement](be) Use per-partition RF monotonicity
add 4eebb2424b0 [improvement](be) Validate RF partition pruning metadata
add ee5e44758db [fix](fe) Reject non-first range RF pruning targets
add 0f1de960017 [fix](fe) Reject unsafe RF partition pruning targets
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 (6be29ffaf96)
\
N -- N -- N refs/heads/dev_runtime_partition_prune (0f1de960017)
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.
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 131 ++-
.github/workflows/comment-to-trigger-teamcity.yml | 4 +
.github/workflows/license-eyes.yml | 4 +
.github/workflows/opencode-review-runner.yml | 58 +-
.gitignore | 2 +
AGENTS.md | 4 +
SECURITY.md | 15 +
be/benchmark/benchmark_column_array_view.hpp | 418 ++++++++
.../benchmark_column_array_view_distance.hpp | 353 +++++++
be/benchmark/benchmark_column_view.hpp | 2 +-
be/benchmark/benchmark_main.cpp | 2 +
be/benchmark/benchmark_zone_map_index.hpp | 4 +-
be/benchmark/binary_cast_benchmark.hpp | 49 +-
be/src/cloud/cloud_schema_change_job.cpp | 4 +
be/src/core/AGENTS.md | 4 +-
be/src/core/assert_cast.h | 2 +-
be/src/core/binary_cast.hpp | 2 +-
be/src/core/block/block.cpp | 207 +++-
be/src/core/block/block.h | 153 ++-
be/src/core/column/column.cpp | 5 +-
be/src/core/column/column.h | 19 +-
be/src/core/column/column_array.cpp | 69 +-
be/src/core/column/column_array.h | 23 +-
be/src/core/column/column_array_view.h | 135 +++
be/src/core/column/column_const.cpp | 14 +-
be/src/core/column/column_const.h | 9 +-
be/src/core/column/column_execute_util.h | 1 +
be/src/core/column/column_fixed_length_object.h | 4 +
be/src/core/column/column_map.cpp | 159 ++-
be/src/core/column/column_map.h | 9 +-
be/src/core/column/column_nullable.cpp | 74 +-
be/src/core/column/column_nullable.h | 20 +-
be/src/core/column/column_varbinary.h | 7 +-
be/src/core/column/column_variant.cpp | 97 +-
be/src/core/column/column_variant.h | 8 +-
be/src/core/column/predicate_column.h | 35 +
be/src/core/cow.h | 30 +-
be/src/core/data_type/data_type_array.cpp | 7 +-
be/src/core/data_type/data_type_factory.cpp | 5 -
be/src/core/data_type/data_type_factory.hpp | 2 -
be/src/core/data_type/data_type_map.cpp | 12 +-
be/src/core/data_type/data_type_nullable.cpp | 20 +-
be/src/core/data_type/data_type_struct.cpp | 3 +-
.../core/data_type_serde/datelike_serde_common.hpp | 10 +-
be/src/core/string_ref.h | 3 +-
be/src/core/value/map_value.h | 57 -
be/src/core/value/struct_value.h | 61 --
.../exec/common/arrow_column_to_doris_column.cpp | 10 +-
.../common/data_gen_functions/vnumbers_tvf.cpp | 4 +-
be/src/exec/common/hash_table/hash_map_context.h | 2 +-
be/src/exec/common/partition_sort_utils.cpp | 14 +-
be/src/exec/common/util.hpp | 18 +-
be/src/exec/common/variant_util.cpp | 24 +-
be/src/exec/exchange/local_exchanger.cpp | 42 +-
be/src/exec/exchange/vdata_stream_sender.cpp | 2 +-
be/src/exec/operator/aggregation_sink_operator.cpp | 17 +-
.../exec/operator/aggregation_source_operator.cpp | 304 +++---
be/src/exec/operator/assert_num_rows_operator.cpp | 2 +-
.../bucketed_aggregation_sink_operator.cpp | 5 +-
.../bucketed_aggregation_source_operator.cpp | 32 +-
be/src/exec/operator/cache_source_operator.cpp | 10 +-
.../distinct_streaming_aggregation_operator.cpp | 24 +-
be/src/exec/operator/exchange_sink_operator.cpp | 2 +-
.../operator/group_commit_block_sink_operator.cpp | 2 +-
be/src/exec/operator/hashjoin_build_sink.cpp | 43 +-
be/src/exec/operator/hashjoin_build_sink.h | 2 +-
be/src/exec/operator/hashjoin_probe_operator.cpp | 5 +-
.../operator/join/process_hash_table_probe_impl.h | 29 +-
be/src/exec/operator/join_build_sink_operator.cpp | 6 +-
.../operator/nested_loop_join_probe_operator.cpp | 671 +++++++++++-
.../operator/nested_loop_join_probe_operator.h | 66 +-
be/src/exec/operator/operator.cpp | 13 +-
.../partitioned_aggregation_sink_operator.cpp | 6 +-
.../partitioned_hash_join_probe_operator.cpp | 19 +-
be/src/exec/operator/repeat_operator.cpp | 10 +-
be/src/exec/operator/scan_operator.cpp | 4 +-
be/src/exec/operator/schema_scan_operator.cpp | 15 +-
be/src/exec/operator/set_sink_operator.cpp | 3 +-
be/src/exec/operator/set_source_operator.cpp | 5 +-
.../operator/spill_iceberg_table_sink_operator.cpp | 33 +-
.../operator/streaming_aggregation_operator.cpp | 77 +-
be/src/exec/operator/table_function_operator.cpp | 17 +-
be/src/exec/operator/union_sink_operator.h | 7 +-
be/src/exec/operator/union_source_operator.cpp | 5 +-
be/src/exec/rowid_fetcher.cpp | 162 ++-
.../runtime_filter/runtime_filter_consumer.cpp | 24 +-
.../exec/runtime_filter/runtime_filter_consumer.h | 12 +-
.../runtime_filter_consumer_helper.cpp | 6 +-
.../runtime_filter_consumer_helper.h | 4 +-
.../exec/runtime_filter/runtime_filter_wrapper.h | 4 +-
be/src/exec/scan/file_scanner.cpp | 21 +-
be/src/exec/scan/meta_scanner.cpp | 19 +-
be/src/exec/scan/olap_scanner.cpp | 12 -
be/src/exec/scan/scanner.cpp | 9 +-
be/src/exec/scan/scanner.h | 5 +-
be/src/exec/sink/vtablet_block_convertor.cpp | 27 +-
.../sink/writer/iceberg/viceberg_sort_writer.cpp | 29 +
.../sink/writer/iceberg/viceberg_sort_writer.h | 25 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 6 +-
.../sink/writer/iceberg/viceberg_table_writer.h | 10 +-
be/src/exec/sink/writer/vmysql_result_writer.cpp | 6 +
be/src/exec/sink/writer/vtablet_writer.cpp | 8 +-
be/src/exec/sink/writer/vtablet_writer_v2.cpp | 8 +-
be/src/exec/sort/partition_sorter.cpp | 13 +-
be/src/exec/sort/sort_cursor.h | 5 +
be/src/exec/sort/sorter.cpp | 27 +-
be/src/exec/sort/vsorted_run_merger.cpp | 8 +-
.../aggregate/aggregate_function_ema.cpp} | 22 +-
be/src/exprs/aggregate/aggregate_function_ema.h | 173 +++
.../exprs/aggregate/aggregate_function_foreach.h | 12 +-
.../exprs/aggregate/aggregate_function_java_udaf.h | 9 +-
.../exprs/aggregate/aggregate_function_null_v2.h | 7 +-
.../aggregate_function_simple_factory.cpp | 2 +
be/src/exprs/aggregate/aggregate_function_sort.h | 62 +-
.../function/array/function_array_aggregation.cpp | 12 +-
.../exprs/function/array/function_array_distance.h | 149 +--
.../function/array/function_array_flatten.cpp | 14 +-
be/src/exprs/function/array/function_array_join.h | 39 +-
.../array/function_array_with_constant.cpp | 2 +-
be/src/exprs/function/cast/cast_base.h | 8 +
.../function/cast/cast_to_basic_number_common.h | 21 +-
be/src/exprs/function/cast/cast_to_boolean.h | 21 +-
be/src/exprs/function/cast/cast_to_date.h | 44 +-
be/src/exprs/function/cast/cast_to_decimal.h | 21 +-
be/src/exprs/function/cast/cast_to_ip.h | 23 +-
be/src/exprs/function/cast/cast_to_string.h | 9 +-
be/src/exprs/function/cast/cast_to_variant.h | 39 +-
be/src/exprs/function/dictionary_util.h | 2 +-
be/src/exprs/function/function.cpp | 9 +-
be/src/exprs/function/function_bitmap.cpp | 10 +-
.../function/function_other_types_to_date.cpp | 22 +-
be/src/exprs/function/function_string_digest.cpp | 47 +
.../exprs/function/function_variadic_arguments.h | 6 +-
be/src/exprs/function/function_variant_element.cpp | 27 +-
be/src/exprs/function/uniform.cpp | 14 +-
be/src/exprs/function/url/functions_url.h | 44 -
.../exprs/lambda_function/varray_map_function.cpp | 4 +-
.../exprs/lambda_function/varray_sort_function.cpp | 2 +-
...efilter_wrapper.cpp => runtime_filter_expr.cpp} | 38 +-
...ntimefilter_wrapper.h => runtime_filter_expr.h} | 16 +-
.../exprs/table_function/python_udtf_function.cpp | 7 +-
be/src/exprs/table_function/udf_table_function.cpp | 4 +-
be/src/exprs/table_function/vexplode.cpp | 10 +-
be/src/exprs/table_function/vexplode_v2.cpp | 11 +-
be/src/exprs/vcase_expr.h | 6 +-
be/src/exprs/vcompound_pred.h | 61 +-
be/src/exprs/vexpr_context.cpp | 4 +-
be/src/exprs/vtopn_pred.h | 2 +-
be/src/format/arrow/arrow_stream_reader.cpp | 15 +-
be/src/format/column_type_convert.cpp | 16 +-
be/src/format/column_type_convert.h | 79 +-
be/src/format/count_reader.h | 4 +-
be/src/format/csv/csv_reader.cpp | 45 +-
be/src/format/csv/csv_reader.h | 6 +-
be/src/format/jni/jni_data_bridge.cpp | 41 +-
be/src/format/json/new_json_reader.cpp | 78 +-
be/src/format/json/new_json_reader.h | 6 +
be/src/format/lance/lance_rust_reader.cpp | 12 +-
be/src/format/orc/vorc_reader.cpp | 135 ++-
be/src/format/orc/vorc_reader.h | 3 +-
be/src/format/parquet/byte_array_dict_decoder.cpp | 29 +-
be/src/format/parquet/byte_array_plain_decoder.cpp | 41 +-
.../format/parquet/byte_stream_split_decoder.cpp | 9 +-
be/src/format/parquet/delta_bit_pack_decoder.h | 22 +-
be/src/format/parquet/fix_length_dict_decoder.hpp | 9 +-
be/src/format/parquet/fix_length_plain_decoder.h | 9 +-
be/src/format/parquet/parquet_column_convert.cpp | 36 +-
be/src/format/parquet/parquet_column_convert.h | 229 ++--
be/src/format/parquet/vparquet_column_reader.cpp | 40 +-
be/src/format/parquet/vparquet_column_reader.h | 3 +-
be/src/format/parquet/vparquet_group_reader.cpp | 30 +-
be/src/format/parquet/vparquet_reader.cpp | 7 +-
be/src/format/parquet/vparquet_reader.h | 3 +-
be/src/format/table/equality_delete.cpp | 8 +-
be/src/format/table/es/es_http_reader.cpp | 7 +-
be/src/format/table/iceberg_reader_mixin.h | 16 +-
be/src/format/table/paimon_cpp_reader.cpp | 16 +-
be/src/format/table/paimon_jni_reader.cpp | 4 +-
be/src/format/table/parquet_metadata_reader.cpp | 30 +-
be/src/format/table/remote_doris_reader.cpp | 14 +-
be/src/format/table/table_format_reader.h | 17 +-
be/src/format/transformer/merge_partitioner.cpp | 5 +-
.../schema_active_queries_scanner.cpp | 3 +-
.../schema_authentication_integrations_scanner.cpp | 3 +-
.../schema_backend_active_tasks.cpp | 5 +-
.../schema_backend_kerberos_ticket_cache.cpp | 3 +-
.../schema_catalog_meta_cache_stats_scanner.cpp | 3 +-
.../schema_database_properties_scanner.cpp | 3 +-
.../schema_file_cache_statistics.cpp | 3 +-
.../schema_partitions_scanner.cpp | 3 +-
.../schema_role_mappings_scanner.cpp | 3 +-
be/src/information_schema/schema_scanner.cpp | 35 +-
.../information_schema/schema_scanner_helper.cpp | 36 +-
.../schema_sql_block_rule_status_scanner.cpp | 3 +-
.../schema_table_options_scanner.cpp | 3 +-
.../schema_table_properties_scanner.cpp | 3 +-
.../schema_table_stream_consumption_scanner.cpp | 5 +-
.../schema_table_streams_scanner.cpp | 5 +-
.../schema_view_dependency_scanner.cpp | 3 +-
.../schema_workload_group_privileges.cpp | 3 +-
...chema_workload_group_resource_usage_scanner.cpp | 5 +-
.../schema_workload_groups_scanner.cpp | 3 +-
.../schema_workload_sched_policy_scanner.cpp | 3 +-
be/src/io/cache/cache_block_meta_store.cpp | 2 -
be/src/io/cache/fs_file_cache_storage.cpp | 32 +-
be/src/io/fs/local_file_system.cpp | 20 +
be/src/io/fs/local_file_system.h | 3 +
be/src/load/memtable/memtable.cpp | 47 +-
be/src/load/memtable/memtable.h | 6 +-
be/src/runtime/collection_value.h | 80 --
be/src/runtime/query_cache/query_cache.cpp | 7 +-
be/src/runtime/result_block_buffer.cpp | 6 +-
be/src/service/point_query_executor.cpp | 173 +--
be/src/storage/field.h | 382 -------
be/src/storage/index/ann/ann_index_writer.cpp | 5 -
be/src/storage/index/ann/ann_index_writer.h | 3 -
be/src/storage/index/index_writer.cpp | 21 +-
be/src/storage/index/index_writer.h | 8 +-
.../index/inverted/inverted_index_reader.cpp | 1 -
.../index/inverted/inverted_index_writer.cpp | 54 -
.../storage/index/inverted/inverted_index_writer.h | 2 -
.../inverted/query_v2/collect/multi_segment_util.h | 153 ++-
be/src/storage/index/zone_map/zone_map_index.cpp | 6 +-
be/src/storage/index/zone_map/zone_map_index.h | 4 +-
be/src/storage/iterator/block_reader.cpp | 22 +-
be/src/storage/iterator/olap_data_convertor.cpp | 1 -
be/src/storage/iterator/olap_data_convertor.h | 3 +-
be/src/storage/iterator/vcollect_iterator.cpp | 14 +-
be/src/storage/iterator/vertical_block_reader.cpp | 34 +-
.../storage/iterator/vertical_merge_iterator.cpp | 5 +-
be/src/storage/iterator/vgeneric_iterators.cpp | 7 +-
be/src/storage/iterators.h | 2 -
be/src/storage/olap_common.h | 12 +-
be/src/storage/partial_update_info.cpp | 66 +-
be/src/storage/predicate/bloom_filter_predicate.h | 2 +-
be/src/storage/predicate/column_predicate.h | 4 +-
be/src/storage/row_cursor.cpp | 53 +-
be/src/storage/row_cursor.h | 9 +-
be/src/storage/rowset/beta_rowset_reader.cpp | 1 -
be/src/storage/rowset/rowset_reader_context.h | 1 -
be/src/storage/schema.cpp | 24 +-
be/src/storage/schema.h | 11 +-
be/src/storage/schema_change/schema_change.cpp | 39 +-
be/src/storage/schema_change/schema_change.h | 1 -
be/src/storage/segment/binary_dict_page.cpp | 7 +
be/src/storage/segment/column_reader.cpp | 37 +-
be/src/storage/segment/column_writer.cpp | 170 ++-
be/src/storage/segment/column_writer.h | 36 +-
.../storage/segment/historical_row_retriever.cpp | 39 +-
.../storage/segment/row_binlog_segment_writer.cpp | 94 +-
be/src/storage/segment/segment.cpp | 19 +-
be/src/storage/segment/segment.h | 10 +-
be/src/storage/segment/segment_iterator.cpp | 101 +-
be/src/storage/segment/segment_iterator.h | 12 +-
be/src/storage/segment/segment_writer.cpp | 16 +-
be/src/storage/segment/segment_writer.h | 2 +-
.../variant/binary_column_extract_iterator.h | 5 +-
.../segment/variant/hierarchical_data_iterator.cpp | 42 +-
.../segment/variant/hierarchical_data_iterator.h | 2 +-
.../segment/variant/sparse_column_merge_iterator.h | 1 -
.../segment/variant/variant_column_reader.cpp | 7 +-
.../segment/variant/variant_column_writer_impl.cpp | 49 +-
.../segment/variant/variant_column_writer_impl.h | 4 +-
.../variant_streaming_compaction_writer.cpp | 16 +-
be/src/storage/segment/vertical_segment_writer.cpp | 35 +-
be/src/storage/segment/vertical_segment_writer.h | 2 +-
be/src/storage/segment/virtual_column_iterator.cpp | 2 +-
be/src/storage/tablet/base_tablet.cpp | 35 +-
be/src/storage/tablet/tablet_reader.cpp | 1 -
be/src/storage/tablet/tablet_reader.h | 1 -
be/src/storage/task/index_builder.cpp | 34 +-
be/src/storage/task/index_builder.h | 12 +-
be/src/storage/types.h | 60 +-
be/src/tools/CMakeLists.txt | 2 +
be/src/tools/meta_tool.cpp | 19 +-
be/src/util/jsonb/serialize.cpp | 51 +-
be/src/util/jsonb/serialize.h | 8 +-
be/src/util/jsonb_document.cpp | 7 +-
be/src/util/jsonb_document.h | 262 ++++-
be/src/util/jsonb_writer.h | 2 -
be/src/util/md5.cpp | 380 ++++++-
be/src/util/md5.h | 5 +
be/src/util/string_parser.hpp | 3 +-
be/src/util/thrift_util.h | 6 +-
be/test/ai/ai_function_test.cpp | 68 +-
be/test/cloud/cloud_schema_change_job_test.cpp | 109 ++
be/test/cloud/cloud_tablet_test.cpp | 50 +
be/test/core/block/block_test.cpp | 331 +++++-
be/test/core/block/column_map_test.cpp | 116 ++-
be/test/core/block/column_nullable_test.cpp | 2 +-
be/test/core/block/column_test.cpp | 19 +
be/test/core/column/column_array_test.cpp | 51 +-
be/test/core/column/column_array_view_test.cpp | 292 ++++++
.../column_check_const_only_in_top_level_test.cpp | 4 +-
be/test/core/column/column_ip_test.cpp | 98 +-
be/test/core/column/column_nullable_test.cpp | 32 +-
be/test/core/column/column_variant_test.cpp | 21 +-
be/test/core/column/common_column_test.h | 18 +-
.../core/data_type/common_data_type_serder_test.h | 2 +-
be/test/core/data_type/complex_type_test.cpp | 126 +++
be/test/core/data_type/data_type_array_test.cpp | 26 +-
.../data_type_serde/data_type_serde_csv_test.cpp | 13 +-
.../data_type_serde/data_type_serde_mysql_test.cpp | 23 +-
.../data_type_serde_struct_test.cpp | 7 +-
be/test/core/jsonb/convert_field_to_type_test.cpp | 4 +-
be/test/core/jsonb/jsonb_document_test.cpp | 109 +-
be/test/core/jsonb/serialize_test.cpp | 1100 ++++++++++++++++++++
be/test/core/value/jsonb_value_test2.cpp | 8 +-
be/test/exec/column_type_convert_test.cpp | 134 +--
be/test/exec/common/schema_util_rowset_test.cpp | 3 +-
be/test/exec/common/schema_util_test.cpp | 13 +-
be/test/exec/connector/vjdbc_connector_test.cpp | 69 +-
be/test/exec/exchange/exchange_writer_test.cpp | 2 +-
be/test/exec/operator/agg_operator_test.cpp | 90 ++
be/test/exec/operator/datagen_operator_test.cpp | 33 +
be/test/exec/operator/hashjoin_build_sink_test.cpp | 75 ++
.../partitioned_hash_join_probe_operator_test.cpp | 39 +
be/test/exec/operator/set_operator_test.cpp | 50 +-
be/test/exec/operator/sort_operator_test.cpp | 19 +-
.../exec/operator/table_function_operator_test.cpp | 6 +-
be/test/exec/pipeline/local_exchanger_test.cpp | 87 ++
.../runtime_filter_consumer_test.cpp | 8 +-
...t.cpp => runtime_filter_expr_sampling_test.cpp} | 30 +-
be/test/exec/scan/vgeneric_iterators_test.cpp | 1 -
be/test/exec/sort/heap_sorter_test.cpp | 16 +-
be/test/exec/sort/merge_sorter_state.cpp | 67 ++
be/test/exprs/aggregate/agg_array_agg_test.cpp | 107 ++
be/test/exprs/aggregate/agg_collect_test.cpp | 4 +-
be/test/exprs/aggregate/vec_count_by_enum_test.cpp | 66 +-
be/test/exprs/aggregate/vec_retention_test.cpp | 67 +-
.../function/cast/function_variant_cast_test.cpp | 75 +-
be/test/exprs/function/function_is_null_test.cpp | 4 +-
be/test/exprs/function/function_string_test.cpp | 104 ++
.../function/function_variant_element_test.cpp | 6 +-
be/test/exprs/hybrid_set_test.cpp | 2 +-
be/test/format/json/json_reader_test.cpp | 81 ++
.../format/native/native_reader_writer_test.cpp | 25 +-
be/test/format/orc/orc_read_lines.cpp | 2 +-
be/test/format/orc/orc_reader_fill_data_test.cpp | 52 +-
.../parquet/byte_array_dict_decoder_test.cpp | 17 +
.../parquet/byte_array_plain_decoder_test.cpp | 43 +
.../parquet/byte_stream_split_decoder_test.cpp | 84 +-
.../parquet/delta_byte_array_decoder_test.cpp | 122 +++
.../parquet/fix_length_dict_decoder_test.cpp | 77 ++
.../parquet/fix_length_plain_decoder_test.cpp | 76 ++
.../format/parquet/parquet_column_convert_test.cpp | 180 ++++
be/test/format/parquet/parquet_read_lines.cpp | 2 +-
be/test/format/parquet/parquet_thrift_test.cpp | 13 +-
be/test/format/table/table_format_reader_test.cpp | 101 ++
.../fs_file_cache_storage_leak_cleaner_test.cpp | 57 +
be/test/io/fs/local_file_system_test.cpp | 24 +
.../delta_writer/delta_writer_cluster_key_test.cpp | 5 +-
be/test/load/delta_writer/delta_writer_test.cpp | 12 +-
.../load/memtable/memtable_flush_executor_test.cpp | 18 +-
.../load/memtable/memtable_memory_limiter_test.cpp | 3 +-
be/test/olap/rowset/group_rowset_writer_test.cpp | 13 +-
be/test/runtime/snapshot_loader_test.cpp | 5 +-
be/test/runtime/stream_load_parquet_test.cpp | 32 +-
.../adaptive_thread_pool_controller_test.cpp | 9 +-
.../compaction/ordered_data_compaction_test.cpp | 7 +-
.../storage/compaction/segcompaction_mow_test.cpp | 60 +-
be/test/storage/compaction/segcompaction_test.cpp | 84 +-
.../variant_doc_mode_compaction_test.cpp | 2 +-
.../compaction/vertical_compaction_test.cpp | 25 +-
be/test/storage/index/ann/ann_index_smoke_test.cpp | 6 -
.../storage/index/ann/ann_index_writer_test.cpp | 24 +-
be/test/storage/index/date_bloom_filter_test.cpp | 6 +-
be/test/storage/index/index_builder_test.cpp | 72 +-
.../common/inverted_index_gc_binlogs_test.cpp | 3 +-
.../compaction/util/index_compaction_utils.cpp | 7 +-
.../inverted/query/phrase_edge_query_test.cpp | 11 +-
.../inverted/query/phrase_prefix_query_test.cpp | 11 +-
.../index/inverted/query/phrase_query_test.cpp | 11 +-
.../query_v2/multi_segment_collector_test.cpp | 216 ++++
.../iterator/block_reader_agg_flush_test.cpp | 3 +-
.../iterator/vertical_merge_iterator_test.cpp | 4 +-
be/test/storage/metadata_adder_test.cpp | 8 +-
be/test/storage/rowid_conversion_test.cpp | 3 +-
.../storage/segment/column_meta_accessor_test.cpp | 71 ++
.../storage/segment/column_reader_writer_test.cpp | 227 ----
.../storage/segment/inverted_index_array_test.cpp | 46 +-
.../storage/segment/inverted_index_reader_test.cpp | 56 +-
.../storage/segment/inverted_index_writer_test.cpp | 174 +---
be/test/storage/segment/segment_cache_test.cpp | 9 +-
.../storage/segment/segment_corruption_test.cpp | 1 -
.../segments_key_bounds_truncation_test.cpp | 3 +-
.../segment/variant_column_writer_reader_test.cpp | 172 +--
.../segment/variant_stats_calculator_test.cpp | 2 +-
be/test/storage/segment/variant_util_test.cpp | 34 +
be/test/storage/segment/zone_map_index_test.cpp | 52 +-
be/test/storage/storage_types_test.cpp | 87 +-
be/test/storage/tablet/tablet_cooldown_test.cpp | 7 +-
be/test/util/bit_util_test.cpp | 32 +-
be/test/util/jsonb_serialize_test.cpp | 8 +-
be/test/util/md5_test.cpp | 148 +++
.../test_data/block_to_jsonb_all_types_golden.bin | Bin 0 -> 1586 bytes
cloud/src/meta-service/meta_service_job.cpp | 12 +-
cloud/src/meta-service/meta_service_txn.cpp | 3 +
cloud/test/meta_service_job_test.cpp | 65 ++
.../doris/alter/MaterializedViewHandler.java | 17 +-
.../apache/doris/alter/SchemaChangeHandler.java | 52 +-
.../java/org/apache/doris/backup/RestoreJob.java | 9 +-
.../doris/catalog/BuiltinAggregateFunctions.java | 2 +
.../apache/doris/catalog/CloudTabletStatMgr.java | 1 +
.../java/org/apache/doris/catalog/LocalTablet.java | 96 +-
.../apache/doris/catalog/MaterializedIndex.java | 89 +-
.../java/org/apache/doris/catalog/OlapTable.java | 7 +-
.../org/apache/doris/catalog/TabletStatMgr.java | 18 +-
.../apache/doris/cloud/backup/CloudRestoreJob.java | 8 +-
.../cloud/datasource/CloudInternalCatalog.java | 12 +-
.../apache/doris/common/proc/IndicesProcDir.java | 4 +-
.../common/proc/ProcReplicaVersionDisplay.java | 44 +
.../apache/doris/common/proc/ReplicasProcNode.java | 17 +-
.../apache/doris/common/proc/TabletsProcDir.java | 14 +-
.../doris/common/util/DatasourcePrintableMap.java | 2 +
.../apache/doris/datasource/InternalCatalog.java | 14 +-
.../apache/doris/datasource/kafka/KafkaUtil.java | 23 +-
.../property/metastore/IcebergRestProperties.java | 1 +
.../insert/streaming/AbstractStreamingTask.java | 8 +-
.../insert/streaming/StreamingInsertJob.java | 6 +
.../org/apache/doris/load/loadv2/LoadManager.java | 20 +
.../glue/translator/PhysicalPlanTranslator.java | 35 +-
.../RuntimeFilterPartitionPruneClassifier.java | 14 +-
.../glue/translator/RuntimeFilterTranslator.java | 4 +-
.../doris/nereids/jobs/executor/Rewriter.java | 8 +-
.../org/apache/doris/nereids/rules/RuleType.java | 2 +-
.../nereids/rules/analysis/BindExpression.java | 13 +-
.../rules/analysis/DatetimeFunctionBinder.java | 5 +-
.../rules/expression/ExpressionOptimization.java | 2 -
.../nereids/rules/expression/rules/TopnToMax.java | 56 -
.../LogicalOlapScanToPhysicalOlapScan.java | 12 +-
...n.java => AddProjectForVolatileExpression.java} | 54 +-
.../rules/rewrite/DistinctAggregateRewriter.java | 115 ++
.../rewrite/MergeOneRowRelationIntoUnion.java | 6 +-
.../PushDownVirtualColumnsIntoOlapScan.java | 2 +-
.../nereids/rules/rewrite/SetPreAggStatus.java | 1 +
.../nereids/trees/expressions/Expression.java | 5 -
.../trees/expressions/VolatileExpression.java | 5 +-
.../expressions/functions/ExpressionTrait.java | 13 +
.../functions/agg/ExponentialMovingAverage.java | 122 +++
.../trees/expressions/functions/scalar/Random.java | 27 +-
.../expressions/functions/scalar/RandomBytes.java | 11 +-
.../functions/scalar/UniqueFunction.java | 39 +-
.../functions/scalar/UniqueFunctionParams.java | 17 +-
.../trees/expressions/functions/scalar/Uuid.java | 11 +-
.../expressions/functions/scalar/UuidNumeric.java | 11 +-
.../trees/expressions/literal/Interval.java | 1 +
.../visitor/AggregateFunctionVisitor.java | 5 +
.../plans/commands/AlterWorkloadGroupCommand.java | 17 +-
.../plans/commands/CreateWorkloadGroupCommand.java | 30 +-
.../plans/commands/DropWorkloadGroupCommand.java | 13 +-
.../trees/plans/commands/ShowTabletIdCommand.java | 7 -
.../trees/plans/logical/LogicalSubQueryAlias.java | 7 +-
.../apache/doris/nereids/util/ExpressionUtils.java | 14 +-
.../java/org/apache/doris/nereids/util/Utils.java | 16 +
.../apache/doris/planner/NestedLoopJoinNode.java | 51 +
.../org/apache/doris/planner/OlapScanNode.java | 3 +-
.../org/apache/doris/qe/runtime/LoadProcessor.java | 6 +
.../WorkloadSchedPolicyMgr.java | 55 +-
.../service/arrowflight/DorisFlightSqlService.java | 6 +
.../auth2/FlightCredentialValidator.java | 3 +-
.../auth2/FlightRemoteIpServerStreamTracer.java | 103 ++
.../java/org/apache/doris/system/Diagnoser.java | 22 +-
.../org/apache/doris/catalog/CreateViewTest.java | 24 +
.../doris/catalog/MaterializedIndexTest.java | 65 ++
.../java/org/apache/doris/catalog/TabletTest.java | 79 ++
.../doris/clone/TabletReplicaTooSlowTest.java | 97 ++
.../common/proc/CloudProcVersionDisplayTest.java | 200 ++++
.../common/util/DatasourcePrintableMapTest.java | 8 +
.../doris/datasource/ExternalCatalogTest.java | 47 +
.../StreamingInsertJobLateCallbackTest.java | 120 +++
.../RuntimeFilterPartitionPruneClassifierTest.java | 50 +
.../rules/analysis/DatetimeFunctionBinderTest.java | 10 +
.../rules/expression/rules/TopnToMaxTest.java | 42 -
...va => AddProjectForVolatileExpressionTest.java} | 43 +-
.../rewrite/DistinctAggregateRewriterTest.java | 224 +++-
.../functions/udf/UdfVolatilityTest.java | 4 +-
.../plans/commands/ShowTabletIdCommandTest.java | 4 +-
.../WorkloadSchedPolicyMgrTest.java | 206 ++++
.../FlightRemoteIpServerStreamTracerTest.java | 92 ++
.../filesystem/properties/BackendStorageKind.java | 61 +-
.../properties/BackendStorageProperties.java | 43 +
.../properties/FileSystemProperties.java | 92 ++
.../properties/HadoopStorageProperties.java | 48 +-
.../S3CompatibleFileSystemProperties.java | 80 ++
.../doris/filesystem/properties/StorageKind.java | 43 +-
.../doris/filesystem/cos/CosObjStorageTest.java | 9 +-
.../doris/filesystem/obs/ObsObjStorageTest.java | 2 +
.../doris/filesystem/oss/OssObjStorageTest.java | 1 +
fe/fe-filesystem/fe-filesystem-s3/pom.xml | 17 +
.../s3/S3CredentialsProviderFactory.java | 201 ++++
.../filesystem/s3/S3CredentialsProviderType.java | 70 ++
.../apache/doris/filesystem/s3/S3FileSystem.java | 17 +
.../filesystem/s3/S3FileSystemProperties.java | 398 +++++++
.../doris/filesystem/s3/S3FileSystemProvider.java | 69 +-
.../apache/doris/filesystem/s3/S3ObjStorage.java | 195 +---
.../s3/S3CredentialsProviderFactoryTest.java | 103 ++
.../filesystem/s3/S3FileSystemPropertiesTest.java | 245 +++++
.../filesystem/s3/S3FileSystemProviderTest.java | 73 ++
.../doris/filesystem/s3/S3ObjStorageMockTest.java | 82 +-
.../doris/filesystem/s3/S3ObjStorageTest.java | 156 +--
.../doris/filesystem/s3/S3OutputStreamTest.java | 4 +-
.../doris/filesystem/spi/FileSystemProvider.java | 23 +
.../external/IncrementalSourceScanFetcher.java | 284 +++++
gensrc/thrift/PlanNodes.thrift | 5 +
.../sql/presto/scalar/TestJsonFunctions.out | 16 +-
.../agg_skew_rewrite/agg_skew_rewrite.out | 6 +-
.../nereids_rules_p0/agg_strategy/agg_strategy.out | 22 +-
.../bind_relation/bind_view_alias_star_agg.out} | 9 +-
.../data/nereids_syntax_p0/test_timestampdiff.out | 6 +
.../exponential_moving_average.out | 31 +
.../test_json_contains_numeric_equality.out} | 9 +-
.../string_functions/test_length_dict_encoded.out | 55 +
.../data/shape_check/clickbench/query10.out | 11 +-
.../data/shape_check/clickbench/query11.out | 7 +-
.../data/shape_check/clickbench/query12.out | 7 +-
.../data/shape_check/clickbench/query14.out | 7 +-
.../data/shape_check/clickbench/query23.out | 7 +-
.../data/shape_check/clickbench/query9.out | 5 +-
regression-test/pipeline/p0/conf/fe.conf | 1 +
.../arrow_flight_sql_p0/test_auth_remote_ip.groovy | 78 ++
.../test_backup_restore_colocate.groovy | 25 +
.../check_hash_bucket_table.groovy | 14 +-
.../test_recycler_with_internal_copy.groovy | 21 +-
.../jdbc/test_doris_jdbc_catalog.groovy | 4 +
.../tvf/test_hdfs_parquet_group6.groovy | 4 +-
.../load_p0/routine_load/test_black_list.groovy | 56 +
.../suites/manager/test_manager_interface_1.groovy | 14 +-
.../nereids_function_p0/scalar_function/U.groovy | 2 +
.../bind_relation/bind_view_alias_star_agg.groovy | 46 +
.../distinct_split/disitinct_split.groovy | 1 +
.../partition_curd_union_rewrite.groovy | 30 +-
.../nereids_rules_p0/set_preagg/set_preagg.groovy | 25 +-
.../nereids_syntax_p0/test_timestampdiff.groovy | 28 +
.../point_query_p0/test_point_query_ck.groovy | 2 +-
.../exponential_moving_average.groovy | 158 +++
.../suites/query_p0/expression/topn_to_max.groovy | 47 -
.../test_nestedloop_lazy_materialization.groovy | 256 +++++
.../test_json_contains_numeric_equality.groovy | 22 +-
.../test_length_dict_encoded.groovy | 107 ++
.../suites/query_profile/scanner_profile.groovy | 9 +-
.../suites/show_p0/test_show_tablet.groovy | 8 +-
.../suites/temp_table_p0/test_temp_table.groovy | 12 +-
threat-model.md | 806 ++++++++++++++
544 files changed, 17701 insertions(+), 5386 deletions(-)
create mode 100644 SECURITY.md
create mode 100644 be/benchmark/benchmark_column_array_view.hpp
create mode 100644 be/benchmark/benchmark_column_array_view_distance.hpp
create mode 100644 be/src/core/column/column_array_view.h
delete mode 100644 be/src/core/value/map_value.h
delete mode 100644 be/src/core/value/struct_value.h
copy be/src/{runtime/collection_value.cpp =>
exprs/aggregate/aggregate_function_ema.cpp} (64%)
create mode 100644 be/src/exprs/aggregate/aggregate_function_ema.h
rename be/src/exprs/{vruntimefilter_wrapper.cpp => runtime_filter_expr.cpp}
(79%)
rename be/src/exprs/{vruntimefilter_wrapper.h => runtime_filter_expr.h} (90%)
delete mode 100644 be/src/runtime/collection_value.h
delete mode 100644 be/src/storage/field.h
create mode 100644 be/test/core/column/column_array_view_test.cpp
rename be/test/exec/runtime_filter/{vruntimefilter_wrapper_sampling_test.cpp
=> runtime_filter_expr_sampling_test.cpp} (87%)
create mode 100644
be/test/storage/index/inverted/query_v2/multi_segment_collector_test.cpp
create mode 100644 be/test/util/test_data/block_to_jsonb_all_types_golden.bin
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/proc/ProcReplicaVersionDisplay.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/TopnToMax.java
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/{AddProjectForUniqueFunction.java
=> AddProjectForVolatileExpression.java} (86%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/ExponentialMovingAverage.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/auth2/FlightRemoteIpServerStreamTracer.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/proc/CloudProcVersionDisplayTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/StreamingInsertJobLateCallbackTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/glue/translator/RuntimeFilterPartitionPruneClassifierTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/rules/TopnToMaxTest.java
rename
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/{AddProjectForUniqueFunctionTest.java
=> AddProjectForVolatileExpressionTest.java} (78%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/resource/workloadschedpolicy/WorkloadSchedPolicyMgrTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/service/arrowflight/auth2/FlightRemoteIpServerStreamTracerTest.java
copy be/src/util/md5.cpp =>
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/BackendStorageKind.java
(50%)
create mode 100644
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/BackendStorageProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/FileSystemProperties.java
copy be/src/util/md5.cpp =>
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/HadoopStorageProperties.java
(50%)
create mode 100644
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/S3CompatibleFileSystemProperties.java
rename be/src/runtime/collection_value.cpp =>
fe/fe-filesystem/fe-filesystem-api/src/main/java/org/apache/doris/filesystem/properties/StorageKind.java
(60%)
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3CredentialsProviderFactory.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3CredentialsProviderType.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3FileSystemProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/test/java/org/apache/doris/filesystem/s3/S3CredentialsProviderFactoryTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/test/java/org/apache/doris/filesystem/s3/S3FileSystemPropertiesTest.java
create mode 100644
fs_brokers/cdc_client/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcher.java
copy regression-test/data/{query_p0/expression/topn_to_max.out =>
nereids_rules_p0/bind_relation/bind_view_alias_star_agg.out} (71%)
create mode 100644
regression-test/data/query_p0/aggregate/exponential_moving_average/exponential_moving_average.out
rename regression-test/data/query_p0/{expression/topn_to_max.out =>
sql_functions/json_functions/test_json_contains_numeric_equality.out} (56%)
create mode 100644
regression-test/data/query_p0/sql_functions/string_functions/test_length_dict_encoded.out
create mode 100644
regression-test/suites/arrow_flight_sql_p0/test_auth_remote_ip.groovy
create mode 100644
regression-test/suites/nereids_rules_p0/bind_relation/bind_view_alias_star_agg.groovy
create mode 100644
regression-test/suites/query_p0/aggregate/exponential_moving_average/exponential_moving_average.groovy
delete mode 100644
regression-test/suites/query_p0/expression/topn_to_max.groovy
create mode 100644
regression-test/suites/query_p0/join/test_nestedloop_lazy_materialization.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/VolatileExpression.java
=>
regression-test/suites/query_p0/sql_functions/json_functions/test_json_contains_numeric_equality.groovy
(62%)
create mode 100644
regression-test/suites/query_p0/sql_functions/string_functions/test_length_dict_encoded.groovy
create mode 100644 threat-model.md
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
