This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from bfa9588f46e [Fix](MTMV) mtmv not refresh cache of external table
before run task (#50979)
add cf5aa68c9a7 [refactor](type) Use PrimitiveType to replace CppType
(#50935)
No new revisions were added by this update.
Summary of changes:
be/src/exec/es/es_scroll_parser.cpp | 204 ++++---
be/src/exec/olap_common.h | 6 +-
be/src/olap/in_list_predicate.h | 8 +-
be/src/olap/like_column_predicate.cpp | 8 +-
be/src/olap/like_column_predicate.h | 8 +-
be/src/olap/partial_update_info.cpp | 6 +-
be/src/olap/push_handler.cpp | 4 +-
be/src/olap/schema.cpp | 4 +-
be/src/pipeline/exec/scan_operator.cpp | 20 +-
be/src/runtime/descriptors.cpp | 8 +
be/src/runtime/descriptors.h | 4 +-
be/src/runtime/primitive_type.h | 335 +++++++++++-
.../aggregate_function_approx_count_distinct.cpp | 58 +-
.../aggregate_function_approx_count_distinct.h | 10 +-
.../aggregate_function_approx_top_sum.h | 10 +-
.../aggregate_function_array_agg.cpp | 46 +-
.../aggregate_function_array_agg.h | 32 +-
.../aggregate_functions/aggregate_function_avg.cpp | 12 +-
.../aggregate_functions/aggregate_function_avg.h | 29 +-
.../aggregate_function_avg_weighted.h | 27 +-
.../aggregate_function_binary.h | 48 +-
.../aggregate_functions/aggregate_function_bit.h | 46 +-
.../aggregate_function_bitmap.h | 9 +-
.../aggregate_function_bitmap_agg.cpp | 9 +-
.../aggregate_function_bitmap_agg.h | 10 +-
.../aggregate_function_collect.cpp | 91 ++--
.../aggregate_function_collect.h | 54 +-
.../aggregate_function_corr.cpp | 2 +-
.../aggregate_functions/aggregate_function_corr.h | 8 +-
.../aggregate_functions/aggregate_function_count.h | 7 +-
.../aggregate_function_covar.cpp | 34 +-
.../aggregate_functions/aggregate_function_covar.h | 14 +-
.../aggregate_function_distinct.cpp | 6 +-
.../aggregate_function_distinct.h | 20 +-
.../aggregate_function_group_array_intersect.cpp | 21 +-
.../aggregate_function_group_array_intersect.h | 64 +--
.../aggregate_function_histogram.cpp | 39 +-
.../aggregate_function_histogram.h | 27 +-
.../aggregate_function_kurtosis.cpp | 30 +-
.../aggregate_function_linear_histogram.cpp | 41 +-
.../aggregate_function_linear_histogram.h | 12 +-
.../aggregate_functions/aggregate_function_map.cpp | 39 +-
.../aggregate_functions/aggregate_function_map.h | 24 +-
.../aggregate_function_min_max.cpp | 15 +-
.../aggregate_function_min_max.h | 68 ++-
.../aggregate_function_min_max_by.h | 70 +--
.../aggregate_function_orthogonal_bitmap.cpp | 6 +-
.../aggregate_function_orthogonal_bitmap.h | 39 +-
.../aggregate_function_percentile.h | 23 +-
.../aggregate_function_regr_union.cpp | 20 +-
.../aggregate_function_regr_union.h | 11 +-
.../aggregate_function_sequence_match.cpp | 16 +-
.../aggregate_function_sequence_match.h | 67 +--
.../aggregate_function_skew.cpp | 30 +-
.../aggregate_function_statistic.h | 4 +-
.../aggregate_function_stddev.cpp | 18 +-
.../aggregate_function_stddev.h | 18 +-
.../aggregate_functions/aggregate_function_sum.h | 39 +-
.../aggregate_function_topn.cpp | 69 +--
.../aggregate_functions/aggregate_function_topn.h | 51 +-
.../aggregate_function_uniq.cpp | 25 +-
.../aggregate_functions/aggregate_function_uniq.h | 47 +-
.../aggregate_function_uniq_distribute_key.cpp | 12 +-
.../aggregate_function_uniq_distribute_key.h | 33 +-
be/src/vec/aggregate_functions/helpers.h | 69 +--
be/src/vec/columns/column_array.cpp | 6 +-
be/src/vec/columns/column_complex.h | 22 +-
be/src/vec/columns/column_decimal.cpp | 16 +
be/src/vec/columns/column_decimal.h | 12 +-
be/src/vec/columns/column_dictionary.h | 61 +--
be/src/vec/columns/column_fixed_length_object.h | 5 +-
be/src/vec/columns/column_map.cpp | 4 +-
be/src/vec/columns/column_map.h | 7 +-
be/src/vec/columns/column_nullable.cpp | 4 +-
be/src/vec/columns/column_object.cpp | 20 +-
be/src/vec/columns/column_string.cpp | 23 +
be/src/vec/columns/column_string.h | 17 +-
be/src/vec/columns/column_struct.cpp | 3 +-
be/src/vec/columns/column_vector.cpp | 42 ++
be/src/vec/columns/column_vector.h | 2 +-
be/src/vec/common/schema_util.cpp | 5 +-
be/src/vec/core/decimal_comparison.h | 2 +-
be/src/vec/core/field.cpp | 588 ++++++++++++++-------
be/src/vec/core/field.h | 141 +----
be/src/vec/core/types.h | 2 +
be/src/vec/data_types/convert_field_to_type.cpp | 39 +-
be/src/vec/data_types/data_type_array.cpp | 2 +-
be/src/vec/data_types/data_type_array.h | 1 -
be/src/vec/data_types/data_type_bitmap.h | 11 +-
be/src/vec/data_types/data_type_date.h | 2 +-
.../vec/data_types/data_type_date_or_datetime_v2.h | 4 +-
be/src/vec/data_types/data_type_date_time.h | 2 +-
be/src/vec/data_types/data_type_decimal.cpp | 15 +-
be/src/vec/data_types/data_type_decimal.h | 15 +-
.../vec/data_types/data_type_fixed_length_object.h | 9 +-
be/src/vec/data_types/data_type_hll.h | 5 +-
be/src/vec/data_types/data_type_ipv4.h | 4 +-
be/src/vec/data_types/data_type_ipv6.h | 2 +-
be/src/vec/data_types/data_type_jsonb.h | 6 +-
be/src/vec/data_types/data_type_map.cpp | 6 +-
be/src/vec/data_types/data_type_map.h | 1 -
be/src/vec/data_types/data_type_nothing.h | 10 +-
be/src/vec/data_types/data_type_nullable.cpp | 2 +-
be/src/vec/data_types/data_type_nullable.h | 2 +-
be/src/vec/data_types/data_type_number_base.cpp | 62 ++-
be/src/vec/data_types/data_type_object.cpp | 13 +
be/src/vec/data_types/data_type_object.h | 15 +-
be/src/vec/data_types/data_type_quantilestate.h | 11 +-
be/src/vec/data_types/data_type_string.cpp | 2 +-
be/src/vec/data_types/data_type_string.h | 2 +-
be/src/vec/data_types/data_type_struct.cpp | 2 +-
be/src/vec/data_types/data_type_struct.h | 1 -
.../data_types/serde/data_type_object_serde.cpp | 4 +-
be/src/vec/exec/format/parquet/parquet_pred_cmp.h | 6 +-
be/src/vec/exec/jni_connector.h | 3 +-
be/src/vec/exec/scan/file_scanner.cpp | 4 +-
be/src/vec/exec/vjdbc_connector.cpp | 3 +-
be/src/vec/exprs/varray_literal.cpp | 2 +-
be/src/vec/exprs/vinfo_func.cpp | 4 +-
be/src/vec/exprs/vmap_literal.cpp | 6 +-
be/src/vec/exprs/vstruct_literal.cpp | 2 +-
.../functions/array/function_array_aggregation.cpp | 58 +-
be/src/vec/functions/function.cpp | 2 +-
be/src/vec/functions/function_bitmap.cpp | 3 +-
be/src/vec/functions/function_bitmap_min_or_max.h | 2 +-
be/src/vec/functions/function_const.h | 3 +-
be/src/vec/functions/function_convert_tz.h | 28 +-
be/src/vec/functions/function_helpers.h | 16 +-
be/src/vec/functions/function_ip.h | 8 +-
be/src/vec/functions/function_string.h | 4 +-
be/src/vec/functions/function_utility.cpp | 10 +-
be/src/vec/functions/functions_comparison.h | 13 +-
be/src/vec/functions/is_not_null.h | 4 +-
be/src/vec/functions/is_null.h | 4 +-
be/src/vec/json/json_parser.cpp | 13 +-
be/src/vec/json/json_parser.h | 10 +-
be/src/vec/json/parse2column.cpp | 4 +-
be/src/vec/olap/vcollect_iterator.cpp | 3 +-
.../sink/writer/iceberg/partition_transformers.h | 9 +-
be/test/olap/index_builder_test.cpp | 4 +-
.../common/inverted_index_gc_binlogs_test.cpp | 4 +-
.../compaction/util/index_compaction_utils.cpp | 25 +-
.../segment_v2/inverted_index_array_test.cpp | 112 ++--
.../pipeline/operator/agg_shared_state_test.cpp | 12 +-
.../operator/hashjoin_probe_operator_test.cpp | 343 +++++++++---
.../runtime_filter_producer_helper_cross_test.cpp | 4 +-
.../runtime_filter_producer_helper_set_test.cpp | 4 +-
.../runtime_filter_producer_helper_test.cpp | 16 +-
.../vec/aggregate_functions/agg_bitmap_test.cpp | 23 +-
.../vec/aggregate_functions/agg_collect_test.cpp | 8 +-
be/test/vec/aggregate_functions/agg_corr_test.cpp | 4 +-
.../agg_group_array_intersect_test.cpp | 128 ++---
.../aggregate_functions/agg_min_max_by_test.cpp | 8 +-
.../vec/aggregate_functions/agg_min_max_test.cpp | 6 +-
.../vec/aggregate_functions/agg_replace_test.cpp | 10 +-
be/test/vec/aggregate_functions/agg_test.cpp | 4 +-
.../aggregate_functions/vec_count_by_enum_test.cpp | 42 +-
.../vec/aggregate_functions/vec_retention_test.cpp | 72 +--
.../vec_sequence_match_test.cpp | 80 +--
.../aggregate_functions/vec_window_funnel_test.cpp | 180 +++----
be/test/vec/columns/column_array_test.cpp | 2 +-
be/test/vec/columns/column_dictionary_test.cpp | 37 +-
be/test/vec/columns/column_hash_func_test.cpp | 56 +-
be/test/vec/columns/column_ip_test.cpp | 3 +-
.../column_nullable_seriazlization_test.cpp | 40 +-
be/test/vec/columns/column_nullable_test.cpp | 8 +-
be/test/vec/columns/column_nullable_test.h | 33 +-
be/test/vec/columns/column_object_test.cpp | 30 +-
be/test/vec/columns/column_resize_test.cpp | 10 +-
be/test/vec/columns/column_string_test.cpp | 4 +-
be/test/vec/columns/common_column_test.h | 47 +-
be/test/vec/common/pod_array_test.cpp | 2 +
be/test/vec/core/block_test.cpp | 6 +-
be/test/vec/core/column_map_test.cpp | 73 +--
be/test/vec/core/column_struct_test.cpp | 13 +-
be/test/vec/core/column_test.cpp | 56 +-
be/test/vec/core/field_test.cpp | 19 +-
.../vec/data_types/data_type_agg_state_test.cpp | 4 +-
be/test/vec/data_types/data_type_array_test.cpp | 24 +-
be/test/vec/data_types/data_type_bitmap_test.cpp | 4 +-
be/test/vec/data_types/data_type_decimal_test.cpp | 3 +-
.../data_type_fixed_length_object_test.cpp | 4 +-
be/test/vec/data_types/data_type_hll_test.cpp | 4 +-
be/test/vec/data_types/data_type_ip_test.cpp | 42 +-
be/test/vec/data_types/data_type_map_test.cpp | 122 ++---
be/test/vec/data_types/data_type_number_test.cpp | 59 ++-
.../data_types/data_type_quantile_state_test.cpp | 4 +-
be/test/vec/data_types/data_type_string_test.cpp | 6 +-
be/test/vec/data_types/data_type_struct_test.cpp | 60 +--
be/test/vec/data_types/data_type_time_v2_test.cpp | 10 +-
be/test/vec/data_types/from_string_test.cpp | 2 +-
.../serde/data_type_serde_arrow_test.cpp | 126 ++---
.../data_types/serde/data_type_serde_csv_test.cpp | 2 +-
.../serde/data_type_serde_mysql_test.cpp | 2 +-
.../data_types/serde/data_type_serde_pb_test.cpp | 112 ++--
.../vec/data_types/serde/data_type_serde_test.cpp | 4 +-
.../data_types/serde/data_type_serde_text_test.cpp | 2 +-
.../data_types/serde/data_type_to_string_test.cpp | 41 +-
.../parquet/byte_array_dict_decoder_test.cpp | 8 +-
.../parquet/fix_length_dict_decoder_test.cpp | 8 +-
be/test/vec/exec/orc/orc_convert_dict_test.cpp | 10 +-
.../function_compressed_materialization_test.cpp | 8 +-
be/test/vec/function/function_eq_for_null_test.cpp | 40 +-
be/test/vec/function/function_is_null_test.cpp | 6 +-
be/test/vec/function/function_round_test.cpp | 4 +-
be/test/vec/function/function_test_util.cpp | 2 +-
be/test/vec/jsonb/serialize_test.cpp | 59 ++-
.../writer/iceberg/partition_transformers_test.cpp | 8 +-
208 files changed, 3501 insertions(+), 2517 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
