This is an automated email from the ASF dual-hosted git repository. morningman pushed a change to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
discard 031ecb782c [temp](statistics) disable statistic tables add b51f6ae050 [feature](Nereids)add rule: PruneOlapScanTablet (#14378) add e5e94e128d [docs](macOS) Fix the render (#14643) add 39dd6682f2 [typo](docs)change the metadata directory from palo-meta to doris-meta #14647 add daeabcf053 [improvement](vec) optimize the logic for _has_null in ColumnNullable (#14633) add c5eb8ab084 [fix](persiste) make ArithmeticExpr wriable (#14615) add 7513c82431 [NLJoin](conjuncts) separate join conjuncts and general conjuncts (#14608) add 2295ab24b0 [fix](metric) fix jvm_young_size_bytes. (#14562) add 0daebde223 [fix](java-udf) Disable the corresponding configuration if building BE without Java UDF support (#14303) add e1f0fa069c [enhancement](memory) Refactored process memory statistics periodically refresh, and fix catch bad_alloc (#14580) add f7a827c06b [fix](new-scan) fix some bugs about new scan node and readers (#14504) add 1bddf9ba5c [docs](readme)update the user numbers (#14639) add 97f0d3a756 [Improvement](datatype) disable new types if vectorized engine is disabled (#14561) add 82da071b45 [Chore](format) update clang-format version to 15 (#13036) add 3e8b3658c7 [feature-wip](decimalv3) Support basic agg and arithmetic operations for decimal v3 (#14513) add c5f9fd5619 [fix](spark load)partition column is not duplicate key, spark load IndexOutOfBounds error (#14661) add facb7cf4e2 [fix](spark load)Temp partition with spark load (#14648) add 7a08a799e9 [Vectorized](function) support order by convert_to function (#14555) add fe95b84c34 [fix](jsonb)fix CAST String to JSONB nullable problem (#14626) add 1713af6cd6 [test](java udf)add new java udf case (#14653) add a60490651f [improvement](function) add timezone cache for convert_tz (#14616) add 85ce3c37b5 [fix](DOE) fix ES query dsl is wrong after FE restarted. (#14652) add 03aa5572da [feature](docker)Add Broker Docker image related files (#14621) add 22883e7e08 [fuzzy](test) be fuzzy conf (#14654) add 82579126cf [fix](Dictionary-codec) heap overflow with in-predicate on nullable columns (#14319) (#14641) add 898d0d42f1 [improvement](load)add more log for better bug tracing experience for be write (#14424) add 33ad616839 [fix](statistics) Fix potential NPE in ShowStatisticsStmt #14679 add 33cda9f22a [improvement](planner)support like in show catalogs stmt #14678 add 5a2e3869df [regression](test) enable fe and be fuzzy test (#14673) add b12ac90d8f [tools](tpch) upgrade decimal type to decimalv3 (#14665) add d5ee721621 [improvement](planner)Adjust the field naming rules when creating tables (#14671) add 4faca56819 [bug](jsonb) fix INSERT/CAST NULL to JSONB (#14682) add dd7ec8f4ca [improvement](test) add tpch1 orc for hive catalog and refactor some test dir (#14669) add ca90253b09 [config](storage-policy) add a FE config to disable storage policy by default (#14655) add 7a1fde379c [Enhancement](function) optimize for decimal arithmetic calculation (#14674) add 3a362fab76 [fix](fe)table function node use wrong info for projection (#14667) add 05b875f521 [feature](multi-catalog) support Jdbc catalog (#14527) add 4924ef3f59 [fix](tcmalloc) use low_watermark instead of hard_mem_limit (#14660) add ff86d6783e [enhencement](netty) bind netty's default logger when launching fe (#14675) add cd1fffa92f [improvement](planner)sort show catalogs result by name (#14684) add 45bd4f7b1c (fix)[test] add some logs (#14695) add e2424ff805 [bug](jsonb) fix be core at insert invalid json to JSONB column (#14686) add cbe104f4d1 [temp](statistics) disable statistic tables add 96613e2c73 [fix](join) runtime filter shared from other instance wasn't be published (#14717) add 5033755fd3 [improvement](multi-catalog) return root cause of exception (#14708) add 6038918000 [Docs](memory) fix document directory and fix memtracker accuracy bug #14710 add dc96b1caf5 [fix](bitmapfilter) fix core dump caused by bitmap filter (#14702) add d85c1e98b4 [Enhancement](bitmapfilter) Support bitmap filter to apply zone_map index to filter pages (#14635) 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 (031ecb782c) \ N -- N -- N refs/heads/branch-1.2-lts (d85c1e98b4) 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/workflows/clang-format.yml | 2 +- .licenserc.yaml | 6 +- README.md | 2 +- be/src/common/config.h | 23 +- be/src/common/configbase.cpp | 19 +- be/src/common/configbase.h | 7 +- be/src/common/daemon.cpp | 73 +- be/src/common/daemon.h | 5 + be/src/exec/tablet_sink.cpp | 13 +- be/src/exprs/bitmapfilter_predicate.h | 35 +- be/src/exprs/runtime_filter.cpp | 21 +- be/src/exprs/runtime_filter.h | 3 + be/src/exprs/timestamp_functions.cpp | 84 +- be/src/exprs/timestamp_functions.h | 3 + be/src/http/http_request.h | 4 +- be/src/olap/bitmap_filter_predicate.h | 45 +- be/src/olap/delta_writer.cpp | 10 +- be/src/olap/in_list_predicate.h | 11 +- be/src/olap/memtable.cpp | 7 + be/src/olap/olap_common.h | 2 + be/src/olap/page_cache.cpp | 2 +- be/src/olap/rowset/segment_v2/segment.h | 2 +- be/src/olap/rowset/segment_v2/segment_iterator.cpp | 4 +- be/src/olap/utils.h | 2 +- be/src/runtime/jsonb_value.h | 5 +- be/src/runtime/load_channel_mgr.cpp | 2 +- be/src/runtime/load_channel_mgr.h | 8 +- be/src/runtime/memory/jemalloc_hook.cpp | 16 +- be/src/runtime/memory/mem_tracker_limiter.cpp | 9 +- be/src/runtime/memory/mem_tracker_limiter.h | 32 +- be/src/runtime/memory/system_allocator.cpp | 2 +- be/src/runtime/memory/thread_mem_tracker_mgr.cpp | 22 +- be/src/runtime/memory/thread_mem_tracker_mgr.h | 71 +- be/src/runtime/tablets_channel.cpp | 5 + be/src/runtime/thread_context.h | 24 +- be/src/service/doris_main.cpp | 20 +- be/src/util/binary_cast.hpp | 2 +- be/src/util/bitmap_value.h | 76 +- be/src/util/mem_info.cpp | 15 +- be/src/util/mem_info.h | 9 + be/src/util/runtime_profile.h | 2 +- .../aggregate_functions/aggregate_function_avg.h | 8 +- .../aggregate_functions/aggregate_function_sum.cpp | 2 +- be/src/vec/aggregate_functions/helpers.h | 2 +- be/src/vec/columns/column_dictionary.h | 25 + be/src/vec/columns/column_nullable.cpp | 41 +- be/src/vec/columns/column_nullable.h | 21 +- be/src/vec/common/allocator.h | 30 +- be/src/vec/core/accurate_comparison.h | 29 +- be/src/vec/core/types.h | 4 + be/src/vec/data_types/data_type_decimal.cpp | 2 +- be/src/vec/data_types/data_type_factory.hpp | 2 +- be/src/vec/exec/format/json/new_json_reader.cpp | 3 +- be/src/vec/exec/join/vhash_join_node.cpp | 71 +- be/src/vec/exec/join/vhash_join_node.h | 15 +- be/src/vec/exec/join/vjoin_node_base.cpp | 12 + be/src/vec/exec/join/vjoin_node_base.h | 9 + be/src/vec/exec/join/vnested_loop_join_node.cpp | 92 +- be/src/vec/exec/join/vnested_loop_join_node.h | 6 + be/src/vec/exec/scan/new_olap_scan_node.cpp | 1 + be/src/vec/exec/scan/new_olap_scan_node.h | 1 + be/src/vec/exec/scan/new_olap_scanner.cpp | 2 + be/src/vec/exec/scan/vfile_scanner.cpp | 2 +- be/src/vec/exec/vaggregation_node.cpp | 4 +- be/src/vec/exec/varrow_scanner.cpp | 4 +- be/src/vec/exec/vjdbc_connector.cpp | 15 +- be/src/vec/exprs/vliteral.cpp | 4 +- .../functions/array/function_array_aggregation.cpp | 8 +- be/src/vec/functions/function_binary_arithmetic.h | 375 +- be/src/vec/functions/function_cast.h | 3 +- be/src/vec/functions/function_convert_tz.h | 48 +- be/src/vec/functions/function_string.cpp | 1 + be/src/vec/functions/function_string.h | 92 + be/src/vec/functions/function_unary_arithmetic.h | 13 +- be/src/vec/functions/minus.cpp | 2 +- be/src/vec/runtime/shared_hash_table_controller.h | 2 +- be/test/vec/function/function_jsonb_test.cpp | 49 +- build.sh | 11 +- docker/runtime/be/resource/init_be.sh | 13 +- docker/runtime/broker/Dockerfile | 41 + docker/runtime/broker/resource/init_broker.sh | 110 + docker/runtime/fe/resource/init_fe.sh | 3 - .../{create.hql => create_preinstalled_table.hql} | 186 +- .../hive/scripts/create_tpch1_orc.hql | 183 + .../hive/scripts/create_tpch1_parquet.hql | 160 + .../docker-compose/hive/scripts/hive-metastore.sh | 32 +- .../csv_format_test/all_types.csv | 0 .../csv_format_test/array_malformat.csv | 0 .../csv_format_test/array_normal.csv | 0 .../csv_format_test/student.csv | 0 .../csv_format_test/student_with_names.csv | 0 .../student_with_names_and_types.csv | 0 .../table_with_vertical_line/dt=2022-11-24/1.txt | 0 .../table_with_vertical_line/dt=2022-11-25/2.txt | 0 .../table_with_x01/dt=2022-11-10/3.txt | 0 .../data_case/account_fund/data_file | 0 .../data_case/hive01/data_file | 0 .../data_case/lineorder/data_file | 0 .../data_case/sale_table/data_file | 0 .../data_case/string_table/data_file | 0 .../data_case/student/data_file | 0 .../data_case/t_hive/data_file | 0 .../data_case/test1/data_file | 0 .../data_case/test2/data_file | 0 .../data_case/test_hive_doris/data_file | 0 .../preinstalled_data/hdfs_tvf/test_orc.snappy.orc | Bin 0 -> 2538668 bytes .../hdfs_tvf/test_parquet.snappy.parquet | Bin 0 -> 399762 bytes .../json_format_test/multi_line_json.json | 0 .../multi_line_json_lack_column.json | 0 .../json_format_test/multi_line_json_unorder.json | 0 .../json_format_test/nest_json.json | 0 .../json_format_test/one_array_json.json | 0 .../json_format_test/simple_object_json.json | 0 ...0032_9ch4x_5b6acedf-02e6-4b4e-9de2-ae050ddb7c35 | Bin ...0032_9ch4x_f45472a3-a935-4ff7-9340-b977d51ef3a2 | Bin ...0032_9ch4x_e5a56983-f7e1-4b66-8d7d-134cd8a3b5d4 | Bin ...0032_9ch4x_d3313b2c-f4da-468a-b3b0-7627b7dd6398 | Bin ...0032_9ch4x_91eb689b-3053-4630-9f72-7e068afd3302 | Bin ...0032_9ch4x_fbdd6369-e923-47ff-af40-d023687b7d88 | Bin ...0032_9ch4x_02ec7d8c-ecb8-49f4-ad32-6a0fa0915743 | Bin ...0032_9ch4x_311f132e-20d2-4e1a-82c1-c0edbc3e7903 | Bin ...0032_9ch4x_feb65e62-844e-4890-b326-3aa48ceb917f | Bin ...0032_9ch4x_2f09f727-20f2-4e4c-adec-6a624df8c9f5 | Bin ...0032_9ch4x_de0f05f9-2fd4-4bd6-886a-434ac3349ca1 | Bin ...0032_9ch4x_099556fa-095b-4a70-8718-912c59154582 | Bin ...0032_9ch4x_3340eb7c-fb57-4cc4-a3ed-fc55eb2674f9 | Bin ...0032_9ch4x_ef0c50af-d5c4-4375-ad11-106c64ca7903 | Bin ...0032_9ch4x_45fd0f90-ca2f-4f89-832b-5b99395e7081 | Bin ...0032_9ch4x_d7af1778-dd22-4e08-804d-be1e462fca25 | Bin ...0032_9ch4x_78760342-f3b8-415c-aaf5-be7a7ed38b4c | Bin ...0032_9ch4x_bbb15063-ee62-4fd3-9602-3e9ce04f72ef | Bin .../nation=cn/city=beijing/beijing1 | Bin .../nation=cn/city=shanghai/shanghai1 | Bin .../partition_table/nation=jp/city=tokyo/tokyo1 | Bin .../partition_table/nation=rus/city=moscow/moscow1 | Bin .../nation=us/city=chicago/chicago1 | Bin .../nation=us/city=washington/washington1 | Bin .../docker-compose/mysql/init/03-create-table.sql | 30 + .../docker-compose/mysql/init/04-insert.sql | 7 +- .../community/developer-guide/cpp-format-code.md | 12 +- .../en/community/developer-guide/fe-eclipse-dev.md | 2 +- docs/en/docs/admin-manual/config/be-config.md | 6 + docs/en/docs/admin-manual/config/fe-config.md | 11 + .../http-actions/fe/bootstrap-action.md | 4 +- .../admin-manual/http-actions/fe/get-small-file.md | 2 +- .../maint-monitor/metadata-operation.md | 24 +- .../docs/ecosystem/external-table/multi-catalog.md | 2 +- .../docs/install/source-install/compilation-mac.md | 6 +- .../sql-functions/string-functions/convert_to.md | 73 + .../Create/CREATE-CATALOG.md | 4 + .../sql-reference/Show-Statements/SHOW-CATALOGS.md | 18 +- docs/sidebars.json | 1 + .../community/developer-guide/cpp-format-code.md | 14 +- .../community/developer-guide/fe-eclipse-dev.md | 2 +- .../developer-guide/regression-testing.md | 10 +- docs/zh-CN/docs/admin-manual/config/be-config.md | 6 + docs/zh-CN/docs/admin-manual/config/fe-config.md | 11 + .../http-actions/fe/bootstrap-action.md | 4 +- .../admin-manual/http-actions/fe/get-small-file.md | 2 +- .../maint-monitor/metadata-operation.md | 24 +- .../docs/ecosystem/external-table/multi-catalog.md | 2 +- .../docs/install/source-install/compilation-mac.md | 7 +- .../sql-functions/string-functions/convert_to.md | 73 + .../Create/CREATE-CATALOG.md | 4 + .../sql-reference/Show-Statements/SHOW-CATALOGS.md | 31 +- fe/fe-core/src/main/cup/sql_parser.cup | 25 +- .../src/main/java/org/apache/doris/PaloFe.java | 6 + .../apache/doris/alter/SchemaChangeHandler.java | 5 +- .../java/org/apache/doris/analysis/Analyzer.java | 3 + .../org/apache/doris/analysis/ArithmeticExpr.java | 168 +- .../org/apache/doris/analysis/BinaryPredicate.java | 5 + .../doris/analysis/BitmapFilterPredicate.java | 2 +- .../java/org/apache/doris/analysis/CastExpr.java | 11 +- .../apache/doris/analysis/CreateFunctionStmt.java | 12 +- .../apache/doris/analysis/CreatePolicyStmt.java | 5 + .../org/apache/doris/analysis/DecimalLiteral.java | 30 +- .../apache/doris/analysis/DropFunctionStmt.java | 8 +- .../main/java/org/apache/doris/analysis/Expr.java | 38 +- .../org/apache/doris/analysis/FloatLiteral.java | 8 +- .../apache/doris/analysis/FunctionCallExpr.java | 93 +- .../org/apache/doris/analysis/FunctionParams.java | 2 +- .../java/org/apache/doris/analysis/IntLiteral.java | 6 +- .../org/apache/doris/analysis/LargeIntLiteral.java | 6 +- .../java/org/apache/doris/analysis/LoadStmt.java | 9 + .../analysis/ModifyTablePropertiesClause.java | 2 - .../org/apache/doris/analysis/ShowCatalogStmt.java | 22 +- .../apache/doris/analysis/ShowColumnStatsStmt.java | 7 +- .../org/apache/doris/catalog/DataProperty.java | 44 +- .../java/org/apache/doris/catalog/Database.java | 59 +- .../doris/catalog/DynamicPartitionProperty.java | 12 +- .../main/java/org/apache/doris/catalog/Env.java | 10 +- .../java/org/apache/doris/catalog/Function.java | 15 + .../java/org/apache/doris/catalog/FunctionSet.java | 16 +- .../doris/catalog/HiveMetaStoreClientHelper.java | 5 +- .../java/org/apache/doris/catalog/JdbcTable.java | 10 +- .../java/org/apache/doris/catalog/OdbcTable.java | 12 +- .../java/org/apache/doris/catalog/OlapTable.java | 33 +- .../org/apache/doris/catalog/PrimitiveType.java | 1 + .../apache/doris/catalog/RangePartitionInfo.java | 14 + .../java/org/apache/doris/catalog/ScalarType.java | 23 +- .../java/org/apache/doris/catalog/TableIf.java | 4 +- .../org/apache/doris/catalog/TableProperty.java | 18 - .../main/java/org/apache/doris/catalog/Type.java | 3 + .../doris/catalog/external/EsExternalDatabase.java | 10 +- .../doris/catalog/external/EsExternalTable.java | 7 - .../doris/catalog/external/HMSExternalTable.java | 7 - ...rnalDatabase.java => JdbcExternalDatabase.java} | 99 +- .../doris/catalog/external/JdbcExternalTable.java | 89 + .../doris/clone/DynamicPartitionScheduler.java | 4 +- .../main/java/org/apache/doris/common/Config.java | 14 +- .../java/org/apache/doris/common/FeNameFormat.java | 2 +- .../doris/common/proc/PartitionsProcDir.java | 2 +- .../org/apache/doris/common/util/BrokerUtil.java | 3 + .../doris/common/util/DynamicPartitionUtil.java | 16 +- .../apache/doris/common/util/PropertyAnalyzer.java | 79 +- .../java/org/apache/doris/common/util/Util.java | 10 + .../apache/doris/datasource/CatalogFactory.java | 3 + .../org/apache/doris/datasource/CatalogIf.java | 4 + .../org/apache/doris/datasource/CatalogMgr.java | 21 +- .../apache/doris/datasource/EsExternalCatalog.java | 44 +- .../apache/doris/datasource/ExternalCatalog.java | 31 +- .../doris/datasource/ExternalSchemaCache.java | 4 +- .../doris/datasource/HMSExternalCatalog.java | 30 - .../apache/doris/datasource/InitCatalogLog.java | 1 + .../apache/doris/datasource/InitDatabaseLog.java | 1 + .../apache/doris/datasource/InternalCatalog.java | 6 - .../doris/datasource/JdbcExternalCatalog.java | 175 + .../apache/doris/external/hive/util/HiveUtil.java | 3 +- .../org/apache/doris/external/jdbc/JdbcClient.java | 441 ++ .../doris/external/jdbc/JdbcClientException.java | 28 + .../main/java/org/apache/doris/load/ExportJob.java | 3 +- .../apache/doris/load/loadv2/BrokerLoadJob.java | 3 +- .../java/org/apache/doris/load/loadv2/LoadJob.java | 4 + .../apache/doris/load/loadv2/LoadLoadingTask.java | 16 +- .../doris/load/loadv2/LoadingTaskPlanner.java | 11 +- .../doris/load/loadv2/SparkLoadPendingTask.java | 2 +- .../org/apache/doris/monitor/jvm/JvmStats.java | 2 +- .../glue/translator/PhysicalPlanTranslator.java | 6 +- .../jobs/batch/NereidsRewriteJobExecutor.java | 2 + .../org/apache/doris/nereids/rules/RuleType.java | 1 + .../rewrite/logical/PruneOlapScanPartition.java | 2 +- .../rules/rewrite/logical/PruneOlapScanTablet.java | 84 + .../trees/expressions/functions/BoundFunction.java | 2 +- .../visitor/ExpressionColumnFilterConverter.java | 134 + .../trees/plans/logical/LogicalOlapScan.java | 50 +- .../apache/doris/nereids/util/ExpressionUtils.java | 30 + .../doris/planner/HashDistributionPruner.java | 2 +- .../org/apache/doris/planner/HashJoinNode.java | 34 +- .../org/apache/doris/planner/JdbcScanNode.java | 14 + .../org/apache/doris/planner/JoinNodeBase.java | 32 +- .../apache/doris/planner/NestedLoopJoinNode.java | 64 +- .../apache/doris/planner/SingleNodePlanner.java | 13 +- .../apache/doris/planner/TableFunctionNode.java | 2 +- .../doris/planner/external/HiveScanProvider.java | 5 +- .../java/org/apache/doris/qe/ConnectProcessor.java | 2 +- .../java/org/apache/doris/qe/StmtExecutor.java | 2 +- .../doris/rewrite/RewriteInPredicateRule.java | 4 +- .../java/org/apache/doris/alter/AlterTest.java | 17 +- .../analysis/CreateTableAsSelectStmtTest.java | 2 +- .../apache/doris/analysis/DecimalLiteralTest.java | 2 +- .../java/org/apache/doris/analysis/ExprTest.java | 38 + .../org/apache/doris/analysis/QueryStmtTest.java | 2 +- .../apache/doris/analysis/ShowCatalogStmtTest.java | 9 +- .../org/apache/doris/catalog/ColumnTypeTest.java | 6 +- .../apache/doris/catalog/CreateFunctionTest.java | 2 +- .../org/apache/doris/catalog/DataPropertyTest.java | 2 +- .../apache/doris/datasource/CatalogMgrTest.java | 24 + .../doris/load/loadv2/BrokerLoadJobTest.java | 3 +- .../rules/analysis/GenerateScalarFunction.java | 14 +- .../rewrite/logical/PruneOlapScanTabletTest.java | 164 + .../apache/doris/planner/ConstantExpressTest.java | 2 +- .../java/org/apache/doris/policy/PolicyTest.java | 2 + .../doris/rewrite/RewriteDateLiteralRuleTest.java | 8 +- .../java/org/apache/doris/udf/JdbcExecutor.java | 3 - .../org/apache/doris/load/loadv2/dpp/SparkDpp.java | 38 +- gensrc/script/doris_builtins_functions.py | 85 + gensrc/script/gen_builtins_functions.py | 6 + gensrc/thrift/PlanNodes.thrift | 2 + .../test_table_function_with_subquery.out} | 8 +- .../data/datev2/tpcds_sf1_p1/sql/q02.out | 5026 ++++++++++---------- .../data/datev2/tpcds_sf1_p1/sql/q03.out | 22 +- .../data/datev2/tpcds_sf1_p1/sql/q05.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q07.out | 184 +- .../data/datev2/tpcds_sf1_p1/sql/q08.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q09.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q11.out | 1 - .../data/datev2/tpcds_sf1_p1/sql/q12.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q13.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q14_1.out | 14 +- .../data/datev2/tpcds_sf1_p1/sql/q14_2.out | 38 +- .../data/datev2/tpcds_sf1_p1/sql/q15.out | 20 +- .../data/datev2/tpcds_sf1_p1/sql/q18.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q19.out | 26 +- .../data/datev2/tpcds_sf1_p1/sql/q20.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q24_1.out | 8 +- .../data/datev2/tpcds_sf1_p1/sql/q26.out | 178 +- .../data/datev2/tpcds_sf1_p1/sql/q27.out | 180 +- .../data/datev2/tpcds_sf1_p1/sql/q28.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q31.out | 101 +- .../data/datev2/tpcds_sf1_p1/sql/q33.out | 26 +- .../data/datev2/tpcds_sf1_p1/sql/q36.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q39_1.out | 122 +- .../data/datev2/tpcds_sf1_p1/sql/q39_2.out | 8 +- .../data/datev2/tpcds_sf1_p1/sql/q40.out | 98 +- .../data/datev2/tpcds_sf1_p1/sql/q42.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q43.out | 6 +- .../data/datev2/tpcds_sf1_p1/sql/q46.out | 62 +- .../data/datev2/tpcds_sf1_p1/sql/q47.out | 194 +- .../data/datev2/tpcds_sf1_p1/sql/q49.out | 64 +- .../data/datev2/tpcds_sf1_p1/sql/q49_rewrite.out | 65 +- .../data/datev2/tpcds_sf1_p1/sql/q51.out | 40 +- .../data/datev2/tpcds_sf1_p1/sql/q52.out | 14 +- .../data/datev2/tpcds_sf1_p1/sql/q53.out | 164 +- .../data/datev2/tpcds_sf1_p1/sql/q55.out | 30 +- .../data/datev2/tpcds_sf1_p1/sql/q56.out | 46 +- .../data/datev2/tpcds_sf1_p1/sql/q57.out | 190 +- .../data/datev2/tpcds_sf1_p1/sql/q58.out | 6 +- .../data/datev2/tpcds_sf1_p1/sql/q59.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q60.out | 30 +- .../data/datev2/tpcds_sf1_p1/sql/q61.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q63.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q64.out | 20 +- .../data/datev2/tpcds_sf1_p1/sql/q65.out | 48 +- .../data/datev2/tpcds_sf1_p1/sql/q66.out | 10 +- .../data/datev2/tpcds_sf1_p1/sql/q67.out | 58 +- .../data/datev2/tpcds_sf1_p1/sql/q68.out | 54 +- .../data/datev2/tpcds_sf1_p1/sql/q71.out | 558 +-- .../data/datev2/tpcds_sf1_p1/sql/q75.out | 198 +- .../data/datev2/tpcds_sf1_p1/sql/q76.out | 22 +- .../data/datev2/tpcds_sf1_p1/sql/q77.out | 28 +- .../data/datev2/tpcds_sf1_p1/sql/q79.out | 48 +- .../data/datev2/tpcds_sf1_p1/sql/q80.out | 162 +- .../data/datev2/tpcds_sf1_p1/sql/q81.out | 200 +- .../data/datev2/tpcds_sf1_p1/sql/q82.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q83.out | 42 +- .../data/datev2/tpcds_sf1_p1/sql/q85.out | 4 +- .../data/datev2/tpcds_sf1_p1/sql/q86.out | 22 +- .../data/datev2/tpcds_sf1_p1/sql/q89.out | 170 +- .../data/datev2/tpcds_sf1_p1/sql/q90.out | 2 +- .../data/datev2/tpcds_sf1_p1/sql/q98.out | 5018 +++++++++---------- .../sql/q90.out => ddl_p0/test_alias_function.out} | 7 +- .../data/decimalv3/tpch_sf1_p1/sql/q01.out | 7 + .../tpch_sf1 => decimalv3/tpch_sf1_p1}/sql/q02.out | 0 .../data/decimalv3/tpch_sf1_p1/sql/q03.out | 13 + .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q04.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q05.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q06.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q07.out | 0 .../q90.out => decimalv3/tpch_sf1_p1/sql/q08.out} | 5 +- .../data/decimalv3/tpch_sf1_p1/sql/q09.out | 178 + .../data/decimalv3/tpch_sf1_p1/sql/q10.out | 23 + .../data/decimalv3/tpch_sf1_p1/sql/q11.out | 1051 ++++ .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q12.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q13.out | 0 .../q90.out => decimalv3/tpch_sf1_p1/sql/q14.out} | 4 +- .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q15.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q16.out | 0 .../q90.out => decimalv3/tpch_sf1_p1/sql/q17.out} | 4 +- .../data/decimalv3/tpch_sf1_p1/sql/q18.out | 60 + .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q19.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q20.out | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q21.out | 0 .../data/decimalv3/tpch_sf1_p1/sql/q22.out | 10 + .../hive/test_hive_other.out} | 0 .../collect/test_javaudf_groupcount.out} | 6 +- .../collect/test_javaudf_murmurhash3.out} | 6 +- .../collect/test_javaudf_sessionize.out} | 5 +- .../date/test_javaudf_adddays.out} | 6 +- .../date/test_javaudf_addisoperioud.out} | 6 +- .../date/test_javaudf_daydiff.out} | 0 .../json/test_javaudf_convertfromcamelcase.out} | 5 +- .../json/test_javaudf_converttocamelcase.out} | 5 +- .../sanity/test_javaudf_assertequal.out} | 4 +- .../sanity/test_javaudf_assertlessthan.out} | 5 +- .../sanity/test_javaudf_assertudf.out} | 4 +- .../sketch/test_javaudf_md5.out} | 5 +- .../jdbc_catalog_p0/test_mysql_jdbc_catalog.out | 154 + .../data/jsonb_p0/test_jsonb_load_and_function.out | 828 +++- .../data/query_p0/join/test_bitmap_filter.out | 8 + .../query_p0/join/test_nestedloop_outer_join.out | 12 + .../datetime_functions/test_date_function.out | 58 + .../hive_catalog_orc.out} | 0 .../hive_catalog_parquet.out} | 0 .../apache/doris/udf/collect/GroupCountUDF.java | 70 + .../apache/doris/udf/collect/MurmurHash3UDF.java | 105 + .../apache/doris/udf/collect/SessionizeUDF.java | 53 + .../java/org/apache/doris/udf/date/AddDaysUDF.java | 44 + .../org/apache/doris/udf/date/AddISOPeriodUDF.java | 58 + .../java/org/apache/doris/udf/date/DayDiffUDF.java | 54 + .../doris/udf/json/ConvertFromCamelCaseUDF.java | 48 + .../doris/udf/json/ConvertToCamelCaseUDF.java | 53 + .../apache/doris/udf/sanity/AssertEqualsUDF.java | 39 + .../apache/doris/udf/sanity/AssertLessThanUDF.java | 39 + .../org/apache/doris/udf/sanity/AssertUDF.java | 45 + .../main/java/org/apache/doris/udf/sketch/Md5.java | 53 + regression-test/pipeline/p0/conf/be.conf | 1 + regression-test/pipeline/p0/conf/fe.conf | 8 +- regression-test/pipeline/p1/conf/be.conf | 1 + regression-test/pipeline/p1/conf/fe.conf | 7 +- .../cold_heat_separation/policy/alter.groovy | 6 +- .../cold_heat_separation/policy/create.groovy | 5 +- .../suites/cold_heat_separation/policy/drop.groovy | 6 +- .../suites/cold_heat_separation/policy/show.groovy | 6 +- .../use_policy/alter_table_add_policy.groovy | 6 +- .../create_table_use_partition_policy.groovy | 35 +- .../use_policy/create_table_use_policy.groovy | 58 +- .../use_policy/modify_partition_add_policy.groovy | 57 +- .../use_policy/use_default_storage_policy.groovy | 6 +- .../table_valued_function/test_hdfs_tvf.groovy | 30 +- .../test_table_function_with_subquery.groovy | 97 + .../suites/datev2/tpcds_sf1_p1/ddl/call_center.sql | 4 +- .../datev2/tpcds_sf1_p1/ddl/catalog_returns.sql | 18 +- .../datev2/tpcds_sf1_p1/ddl/catalog_sales.sql | 30 +- .../datev2/tpcds_sf1_p1/ddl/customer_address.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/ddl/item.sql | 4 +- .../suites/datev2/tpcds_sf1_p1/ddl/promotion.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/ddl/store.sql | 4 +- .../datev2/tpcds_sf1_p1/ddl/store_returns.sql | 18 +- .../suites/datev2/tpcds_sf1_p1/ddl/store_sales.sql | 24 +- .../suites/datev2/tpcds_sf1_p1/ddl/warehouse.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/ddl/web_returns.sql | 18 +- .../suites/datev2/tpcds_sf1_p1/ddl/web_sales.sql | 30 +- .../suites/datev2/tpcds_sf1_p1/ddl/web_site.sql | 4 +- .../suites/datev2/tpcds_sf1_p1/sql/q01.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q05.sql | 24 +- .../suites/datev2/tpcds_sf1_p1/sql/q06.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q11.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q13.sql | 6 +- .../suites/datev2/tpcds_sf1_p1/sql/q18.sql | 14 +- .../suites/datev2/tpcds_sf1_p1/sql/q21.sql | 4 +- .../suites/datev2/tpcds_sf1_p1/sql/q23_1.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q23_2.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q24_1.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q24_2.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q30.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q31.sql | 4 +- .../suites/datev2/tpcds_sf1_p1/sql/q32.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q34.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q39_2.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q40.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q44.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q47.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q48.sql | 6 +- .../suites/datev2/tpcds_sf1_p1/sql/q49.sql | 12 +- .../suites/datev2/tpcds_sf1_p1/sql/q49_rewrite.sql | 12 +- .../suites/datev2/tpcds_sf1_p1/sql/q53.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q57.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q58.sql | 18 +- .../suites/datev2/tpcds_sf1_p1/sql/q61.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q63.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q65.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q73.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q75.sql | 8 +- .../suites/datev2/tpcds_sf1_p1/sql/q78.sql | 4 +- .../suites/datev2/tpcds_sf1_p1/sql/q81.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q83.sql | 8 +- .../suites/datev2/tpcds_sf1_p1/sql/q85.sql | 6 +- .../suites/datev2/tpcds_sf1_p1/sql/q89.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q90.sql | 2 +- .../suites/datev2/tpcds_sf1_p1/sql/q92.sql | 2 +- .../suites/ddl_p0/test_alias_function.groovy | 27 + regression-test/suites/ddl_p0/test_fnf.groovy | 84 + .../suites/decimalv3/tpch_sf1_p1/ddl/customer.sql | 16 + .../tpch_sf1_p1/ddl/customer_delete.sql | 0 .../suites/decimalv3/tpch_sf1_p1/ddl/lineitem.sql | 24 + .../tpch_sf1_p1/ddl/lineitem_delete.sql | 0 .../tpch_sf1_p1/ddl/nation.sql | 0 .../tpch_sf1_p1/ddl/nation_delete.sql | 0 .../suites/decimalv3/tpch_sf1_p1/ddl/orders.sql | 17 + .../tpch_sf1_p1/ddl/orders_delete.sql | 0 .../suites/decimalv3/tpch_sf1_p1/ddl/part.sql | 17 + .../tpch_sf1_p1/ddl/part_delete.sql | 0 .../suites/decimalv3/tpch_sf1_p1/ddl/partsupp.sql | 13 + .../tpch_sf1_p1/ddl/partsupp_delete.sql | 0 .../tpch_sf1_p1/ddl/region.sql | 0 .../tpch_sf1_p1/ddl/region_delete.sql | 0 .../tpch_sf1_p1/ddl/revenue1.sql | 0 .../tpch_sf1_p1/ddl/revenue1_delete.sql | 0 .../suites/decimalv3/tpch_sf1_p1/ddl/supplier.sql | 14 + .../tpch_sf1_p1/ddl/supplier_delete.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/load.groovy | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q01.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q02.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q03.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q04.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q05.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q06.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q07.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q08.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q09.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q10.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q11.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q12.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q13.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q14.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q15.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q16.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q17.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q18.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q19.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q20.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q21.sql | 0 .../{datev2 => decimalv3}/tpch_sf1_p1/sql/q22.sql | 0 .../hive/test_hive_other.groovy} | 2 +- .../collect/test_javaudf_groupcount.groovy | 58 + .../collect/test_javaudf_murmurhash3.groovy | 58 + .../collect/test_javaudf_sessionize.groovy | 61 + .../javaudf_p0/date/test_javaudf_adddays.groovy | 58 + .../date/test_javaudf_addisoperioud.groovy | 58 + .../javaudf_p0/date/test_javaudf_daydiff.groovy | 59 + .../json/test_javaudf_convertfromcamelcase.groovy | 58 + .../json/test_javaudf_converttocamelcase.groovy | 58 + .../sanity/test_javaudf_assertequal.groovy | 60 + .../sanity/test_javaudf_assertlessthan.groovy | 60 + .../sanity/test_javaudf_assertudf.groovy | 50 + .../javaudf_p0/sketch/test_javaudf_md5.groovy | 58 + .../jdbc_catalog_p0/test_mysql_jdbc_catalog.groovy | 103 + .../suites/jdbc_p0/test_jdbc_query_pg.groovy | 6 +- .../jsonb_p0/test_jsonb_load_and_function.groovy | 90 +- .../load_p0/broker_load/test_broker_load.groovy | 23 +- .../load_p0/stream_load/test_hdfs_json_load.groovy | 12 +- .../suites/query_p0/join/test_bitmap_filter.groovy | 2 + .../join/test_nestedloop_outer_join.groovy | 16 + .../datetime_functions/test_date_function.groovy | 121 + .../suites/statistics/alter_col_stats.groovy | 2 +- .../hive_catalog_orc.groovy} | 5 +- .../hive_catalog_parquet.groovy} | 5 +- run-regression-test.sh | 1 + tools/tpch-tools/ddl/create-tpch-tables.sql | 18 +- 529 files changed, 16352 insertions(+), 9493 deletions(-) create mode 100644 docker/runtime/broker/Dockerfile create mode 100644 docker/runtime/broker/resource/init_broker.sh rename docker/thirdparties/docker-compose/hive/scripts/{create.hql => create_preinstalled_table.hql} (56%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/create_tpch1_orc.hql create mode 100644 docker/thirdparties/docker-compose/hive/scripts/create_tpch1_parquet.hql rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_format_test/all_types.csv (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_format_test/array_malformat.csv (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_format_test/array_normal.csv (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_format_test/student.csv (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_format_test/student_with_names.csv (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_format_test/student_with_names_and_types.csv (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_partition_table/table_with_vertical_line/dt=2022-11-24/1.txt (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_partition_table/table_with_vertical_line/dt=2022-11-25/2.txt (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/csv_partition_table/table_with_x01/dt=2022-11-10/3.txt (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/account_fund/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/hive01/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/lineorder/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/sale_table/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/string_table/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/student/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/t_hive/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/test1/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/test2/data_file (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/data_case/test_hive_doris/data_file (100%) create mode 100644 docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/hdfs_tvf/test_orc.snappy.orc create mode 100644 docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/hdfs_tvf/test_parquet.snappy.parquet rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/json_format_test/multi_line_json.json (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/json_format_test/multi_line_json_lack_column.json (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/json_format_test/multi_line_json_unorder.json (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/json_format_test/nest_json.json (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/json_format_test/one_array_json.json (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/json_format_test/simple_object_json.json (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=desktops/p2_col=bigint_col/20221027_110128_00032_9ch4x_5b6acedf-02e6-4b4e-9de2-ae050ddb7c35 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=desktops/p2_col=boolean_col/20221027_110128_00032_9ch4x_f45472a3-a935-4ff7-9340-b977d51ef3a2 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=desktops/p2_col=float_col/20221027_110128_00032_9ch4x_e5a56983-f7e1-4b66-8d7d-134cd8a3b5d4 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=desktops/p2_col=int_col/20221027_110128_00032_9ch4x_d3313b2c-f4da-468a-b3b0-7627b7dd6398 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=desktops/p2_col=smallint_col/20221027_110128_00032_9ch4x_91eb689b-3053-4630-9f72-7e068afd3302 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=desktops/p2_col=tinyint_col/20221027_110128_00032_9ch4x_fbdd6369-e923-47ff-af40-d023687b7d88 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=phones/p2_col=bigint_col/20221027_110128_00032_9ch4x_02ec7d8c-ecb8-49f4-ad32-6a0fa0915743 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=phones/p2_col=boolean_col/20221027_110128_00032_9ch4x_311f132e-20d2-4e1a-82c1-c0edbc3e7903 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=phones/p2_col=float_col/20221027_110128_00032_9ch4x_feb65e62-844e-4890-b326-3aa48ceb917f (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=phones/p2_col=int_col/20221027_110128_00032_9ch4x_2f09f727-20f2-4e4c-adec-6a624df8c9f5 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=phones/p2_col=smallint_col/20221027_110128_00032_9ch4x_de0f05f9-2fd4-4bd6-886a-434ac3349ca1 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=phones/p2_col=tinyint_col/20221027_110128_00032_9ch4x_099556fa-095b-4a70-8718-912c59154582 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=tablets/p2_col=bigint_col/20221027_110128_00032_9ch4x_3340eb7c-fb57-4cc4-a3ed-fc55eb2674f9 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=tablets/p2_col=boolean_col/20221027_110128_00032_9ch4x_ef0c50af-d5c4-4375-ad11-106c64ca7903 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=tablets/p2_col=float_col/20221027_110128_00032_9ch4x_45fd0f90-ca2f-4f89-832b-5b99395e7081 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=tablets/p2_col=int_col/20221027_110128_00032_9ch4x_d7af1778-dd22-4e08-804d-be1e462fca25 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=tablets/p2_col=smallint_col/20221027_110128_00032_9ch4x_78760342-f3b8-415c-aaf5-be7a7ed38b4c (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/orc/orc_all_types/p1_col=tablets/p2_col=tinyint_col/20221027_110128_00032_9ch4x_bbb15063-ee62-4fd3-9602-3e9ce04f72ef (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/parquet/partition_table/nation=cn/city=beijing/beijing1 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/parquet/partition_table/nation=cn/city=shanghai/shanghai1 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/parquet/partition_table/nation=jp/city=tokyo/tokyo1 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/parquet/partition_table/nation=rus/city=moscow/moscow1 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/parquet/partition_table/nation=us/city=chicago/chicago1 (100%) rename docker/thirdparties/docker-compose/hive/scripts/{ => preinstalled_data}/parquet/partition_table/nation=us/city=washington/washington1 (100%) create mode 100644 docs/en/docs/sql-manual/sql-functions/string-functions/convert_to.md create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/string-functions/convert_to.md copy fe/fe-core/src/main/java/org/apache/doris/catalog/external/{EsExternalDatabase.java => JdbcExternalDatabase.java} (70%) create mode 100644 fe/fe-core/src/main/java/org/apache/doris/catalog/external/JdbcExternalTable.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/datasource/JdbcExternalCatalog.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/external/jdbc/JdbcClient.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/external/jdbc/JdbcClientException.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/logical/PruneOlapScanTablet.java create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/ExpressionColumnFilterConverter.java create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/logical/PruneOlapScanTabletTest.java copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => correctness_p0/test_table_function_with_subquery.out} (71%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => ddl_p0/test_alias_function.out} (76%) create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q01.out copy regression-test/data/{datev2/tpch_sf1_p1/tpch_sf1 => decimalv3/tpch_sf1_p1}/sql/q02.out (100%) create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q03.out copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q04.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q05.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q06.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q07.out (100%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => decimalv3/tpch_sf1_p1/sql/q08.out} (73%) create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q09.out create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q10.out create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q11.out copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q12.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q13.out (100%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => decimalv3/tpch_sf1_p1/sql/q14.out} (80%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q15.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q16.out (100%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => decimalv3/tpch_sf1_p1/sql/q17.out} (80%) create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q18.out copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q19.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q20.out (100%) copy regression-test/data/{datev2 => decimalv3}/tpch_sf1_p1/sql/q21.out (100%) create mode 100644 regression-test/data/decimalv3/tpch_sf1_p1/sql/q22.out rename regression-test/data/{hive_catalog_p0/hive_catalog_case.out => external_catalog_p0/hive/test_hive_other.out} (100%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/collect/test_javaudf_groupcount.out} (80%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/collect/test_javaudf_murmurhash3.out} (67%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q61.out => javaudf_p0/collect/test_javaudf_sessionize.out} (52%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/date/test_javaudf_adddays.out} (70%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/date/test_javaudf_addisoperioud.out} (70%) copy regression-test/data/{correctness_p0/test_union_has_in_predicate.out => javaudf_p0/date/test_javaudf_daydiff.out} (100%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/json/test_javaudf_convertfromcamelcase.out} (67%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/json/test_javaudf_converttocamelcase.out} (70%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/sanity/test_javaudf_assertequal.out} (76%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/sanity/test_javaudf_assertlessthan.out} (69%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q90.out => javaudf_p0/sanity/test_javaudf_assertudf.out} (80%) copy regression-test/data/{datev2/tpcds_sf1_p1/sql/q61.out => javaudf_p0/sketch/test_javaudf_md5.out} (54%) create mode 100644 regression-test/data/jdbc_catalog_p0/test_mysql_jdbc_catalog.out copy regression-test/data/tpch_sf1_p0/{multi_catalog_query_parquet/hive_catalog.out => multi_catalog_query/hive_catalog_orc.out} (100%) rename regression-test/data/tpch_sf1_p0/{multi_catalog_query_parquet/hive_catalog.out => multi_catalog_query/hive_catalog_parquet.out} (100%) create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/collect/GroupCountUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/collect/MurmurHash3UDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/collect/SessionizeUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/date/AddDaysUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/date/AddISOPeriodUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/date/DayDiffUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/json/ConvertFromCamelCaseUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/json/ConvertToCamelCaseUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/sanity/AssertEqualsUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/sanity/AssertLessThanUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/sanity/AssertUDF.java create mode 100644 regression-test/java-udf-src/src/main/java/org/apache/doris/udf/sketch/Md5.java create mode 100644 regression-test/suites/correctness_p0/test_table_function_with_subquery.groovy create mode 100644 regression-test/suites/ddl_p0/test_alias_function.groovy create mode 100644 regression-test/suites/ddl_p0/test_fnf.groovy create mode 100644 regression-test/suites/decimalv3/tpch_sf1_p1/ddl/customer.sql copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/customer_delete.sql (100%) create mode 100644 regression-test/suites/decimalv3/tpch_sf1_p1/ddl/lineitem.sql copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/lineitem_delete.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/nation.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/nation_delete.sql (100%) create mode 100644 regression-test/suites/decimalv3/tpch_sf1_p1/ddl/orders.sql copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/orders_delete.sql (100%) create mode 100644 regression-test/suites/decimalv3/tpch_sf1_p1/ddl/part.sql copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/part_delete.sql (100%) create mode 100644 regression-test/suites/decimalv3/tpch_sf1_p1/ddl/partsupp.sql copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/partsupp_delete.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/region.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/region_delete.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/revenue1.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/revenue1_delete.sql (100%) create mode 100644 regression-test/suites/decimalv3/tpch_sf1_p1/ddl/supplier.sql copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/ddl/supplier_delete.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/load.groovy (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q01.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q02.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q03.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q04.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q05.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q06.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q07.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q08.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q09.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q10.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q11.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q12.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q13.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q14.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q15.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q16.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q17.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q18.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q19.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q20.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q21.sql (100%) copy regression-test/suites/{datev2 => decimalv3}/tpch_sf1_p1/sql/q22.sql (100%) rename regression-test/suites/{hive_catalog_p0/hive_catalog_case.groovy => external_catalog_p0/hive/test_hive_other.groovy} (99%) create mode 100644 regression-test/suites/javaudf_p0/collect/test_javaudf_groupcount.groovy create mode 100644 regression-test/suites/javaudf_p0/collect/test_javaudf_murmurhash3.groovy create mode 100644 regression-test/suites/javaudf_p0/collect/test_javaudf_sessionize.groovy create mode 100644 regression-test/suites/javaudf_p0/date/test_javaudf_adddays.groovy create mode 100644 regression-test/suites/javaudf_p0/date/test_javaudf_addisoperioud.groovy create mode 100644 regression-test/suites/javaudf_p0/date/test_javaudf_daydiff.groovy create mode 100644 regression-test/suites/javaudf_p0/json/test_javaudf_convertfromcamelcase.groovy create mode 100644 regression-test/suites/javaudf_p0/json/test_javaudf_converttocamelcase.groovy create mode 100644 regression-test/suites/javaudf_p0/sanity/test_javaudf_assertequal.groovy create mode 100644 regression-test/suites/javaudf_p0/sanity/test_javaudf_assertlessthan.groovy create mode 100644 regression-test/suites/javaudf_p0/sanity/test_javaudf_assertudf.groovy create mode 100644 regression-test/suites/javaudf_p0/sketch/test_javaudf_md5.groovy create mode 100644 regression-test/suites/jdbc_catalog_p0/test_mysql_jdbc_catalog.groovy copy regression-test/suites/tpch_sf1_p0/{multi_catalog_query_parquet/hive_catalog.groovy => multi_catalog_query/hive_catalog_orc.groovy} (99%) rename regression-test/suites/tpch_sf1_p0/{multi_catalog_query_parquet/hive_catalog.groovy => multi_catalog_query/hive_catalog_parquet.groovy} (99%) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org