This is an automated email from the ASF dual-hosted git repository.
englefly pushed a change to branch groupjoin
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 60f5bbfecd4 [fix](fe) Apply HAVING filters above fused GroupJoin via
SelectNode
discard c789987f787 [fix](fe) Do not fuse GroupJoin with residual non-equi ON
conjuncts
discard 0f548a414a7 [fix](fe) Do not fuse GroupJoin with no aggregate functions
discard 85b28fba3ba [fix](fe) Enforce GroupJoin input hash distribution
discard 952f0cdfa7f [fix](fe) Correct GroupJoin runtime filter distribution
discard 450069bbdbd [fix](join) Restore nullable GroupJoin output keys
omit 6a064cf21ae [fix](fe) Fix GroupJoin fusion output tuple handling
omit 762d4a2721f [fix](fe) Fix GroupJoin session variable annotation
omit 1353543a175 fix be
omit aa55aed793b fe-part (#64763)
omit 9856466f9ee be fix
omit 8ba243d82cf be part
omit 91ffd58c03a thrift
add 43db29b8dbb [fix](zonemap) Treat reversed zone map bounds as invalid
(#67431)
add dc848b3fc32 [fix](temp-table) Fix CTAS/DROP for temporary tables and
unmute 5 P0 cases (#67529)
add ad4e9d73080 [feature](be) Support file metadata columns in V2 scans
(#67207)
add 050442dfc47 [fix](test) remove JUnit 4 from the fe reactor and unblock
the dependency licence review (#67396)
add caa7bbf4684 [fix](test) move StreamingInsertJobStatusTransitionTest to
JUnit 5 (#67543)
add b58b2c53ff5 [enhancement](thirdparty) fix arrow build bug and clear
dangerous env… (#67535)
add 74ccaf8938d [chore](lance) update lance version to tag 0.1.9 (#67496)
add 287a334b63c [feature](function) Support map arguments for
inner_product (#67311)
add 23b5ee5700f [fix](arrow-flight) Release a finished Flight query's
coordinator instead of holding it until wait_timeout (#67504)
add 66f237a9fbb [fix](config) Mask sensitive FE configs in SHOW FRONTEND
CONFIG via @ConfField(sensitive) (#67338)
add cf1a553731a [fix](be) Eliminate undefined float-to-wide-integer
conversion (#67463)
add 4d9468cdba3 [fix](subquery) Resolve correlated qualified columns
before dereference (#67438)
add cace2bb01f1 [improvement](workflow) Accept qualified local review
receipts (#66959)
add f75e66f8810 [improvement](parquet) Prune array_contains with row group
statistics (#67441)
add efedf10c7e3 [improvement](ci) Harden Litefuse OTLP reliability (#67416)
add 94f0d69ac8d [improvement](ci) Accept Astra and Fable 5.1 review
receipts (#67561)
add eea19b3f3cf [improvement](predicate) Extend monotonic predicate
inference to storage scans (#67182)
add 54f5c412205 [improvement](cascades) Fuse project pushdown into join
reorder (#67541)
add c7a44c738e6 [fix](auth) Add privilege checks to SHOW/EXPLAIN/REFRESH
DICTIONARY (#67343)
add 612896bff0d [improvement](ci) Verify Litefuse subagent trace
completeness (#67567)
add 28c63a4809d [fix](profile) Nereids Optimize Time shows N/A when MV
pre-rewrite is skipped (#67532)
add 2be8fba29d7 [improvement](snapshot) Add snapshot retained analysis
interface (#67616)
add be7c013c119 [fix](fe) Upgrade gRPC and remove unused LZ4 dependencies
(#67585)
add 53e1f62096e [Improve](cloud) Only register watershed txn id once when
BE enters decommissioning state (#67322)
add 62b8b4b3b88 [fix](be) Preserve rows for untrusted Parquet null counts
(#67573)
add 53264e01c6a [fix](be) Reduce Iceberg equality delete index memory
(#67570)
add 685e91f962a [feature](timestamp_ns) Add end-to-end TIMESTAMP_NS
support (#66761)
add ac7244ff197 [fix](ci) Skip Codex auth with reused refresh tokens
(#67635)
add e1df149d617 [fix](local shuffle) Prevent local exchange under serial
parent pipeline (#67490)
add 798eb24b176 [fix](binlog) Fix row binlog recovery for multi-tablet
transactions (#67508)
add c275e05579b [fix](catalog) Restore DLF support for Iceberg and Paimon
(#67545)
add 94ad62a4aea [fix](cloud) prevent warm-up job scheduling starvation
(#67527)
add bd01e332267 [refactor](qe) Merge the duplicate ConnectType enum and
drop the unreachable forward branch (#67572)
add a42928c5caf [fix](be) Avoid repeated peer connect failures (#67464)
add c88e889515e [feature](function) Add ST_IsClosed function (#67350)
add 396ad795b05 [fix](test) Isolate TPC-H MOR-as-DUP tables from
compaction (#67566)
add 9957987d5bf [fix](cloud) Return existing rowset for concurrent commits
(#67637)
add eeba1511353 thrift
add 7e72b092fb1 be part
add d5285f0229b be fix
add caaec6ca5f1 fe-part (#64763)
add 873f81fd110 fix be
add 8da2e4679e8 [fix](fe) Fix GroupJoin session variable annotation
add c33d2aa4125 [fix](fe) Fix GroupJoin fusion output tuple handling
add 7637ca75012 [fix](join) Restore nullable GroupJoin output keys
add 2ed6065e686 [fix](fe) Correct GroupJoin runtime filter distribution
add 2d78e2d249e [fix](fe) Enforce GroupJoin input hash distribution
add b36220cd077 [fix](fe) Do not fuse GroupJoin with no aggregate functions
add 27aa579a506 [fix](fe) Do not fuse GroupJoin with residual non-equi ON
conjuncts
add c8e0a818dd5 [fix](fe) Apply HAVING filters above fused GroupJoin via
SelectNode
add 0ae9389a43a [fix](fe) Do not fuse GroupJoin with aggregates over
intermediate Project slots
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 (60f5bbfecd4)
\
N -- N -- N refs/heads/groupjoin (0ae9389a43a)
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/scripts/emit_litefuse_otel_io.py | 463 ++--
.github/scripts/resolve_code_review_status.py | 123 +
.github/scripts/test_emit_litefuse_otel_io.py | 579 +++++
.github/scripts/test_resolve_code_review_status.py | 119 +
.github/scripts/test_review_auth_quarantine.py | 394 +++
.../scripts/test_validate_review_pass_comment.py | 299 +++
.github/scripts/validate_review_pass_comment.py | 238 ++
.github/workflows/code-review-aggregate-status.yml | 85 +
.github/workflows/code-review-runner.yml | 140 +-
.github/workflows/code-review-sync-result.yml | 252 +-
.github/workflows/third_party_review.yml | 17 +-
be/src/agent/be_exec_version_manager.cpp | 4 +-
be/src/agent/be_exec_version_manager.h | 1 +
be/src/cloud/config.cpp | 4 +
be/src/cloud/config.h | 3 +
be/src/common/consts.h | 4 +
be/src/core/CMakeLists.txt | 12 +-
be/src/core/call_on_type_index.h | 5 +
be/src/core/column/column_array.cpp | 6 +
be/src/core/column/column_array.h | 2 +-
be/src/core/column/column_vector.cpp | 1 +
be/src/core/column/column_vector.h | 9 +-
be/src/core/column/columns_common.cpp | 2 +
.../variant_v2/column_variant_v2_typed_column.cpp | 1 +
.../variant_v2/column_variant_v2_typed_column.h | 2 +
be/src/core/data_type/convert_field_to_type.cpp | 6 +
be/src/core/data_type/data_type.cpp | 2 +
be/src/core/data_type/data_type_factory.cpp | 10 +
be/src/core/data_type/data_type_number_base.cpp | 11 +-
be/src/core/data_type/data_type_number_base.h | 3 +-
be/src/core/data_type/data_type_time.h | 4 +-
be/src/core/data_type/data_type_timestamp_ns.cpp | 48 +
.../src/core/data_type/data_type_timestamp_ns.h | 35 +-
be/src/core/data_type/define_primitive_type.h | 3 +-
be/src/core/data_type/primitive_type.cpp | 9 +
be/src/core/data_type/primitive_type.h | 15 +
be/src/core/data_type/storage_field_type.cpp | 4 +
.../data_type_serde/data_type_number_serde.cpp | 38 +-
.../core/data_type_serde/data_type_number_serde.h | 20 +-
be/src/core/data_type_serde/data_type_serde.cpp | 2 +
.../data_type_timestamp_ns_serde.cpp | 505 ++++
.../data_type_serde/data_type_timestamp_ns_serde.h | 102 +
be/src/core/field.cpp | 23 +
be/src/core/type_limit.h | 8 +
be/src/core/value/time_value.h | 6 +-
be/src/core/value/timestamp_ns_value.cpp | 98 +
be/src/core/value/timestamp_ns_value.h | 324 +++
be/src/core/value/vdatetime_value.cpp | 25 +-
be/src/core/value/vdatetime_value.h | 4 +-
be/src/core/wide_integer_from_double.cpp | 50 -
be/src/core/wide_integer_impl.h | 194 +-
be/src/exec/common/field_visitors.h | 3 +
be/src/exec/common/hash_table/hash.h | 12 +
be/src/exec/common/join_op_utils.h | 16 +-
be/src/exec/common/join_utils.h | 27 +-
be/src/exec/common/variant_util.cpp | 4 +-
be/src/exec/operator/hashjoin_build_sink.cpp | 197 +-
be/src/exec/operator/hashjoin_build_sink.h | 1 +
.../operator/join/process_hash_table_probe_impl.h | 43 +-
be/src/exec/operator/scan_operator.cpp | 22 +-
be/src/exec/operator/scan_operator.h | 4 +
be/src/exec/pipeline/dependency.h | 3 +-
.../runtime_filter_partition_pruner.cpp | 3 +
.../exec/runtime_filter/runtime_filter_wrapper.cpp | 4 +
be/src/exec/runtime_filter/utils.h | 3 +
be/src/exec/scan/file_scanner_v2.cpp | 22 +-
be/src/exec/sink/vrow_distribution.h | 1 +
.../aggregate_function_approx_count_distinct.cpp | 2 +-
.../aggregate_function_approx_count_distinct.h | 3 +-
.../exprs/aggregate/aggregate_function_array_agg.h | 5 +-
.../exprs/aggregate/aggregate_function_collect.h | 2 +-
.../aggregate/aggregate_function_histogram.cpp | 12 +-
.../exprs/aggregate/aggregate_function_map_v2.cpp | 3 +-
.../aggregate/aggregate_function_min_max_by.cpp | 4 +
.../aggregate/aggregate_function_min_max_by.h | 6 +
.../aggregate/aggregate_function_min_max_impl.h | 4 +
.../aggregate_function_sequence_match.cpp | 3 +
.../aggregate/aggregate_function_topn_array.cpp | 9 +-
.../aggregate/aggregate_function_topn_weighted.cpp | 9 +-
be/src/exprs/aggregate/aggregate_function_uniq.cpp | 13 +-
.../aggregate/aggregate_function_window_funnel.cpp | 3 +
.../aggregate/aggregate_function_window_funnel.h | 32 +-
.../aggregate_function_window_funnel_v2.cpp | 3 +
.../aggregate_function_window_funnel_v2.h | 57 +-
be/src/exprs/create_predicate_function.h | 1 +
be/src/exprs/expr_zonemap_filter.cpp | 123 +-
be/src/exprs/expr_zonemap_filter.h | 27 +-
.../function/array/function_array_aggregation.cpp | 5 +-
.../function/array/function_array_distance.cpp | 3 +-
be/src/exprs/function/array/function_array_index.h | 25 +-
.../exprs/function/array/function_array_range.cpp | 45 +-
.../function/cast/cast_to_basic_number_common.h | 8 +-
be/src/exprs/function/cast/cast_to_date.h | 70 +
.../function/cast/cast_to_datetimev2_impl.hpp | 227 +-
be/src/exprs/function/cast/cast_to_float.h | 1 +
be/src/exprs/function/cast/cast_to_int.h | 5 +-
be/src/exprs/function/cast/cast_to_string.h | 13 +
be/src/exprs/function/cast/cast_to_timestamp_ns.h | 403 +++
be/src/exprs/function/cast/cast_to_timestamptz.h | 48 +
be/src/exprs/function/cast/cast_wrapper_decls.h | 5 +-
be/src/exprs/function/cast/function_cast.cpp | 3 +
be/src/exprs/function/cast/function_cast_date.cpp | 4 +-
...estamptz.cpp => function_cast_timestamp_ns.cpp} | 42 +-
.../function/cast/function_cast_timestamptz.cpp | 3 +-
.../cast/variant_v2/cast_variant_to_scalar.cpp | 81 +-
be/src/exprs/function/date_format_type.h | 3 +-
be/src/exprs/function/date_time_transforms.h | 230 +-
be/src/exprs/function/dictionary.h | 8 +-
be/src/exprs/function/function.cpp | 7 +
be/src/exprs/function/function.h | 4 +-
be/src/exprs/function/function_convert_tz.cpp | 66 +-
.../function_date_or_datetime_computation.cpp | 144 +-
.../function_date_or_datetime_computation.h | 482 +++-
.../function_date_or_datetime_to_something.h | 9 +-
.../function_date_or_datetime_to_string.cpp | 46 +-
.../function/function_datetime_floor_ceil.cpp | 154 +-
.../function_datetime_string_to_string.cpp | 8 +
.../function/function_datetime_string_to_string.h | 1 +
be/src/exprs/function/function_inner_product.h | 479 ++++
be/src/exprs/function/function_map.cpp | 12 +-
.../function/function_other_types_to_date.cpp | 155 +-
be/src/exprs/function/functions_comparison.h | 114 +-
be/src/exprs/function/geo/functions_geo.cpp | 41 +
be/src/exprs/function/least_greast.cpp | 17 +-
be/src/exprs/function/time_of_function.cpp | 19 +
be/src/exprs/function/to_time_function.cpp | 59 +
be/src/exprs/function_context.cpp | 1 +
be/src/exprs/function_context.h | 5 +
.../exprs/lambda_function/varray_sort_function.cpp | 3 +-
be/src/exprs/vcase_expr.h | 3 +
be/src/exprs/vcast_expr.cpp | 3 +
be/src/exprs/vcast_expr.h | 10 +-
be/src/exprs/vcondition_expr.cpp | 5 +
be/src/exprs/vdirect_in_predicate.h | 1 +
be/src/exprs/vectorized_fn_call.cpp | 36 +-
be/src/exprs/vexpr.cpp | 9 +
be/src/exprs/vexpr.h | 9 +
be/src/exprs/vexpr_context.h | 6 +
be/src/exprs/vin_predicate.cpp | 5 +-
be/src/exprs/vtopn_pred.cpp | 2 +
be/src/format/arrow/arrow_row_batch.cpp | 4 +
be/src/format/jni/jni_data_bridge.cpp | 5 +
be/src/format/jni/jni_data_bridge.h | 4 +-
be/src/format_v2/column_data.h | 4 +
be/src/format_v2/column_mapper.cpp | 53 +-
be/src/format_v2/column_mapper.h | 10 +
be/src/format_v2/expr/equality_delete_hash_index.h | 61 +
.../format_v2/expr/equality_delete_predicate.cpp | 24 +-
be/src/format_v2/expr/equality_delete_predicate.h | 12 +-
be/src/format_v2/parquet/parquet_statistics.cpp | 179 +-
be/src/format_v2/parquet/parquet_statistics.h | 3 +-
.../parquet/reader/native/column_chunk_reader.cpp | 10 +-
.../parquet/reader/native/column_chunk_reader.h | 2 +
be/src/format_v2/table/iceberg_reader.cpp | 101 +-
be/src/format_v2/table/iceberg_reader.h | 6 +
be/src/format_v2/table/paimon_reader.cpp | 110 +
be/src/format_v2/table/paimon_reader.h | 12 +
be/src/format_v2/table_reader.cpp | 8 +
be/src/format_v2/table_reader.h | 3 +
.../information_schema/schema_columns_scanner.cpp | 14 +-
be/src/io/cache/peer_file_cache_reader.cpp | 63 +-
be/src/runtime/fold_constant_executor.cpp | 16 +-
be/src/runtime/runtime_predicate.cpp | 3 +-
be/src/storage/data_dir.cpp | 11 +-
be/src/storage/delete/delete_handler.cpp | 2 +
be/src/storage/field_type.h | 2 +
.../bloom_filter/bloom_filter_index_writer.cpp | 1 +
be/src/storage/index/index_writer.cpp | 1 +
.../index/inverted/inverted_index_writer.cpp | 3 +-
.../storage/index/inverted/inverted_index_writer.h | 3 +-
be/src/storage/index/snii/bkd/bkd_index_block.cpp | 4 +-
be/src/storage/index/zone_map/zone_map_index.cpp | 37 +-
be/src/storage/iterator/olap_data_convertor.cpp | 3 +
be/src/storage/key_coder.cpp | 1 +
be/src/storage/key_coder.h | 1 +
be/src/storage/olap_scan_common.h | 9 +-
be/src/storage/partial_update_info.cpp | 28 +
be/src/storage/predicate/predicate_creator.cpp | 4 +
.../predicate/predicate_creator_comparison.cpp | 4 +
.../predicate/predicate_creator_in_list_in.cpp | 4 +
.../predicate/predicate_creator_in_list_not_in.cpp | 4 +
be/src/storage/segment/encoding_info.cpp | 5 +
.../segment/variant/v2/variant_path_builder.cpp | 43 +-
.../segment/variant/v2/variant_storage_cell.cpp | 13 +
be/src/storage/tablet/tablet_manager.cpp | 25 +-
be/src/storage/tablet/tablet_meta.cpp | 9 +
be/src/storage/tablet/tablet_meta.h | 3 +
be/src/storage/tablet/tablet_schema.cpp | 16 +
be/src/storage/tablet/tablet_schema.h | 8 +
be/src/storage/tablet_info.cpp | 6 +
be/src/storage/types.h | 10 +-
be/src/storage/utils.cpp | 26 +-
be/src/storage/utils.h | 3 +-
be/src/tools/meta_tool.cpp | 10 +
be/src/udf/python/python_server.py | 10 +
be/src/util/brpc_client_cache.h | 7 +-
be/src/util/raw_value.h | 3 +-
be/test/core/column/common_column_test.h | 5 +-
be/test/core/data_type/common_data_type_test.h | 1 +
.../core/data_type/data_type_datetime_v2_test.cpp | 5 +-
.../core/data_type/data_type_timestamp_ns_test.cpp | 681 +++++
be/test/core/data_type/storage_field_type_test.cpp | 4 +-
.../data_type_serde/data_type_serde_arrow_test.cpp | 178 ++
.../data_type_serde_datelike_batch_test.cpp | 78 +-
.../data_type_serde_decoded_values_test.cpp | 2 +-
be/test/core/jsonb/convert_field_to_type_test.cpp | 20 +
be/test/core/wide_integer_test.cpp | 40 +
be/test/exec/common/schema_util_test.cpp | 9 +
be/test/exec/operator/asof_join_test.cpp | 50 +
.../operator/scan_normalize_predicate_test.cpp | 89 +
.../runtime_filter_partition_pruner_test.cpp | 50 +
.../runtime_filter/runtime_filter_wrapper_test.cpp | 2 +
be/test/exec/scan/file_scanner_v2_test.cpp | 41 +-
.../sink/tablet_sink_hash_partitioner_test.cpp | 109 +
.../aggregate/agg_approx_count_distinct_test.cpp | 64 +
be/test/exprs/aggregate/agg_min_max_test.cpp | 37 +
.../exprs/aggregate/vec_sequence_match_test.cpp | 10 +
be/test/exprs/aggregate/vec_window_funnel_test.cpp | 50 +
.../exprs/aggregate/vec_window_funnel_v2_test.cpp | 23 +
be/test/exprs/expr_zonemap_filter_test.cpp | 56 +-
be/test/exprs/function/cast/cast_test.h | 2 +
.../exprs/function/cast/cast_timestamp_ns_test.cpp | 292 +++
.../function/cast/cast_to_timestamptz_test.cpp | 100 +
.../function/cast/cast_variant_v2_from_test.cpp | 44 +
...ion_comparison_evaluate_inverted_index_test.cpp | 51 +
.../function/function_map_inner_product_test.cpp | 429 ++++
be/test/exprs/function/function_test_util.cpp | 21 +-
be/test/exprs/function/function_test_util.h | 9 +
be/test/exprs/function/function_time_test.cpp | 29 +
.../exprs/function/function_timestamp_ns_test.cpp | 652 +++++
be/test/exprs/function/geo/functions_geo_test.cpp | 32 +
.../function/simple_function_factory_test.cpp | 107 +
be/test/exprs/vcondition_expr_test.cpp | 56 +-
be/test/exprs/vexpr_unaligned_int128_test.cpp | 11 +
be/test/format_v2/column_mapper_test.cpp | 70 +-
be/test/format_v2/jni/jni_table_reader_test.cpp | 38 +
be/test/format_v2/parquet/parquet_reader_test.cpp | 9 +-
be/test/format_v2/parquet/parquet_scan_test.cpp | 57 +-
.../format_v2/parquet/parquet_statistics_test.cpp | 312 ++-
.../pyarrow-3.0.0-dictionary-null-count.parquet | Bin 0 -> 944 bytes
be/test/format_v2/table/iceberg_reader_test.cpp | 107 +
be/test/format_v2/table_reader_test.cpp | 78 +
.../cache/cached_remote_file_reader_peer_test.cpp | 23 +
be/test/olap/rowset/group_rowset_builder_test.cpp | 131 +-
be/test/runtime/fold_constant_executor_test.cpp | 87 +
be/test/runtime/runtime_predicate_test.cpp | 23 +-
be/test/storage/delete/delete_handler_test.cpp | 7 +
.../index/snii/snii_bkd_adapter_types_test.cpp | 5 +-
be/test/storage/key/row_key_encoder_test.cpp | 61 +-
be/test/storage/key_coder_test.cpp | 1 +
be/test/storage/partial_update_info_test.cpp | 84 +
.../predicate/block_column_predicate_test.cpp | 52 +-
.../storage/predicate/predicate_creator_test.cpp | 135 +
.../bloom_filter_index_reader_writer_test.cpp | 42 +
.../storage/segment/inverted_index_writer_test.cpp | 112 +-
.../segment/variant_assembler_legacy_test.cpp | 7 +
be/test/storage/segment/zone_map_index_test.cpp | 271 ++
be/test/storage/tablet/tablet_schema_test.cpp | 19 +
.../variant/variant_column_writer_reader_test.cpp | 104 +
be/test/testutil/datetime_ut_util.h | 2 +-
cloud/src/common/http_helper.cpp | 32 +
cloud/src/common/http_helper.h | 6 +
cloud/src/meta-service/meta_service.cpp | 40 +-
cloud/src/recycler/recycler.h | 2 +
cloud/src/snapshot/snapshot_manager.cpp | 10 +
cloud/src/snapshot/snapshot_manager.h | 15 +
cloud/test/meta_service_http_test.cpp | 6 +
cloud/test/meta_service_test.cpp | 45 +
.../doris/common/jni/utils/JavaUdfDataType.java | 6 +
.../doris/common/jni/utils/TypeNativeBytes.java | 18 +
.../apache/doris/common/jni/vec/ColumnType.java | 5 +
.../apache/doris/common/jni/vec/VectorColumn.java | 55 +
.../apache/doris/common/jni/JniScannerTest.java | 89 +
.../java/org/apache/doris/udf/BaseExecutor.java | 6 +-
.../max-compute-connector/pom.xml | 3 +
.../doris/maxcompute/MaxComputeJniWriterTest.java | 52 +
fe/check/checkstyle/checkstyle.xml | 20 +
fe/check/checkstyle/suppressions.xml | 10 +
.../java/org/apache/doris/analysis/CastExpr.java | 15 +-
.../org/apache/doris/analysis/DateLiteral.java | 3 +
.../org/apache/doris/analysis/ExprVisitor.java | 6 +-
.../apache/doris/analysis/TimeStampNsLiteral.java | 373 +++
.../org/apache/doris/catalog/AggregateType.java | 2 +
.../java/org/apache/doris/catalog/ColumnType.java | 9 +
.../doris/persist/gson/GsonUtilsCatalog.java | 2 +
.../main/java/org/apache/doris/common/Config.java | 40 +-
.../java/org/apache/doris/common/ConfigTest.java | 75 +-
.../apache/doris/common/FractionalFormatTest.java | 42 +-
.../java/org/apache/doris/common/PairTest.java | 20 +-
.../apache/doris/common/io/BitmapValueTest.java | 166 +-
.../io/ByteBufferNetworkInputStreamTest.java | 22 +-
.../org/apache/doris/common/io/DiskUtilsTest.java | 8 +-
.../java/org/apache/doris/common/io/HllTest.java | 92 +-
.../connector/hive/HiveConnectorMetadata.java | 29 +-
.../hive/HiveConnectorMetadataSchemaTest.java | 10 +
...HiveConnectorMetadataSiblingDelegationTest.java | 7 +-
.../fe-connector-hms-hive-shade/pom.xml | 22 +
.../connector/iceberg/IcebergCatalogFactory.java | 14 +-
.../iceberg/IcebergCatalogProperties.java | 9 +-
.../doris/connector/iceberg/IcebergConnector.java | 88 +-
.../iceberg/IcebergConnectorMetadata.java | 74 +-
.../iceberg/IcebergConnectorProvider.java | 8 +
.../connector/iceberg/IcebergScanPlanProvider.java | 59 +-
.../doris/connector/iceberg/dlf/DLFCatalog.java | 132 +
.../connector/iceberg/dlf/DLFTableOperations.java} | 28 +-
.../iceberg/dlf/HiveCompatibleCatalog.java | 292 +++
.../iceberg/dlf/client/DLFCachedClientPool.java | 83 +
.../iceberg/dlf/client/DLFClientPool.java | 47 +
.../iceberg/IcebergCatalogFactoryTest.java | 16 +-
.../iceberg/IcebergCatalogPropertiesTest.java | 14 +
.../iceberg/IcebergConnectorMetadataDdlTest.java | 68 +
.../iceberg/IcebergConnectorMetadataMvccTest.java | 8 +-
.../iceberg/IcebergConnectorMetadataTest.java | 71 +-
.../connector/iceberg/IcebergConnectorTest.java | 22 +-
.../IcebergConnectorTestConnectionTest.java | 64 +
.../IcebergConnectorValidatePropertiesTest.java | 13 +-
.../IcebergScanPlanProviderClassifyColumnTest.java | 2 +
.../iceberg/IcebergScanPlanProviderTest.java | 95 +
.../connector/iceberg/dlf/DLFCatalogTest.java | 48 +
.../iceberg/dlf/HiveCompatibleCatalogTest.java | 320 +++
.../metastore/DlfMetaStoreProperties.java} | 15 +-
.../iceberg/dlf/IcebergDlfMetaStoreProperties.java | 42 +
.../iceberg/dlf/IcebergDlfMetaStoreProvider.java | 49 +
...doris.connector.metastore.spi.MetaStoreProvider | 1 +
.../IcebergMetaStoreProvidersDispatchTest.java | 16 +-
.../dlf/IcebergDlfMetaStorePropertiesTest.java | 109 +
.../paimon/dlf/PaimonDlfMetaStoreProperties.java | 43 +
.../paimon/dlf/PaimonDlfMetaStoreProvider.java | 49 +
...doris.connector.metastore.spi.MetaStoreProvider | 1 +
.../paimon/MetaStoreProvidersDispatchTest.java | 16 +-
.../dlf/PaimonDlfMetaStorePropertiesTest.java | 72 +
.../spi/AbstractDlfMetaStoreProperties.java | 128 +
.../fe-connector-paimon-hive-shade/pom.xml | 19 +
.../connector/paimon/PaimonCatalogFactory.java | 39 +
.../connector/paimon/PaimonCatalogProperties.java | 5 +-
.../doris/connector/paimon/PaimonColumnHandle.java | 4 +
.../doris/connector/paimon/PaimonConnector.java | 75 +
.../connector/paimon/PaimonConnectorMetadata.java | 75 +-
.../connector/paimon/PaimonScanPlanProvider.java | 86 +-
.../doris/connector/paimon/PaimonScanRange.java | 13 +
.../connector/paimon/PaimonCatalogFactoryTest.java | 76 +-
.../paimon/PaimonConnectorMetadataMvccTest.java | 14 +-
.../paimon/PaimonConnectorMetadataTest.java | 68 +-
.../paimon/PaimonConnectorTestConnectionTest.java | 85 +
.../PaimonConnectorValidatePropertiesTest.java | 27 +-
.../paimon/PaimonCreateTableValidationTest.java | 13 +
.../PaimonScanPlanProviderClassifyColumnTest.java} | 25 +-
.../paimon/PaimonScanPlanProviderTest.java | 48 +
.../paimon/PaimonScanRangeReaderTypeTest.java | 4 +
.../paimon/PaimonTableHandleScanOptionsTest.java | 4 +-
.../paimon/RecordingConnectorContext.java | 22 +-
.../doris/connector/spi/ConnectorCapability.java | 16 +-
.../doris/connector/spi/ConnectorProvider.java | 12 +
.../apache/doris/connector/spi/package-info.java | 5 +-
.../connector/spi/ConnectorPluginSurfaceTest.java | 23 +-
.../test/resources/connector-plugin-surface.txt | 15 +
fe/fe-connector/pom.xml | 2 +-
fe/fe-core/pom.xml | 1 +
.../java/org/apache/doris/analysis/ColumnDef.java | 14 +-
.../apache/doris/analysis/DateLiteralUtils.java | 171 +-
.../apache/doris/analysis/ExprToSqlVisitor.java | 5 +
.../doris/analysis/ExprToStringValueVisitor.java | 8 +
.../apache/doris/analysis/ExprToThriftVisitor.java | 15 +
.../apache/doris/analysis/LiteralExprUtils.java | 5 +-
.../apache/doris/analysis/PartitionExprUtil.java | 75 +-
.../doris/catalog/BuiltinScalarFunctions.java | 10 +
.../org/apache/doris/catalog/ColumnToProtobuf.java | 12 +-
.../org/apache/doris/catalog/ColumnToThrift.java | 8 +-
.../org/apache/doris/catalog/PartitionInfo.java | 3 +-
.../org/apache/doris/catalog/PartitionKey.java | 33 +-
.../apache/doris/cloud/CacheHotspotManager.java | 120 +-
.../doris/cloud/catalog/CloudClusterChecker.java | 6 +-
.../doris/common/profile/SummaryProfile.java | 12 +-
.../doris/common/util/DatasourcePrintableMap.java | 1 +
.../doris/common/util/DynamicPartitionUtil.java | 1 +
.../common/util/FetchRemoteTabletSchemaUtil.java | 1 +
.../org/apache/doris/common/util/LocationPath.java | 16 +-
.../apache/doris/common/util/PropertyAnalyzer.java | 4 +-
.../java/org/apache/doris/common/util/Util.java | 1 +
.../apache/doris/connector/ConnectorFactory.java | 8 +
.../doris/connector/ConnectorPluginManager.java | 18 +
.../org/apache/doris/datasource/CatalogIf.java | 5 +
.../apache/doris/datasource/InternalCatalog.java | 8 +
.../plugin/PluginDrivenExternalCatalog.java | 17 +
.../plugin/PluginDrivenExternalTable.java | 5 +
.../plugin/PluginDrivenSysExternalTable.java | 6 +
.../doris/httpv2/util/StatementSubmitter.java | 3 +-
.../util/streamresponse/JsonStreamResponse.java | 3 +-
.../insert/streaming/StreamingInsertJob.java | 24 +
.../streaming/StreamingJobSchedulerTask.java | 7 +-
.../doris/mtmv/MTMVPartitionExprDateTrunc.java | 83 +
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 4 +-
...MTMVRelatedPartitionDescSyncLimitGenerator.java | 5 +-
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 9 +
.../org/apache/doris/mysql/MysqlSerializer.java | 26 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 114 +-
.../org/apache/doris/nereids/analyzer/Scope.java | 19 +
.../glue/translator/ExpressionTranslator.java | 1 +
.../glue/translator/PhysicalPlanTranslator.java | 28 +
.../glue/translator/PlanTranslatorContext.java | 14 +
.../nereids/load/NereidsLoadScanProvider.java | 8 +-
.../nereids/load/NereidsStreamLoadPlanner.java | 8 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 4 +-
.../AddMonotonicFunctionPruningPredicates.java | 92 +
.../nereids/processor/post/PlanPostProcessors.java | 1 +
.../org/apache/doris/nereids/rules/RuleSet.java | 2 -
.../nereids/rules/analysis/BindExpression.java | 158 +-
.../doris/nereids/rules/analysis/BindSink.java | 8 +-
.../rules/analysis/DatetimeFunctionBinder.java | 35 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 224 +-
.../exploration/join/InnerJoinLAsscomProject.java | 17 +-
.../join/InnerJoinLeftAssociateProject.java | 17 +-
.../join/InnerJoinRightAssociateProject.java | 17 +-
.../exploration/join/JoinExchangeBothProject.java | 25 +-
.../join/LogicalJoinSemiJoinTransposeProject.java | 33 +-
.../exploration/join/OuterJoinAssocProject.java | 21 +-
.../exploration/join/OuterJoinLAsscomProject.java | 24 +-
.../exploration/join/ProjectJoinReorderHelper.java | 192 ++
.../join/PushDownProjectThroughInnerOuterJoin.java | 94 +-
.../join/PushDownProjectThroughSemiJoin.java | 41 +-
.../join/SemiJoinSemiJoinTransposeProject.java | 17 +-
.../mv/AbstractMaterializedViewRule.java | 2 +-
.../nereids/rules/expression/check/CheckCast.java | 26 +
.../expression/rules/DateFunctionRewrite.java | 28 +
.../expression/rules/FoldConstantRuleOnBE.java | 33 +-
.../expression/rules/FoldConstantRuleOnFE.java | 12 +-
.../rules/InferPredicateFromMonotonicFunction.java | 336 ++-
.../rules/expression/rules/PartitionPruner.java | 2 +-
.../rules/PredicateRewriteForPartitionPrune.java | 121 +-
.../rules/expression/rules/SimplifyCastRule.java | 2 +-
.../rules/SimplifyComparisonPredicate.java | 100 +-
.../expression/rules/SimplifyInPredicate.java | 7 +-
.../PushDownVirtualColumnsIntoOlapScan.java | 2 +
.../doris/nereids/stats/FilterEstimation.java | 35 +-
.../doris/nereids/trees/expressions/Cast.java | 111 +-
.../functions/ComputeSignatureHelper.java | 42 +-
.../functions/DateCeilFloorMonotonic.java | 37 +
.../functions/DateTimeWithPrecision.java | 16 +-
.../expressions/functions/RoundingMonotonic.java | 21 +
.../expressions/functions/SearchSignature.java | 46 +-
.../SupportsMixedTimeStampNsDateTime.java} | 15 +-
.../expressions/functions/agg/SequenceCount.java | 3 +
.../functions/agg/SequenceFunction.java | 3 +-
.../expressions/functions/agg/SequenceMatch.java | 3 +
.../expressions/functions/agg/TopNWeighted.java | 8 +
.../expressions/functions/agg/WindowFunnel.java | 6 +-
.../expressions/functions/agg/WindowFunnelV2.java | 6 +-
.../functions/executable/DateTimeAcquire.java | 66 +-
.../functions/executable/DateTimeArithmetic.java | 293 ++-
.../executable/DateTimeExtractAndTransform.java | 481 +++-
.../functions/executable/StringArithmetic.java | 15 +
.../functions/executable/TimeRoundSeries.java | 353 ++-
.../expressions/functions/scalar/AddTime.java | 3 +
.../expressions/functions/scalar/ArrayRange.java | 5 +
.../functions/scalar/ArrayRangeDayUnit.java | 3 +
.../functions/scalar/ArrayRangeHourUnit.java | 3 +
.../functions/scalar/ArrayRangeMinuteUnit.java | 3 +
.../functions/scalar/ArrayRangeMonthUnit.java | 3 +
.../functions/scalar/ArrayRangeQuarterUnit.java | 3 +
.../functions/scalar/ArrayRangeSecondUnit.java | 3 +
.../functions/scalar/ArrayRangeWeekUnit.java | 3 +
.../functions/scalar/ArrayRangeYearUnit.java | 3 +
.../expressions/functions/scalar/Century.java | 4 +-
.../expressions/functions/scalar/Coalesce.java | 7 +-
.../expressions/functions/scalar/ConvertTz.java | 5 +-
.../trees/expressions/functions/scalar/Date.java | 12 +-
.../expressions/functions/scalar/DateDiff.java | 11 +-
.../expressions/functions/scalar/DateFormat.java | 3 +
.../expressions/functions/scalar/DateTrunc.java | 33 +
.../trees/expressions/functions/scalar/DateV2.java | 4 +-
.../expressions/functions/scalar/DayCeil.java | 19 +
.../expressions/functions/scalar/DayFloor.java | 19 +
.../expressions/functions/scalar/DayHour.java | 4 +-
.../expressions/functions/scalar/DayHourAdd.java | 3 +
.../expressions/functions/scalar/DayHourSub.java | 3 +
.../functions/scalar/DayMicrosecond.java | 4 +-
.../functions/scalar/DayMicrosecondAdd.java | 6 +
.../functions/scalar/DayMicrosecondSub.java | 6 +
.../expressions/functions/scalar/DayMinute.java | 4 +-
.../expressions/functions/scalar/DayMinuteAdd.java | 3 +
.../expressions/functions/scalar/DayMinuteSub.java | 3 +
.../expressions/functions/scalar/DayName.java | 4 +-
.../expressions/functions/scalar/DayOfMonth.java | 4 +-
.../expressions/functions/scalar/DayOfWeek.java | 4 +-
.../expressions/functions/scalar/DayOfYear.java | 4 +-
.../expressions/functions/scalar/DaySecond.java | 4 +-
.../expressions/functions/scalar/DaySecondAdd.java | 3 +
.../expressions/functions/scalar/DaySecondSub.java | 3 +
.../expressions/functions/scalar/DaysAdd.java | 3 +
.../expressions/functions/scalar/DaysDiff.java | 9 +-
.../expressions/functions/scalar/DaysSub.java | 2 +
.../trees/expressions/functions/scalar/Field.java | 2 +
.../expressions/functions/scalar/FromUnixtime.java | 61 +-
.../functions/scalar/GreatestLeast.java | 7 +-
.../trees/expressions/functions/scalar/Hour.java | 2 +
.../expressions/functions/scalar/HourCeil.java | 19 +
.../expressions/functions/scalar/HourFloor.java | 19 +
.../functions/scalar/HourMicrosecond.java | 4 +-
.../functions/scalar/HourMicrosecondAdd.java | 6 +
.../functions/scalar/HourMicrosecondSub.java | 6 +
.../expressions/functions/scalar/HourMinute.java | 4 +-
.../functions/scalar/HourMinuteAdd.java | 3 +
.../functions/scalar/HourMinuteSub.java | 3 +
.../expressions/functions/scalar/HourSecond.java | 4 +-
.../functions/scalar/HourSecondAdd.java | 3 +
.../functions/scalar/HourSecondSub.java | 3 +
.../expressions/functions/scalar/HoursAdd.java | 4 +-
.../expressions/functions/scalar/HoursDiff.java | 10 +-
.../expressions/functions/scalar/HoursSub.java | 4 +-
.../trees/expressions/functions/scalar/If.java | 2 +-
.../expressions/functions/scalar/InnerProduct.java | 42 +-
.../expressions/functions/scalar/LastDay.java | 4 +-
.../functions/scalar/MicroSecondTimestamp.java | 4 +-
.../functions/scalar/MicroSecondsAdd.java | 5 +
.../functions/scalar/MicroSecondsDiff.java | 10 +-
.../functions/scalar/MicroSecondsSub.java | 5 +
.../expressions/functions/scalar/Microsecond.java | 13 +
.../functions/scalar/MilliSecondTimestamp.java | 4 +-
.../functions/scalar/MilliSecondsAdd.java | 5 +
.../functions/scalar/MilliSecondsDiff.java | 10 +-
.../functions/scalar/MilliSecondsSub.java | 5 +
.../trees/expressions/functions/scalar/Minute.java | 11 +
.../expressions/functions/scalar/MinuteCeil.java | 19 +
.../expressions/functions/scalar/MinuteFloor.java | 19 +
.../functions/scalar/MinuteMicrosecond.java | 4 +-
.../functions/scalar/MinuteMicrosecondAdd.java | 6 +
.../functions/scalar/MinuteMicrosecondSub.java | 6 +
.../expressions/functions/scalar/MinuteSecond.java | 4 +-
.../functions/scalar/MinuteSecondAdd.java | 3 +
.../functions/scalar/MinuteSecondSub.java | 3 +
.../expressions/functions/scalar/MinutesAdd.java | 4 +-
.../expressions/functions/scalar/MinutesDiff.java | 10 +-
.../expressions/functions/scalar/MinutesSub.java | 4 +-
.../trees/expressions/functions/scalar/Month.java | 4 +-
.../expressions/functions/scalar/MonthCeil.java | 19 +
.../expressions/functions/scalar/MonthFloor.java | 19 +
.../expressions/functions/scalar/MonthName.java | 4 +-
.../expressions/functions/scalar/MonthsAdd.java | 3 +
.../functions/scalar/MonthsBetween.java | 5 +
.../expressions/functions/scalar/MonthsDiff.java | 10 +-
.../expressions/functions/scalar/MonthsSub.java | 3 +
.../{MinutesAdd.java => NanoSecondsAdd.java} | 31 +-
.../{WeeksDiff.java => NanoSecondsDiff.java} | 45 +-
.../{MinutesAdd.java => NanoSecondsSub.java} | 31 +-
.../scalar/{Microsecond.java => Nanosecond.java} | 50 +-
.../expressions/functions/scalar/NextDay.java | 2 +
.../trees/expressions/functions/scalar/NullIf.java | 13 +-
.../trees/expressions/functions/scalar/Nvl.java | 2 +-
.../expressions/functions/scalar/PreviousDay.java | 2 +
.../expressions/functions/scalar/Quarter.java | 2 +
.../expressions/functions/scalar/QuarterCeil.java | 19 +
.../expressions/functions/scalar/QuarterFloor.java | 19 +
.../expressions/functions/scalar/QuartersAdd.java | 3 +
.../expressions/functions/scalar/QuartersDiff.java | 10 +-
.../expressions/functions/scalar/QuartersSub.java | 3 +
.../trees/expressions/functions/scalar/Second.java | 12 +
.../expressions/functions/scalar/SecondCeil.java | 19 +
.../expressions/functions/scalar/SecondFloor.java | 19 +
.../functions/scalar/SecondMicrosecond.java | 4 +-
.../functions/scalar/SecondMicrosecondAdd.java | 6 +
.../functions/scalar/SecondMicrosecondSub.java | 6 +
.../functions/scalar/SecondTimestamp.java | 4 +-
.../expressions/functions/scalar/SecondsAdd.java | 4 +-
.../expressions/functions/scalar/SecondsDiff.java | 10 +-
.../expressions/functions/scalar/SecondsSub.java | 4 +-
.../scalar/{DateV2.java => StIsClosed.java} | 26 +-
.../expressions/functions/scalar/SubTime.java | 3 +
.../trees/expressions/functions/scalar/Time.java | 4 +-
.../expressions/functions/scalar/TimeDiff.java | 17 +-
.../expressions/functions/scalar/TimeFormat.java | 5 +-
.../expressions/functions/scalar/TimeToSec.java | 2 +
.../expressions/functions/scalar/Timestamp.java | 5 +-
.../trees/expressions/functions/scalar/ToDate.java | 12 +-
.../expressions/functions/scalar/ToDateV2.java | 4 +-
.../trees/expressions/functions/scalar/ToDays.java | 4 +-
.../expressions/functions/scalar/ToIso8601.java | 2 +
.../trees/expressions/functions/scalar/ToJson.java | 2 +
.../expressions/functions/scalar/ToMonday.java | 12 +-
.../expressions/functions/scalar/ToSeconds.java | 4 +-
.../functions/scalar/UnixTimestamp.java | 46 +-
.../expressions/functions/scalar/UtcTimestamp.java | 18 +-
.../trees/expressions/functions/scalar/Week.java | 5 +-
.../expressions/functions/scalar/WeekCeil.java | 19 +
.../expressions/functions/scalar/WeekFloor.java | 19 +
.../expressions/functions/scalar/WeekOfYear.java | 4 +-
.../expressions/functions/scalar/Weekday.java | 4 +-
.../expressions/functions/scalar/WeeksAdd.java | 3 +
.../expressions/functions/scalar/WeeksDiff.java | 10 +-
.../expressions/functions/scalar/WeeksSub.java | 3 +
.../trees/expressions/functions/scalar/Year.java | 4 +-
.../expressions/functions/scalar/YearCeil.java | 19 +
.../expressions/functions/scalar/YearFloor.java | 19 +
.../expressions/functions/scalar/YearMonth.java | 4 +-
.../expressions/functions/scalar/YearMonthAdd.java | 3 +
.../expressions/functions/scalar/YearMonthSub.java | 3 +
.../expressions/functions/scalar/YearOfWeek.java | 2 +
.../expressions/functions/scalar/YearWeek.java | 5 +-
.../expressions/functions/scalar/YearsAdd.java | 3 +
.../expressions/functions/scalar/YearsDiff.java | 10 +-
.../expressions/functions/scalar/YearsSub.java | 3 +
.../functions/window/RequireTrivialTypes.java | 2 +
.../trees/expressions/literal/DateLiteral.java | 65 +-
.../trees/expressions/literal/DateTimeLiteral.java | 32 +
.../expressions/literal/DateTimeV2Literal.java | 26 +-
.../nereids/trees/expressions/literal/Literal.java | 18 +-
.../trees/expressions/literal/NumericLiteral.java | 12 +-
.../expressions/literal/StringLikeLiteral.java | 12 +-
.../expressions/literal/TimeStampNsLiteral.java | 355 +++
.../trees/expressions/literal/TimeV2Literal.java | 4 +
.../expressions/literal/TimestampTzLiteral.java | 12 +-
.../expressions/visitor/ExpressionVisitor.java | 5 +
.../expressions/visitor/ScalarFunctionVisitor.java | 25 +
.../plans/commands/CreateFunctionCommand.java | 3 +
.../trees/plans/commands/CreateTableCommand.java | 23 +-
.../plans/commands/ExplainDictionaryCommand.java | 14 +-
.../plans/commands/ShowDictionariesCommand.java | 26 +-
.../plans/commands/info/ColumnDefinition.java | 2 +-
.../trees/plans/commands/info/DefaultValue.java | 39 +-
.../commands/refresh/RefreshDictionaryCommand.java | 14 +
.../trees/plans/logical/LogicalRecursiveUnion.java | 6 +-
.../trees/plans/logical/LogicalSetOperation.java | 6 +-
.../nereids/trees/plans/logical/LogicalUnion.java | 4 +-
.../org/apache/doris/nereids/types/DataType.java | 43 +-
.../doris/nereids/types/TimeStampNsType.java | 99 +
.../doris/nereids/types/coercion/DateLikeType.java | 4 +
.../doris/nereids/util/DateTimeFormatterUtils.java | 93 +-
.../org/apache/doris/nereids/util/DateUtils.java | 114 +
.../org/apache/doris/nereids/util/JoinUtils.java | 6 +
.../doris/nereids/util/PredicateInferUtils.java | 6 +
.../doris/nereids/util/TypeCoercionUtils.java | 759 +++++-
.../org/apache/doris/persist/gson/GsonUtils.java | 2 +
.../org/apache/doris/planner/AddLocalExchange.java | 1 +
.../apache/doris/planner/GroupCommitPlanner.java | 20 +-
.../java/org/apache/doris/planner/PlanNode.java | 16 +-
.../java/org/apache/doris/planner/ScanNode.java | 11 +
.../java/org/apache/doris/qe/ConnectContext.java | 58 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 12 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 36 +-
.../org/apache/doris/qe/CoordinatorContext.java | 34 +-
.../org/apache/doris/qe/MysqlConnectProcessor.java | 1 +
.../java/org/apache/doris/qe/StmtExecutor.java | 56 +-
.../org/apache/doris/qe/cache/PartitionRange.java | 1 +
.../apache/doris/service/FrontendServiceImpl.java | 17 +-
.../arrowflight/FlightSqlConnectProcessor.java | 12 +-
.../service/arrowflight/FlightSqlSchemaHelper.java | 2 +
.../doris/statistics/util/StatisticsUtil.java | 4 +-
.../apache/doris/alter/AlterJobV2RetryTest.java | 24 +-
.../org/apache/doris/alter/CloudIndexTest.java | 210 +-
.../doris/alter/CloudSchemaChangeJobV2Test.java | 6 +-
.../org/apache/doris/alter/IndexChangeJobTest.java | 475 ++--
.../doris/alter/MaterializedViewHandlerTest.java | 38 +-
.../org/apache/doris/alter/RollupJobV2Test.java | 110 +-
.../doris/alter/SchemaChangeHandlerTest.java | 93 +-
.../apache/doris/alter/SchemaChangeJobV2Test.java | 213 +-
.../apache/doris/analysis/AlterUserStmtTest.java | 116 +-
.../doris/analysis/CastExprHashPartitionTest.java | 46 +
.../apache/doris/analysis/CreateUserStmtTest.java | 102 +-
.../analysis/CurrentTimestampDefaultValueTest.java | 86 +
.../doris/analysis/DateLiteralUtilsTest.java | 278 ++
.../analysis/DescriptorToThriftConverterTest.java | 25 +
.../doris/analysis/ExprGsonSerializationTest.java | 2 +
.../analysis/ExprToStringValueVisitorTest.java | 11 +
.../doris/analysis/ExprToThriftBehaviorTest.java | 11 +
.../doris/analysis/StorageDescPersistTest.java | 28 +-
.../apache/doris/analysis/TableScanParamsTest.java | 30 +-
.../org/apache/doris/analysis/TlsOptionsTest.java | 18 +-
.../doris/auth/certificate/SanEntryCodecTest.java | 10 +-
.../org/apache/doris/backup/BackupHandlerTest.java | 14 +-
.../org/apache/doris/backup/BackupJobInfoTest.java | 36 +-
.../org/apache/doris/backup/BackupJobTest.java | 198 +-
.../org/apache/doris/backup/PathMakerTest.java | 2 +-
.../org/apache/doris/backup/RepositoryTest.java | 101 +-
.../doris/backup/RestoreFileMappingTest.java | 24 +-
.../org/apache/doris/backup/RestoreJobTest.java | 24 +-
.../org/apache/doris/binlog/BinlogManagerTest.java | 86 +-
.../java/org/apache/doris/binlog/DbBinlogTest.java | 64 +-
.../org/apache/doris/binlog/TableBinlogTest.java | 48 +-
.../doris/blockrule/SqlBlockRuleMgrTest.java | 32 +-
.../org/apache/doris/catalog/AIResourceTest.java | 174 +-
.../java/org/apache/doris/catalog/BackendTest.java | 74 +-
.../doris/catalog/ColocateTableIndexTest.java | 16 +-
.../apache/doris/catalog/ColocateTableTest.java | 228 +-
.../ColumnBloomFilterMaterializationTest.java | 32 +-
.../doris/catalog/ColumnGsonSerializationTest.java | 42 +-
.../java/org/apache/doris/catalog/ColumnTest.java | 259 +-
.../org/apache/doris/catalog/ColumnTypeTest.java | 100 +-
.../apache/doris/catalog/CreateFunctionTest.java | 6 +
.../org/apache/doris/catalog/CreateTableTest.java | 106 +-
.../org/apache/doris/catalog/DataPropertyTest.java | 12 +-
.../doris/catalog/DataSizeDisplayUtilTest.java | 28 +-
.../org/apache/doris/catalog/DatabaseTest.java | 62 +-
.../doris/catalog/DynamicPartitionTableTest.java | 620 ++---
.../org/apache/doris/catalog/EnvFactoryTest.java | 36 +-
.../org/apache/doris/catalog/EnvOperationTest.java | 32 +-
.../java/org/apache/doris/catalog/EnvTest.java | 16 +-
.../java/org/apache/doris/catalog/IndexTest.java | 56 +-
.../org/apache/doris/catalog/InfoSchemaDbTest.java | 12 +-
.../org/apache/doris/catalog/JdbcResourceTest.java | 105 +-
.../doris/catalog/ListPartitionInfoTest.java | 74 +-
.../doris/catalog/MaterializedIndexTest.java | 100 +-
.../apache/doris/catalog/MetaIdGeneratorTest.java | 20 +-
.../apache/doris/catalog/MetadataViewerTest.java | 24 +-
.../apache/doris/catalog/ModifyBrokerInfoTest.java | 10 +-
.../java/org/apache/doris/catalog/MysqlDbTest.java | 12 +-
.../org/apache/doris/catalog/MysqlTableTest.java | 194 +-
.../org/apache/doris/catalog/OlapTableTest.java | 250 +-
.../org/apache/doris/catalog/PartitionKeyTest.java | 318 ++-
.../doris/catalog/RangePartitionInfoTest.java | 470 ++--
.../apache/doris/catalog/RefreshManagerTest.java | 98 +-
.../doris/catalog/ReplicaAllocationTest.java | 86 +-
.../java/org/apache/doris/catalog/ReplicaTest.java | 96 +-
.../org/apache/doris/catalog/ResourceMgrTest.java | 54 +-
.../org/apache/doris/catalog/S3ResourceTest.java | 146 +-
.../org/apache/doris/catalog/SchemaTableTest.java | 2 +-
.../doris/catalog/SessionVariablesNullFixTest.java | 34 +-
.../apache/doris/catalog/TablePropertyTest.java | 68 +-
.../java/org/apache/doris/catalog/TableTest.java | 40 +-
.../java/org/apache/doris/catalog/TabletTest.java | 124 +-
.../TimestampNsUdf.java} | 16 +-
.../java/org/apache/doris/catalog/TypeTest.java | 101 +-
.../org/apache/doris/catalog/UserPropertyTest.java | 76 +-
.../hive/RangerHiveAccessControllerTest.java | 14 +-
.../ranger/hive/RangerHiveAuditLogFlusherTest.java | 16 +-
.../clone/BeLoadRebalancePartitionSkewTest.java | 72 +-
.../doris/clone/ClusterLoadStatisticsTest.java | 20 +-
.../clone/ColocateTableCheckerAndBalancerTest.java | 76 +-
.../org/apache/doris/clone/DiskRebalanceTest.java | 24 +-
.../java/org/apache/doris/clone/PathSlotTest.java | 6 +-
.../java/org/apache/doris/clone/RebalanceTest.java | 60 +-
.../doris/clone/RootPathLoadStatisticTest.java | 8 +-
.../doris/clone/RowBinlogRebalancerTest.java | 22 +-
.../doris/clone/RowBinlogTabletSchedulerTest.java | 140 +-
.../org/apache/doris/clone/TabletSchedCtxTest.java | 29 +-
.../TwoDimensionalGreedyRebalanceAlgoTest.java | 34 +-
.../cloud/CacheHotspotManagerSchedulerTest.java | 149 ++
.../org/apache/doris/cloud/CloudWarmUpJobTest.java | 40 +-
.../cloud/alter/CloudSchemaChangeHandlerTest.java | 44 +-
.../doris/cloud/backup/CloudRestoreJobTest.java | 28 +-
.../doris/cloud/cache/CacheHotspotManagerTest.java | 120 +-
.../doris/cloud/catalog/CloudEnvFactoryTest.java | 36 +-
.../doris/cloud/catalog/CloudPartitionTest.java | 6 +-
.../doris/cloud/catalog/CloudUpgradeMgrTest.java | 32 +-
.../doris/cloud/common/util/CopyUtilTest.java | 56 +-
...ernalCatalogBloomFilterMaterializationTest.java | 38 +-
.../cloud/datasource/CloudInternalCatalogTest.java | 24 +-
.../doris/cloud/load/CloudBrokerLoadJobTest.java | 16 +-
.../org/apache/doris/cloud/load/CopyJobTest.java | 24 +-
.../doris/cloud/load/CopyLoadPendingTaskTest.java | 45 +-
.../doris/cloud/master/CloudReportHandlerTest.java | 6 +-
.../doris/cloud/rpc/MetaServiceProxyTest.java | 104 +-
.../cloud/rpc/MetaServiceRpcRateLimiterTest.java | 42 +-
.../cloud/snapshot/CloudSnapshotHandlerTest.java | 22 +-
.../apache/doris/cloud/stage/StageUtilTest.java | 8 +-
.../doris/cloud/storage/ObjectInfoAdapterTest.java | 30 +-
.../cloud/system/CloudSystemInfoServiceTest.java | 86 +-
.../transaction/CloudGlobalTransactionMgrTest.java | 47 +-
.../doris/cluster/ClusterGuardExceptionTest.java | 16 +-
.../doris/cluster/ClusterGuardFactoryTest.java | 52 +-
.../apache/doris/cluster/NoOpClusterGuardTest.java | 8 +-
.../doris/cluster/SystemInfoServiceTest.java | 58 +-
.../java/org/apache/doris/common/CidrTest.java | 36 +-
.../doris/common/CommandLineOptionsTest.java | 22 +-
.../java/org/apache/doris/common/DNSCacheTest.java | 51 +-
.../org/apache/doris/common/ExceptionChecker.java | 9 +-
.../org/apache/doris/common/GenericPoolTest.java | 42 +-
.../java/org/apache/doris/common/JdkUtilsTest.java | 18 +-
.../org/apache/doris/common/Log4jConfigTest.java | 16 +-
.../test/java/org/apache/doris/common/MD5Test.java | 10 +-
.../apache/doris/common/MarkDownParserTest.java | 104 +-
.../apache/doris/common/PatternMatcherTest.java | 90 +-
.../apache/doris/common/PropertyAnalyzerTest.java | 158 +-
.../apache/doris/common/TestEvictableCache.java | 172 +-
.../apache/doris/common/ThreadPoolManagerTest.java | 40 +-
.../org/apache/doris/common/io/DeepCopyTest.java | 10 +-
.../doris/common/parquet/ParquetReaderTest.java | 6 +-
.../proc/AlterProcDirFilterExpressionTest.java | 16 +-
.../doris/common/proc/BackendProcNodeTest.java | 20 +-
.../doris/common/proc/BackendsProcDirTest.java | 80 +-
.../common/proc/CloudProcVersionDisplayTest.java | 26 +-
.../proc/CurrentQueryStatisticsProcDirTest.java | 24 +-
.../apache/doris/common/proc/DbsProcDirTest.java | 102 +-
.../doris/common/proc/IndexSchemaProcNodeTest.java | 28 +-
.../doris/common/proc/IndexesProcNodeTest.java | 48 +-
.../doris/common/proc/PartitionsProcDirTest.java | 20 +-
.../apache/doris/common/proc/ProcServiceTest.java | 100 +-
.../doris/common/profile/AutoProfileTest.java | 2 +-
.../doris/common/profile/ExecutionProfileTest.java | 14 +-
.../common/profile/ProfilePersistentTest.java | 88 +-
.../doris/common/profile/ProfileStructureTest.java | 36 +-
.../apache/doris/common/profile/ProfileTest.java | 2 -
.../common/profile/RuntimeProfileMergeTest.java | 18 +-
.../doris/common/profile/RuntimeProfileTest.java | 30 +-
.../doris/common/profile/SummaryProfileTest.java | 46 +
.../doris/common/util/AutoBucketUtilsTest.java | 54 +-
.../apache/doris/common/util/BrokerUtilTest.java | 46 +-
.../common/util/DatasourcePrintableMapTest.java | 12 +
.../doris/common/util/DebugPointUtilTest.java | 48 +-
.../apache/doris/common/util/DebugUtilTest.java | 74 +-
.../common/util/DynamicPartitionUtilTest.java | 78 +-
.../apache/doris/common/util/HttpURLUtilTest.java | 36 +-
.../doris/common/util/InternalHttpsUtilsTest.java | 19 +-
.../doris/common/util/ListComparatorTest.java | 64 +-
.../org/apache/doris/common/util/ListUtilTest.java | 75 +-
.../doris/common/util/MetaLockUtilsTest.java | 97 +-
.../org/apache/doris/common/util/NetUtilsTest.java | 10 +-
.../common/util/QueryableReentrantLockTest.java | 6 +-
.../org/apache/doris/common/util/S3URITest.java | 210 +-
.../org/apache/doris/common/util/S3UtilTest.java | 154 +-
.../doris/common/util/SafeStringBuilderTest.java | 46 +-
.../apache/doris/common/util/SortAndLimitTest.java | 14 +-
.../doris/common/util/SymmetricEncryptionTest.java | 6 +-
.../apache/doris/common/util/TimeUtilsTest.java | 106 +-
.../java/org/apache/doris/common/util/URITest.java | 46 +-
.../org/apache/doris/common/util/UnitTestUtil.java | 4 +-
.../org/apache/doris/common/util/VersionTest.java | 32 +-
.../doris/connector/ConnectorPluginConfTest.java | 14 +
.../DefaultConnectorContextNormalizeUriTest.java | 65 +
.../testplugins/ConfProbeConnectorProviderA.java | 13 +-
.../doris/cooldown/CooldownConfHandlerTest.java | 6 +-
.../doris/datasource/CatalogFactoryTest.java | 12 +-
.../doris/datasource/CatalogPropertyTest.java | 17 +-
.../apache/doris/datasource/ColumnPrivTest.java | 7 +-
.../doris/datasource/ExternalEqualsTest.java | 16 +-
.../ExternalTableSchemaCacheDelegationTest.java | 15 +-
.../FileCacheAdmissionRuleRefresherTest.java | 62 +-
.../doris/datasource/InternalCatalogTest.java | 30 +-
.../datasource/RoundRobinCreateTabletTest.java | 14 +-
.../converter/WriteConstraintExtractorTest.java | 55 +-
.../doris/DorisExternalMetaCacheTest.java | 8 +-
.../doris/RemoteDorisCompatibleRestClientTest.java | 6 +-
.../doris/RemoteDorisRestClientTest.java | 20 +-
.../jdbc/client/JdbcClickHouseClientTest.java | 40 +-
.../jdbc/client/JdbcClientExceptionTest.java | 44 +-
.../jdbc/client/JdbcMySQLClientTest.java | 18 +-
.../jdbc/client/JdbcOceanBaseClientTest.java | 18 +-
.../datasource/jdbc/util/JdbcFieldSchemaTest.java | 8 +-
.../doris/datasource/kafka/KafkaUtilTest.java | 22 +-
.../doris/datasource/metacache/CacheSpecTest.java | 76 +-
.../metacache/ExternalCatalogMetaCacheTest.java | 30 +-
.../datasource/metacache/FeMetaCacheEntryTest.java | 166 +-
.../datasource/metacache/IdNameIndexTest.java | 74 +-
.../metacache/MetaCacheDeadlockTest.java | 7 +-
.../datasource/metacache/NameCacheValueTest.java | 80 +-
.../PluginDrivenExternalCatalogDdlRoutingTest.java | 43 +
.../plugin/PluginDrivenExternalTableTest.java | 13 +
.../plugin/PluginDrivenSysExternalTableTest.java | 14 +-
.../fileformat/AvroFileFormatPropertiesTest.java | 6 +-
.../fileformat/CsvFileFormatPropertiesTest.java | 46 +-
.../fileformat/FileFormatPropertiesTest.java | 6 +-
.../fileformat/JsonFileFormatPropertiesTest.java | 62 +-
.../fileformat/OrcFileFormatPropertiesTest.java | 38 +-
.../ParquetFileFormatPropertiesTest.java | 56 +-
.../fileformat/TextFileFormatPropertiesTest.java | 30 +-
.../fileformat/WalFileFormatPropertiesTest.java | 6 +-
.../scan/FileCacheAdmissionManagerTest.java | 153 +-
.../datasource/scan/FileQueryScanNodeTest.java | 36 +-
.../PluginDrivenScanNodeCompatibilityTest.java | 22 +-
.../doris/datasource/split/FileSplitterTest.java | 72 +-
.../doris/datasource/systable/SysTableTest.java | 38 +-
.../tvf/source/MetadataScanNodeTest.java | 29 +-
.../datasource/tvf/source/TVFScanNodeTest.java | 10 +-
.../doris/dictionary/DictionaryManagerTest.java | 14 +-
.../org/apache/doris/fs/FileSystemCacheTest.java | 26 +-
.../org/apache/doris/fs/MemoryFileSystemTest.java | 95 +-
.../doris/fs/SpiSwitchingFileSystemTest.java | 50 +-
.../org/apache/doris/http/DorisHttpTestCase.java | 23 +-
.../org/apache/doris/http/ForwardToMasterTest.java | 44 +-
.../org/apache/doris/http/HttpAuthManagerTest.java | 16 +-
.../java/org/apache/doris/http/MimeTypeTest.java | 12 +-
.../doris/http/TableQueryPlanActionTest.java | 74 +-
.../apache/doris/http/TableRowCountActionTest.java | 10 +-
.../apache/doris/http/TableSchemaActionTest.java | 20 +-
.../apache/doris/httpv2/meta/MetaServiceTest.java | 47 +-
.../org/apache/doris/httpv2/rest/CopyIntoTest.java | 36 +-
.../apache/doris/httpv2/rest/HttpApiAuthTest.java | 29 +-
.../doris/httpv2/rest/RestBaseControllerTest.java | 10 +-
.../doris/httpv2/rest/manager/HttpUtilsTest.java | 23 +-
.../InsertOverwriteManagerTest.java | 6 +-
.../insertoverwrite/InsertOverwriteUtilTest.java | 2 +-
.../job/extensions/insert/InsertTaskTest.java | 6 +-
.../streaming/DataSourceConfigValidatorTest.java | 86 +-
.../streaming/PostgresResourceValidatorTest.java | 10 +-
.../StreamingInsertJobAdvanceSplitsTest.java | 14 +-
.../StreamingInsertJobCheckDataQualityTest.java | 49 +-
.../streaming/StreamingInsertJobLagTest.java | 12 +-
.../StreamingInsertJobLateCallbackTest.java | 30 +-
.../StreamingInsertJobOffsetPersistenceTest.java | 50 +-
.../StreamingInsertJobStatusTransitionTest.java | 66 +
.../streaming/StreamingJdbcUrlNormalizerTest.java | 20 +-
.../streaming/StreamingJobPropertiesTest.java | 38 +-
.../StreamingMultiTblTaskTimeoutTest.java | 22 +-
.../extensions/mtmv/MTMVTaskContextCompatTest.java | 58 +-
.../apache/doris/job/manager/JobManagerTest.java | 16 +-
.../JdbcSourceOffsetProviderAsyncSplitTest.java | 174 +-
.../JdbcSourceOffsetProviderErrorHandlingTest.java | 29 +-
.../jdbc/JdbcSourceOffsetProviderLagTest.java | 54 +-
.../jdbc/JdbcSourceOffsetProviderOffsetTest.java | 102 +-
.../jdbc/JdbcTvfSourceOffsetProviderTest.java | 8 +-
.../doris/job/offset/jdbc/SplitProgressTest.java | 24 +-
.../doris/job/util/StreamingJobUtilsTest.java | 84 +-
.../doris/journal/bdbje/BDBToolOptionsTest.java | 18 +-
.../apache/doris/journal/bdbje/BDBToolTest.java | 24 +-
.../java/org/apache/doris/load/DeleteJobTest.java | 22 +-
.../org/apache/doris/load/EtlJobStatusTest.java | 14 +-
.../java/org/apache/doris/load/ExportJobTest.java | 8 +-
.../apache/doris/load/ExportOutfileInfoTest.java | 6 +-
.../java/org/apache/doris/load/FailMsgTest.java | 10 +-
.../GroupCommitManagerBackendSelectionTest.java | 40 +-
.../apache/doris/load/GroupCommitManagerTest.java | 26 +-
.../apache/doris/load/LoadJobRowResultTest.java | 18 +-
.../apache/doris/load/PartitionLoadInfoTest.java | 22 +-
.../java/org/apache/doris/load/SourceTest.java | 20 +-
.../apache/doris/load/StreamLoadHandlerTest.java | 14 +-
.../org/apache/doris/load/TabletLoadInfoTest.java | 18 +-
.../load/loadv2/BrokerFileGroupAggInfoTest.java | 68 +-
.../doris/load/loadv2/BrokerLoadJobTest.java | 90 +-
.../load/loadv2/BrokerLoadPendingTaskTest.java | 8 +-
.../apache/doris/load/loadv2/ExportMgrTest.java | 30 +-
.../doris/load/loadv2/InsertLoadJobTest.java | 12 +-
.../org/apache/doris/load/loadv2/LoadJobTest.java | 50 +-
.../doris/load/loadv2/LoadLoadingTaskTest.java | 12 +-
.../apache/doris/load/loadv2/LoadManagerTest.java | 24 +-
.../apache/doris/load/loadv2/TokenManagerTest.java | 14 +-
.../load/routineload/KafkaAwsMskIamAuthTest.java | 150 +-
.../load/routineload/KafkaRoutineLoadJobTest.java | 206 +-
.../routineload/KinesisRoutineLoadJobTest.java | 106 +-
.../RoutineLoadBackendSelectionTest.java | 12 +-
.../doris/load/routineload/RoutineLoadJobTest.java | 96 +-
.../load/routineload/RoutineLoadManagerTest.java | 108 +-
.../load/routineload/RoutineLoadSchedulerTest.java | 10 +-
.../routineload/RoutineLoadTaskSchedulerTest.java | 28 +-
.../kinesis/KinesisDataSourcePropertiesTest.java | 16 +-
.../doris/master/MasterImplDeleteTaskTest.java | 34 +-
.../org/apache/doris/master/MetaHelperTest.java | 14 +-
.../doris/master/RowBinlogReportHandlerTest.java | 24 +-
.../java/org/apache/doris/metric/MetricsTest.java | 290 +--
.../apache/doris/mtmv/MTMVExpandPartitionTest.java | 44 +-
.../org/apache/doris/mtmv/MTMVJobInfoTest.java | 10 +-
.../org/apache/doris/mtmv/MTMVJobManagerTest.java | 12 +-
.../doris/mtmv/MTMVPartitionCheckUtilTest.java | 30 +-
.../apache/doris/mtmv/MTMVPartitionUtilTest.java | 137 +-
.../apache/doris/mtmv/MTMVRefreshSnapshotTest.java | 28 +-
...TMVRelatedPartitionDescRollUpGeneratorTest.java | 72 +-
...RelatedPartitionDescSyncLimitGeneratorTest.java | 45 +-
.../apache/doris/mtmv/MTMVRelationManagerTest.java | 38 +-
.../org/apache/doris/mtmv/MTMVRewriteUtilTest.java | 42 +-
.../java/org/apache/doris/mtmv/MTMVTaskTest.java | 176 +-
.../test/java/org/apache/doris/mtmv/MTMVTest.java | 112 +-
.../java/org/apache/doris/mtmv/MTMVUtilTest.java | 21 +-
.../apache/doris/mysql/ConnectionExceedTest.java | 30 +-
.../apache/doris/mysql/MysqlAuthPacketTest.java | 22 +-
.../apache/doris/mysql/MysqlCapabilityTest.java | 20 +-
.../org/apache/doris/mysql/MysqlChannelTest.java | 6 +-
.../org/apache/doris/mysql/MysqlColDefTest.java | 2 +-
.../org/apache/doris/mysql/MysqlColTypeTest.java | 32 +-
.../org/apache/doris/mysql/MysqlCommandTest.java | 10 +-
.../org/apache/doris/mysql/MysqlEofPacketTest.java | 16 +-
.../org/apache/doris/mysql/MysqlErrPacketTest.java | 32 +-
.../doris/mysql/MysqlHandshakePacketTest.java | 40 +-
.../org/apache/doris/mysql/MysqlOkPacketTest.java | 26 +-
.../org/apache/doris/mysql/MysqlPasswordTest.java | 152 +-
.../doris/mysql/MysqlProtoLenEncStringTest.java | 10 +-
.../org/apache/doris/mysql/MysqlProtoTest.java | 66 +-
.../doris/mysql/MysqlResultSetEndPacketTest.java | 34 +-
.../doris/mysql/MysqlSerializerDateTimeTest.java | 72 +
.../authenticate/DefaultAuthenticatorTest.java | 24 +-
.../authenticate/ldap/LdapAuthenticatorTest.java | 38 +-
.../mysql/authenticate/ldap/LdapClientTest.java | 62 +-
.../mysql/authenticate/ldap/LdapManagerTest.java | 92 +-
.../mysql/authenticate/ldap/LdapUserInfoTest.java | 6 +-
.../privilege/AccessControllerManagerTest.java | 36 +-
.../org/apache/doris/mysql/privilege/AuthTest.java | 12 +-
.../privilege/CatalogAccessControllerTest.java | 48 +-
.../doris/mysql/privilege/CloudAuthTest.java | 128 +-
.../mysql/privilege/CommonUserPropertiesTest.java | 36 +-
.../doris/mysql/privilege/PasswordPolicyTest.java | 66 +-
.../doris/mysql/privilege/PrivEntryTest.java | 16 +-
.../RangerDorisAccessControllerFactoryTest.java | 8 +-
.../apache/doris/mysql/privilege/RangerTest.java | 56 +-
.../doris/mysql/privilege/SetPasswordTest.java | 20 +-
.../doris/mysql/privilege/UserIdentityTest.java | 14 +-
.../apache/doris/nereids/analyzer/ScopeTest.java | 48 +
.../nereids/load/NereidsLoadScanProviderTest.java | 29 +
.../AddMonotonicFunctionPruningPredicatesTest.java | 219 ++
.../rules/analysis/DatetimeFunctionBinderTest.java | 18 +
.../rules/analysis/ExpressionAnalyzerTest.java | 51 +
.../nereids/rules/analysis/TestDereference.java | 135 +
.../rules/analysis/UserVariableAnalysisTest.java | 14 +
.../ProjectAwareJoinReorderComplexProjectTest.java | 354 +++
.../join/ProjectJoinReorderHelperTest.java | 201 ++
.../nereids/rules/expression/FoldConstantTest.java | 221 +-
.../rules/expression/check/CheckCastTest.java | 65 +
.../expression/rules/DateFunctionRewriteTest.java | 84 +
.../InferPredicateFromMonotonicFunctionTest.java | 300 ++-
.../PredicateRewriteForPartitionPruneTest.java | 139 +
.../expression/rules/SimplifyCastRuleTest.java | 5 +
.../rules/SimplifyComparisonPredicateTest.java | 143 ++
.../rules/rewrite/InferPredicateByReplaceTest.java | 19 +
.../PushDownVirtualColumnsIntoOlapScanTest.java | 12 +
.../doris/nereids/stats/FilterEstimationTest.java | 28 +
.../doris/nereids/stats/StatsCalculatorTest.java | 2 +-
.../trees/expressions/CastMonotonicityTest.java | 41 +
.../doris/nereids/trees/expressions/CastTest.java | 50 +
.../nereids/trees/expressions/LiteralTest.java | 89 +
.../functions/ComputeSignatureHelperTest.java | 48 +
.../functions/executable/DateTimeAcquireTest.java | 109 +
.../DateTimeExtractAndTransformTest.java | 76 +
.../functions/executable/StringArithmeticTest.java | 11 +
.../functions/scalar/FromUnixtimeTest.java | 56 +
.../functions/scalar/InnerProductTest.java | 82 +
.../scalar/StGeoComponentFunctionsTest.java | 31 +-
.../scalar/TimestampNsFunctionSignatureTest.java | 350 +++
.../scalar/TimestampNsMonotonicityTest.java | 99 +
.../trees/expressions/literal/DateLiteralTest.java | 50 +
.../expressions/literal/DateTimeLiteralTest.java | 147 +-
.../expressions/literal/IntegerLiteralTest.java | 4 +
.../literal/TimeStampNsLiteralTest.java | 258 ++
.../plans/commands/CreateTableCommandTest.java | 11 +-
.../plans/commands/ShowConfigCommandTest.java | 148 ++
.../plans/commands/insert/InsertUtilsTest.java | 19 +
.../apache/doris/nereids/types/DataTypeTest.java | 82 +
.../apache/doris/nereids/util/JoinUtilsTest.java | 22 +
.../doris/nereids/util/TypeCoercionMatrixTest.java | 25 +
.../doris/nereids/util/TypeCoercionUtilsTest.java | 655 +++++
.../persist/AlterRoutineLoadOperationLogTest.java | 20 +-
.../apache/doris/persist/AlterViewInfoTest.java | 10 +-
.../doris/persist/BackendReplicaInfosTest.java | 14 +-
.../persist/BatchModifyPartitionsInfoTest.java | 10 +-
.../BatchRemoveTransactionOperationTest.java | 10 +-
.../doris/persist/ConsistencyCheckInfoTest.java | 6 +-
.../org/apache/doris/persist/CreateDbInfoTest.java | 16 +-
.../apache/doris/persist/CreateTableInfoTest.java | 18 +-
.../doris/persist/DataSourcePropertiesTest.java | 34 +-
.../org/apache/doris/persist/DatabaseInfoTest.java | 10 +-
.../doris/persist/DropAndRecoverInfoTest.java | 38 +-
.../org/apache/doris/persist/DropDbInfoTest.java | 22 +-
.../doris/persist/DropPartitionInfoTest.java | 32 +-
.../java/org/apache/doris/persist/EditLogTest.java | 45 +-
.../org/apache/doris/persist/FsBrokerTest.java | 36 +-
.../doris/persist/GlobalVarPersistInfoTest.java | 6 +-
.../org/apache/doris/persist/LdapInfoTest.java | 6 +-
.../apache/doris/persist/LoadJobV2PersistTest.java | 10 +-
.../doris/persist/ModifyCloudWarmUpJobTest.java | 40 +-
.../persist/ModifyCommentOperationLogTest.java | 24 +-
.../persist/ModifyDynamicPartitionInfoTest.java | 20 +-
.../org/apache/doris/persist/PrivInfoTest.java | 24 +-
.../persist/RefreshExternalTableInfoTest.java | 18 +-
.../persist/ReplaceTableOperationLogTest.java | 16 +-
.../doris/persist/ReplicaPersistInfoTest.java | 20 +-
.../apache/doris/persist/ResourcePersistTest.java | 26 +-
.../org/apache/doris/persist/ScalarTypeTest.java | 14 +-
.../org/apache/doris/persist/StorageInfoTest.java | 22 +-
.../doris/persist/StoragePolicyPersistTest.java | 10 +-
.../java/org/apache/doris/persist/StorageTest.java | 44 +-
.../persist/TableAddOrDropColumnsInfoTest.java | 14 +-
.../org/apache/doris/persist/TableInfoTest.java | 10 +-
.../gson/GsonDerivedClassSerializationTest.java | 28 +-
.../gson/GsonProtobufCompatibilityTest.java | 8 +-
.../doris/persist/gson/GsonSerializationTest.java | 108 +-
.../doris/persist/gson/ThriftToJsonTest.java | 6 +-
.../apache/doris/planner/ConstantExpressTest.java | 6 +-
.../doris/planner/FederationBackendPolicyTest.java | 57 +-
.../doris/planner/GroupCommitBlockSinkTest.java | 20 +-
.../doris/planner/GroupCommitPlannerTest.java | 59 +
.../doris/planner/HashDistributionPrunerTest.java | 16 +-
.../doris/planner/ListPartitionPrunerV2Test.java | 8 +-
.../org/apache/doris/planner/OlapScanNodeTest.java | 54 +-
.../OlapTableSinkBackendSelectionExplainTest.java | 12 +-
.../apache/doris/planner/OlapTableSinkTest.java | 68 +-
.../doris/planner/PluginDrivenTableSinkTest.java | 60 +-
.../doris/planner/QueryCacheNormalizerTest.java | 39 +-
.../apache/doris/planner/StatisticDeriveTest.java | 50 +-
.../doris/planner/StreamLoadPlannerTest.java | 8 +-
.../java/org/apache/doris/planner/TpchTest.java | 4 +-
.../apache/doris/plugin/HttpDialectUtilsTest.java | 20 +-
.../apache/doris/plugin/audit/AuditLoaderTest.java | 28 +-
.../doris/plugin/audit/AuditLogBuilderTest.java | 161 +-
.../doris/qe/ArrowFlightDeferralGateTest.java | 69 +
.../apache/doris/qe/AuditEventProcessorTest.java | 24 +-
.../qe/AuditLogHelperBackendSelectionTest.java | 16 +-
.../org/apache/doris/qe/AuditLogHelperTest.java | 20 +-
.../apache/doris/qe/AuditLogWorkloadGroupTest.java | 42 +-
.../doris/qe/ConnectAttributesForwardTest.java | 26 +-
.../org/apache/doris/qe/ConnectContextTest.java | 254 +-
.../ConnectProcessorDelegatedCredentialTest.java | 1 +
.../doris/qe/ConnectProcessorTimestampNsTest.java | 51 +
.../org/apache/doris/qe/ConnectSchedulerTest.java | 30 +-
.../apache/doris/qe/CoordinatorContextTest.java | 72 +
.../qe/FEOpExecutorDelegatedCredentialTest.java | 20 +-
.../doris/qe/ForceForwardAllQueriesTest.java | 12 +-
.../java/org/apache/doris/qe/HelpModuleTest.java | 66 +-
.../org/apache/doris/qe/HelpObjectLoaderTest.java | 42 +-
.../doris/qe/InsertStreamTxnExecutorTest.java | 6 +-
.../org/apache/doris/qe/JournalObservableTest.java | 60 +-
.../java/org/apache/doris/qe/LimitUtilsTest.java | 28 +-
.../qe/MasterOpExecutorBackendSelectionTest.java | 30 +-
.../org/apache/doris/qe/OlapQueryCacheTest.java | 74 +-
.../apache/doris/qe/PointQueryExecutorTest.java | 8 +-
.../apache/doris/qe/ProxyProtocolHandlerTest.java | 72 +-
.../org/apache/doris/qe/QeProcessorImplTest.java | 22 +-
.../doris/qe/QueryFinishCallbackRegistryTest.java | 18 +-
.../java/org/apache/doris/qe/QueryStateTest.java | 14 +-
.../doris/qe/ResultReceiverConsumerTest.java | 15 +-
.../doris/qe/RuntimeFilterTypeHelperTest.java | 104 +-
.../java/org/apache/doris/qe/ShowExecutorTest.java | 74 +-
.../apache/doris/qe/ShowResultSetMetaDataTest.java | 22 +-
.../org/apache/doris/qe/ShowResultSetTest.java | 52 +-
.../org/apache/doris/qe/SimpleSchedulerTest.java | 20 +-
.../org/apache/doris/qe/SqlModeHelperTest.java | 34 +-
.../doris/qe/StmtExecutorInternalQueryTest.java | 46 +-
.../java/org/apache/doris/qe/StmtExecutorTest.java | 105 +-
.../apache/doris/qe/cache/CacheManagerTest.java | 62 +-
.../qe/cache/PluginTableCacheAnalyzerTest.java | 20 +-
.../apache/doris/resource/ComputeGroupTest.java | 186 +-
.../doris/resource/TagSerializationTest.java | 10 +-
.../java/org/apache/doris/resource/TagTest.java | 54 +-
.../apache/doris/resource/WorkloadSchedTest.java | 34 +-
.../workloadgroup/WorkloadGroupMgrTest.java | 152 +-
.../resource/workloadgroup/WorkloadGroupTest.java | 72 +-
.../WorkloadRuntimeStatusMgrTest.java | 114 +-
.../WorkloadSchedPolicyMgrTest.java | 109 +-
.../apache/doris/rpc/BackendServiceClientTest.java | 44 +-
.../apache/doris/rpc/BackendServiceProxyTest.java | 64 +-
.../org/apache/doris/service/ExecuteEnvTest.java | 6 +-
.../apache/doris/service/FrontendOptionsTest.java | 14 +-
.../FrontendServiceImplBackendSelectionTest.java | 32 +-
.../service/FrontendServiceImplCloudTest.java | 9 +-
.../arrowflight/DorisFlightSqlProducerTest.java | 24 +-
.../FlightSqlSchemaHelperArrowTypeTest.java | 25 +
.../FlightRemoteIpServerStreamTracerTest.java | 10 +-
.../sessions/FlightSqlConnectPoolMgrTest.java | 6 +-
.../FlightSqlDeferredQueryIdleTimeoutTest.java | 156 ++
.../statistics/analysis/HistogramTaskTest.java | 6 +-
.../apache/doris/statistics/util/Hll128Test.java | 80 +-
.../statistics/util/InternalQueryBufferTest.java | 40 +-
.../statistics/util/InternalSqlTemplateTest.java | 56 +-
.../doris/statistics/util/StatisticsUtilTest.java | 29 +
.../org/apache/doris/system/HeartbeatMgrTest.java | 48 +-
.../apache/doris/system/SystemInfoServiceTest.java | 172 +-
.../CdcStreamTableValuedFunctionTest.java | 22 +-
.../ExternalFileTableValuedFunctionTest.java | 66 +-
.../FrontendsTableValuedFunctionTest.java | 12 +-
.../apache/doris/tablefunction/HFUtilsTest.java | 252 +-
.../java/org/apache/doris/task/AgentTaskTest.java | 116 +-
.../apache/doris/task/MasterTaskExecutorTest.java | 26 +-
.../doris/task/PriorityMasterTaskExecutorTest.java | 40 +-
.../apache/doris/task/PublishVersionTaskTest.java | 33 +-
.../transaction/AutoPartitionCacheManagerTest.java | 20 +-
.../CheckReplicaContinuousVersionSuccTest.java | 24 +-
.../transaction/CommitDataSerializerTest.java | 10 +-
.../transaction/DatabaseTransactionMgrTest.java | 279 +-
.../transaction/GlobalTransactionMgrTest.java | 184 +-
.../PluginDrivenTransactionManagerTest.java | 34 +-
.../doris/transaction/TransactionStateTest.java | 34 +-
.../java/org/apache/doris/tso/TSOServiceTest.java | 98 +-
.../org/apache/doris/tso/TSOTimestampTest.java | 70 +-
.../java/org/apache/doris/utframe/DorisAssert.java | 10 +-
.../apache/doris/utframe/TestWithFeService.java | 2 +-
.../hdfs/properties/OssHdfsProperties.java | 47 +-
.../hdfs/properties/OssHdfsPropertiesTest.java | 76 +-
.../filesystem/oss/OssFileSystemProperties.java | 18 +-
.../oss/OssFileSystemPropertiesTest.java | 35 +
.../property/ConnectorPropertiesUtils.java | 21 +
.../apache/doris/kerberos/AuthenticationTest.java | 16 +-
.../doris/kerberos/KerberosTicketUtilsTest.java | 12 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 1 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 2 +
.../org/apache/doris/catalog/PrimitiveType.java | 16 +-
.../java/org/apache/doris/catalog/ScalarType.java | 26 +-
.../main/java/org/apache/doris/catalog/Type.java | 27 +-
.../test/java/org/apache/doris/BitmapUDFTest.java | 24 +-
.../src/test/java/org/apache/doris/HllUDFTest.java | 10 +-
fe/pom.xml | 12 +-
gensrc/proto/internal_service.proto | 3 +
gensrc/proto/olap_file.proto | 2 +
gensrc/proto/types.proto | 1 +
gensrc/thrift/Descriptors.thrift | 3 +
gensrc/thrift/Exprs.thrift | 2 +
gensrc/thrift/PlanNodes.thrift | 3 +
gensrc/thrift/Types.thrift | 3 +-
.../data/arrow_flight_sql_p0/test_select.out | 16 +
.../test_vertical_compaction_agg_state.out | 2 +-
.../timestamp_ns/test_cast_string_non_strict.out | 18 +
.../test_from_unixtime_decimal_paths.out | 5 +
.../test_nanosecond_datev2_datetimev2.out | 14 +
...tamp_ns_additional_function_argument_matrix.out | 583 +++++
.../timestamp_ns/test_timestamp_ns_agg_state.out | 3 +
.../test_timestamp_ns_binary_output.out | 16 +
.../timestamp_ns/test_timestamp_ns_cast.out | 77 +
.../test_timestamp_ns_complex_type.out | 13 +
.../test_timestamp_ns_count_distinct.out | 6 +
.../timestamp_ns/test_timestamp_ns_delete.out | 20 +
...est_timestamp_ns_expression_argument_matrix.out | 31 +
.../timestamp_ns/test_timestamp_ns_expressions.out | 105 +
.../test_timestamp_ns_function_argument_matrix.out | 110 +
.../timestamp_ns/test_timestamp_ns_functions.out | 214 ++
.../test_timestamp_ns_generated_column.out | 5 +
.../timestamp_ns/test_timestamp_ns_group_by.out | 6 +
.../timestamp_ns/test_timestamp_ns_index.out | 44 +
.../timestamp_ns/test_timestamp_ns_join.out | 79 +
.../timestamp_ns/test_timestamp_ns_jsonb.out | 17 +
.../timestamp_ns/test_timestamp_ns_literal.out | 49 +
.../test_timestamp_ns_mixed_datetime_coercion.out | 127 +
...est_timestamp_ns_mixed_datetime_expressions.out | 403 +++
.../timestamp_ns/test_timestamp_ns_mv.out | 18 +
.../test_timestamp_ns_named_zone_gap.out | 6 +
.../test_timestamp_ns_partition_bucket.out | 49 +
.../timestamp_ns/test_timestamp_ns_primary_key.out | 18 +
.../timestamp_ns/test_timestamp_ns_rf.out | 15 +
.../timestamp_ns/test_timestamp_ns_sort.out | 25 +
.../timestamp_ns/test_timestamp_ns_statistics.out | 8 +
.../test_timestamp_ns_storage_agg_key.out | 42 +
.../test_timestamp_ns_storage_dup_key.out | 80 +
.../test_timestamp_ns_storage_uniq_key.out | 46 +
.../timestamp_ns/test_timestamp_ns_stream_load.csv | 9 +
.../timestamp_ns/test_timestamp_ns_stream_load.out | 17 +
.../test_timestamptz_storage_dup_key.out | 2 +
.../test_timestamptz_storage_uniq_key.out | 1 +
.../iceberg/test_iceberg_file_metadata_columns.out | 28 +
.../data/external_table_p0/test_dlf_catalog.out | 6 +
.../data/javaudf_p0/test_javaudf_timestamp_ns.out | 36 +
.../load_p0/routine_load/test_routine_load.out | 20 +
.../data/mtmv_p0/test_mtmv_timestamp_ns_rollup.out | 6 +
.../data/nereids_function_p0/agg_function/agg.out | 2600 ++++++++++---------
.../array/test_array_timestamp_ns.csv | 11 +
.../data/nereids_function_p0/fn_test.dat | 26 +-
.../data/nereids_function_p0/gen_function/gen.out | 104 +-
.../nereids_function_p0/scalar_function/Array.out | 852 +++++++
.../nereids_function_p0/scalar_function/Array1.out | 2696 ++++++++++++++++++--
.../nereids_function_p0/scalar_function/Array2.out | 11 +
.../data/nereids_function_p0/scalar_function/C.out | 170 +-
.../data/nereids_function_p0/scalar_function/D.out | 896 ++++++-
.../data/nereids_function_p0/scalar_function/F.out | 129 +-
.../data/nereids_function_p0/scalar_function/G.out | 33 +-
.../data/nereids_function_p0/scalar_function/H.out | 414 +++
.../data/nereids_function_p0/scalar_function/L.out | 126 +-
.../data/nereids_function_p0/scalar_function/M.out | 857 +++++++
.../data/nereids_function_p0/scalar_function/N.out | 66 +-
.../data/nereids_function_p0/scalar_function/Q.out | 29 +
.../data/nereids_function_p0/scalar_function/S.out | 650 ++++-
.../data/nereids_function_p0/scalar_function/T.out | 268 +-
.../data/nereids_function_p0/scalar_function/U.out | 29 +
.../data/nereids_function_p0/scalar_function/W.out | 525 ++++
.../data/nereids_function_p0/scalar_function/Y.out | 472 ++++
.../scalar_function/nereids_scalar_fn_map.out | 290 +++
.../test_timestamp_arithmetic.out | 384 +++
.../data/nereids_rules_p0/pkfk/eliminate_inner.out | 16 +-
.../pythonudf_p0/test_pythonudf_timestamp_ns.out | 37 +
.../data/query_p0/show/test_show_data_types.out | 1 +
.../map_functions/test_map_inner_product.out | 20 +
regression-test/data/query_p0/test_dereference.out | 40 +
.../tpcds_sf100/noStatsRfPrune/query2.out | 10 +-
.../tpcds_sf100/noStatsRfPrune/query59.out | 20 +-
.../tpcds_sf100/no_stats_shape/query2.out | 10 +-
.../tpcds_sf100/no_stats_shape/query59.out | 22 +-
.../data/types/test_show_data_types.out | 1 +
.../predefine/test_all_prdefine_type_to_sparse.out | 1058 ++++----
.../java/org/apache/doris/udf/TimestampNsTest.java | 38 +-
.../test_arrow_flight_query_release.groovy | 88 +
.../suites/arrow_flight_sql_p0/test_select.groovy | 62 +
.../auth_call/test_ddl_dictionary_auth.groovy | 63 +
.../test_mow_compact_multi_segments.groovy | 16 +-
.../test_vertical_compaction_agg_state.groovy | 2 +-
.../test_cast_string_non_strict.groovy | 66 +
.../test_from_unixtime_decimal_paths.groovy | 50 +
.../test_nanosecond_datev2_datetimev2.groovy | 64 +
...p_ns_additional_function_argument_matrix.groovy | 388 +++
.../test_timestamp_ns_agg_state.groovy | 42 +
.../test_timestamp_ns_binary_output.groovy | 63 +
.../timestamp_ns/test_timestamp_ns_cast.groovy | 494 ++++
.../test_timestamp_ns_complex_type.groovy | 95 +
.../test_timestamp_ns_count_distinct.groovy | 52 +
.../timestamp_ns/test_timestamp_ns_delete.groovy | 54 +
..._timestamp_ns_expression_argument_matrix.groovy | 173 ++
.../test_timestamp_ns_expressions.groovy | 285 +++
...st_timestamp_ns_function_argument_matrix.groovy | 512 ++++
.../test_timestamp_ns_functions.groovy | 708 +++++
.../test_timestamp_ns_generated_column.groovy | 41 +
.../timestamp_ns/test_timestamp_ns_group_by.groovy | 41 +-
.../timestamp_ns/test_timestamp_ns_index.groovy | 270 ++
.../timestamp_ns/test_timestamp_ns_join.groovy | 314 +++
.../timestamp_ns/test_timestamp_ns_jsonb.groovy | 53 +
.../timestamp_ns/test_timestamp_ns_literal.groovy | 242 ++
...est_timestamp_ns_mixed_datetime_coercion.groovy | 148 ++
..._timestamp_ns_mixed_datetime_expressions.groovy | 597 +++++
.../timestamp_ns/test_timestamp_ns_mv.groovy | 147 ++
.../test_timestamp_ns_named_zone_gap.groovy | 29 +-
.../test_timestamp_ns_partition_bucket.groovy | 350 +++
.../test_timestamp_ns_primary_key.groovy | 125 +
.../timestamp_ns/test_timestamp_ns_rf.groovy | 103 +
.../timestamp_ns/test_timestamp_ns_sort.groovy | 45 +
.../test_timestamp_ns_statistics.groovy | 47 +
.../test_timestamp_ns_storage_agg_key.groovy | 84 +
.../test_timestamp_ns_storage_dup_key.groovy | 119 +
.../test_timestamp_ns_storage_uniq_key.groovy | 76 +
.../test_timestamp_ns_stream_load.groovy | 75 +
...urrent_timestamp_as_column_default_value.groovy | 8 +-
.../sql-manual/sql-functions/doc_date_error.groovy | 22 +-
.../hive/test_parquet_lazy_mat_profile.groovy | 22 +
.../test_iceberg_arrow_flight_split_source.groovy | 73 +
.../test_iceberg_file_metadata_columns.groovy | 167 ++
.../test_iceberg_v1_rowid_hidden_column.groovy | 14 +-
...test_iceberg_v3_row_lineage_query_insert.groovy | 7 +-
.../test_paimon_file_metadata_columns.groovy | 170 ++
.../external_table_p0/test_dlf_catalog.groovy | 146 ++
.../test_group_join_fusion_binary_agg.groovy | 139 +
.../javaudf_p0/test_javaudf_timestamp_ns.groovy | 115 +
.../load_p0/routine_load/test_routine_load.groovy | 22 +
.../mtmv_p0/test_mtmv_timestamp_ns_rollup.groovy | 77 +
.../nereids_function_p0/agg_function/agg.groovy | 98 +
.../nereids_function_p0/gen_function/gen.groovy | 2 +
.../suites/nereids_function_p0/load.groovy | 33 +-
.../scalar_function/Array.groovy | 68 +-
.../scalar_function/Array1.groovy | 46 +
.../scalar_function/Array2.groovy | 24 +-
.../nereids_function_p0/scalar_function/C.groovy | 14 +
.../nereids_function_p0/scalar_function/D.groovy | 54 +
.../nereids_function_p0/scalar_function/F.groovy | 2 +
.../nereids_function_p0/scalar_function/G.groovy | 2 +
.../nereids_function_p0/scalar_function/H.groovy | 34 +-
.../nereids_function_p0/scalar_function/L.groovy | 4 +
.../nereids_function_p0/scalar_function/M.groovy | 68 +-
.../nereids_function_p0/scalar_function/N.groovy | 14 +-
.../nereids_function_p0/scalar_function/Q.groovy | 2 +
.../nereids_function_p0/scalar_function/S.groovy | 32 +-
.../nereids_function_p0/scalar_function/T.groovy | 16 +
.../nereids_function_p0/scalar_function/U.groovy | 2 +
.../nereids_function_p0/scalar_function/W.groovy | 42 +-
.../nereids_function_p0/scalar_function/Y.groovy | 38 +-
.../scalar_function/nereids_scalar_fn_map.groovy | 22 +-
.../test_timestamp_arithmetic.sql | 32 +
.../test_local_shuffle_rqg_bugs.groovy | 35 +
.../partition_prune/always_mono_func.groovy | 4 +-
.../test_add_sub_diff_ceil_floor.groovy | 10 +
.../test_pythonudf_timestamp_ns.groovy | 143 ++
.../query_p0/cache/sql_cache_object_type.groovy | 7 +-
.../expr_zonemap/test_expr_zonemap_pruning.groovy | 107 +-
.../runtime_filter/rf_bucket_pruning.groovy | 5 +
.../datetime_functions/test_date_function.groovy | 12 +-
.../map_functions/test_map_inner_product.groovy | 124 +
.../spatial_functions/test_st_isclosed.groovy | 22 +-
.../suites/query_p0/test_dereference.groovy | 168 +-
.../temp_table_p0/test_drop_temporary_table.groovy | 92 +
.../test_temp_table_ctas_name_conflict.groovy | 106 +
.../ddl/customer_mor_as_dup.sql | 18 +
.../ddl/lineitem_mor_as_dup.sql | 26 +
.../ddl/nation_mor_as_dup.sql | 14 +
.../ddl/orders_mor_as_dup.sql | 19 +
.../ddl/part_mor_as_dup.sql | 19 +
.../ddl/partsupp_mor_as_dup.sql | 15 +
.../ddl/region_mor_as_dup.sql | 13 +
.../ddl/supplier_mor_as_dup.sql | 17 +
.../suites/tpch_sf100_unique_mor_p2/load.groovy | 12 +-
.../test_read_mor_as_dup.groovy | 12 +-
thirdparty/AGENTS.md | 67 +
thirdparty/build-thirdparty.sh | 35 +-
thirdparty/download-thirdparty.sh | 7 +-
thirdparty/patches/apache-arrow-24.0.0-lzo.patch | 17 +
thirdparty/patches/lance-c-0.1.8-pr-69.patch | 653 -----
thirdparty/patches/lance-c-0.1.9-pr-73.patch | 2317 +++++++++++++++++
thirdparty/patches/lance-c-0.1.9-pr-74.patch | 1159 +++++++++
thirdparty/vars.sh | 8 +-
1362 files changed, 66686 insertions(+), 17028 deletions(-)
create mode 100644 .github/scripts/resolve_code_review_status.py
create mode 100644 .github/scripts/test_resolve_code_review_status.py
create mode 100644 .github/scripts/test_review_auth_quarantine.py
create mode 100644 .github/scripts/test_validate_review_pass_comment.py
create mode 100644 .github/scripts/validate_review_pass_comment.py
create mode 100644 .github/workflows/code-review-aggregate-status.yml
create mode 100644 be/src/core/data_type/data_type_timestamp_ns.cpp
copy
fe/fe-core/src/test/java/org/apache/doris/datasource/property/fileformat/WalFileFormatPropertiesTest.java
=> be/src/core/data_type/data_type_timestamp_ns.h (55%)
create mode 100644 be/src/core/data_type_serde/data_type_timestamp_ns_serde.cpp
create mode 100644 be/src/core/data_type_serde/data_type_timestamp_ns_serde.h
create mode 100644 be/src/core/value/timestamp_ns_value.cpp
create mode 100644 be/src/core/value/timestamp_ns_value.h
delete mode 100644 be/src/core/wide_integer_from_double.cpp
create mode 100644 be/src/exprs/function/cast/cast_to_timestamp_ns.h
copy be/src/exprs/function/cast/{function_cast_timestamptz.cpp =>
function_cast_timestamp_ns.cpp} (52%)
create mode 100644 be/src/exprs/function/function_inner_product.h
create mode 100644 be/src/format_v2/expr/equality_delete_hash_index.h
create mode 100644 be/test/core/data_type/data_type_timestamp_ns_test.cpp
create mode 100644 be/test/exprs/aggregate/agg_approx_count_distinct_test.cpp
create mode 100644 be/test/exprs/function/cast/cast_timestamp_ns_test.cpp
create mode 100644 be/test/exprs/function/function_map_inner_product_test.cpp
create mode 100644 be/test/exprs/function/function_timestamp_ns_test.cpp
create mode 100644
be/test/format_v2/parquet/test_data/pyarrow-3.0.0-dictionary-null-count.parquet
create mode 100644 be/test/runtime/fold_constant_executor_test.cpp
create mode 100644 be/test/storage/partial_update_info_test.cpp
create mode 100644 be/test/storage/predicate/predicate_creator_test.cpp
create mode 100644
fe/fe-catalog/src/main/java/org/apache/doris/analysis/TimeStampNsLiteral.java
create mode 100644
fe/fe-connector/fe-connector-iceberg/src/main/java/org/apache/doris/connector/iceberg/dlf/DLFCatalog.java
copy
fe/{fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/RoundingMonotonic.java
=>
fe-connector/fe-connector-iceberg/src/main/java/org/apache/doris/connector/iceberg/dlf/DLFTableOperations.java}
(51%)
create mode 100644
fe/fe-connector/fe-connector-iceberg/src/main/java/org/apache/doris/connector/iceberg/dlf/HiveCompatibleCatalog.java
create mode 100644
fe/fe-connector/fe-connector-iceberg/src/main/java/org/apache/doris/connector/iceberg/dlf/client/DLFCachedClientPool.java
create mode 100644
fe/fe-connector/fe-connector-iceberg/src/main/java/org/apache/doris/connector/iceberg/dlf/client/DLFClientPool.java
create mode 100644
fe/fe-connector/fe-connector-iceberg/src/test/java/org/apache/doris/connector/iceberg/dlf/DLFCatalogTest.java
create mode 100644
fe/fe-connector/fe-connector-iceberg/src/test/java/org/apache/doris/connector/iceberg/dlf/HiveCompatibleCatalogTest.java
copy
fe/{fe-core/src/test/java/org/apache/doris/mysql/authenticate/ldap/LdapUserInfoTest.java
=>
fe-connector/fe-connector-metastore-api/src/main/java/org/apache/doris/connector/metastore/DlfMetaStoreProperties.java}
(69%)
create mode 100644
fe/fe-connector/fe-connector-metastore-iceberg/src/main/java/org/apache/doris/connector/metastore/iceberg/dlf/IcebergDlfMetaStoreProperties.java
create mode 100644
fe/fe-connector/fe-connector-metastore-iceberg/src/main/java/org/apache/doris/connector/metastore/iceberg/dlf/IcebergDlfMetaStoreProvider.java
create mode 100644
fe/fe-connector/fe-connector-metastore-iceberg/src/test/java/org/apache/doris/connector/metastore/iceberg/dlf/IcebergDlfMetaStorePropertiesTest.java
create mode 100644
fe/fe-connector/fe-connector-metastore-paimon/src/main/java/org/apache/doris/connector/metastore/paimon/dlf/PaimonDlfMetaStoreProperties.java
create mode 100644
fe/fe-connector/fe-connector-metastore-paimon/src/main/java/org/apache/doris/connector/metastore/paimon/dlf/PaimonDlfMetaStoreProvider.java
create mode 100644
fe/fe-connector/fe-connector-metastore-paimon/src/test/java/org/apache/doris/connector/metastore/paimon/dlf/PaimonDlfMetaStorePropertiesTest.java
create mode 100644
fe/fe-connector/fe-connector-metastore-spi/src/main/java/org/apache/doris/connector/metastore/spi/AbstractDlfMetaStoreProperties.java
create mode 100644
fe/fe-connector/fe-connector-paimon/src/test/java/org/apache/doris/connector/paimon/PaimonConnectorTestConnectionTest.java
copy
fe/{fe-core/src/test/java/org/apache/doris/insertoverwrite/InsertOverwriteUtilTest.java
=>
fe-connector/fe-connector-paimon/src/test/java/org/apache/doris/connector/paimon/PaimonScanPlanProviderClassifyColumnTest.java}
(52%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/AddMonotonicFunctionPruningPredicates.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/join/ProjectJoinReorderHelper.java
copy fe/fe-core/src/{test/java/org/apache/doris/backup/PathMakerTest.java =>
main/java/org/apache/doris/nereids/trees/expressions/functions/SupportsMixedTimeStampNsDateTime.java}
(72%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{MinutesAdd.java
=> NanoSecondsAdd.java} (66%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{WeeksDiff.java
=> NanoSecondsDiff.java} (65%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{MinutesAdd.java
=> NanoSecondsSub.java} (66%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Microsecond.java
=> Nanosecond.java} (67%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{DateV2.java
=> StIsClosed.java} (73%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/TimeStampNsLiteral.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/types/TimeStampNsType.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CastExprHashPartitionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CurrentTimestampDefaultValueTest.java
copy fe/fe-core/src/test/java/org/apache/doris/{backup/PathMakerTest.java =>
catalog/TimestampNsUdf.java} (67%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/cloud/CacheHotspotManagerSchedulerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/job/extensions/insert/streaming/StreamingInsertJobStatusTransitionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlSerializerDateTimeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/analyzer/ScopeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/processor/post/AddMonotonicFunctionPruningPredicatesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/join/ProjectAwareJoinReorderComplexProjectTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/join/ProjectJoinReorderHelperTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/rules/DateFunctionRewriteTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/rules/PredicateRewriteForPartitionPruneTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/executable/DateTimeAcquireTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/InnerProductTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/TimestampNsFunctionSignatureTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/TimestampNsMonotonicityTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/TimeStampNsLiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/ShowConfigCommandTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/planner/GroupCommitPlannerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/ArrowFlightDeferralGateTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/ConnectProcessorTimestampNsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/CoordinatorContextTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/service/arrowflight/sessions/FlightSqlDeferredQueryIdleTimeoutTest.java
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_cast_string_non_strict.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_from_unixtime_decimal_paths.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_nanosecond_datev2_datetimev2.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_additional_function_argument_matrix.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_agg_state.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_binary_output.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_cast.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_complex_type.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_count_distinct.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_delete.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_expression_argument_matrix.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_expressions.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_function_argument_matrix.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_functions.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_generated_column.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_group_by.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_index.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_join.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_jsonb.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_literal.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_mixed_datetime_coercion.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_mixed_datetime_expressions.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_mv.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_named_zone_gap.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_partition_bucket.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_primary_key.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_rf.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_sort.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_statistics.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_storage_agg_key.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_storage_dup_key.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_storage_uniq_key.out
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_stream_load.csv
create mode 100644
regression-test/data/datatype_p0/timestamp_ns/test_timestamp_ns_stream_load.out
create mode 100644
regression-test/data/external_table_p0/iceberg/test_iceberg_file_metadata_columns.out
create mode 100644 regression-test/data/external_table_p0/test_dlf_catalog.out
create mode 100644
regression-test/data/javaudf_p0/test_javaudf_timestamp_ns.out
create mode 100644
regression-test/data/mtmv_p0/test_mtmv_timestamp_ns_rollup.out
create mode 100644
regression-test/data/nereids_function_p0/array/test_array_timestamp_ns.csv
create mode 100644
regression-test/data/pythonudf_p0/test_pythonudf_timestamp_ns.out
create mode 100644
regression-test/data/query_p0/sql_functions/map_functions/test_map_inner_product.out
create mode 100644 regression-test/data/query_p0/test_dereference.out
copy
fe/fe-core/src/test/java/org/apache/doris/datasource/property/fileformat/AvroFileFormatPropertiesTest.java
=>
regression-test/java-udf-src/src/main/java/org/apache/doris/udf/TimestampNsTest.java
(54%)
create mode 100644
regression-test/suites/arrow_flight_sql_p0/test_arrow_flight_query_release.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_cast_string_non_strict.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_from_unixtime_decimal_paths.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_nanosecond_datev2_datetimev2.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_additional_function_argument_matrix.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_agg_state.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_binary_output.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_cast.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_complex_type.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_count_distinct.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_delete.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_expression_argument_matrix.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_expressions.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_function_argument_matrix.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_functions.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_generated_column.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/RoundingMonotonic.java
=>
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_group_by.groovy
(50%)
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_index.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_join.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_jsonb.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_literal.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_mixed_datetime_coercion.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_mixed_datetime_expressions.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_mv.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/RoundingMonotonic.java
=>
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_named_zone_gap.groovy
(50%)
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_partition_bucket.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_primary_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_rf.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_sort.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_statistics.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_storage_agg_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_storage_dup_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_storage_uniq_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamp_ns/test_timestamp_ns_stream_load.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_file_metadata_columns.groovy
create mode 100644
regression-test/suites/external_table_p0/paimon/test_paimon_file_metadata_columns.groovy
create mode 100644
regression-test/suites/external_table_p0/test_dlf_catalog.groovy
create mode 100644
regression-test/suites/group_join_fusion_p0/test_group_join_fusion_binary_agg.groovy
create mode 100644
regression-test/suites/javaudf_p0/test_javaudf_timestamp_ns.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_mtmv_timestamp_ns_rollup.groovy
create mode 100644
regression-test/suites/pythonudf_p0/test_pythonudf_timestamp_ns.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/map_functions/test_map_inner_product.groovy
copy
fe/fe-core/src/test/java/org/apache/doris/mysql/authenticate/ldap/LdapUserInfoTest.java
=>
regression-test/suites/query_p0/sql_functions/spatial_functions/test_st_isclosed.groovy
(64%)
create mode 100644
regression-test/suites/temp_table_p0/test_drop_temporary_table.groovy
create mode 100644
regression-test/suites/temp_table_p0/test_temp_table_ctas_name_conflict.groovy
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/customer_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/lineitem_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/nation_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/orders_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/part_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/partsupp_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/region_mor_as_dup.sql
create mode 100644
regression-test/suites/tpch_sf100_unique_mor_p2/ddl/supplier_mor_as_dup.sql
create mode 100644 thirdparty/AGENTS.md
delete mode 100644 thirdparty/patches/lance-c-0.1.8-pr-69.patch
create mode 100644 thirdparty/patches/lance-c-0.1.9-pr-73.patch
create mode 100644 thirdparty/patches/lance-c-0.1.9-pr-74.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
