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 77d75e24418 [test](case) add some test case about partition sort hash
types (#50318)
add 559b1837a3f [refactor](type) Use DataType to replace TypeDescriptor
(#50290)
No new revisions were added by this update.
Summary of changes:
be/src/exec/es/es_scroll_parser.cpp | 10 +-
be/src/exec/odbc_connector.cpp | 7 +-
be/src/exec/rowid_fetcher.cpp | 40 +-
be/src/exec/schema_scanner.cpp | 4 +-
.../schema_active_queries_scanner.cpp | 4 +-
.../schema_scanner/schema_backend_active_tasks.cpp | 5 +-
.../schema_backend_kerberos_ticket_cache.cpp | 5 +-
.../schema_catalog_meta_cache_stats_scanner.cpp | 4 +-
.../schema_file_cache_statistics.cpp | 5 +-
.../schema_scanner/schema_partitions_scanner.cpp | 4 +-
.../exec/schema_scanner/schema_routine_scanner.cpp | 4 +-
.../schema_table_options_scanner.cpp | 4 +-
.../schema_table_properties_scanner.cpp | 4 +-
.../schema_workload_group_privileges.cpp | 4 +-
...chema_workload_group_resource_usage_scanner.cpp | 5 +-
.../schema_workload_groups_scanner.cpp | 4 +-
.../schema_workload_sched_policy_scanner.cpp | 4 +-
be/src/exec/table_connector.cpp | 16 +-
be/src/exec/table_connector.h | 5 +-
be/src/exec/tablet_info.cpp | 10 +-
be/src/exec/tablet_info.h | 3 +-
be/src/olap/iterators.h | 2 +-
be/src/olap/match_predicate.cpp | 31 +-
be/src/olap/push_handler.cpp | 18 +-
be/src/olap/push_handler.h | 2 +-
be/src/olap/rowset/rowset_reader_context.h | 2 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 2 +-
be/src/olap/rowset/segment_v2/column_writer.cpp | 2 +-
be/src/olap/rowset/segment_v2/segment.h | 5 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 2 +-
be/src/olap/tablet_reader.cpp | 4 +-
be/src/olap/tablet_reader.h | 2 +-
be/src/olap/tablet_schema.cpp | 2 +-
be/src/pipeline/exec/hashjoin_build_sink.cpp | 3 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 2 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 2 +-
be/src/pipeline/exec/scan_operator.cpp | 70 +--
be/src/pipeline/exec/scan_operator.h | 5 +-
be/src/pipeline/exec/schema_scan_operator.cpp | 15 +-
be/src/runtime/descriptors.cpp | 41 +-
be/src/runtime/descriptors.h | 12 +-
be/src/runtime/fold_constant_executor.cpp | 32 +-
be/src/runtime/fold_constant_executor.h | 2 +-
be/src/runtime/fragment_mgr.cpp | 2 +-
be/src/runtime/primitive_type.h | 8 +
be/src/runtime/types.cpp | 329 --------------
be/src/runtime/types.h | 239 -----------
be/src/runtime_filter/runtime_filter.cpp | 8 +-
be/src/runtime_filter/runtime_filter_consumer.cpp | 22 +-
be/src/runtime_filter/runtime_filter_merger.h | 4 +-
be/src/runtime_filter/utils.cpp | 18 +-
be/src/runtime_filter/utils.h | 6 +-
be/src/service/internal_service.cpp | 5 +-
be/src/udf/udf.cpp | 11 +-
be/src/udf/udf.h | 17 +-
be/src/util/arrow/row_batch.cpp | 48 ++-
be/src/util/arrow/row_batch.h | 4 +-
be/src/vec/columns/column_nullable.cpp | 4 +-
be/src/vec/core/types.h | 10 +
be/src/vec/data_types/data_type.h | 44 +-
be/src/vec/data_types/data_type_agg_state.h | 6 +-
be/src/vec/data_types/data_type_array.h | 21 +-
be/src/vec/data_types/data_type_bitmap.h | 5 +-
be/src/vec/data_types/data_type_date.h | 4 +-
be/src/vec/data_types/data_type_date_time.h | 4 +-
be/src/vec/data_types/data_type_decimal.cpp | 53 +++
be/src/vec/data_types/data_type_decimal.h | 33 +-
be/src/vec/data_types/data_type_factory.cpp | 473 +++++++++++++++------
be/src/vec/data_types/data_type_factory.hpp | 23 +-
.../vec/data_types/data_type_fixed_length_object.h | 5 +-
be/src/vec/data_types/data_type_hll.h | 2 +-
be/src/vec/data_types/data_type_ipv4.h | 2 +-
be/src/vec/data_types/data_type_ipv6.h | 4 +-
be/src/vec/data_types/data_type_jsonb.h | 4 +-
be/src/vec/data_types/data_type_map.h | 24 +-
be/src/vec/data_types/data_type_nothing.h | 6 +-
be/src/vec/data_types/data_type_nullable.h | 15 +-
be/src/vec/data_types/data_type_number_base.h | 20 +-
be/src/vec/data_types/data_type_object.h | 7 +-
be/src/vec/data_types/data_type_quantilestate.h | 4 +-
be/src/vec/data_types/data_type_string.h | 34 +-
be/src/vec/data_types/data_type_struct.h | 36 +-
be/src/vec/data_types/data_type_time.h | 4 +-
be/src/vec/data_types/data_type_time_v2.h | 11 +-
.../vec/exec/format/arrow/arrow_stream_reader.cpp | 2 +-
be/src/vec/exec/format/arrow/arrow_stream_reader.h | 2 +-
be/src/vec/exec/format/avro/avro_jni_reader.cpp | 39 +-
be/src/vec/exec/format/avro/avro_jni_reader.h | 7 +-
be/src/vec/exec/format/column_type_convert.cpp | 85 ++--
be/src/vec/exec/format/column_type_convert.h | 15 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 37 +-
be/src/vec/exec/format/csv/csv_reader.h | 8 +-
be/src/vec/exec/format/generic_reader.h | 6 +-
be/src/vec/exec/format/jni_reader.cpp | 4 +-
be/src/vec/exec/format/jni_reader.h | 3 +-
be/src/vec/exec/format/json/new_json_reader.cpp | 91 ++--
be/src/vec/exec/format/json/new_json_reader.h | 9 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 103 ++---
be/src/vec/exec/format/orc/vorc_reader.h | 6 +-
.../vec/exec/format/parquet/bool_plain_decoder.cpp | 2 +-
.../vec/exec/format/parquet/bool_rle_decoder.cpp | 2 +-
.../exec/format/parquet/parquet_column_convert.cpp | 45 +-
.../exec/format/parquet/parquet_column_convert.h | 28 +-
be/src/vec/exec/format/parquet/parquet_pred_cmp.h | 4 +-
be/src/vec/exec/format/parquet/schema_desc.cpp | 186 ++++----
be/src/vec/exec/format/parquet/schema_desc.h | 19 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 64 +--
.../exec/format/parquet/vparquet_group_reader.cpp | 5 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 18 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 5 +-
be/src/vec/exec/format/table/equality_delete.cpp | 14 +-
be/src/vec/exec/format/table/hudi_jni_reader.cpp | 2 +-
be/src/vec/exec/format/table/hudi_jni_reader.h | 3 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 10 +-
be/src/vec/exec/format/table/iceberg_reader.h | 9 +-
.../vec/exec/format/table/lakesoul_jni_reader.cpp | 2 +-
be/src/vec/exec/format/table/lakesoul_jni_reader.h | 3 +-
.../exec/format/table/max_compute_jni_reader.cpp | 7 +-
.../vec/exec/format/table/max_compute_jni_reader.h | 3 +-
be/src/vec/exec/format/table/paimon_jni_reader.cpp | 4 +-
be/src/vec/exec/format/table/paimon_jni_reader.h | 3 +-
be/src/vec/exec/format/table/table_format_reader.h | 5 +-
.../format/table/transactional_hive_reader.cpp | 4 +-
.../exec/format/table/transactional_hive_reader.h | 1 -
.../format/table/trino_connector_jni_reader.cpp | 4 +-
.../exec/format/table/trino_connector_jni_reader.h | 3 +-
be/src/vec/exec/format/wal/wal_reader.cpp | 2 +-
be/src/vec/exec/format/wal/wal_reader.h | 2 +-
be/src/vec/exec/jni_connector.cpp | 44 +-
be/src/vec/exec/jni_connector.h | 6 +-
be/src/vec/exec/scan/file_scanner.cpp | 48 ++-
be/src/vec/exec/scan/file_scanner.h | 7 +-
be/src/vec/exec/scan/meta_scanner.cpp | 28 +-
be/src/vec/exec/scan/olap_scanner.cpp | 11 +-
be/src/vec/exec/vjdbc_connector.cpp | 19 +-
.../exprs/table_function/udf_table_function.cpp | 3 +-
be/src/vec/exprs/varray_literal.cpp | 2 -
be/src/vec/exprs/vectorized_agg_fn.cpp | 15 +-
be/src/vec/exprs/vectorized_agg_fn.h | 2 -
be/src/vec/exprs/vectorized_fn_call.cpp | 2 +-
be/src/vec/exprs/vexpr.cpp | 33 +-
be/src/vec/exprs/vexpr.h | 7 +-
be/src/vec/exprs/vexpr_context.cpp | 4 +-
be/src/vec/exprs/vexpr_context.h | 4 +-
be/src/vec/exprs/vinfo_func.cpp | 4 +-
be/src/vec/exprs/vmap_literal.cpp | 2 -
be/src/vec/exprs/vslot_ref.cpp | 5 +-
be/src/vec/functions/array/function_array_index.h | 6 +-
.../vec/functions/array/function_arrays_overlap.h | 3 +-
be/src/vec/functions/function_binary_arithmetic.h | 9 +-
be/src/vec/functions/function_collection_in.h | 3 +-
be/src/vec/functions/function_ip.h | 2 +-
be/src/vec/functions/function_multi_match.cpp | 2 +-
be/src/vec/functions/function_timestamp.cpp | 3 +-
be/src/vec/functions/functions_comparison.h | 2 +-
be/src/vec/functions/in.h | 16 +-
be/src/vec/functions/match.cpp | 2 +-
be/src/vec/olap/olap_data_convertor.cpp | 2 +-
be/src/vec/runtime/partitioner.cpp | 5 +-
be/src/vec/runtime/vcsv_transformer.cpp | 2 +-
be/src/vec/runtime/vorc_transformer.cpp | 42 +-
be/src/vec/runtime/vorc_transformer.h | 2 +-
be/src/vec/runtime/vparquet_transformer.cpp | 2 +-
be/src/vec/runtime/vparquet_transformer.h | 4 -
be/src/vec/sink/vmysql_result_writer.cpp | 5 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 116 ++---
be/src/vec/sink/vtablet_block_convertor.h | 17 +-
.../sink/writer/iceberg/partition_transformers.cpp | 48 +--
.../sink/writer/iceberg/partition_transformers.h | 307 ++++++-------
.../sink/writer/iceberg/viceberg_table_writer.cpp | 35 +-
.../sink/writer/iceberg/viceberg_table_writer.h | 9 +-
be/src/vec/sink/writer/vfile_result_writer.cpp | 13 +-
be/src/vec/sink/writer/vhive_table_writer.cpp | 24 +-
be/src/vec/sink/writer/vhive_table_writer.h | 3 +-
be/src/vec/sink/writer/vmysql_table_writer.cpp | 9 +-
be/test/olap/delta_writer_cluster_key_test.cpp | 3 +-
be/test/olap/delta_writer_test.cpp | 10 +-
be/test/olap/memtable_memory_limiter_test.cpp | 3 +-
be/test/olap/segment_cache_test.cpp | 3 +-
be/test/olap/tablet_cooldown_test.cpp | 3 +-
.../operator/hashjoin_probe_operator_test.cpp | 8 +-
be/test/pipeline/operator/repeat_operator_test.cpp | 3 -
.../operator/scan_normalize_predicate_test.cpp | 29 ++
be/test/runtime/snapshot_loader_test.cpp | 3 +-
.../runtime_filter_consumer_helper_test.cpp | 3 +
be/test/runtime_filter/utils_test.cpp | 13 +-
be/test/testutil/desc_tbl_builder.cpp | 33 +-
be/test/testutil/desc_tbl_builder.h | 10 +-
be/test/testutil/function_utils.cpp | 9 +-
be/test/testutil/function_utils.h | 5 +-
be/test/testutil/mock/mock_descriptors.h | 14 +-
be/test/vec/columns/column_string_test.cpp | 2 +-
be/test/vec/data_types/common_data_type_test.h | 9 +-
.../vec/data_types/data_type_agg_state_test.cpp | 4 +-
be/test/vec/data_types/data_type_array_test.cpp | 8 +-
be/test/vec/data_types/data_type_bitmap_test.cpp | 5 +-
be/test/vec/data_types/data_type_decimal_test.cpp | 46 +-
.../data_type_fixed_length_object_test.cpp | 4 +-
be/test/vec/data_types/data_type_hll_test.cpp | 5 +-
be/test/vec/data_types/data_type_ip_test.cpp | 10 +-
be/test/vec/data_types/data_type_number_test.cpp | 21 +-
.../data_types/data_type_quantile_state_test.cpp | 5 +-
be/test/vec/data_types/data_type_string_test.cpp | 5 +-
.../serde/data_type_serde_arrow_test.cpp | 330 +++++++-------
.../serde/data_type_serde_mysql_test.cpp | 63 ++-
be/test/vec/exec/column_type_convert_test.cpp | 168 ++++----
.../exec/format/parquet/parquet_reader_test.cpp | 6 +-
.../exec/format/parquet/parquet_thrift_test.cpp | 37 +-
be/test/vec/exec/orc_reader_test.cpp | 28 +-
be/test/vec/exprs/vexpr_test.cpp | 23 +-
.../vec/function/function_money_format_test.cpp | 11 +-
be/test/vec/function/function_test_util.cpp | 61 ++-
be/test/vec/function/function_test_util.h | 50 ++-
be/test/vec/jsonb/serialize_test.cpp | 60 +--
.../writer/iceberg/partition_transformers_test.cpp | 50 ++-
.../utils/arrow_column_to_doris_column_test.cpp | 8 +-
.../tvf/test_hdfs_parquet_group4.groovy | 4 +-
.../tvf/test_hdfs_parquet_group5.groovy | 4 +-
.../tvf/test_hdfs_parquet_group6.groovy | 6 +-
219 files changed, 2450 insertions(+), 2538 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
