This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch sc_retry_net
in repository https://gitbox.apache.org/repos/asf/doris.git
discard b0e1ffafe0c fix
discard 515d42b47f5 fix review
discard ed9b31ba921 [fix](sc) retry on network error
omit 6bfb02b3552 [fix](case) check task info message less strict
add a1de4cdbc8a [Chore](nereids) Remove CreateFunctionStmt (#54096)
add 908f0209524 [Enhancement] support table comment for mysql jdbc catalog
(#54088)
add 76d5d0d77ba [regression-test](variant) add
disable_variant_flatten_nested session var conf in nest table test case
(#54335)
add 65ee1b6b6e4 [fix](constant propagation) don't extract constant
relation for null aware anti join (#54128)
add 97bceb37155 [fix](tokenize) fix output for tokenize when parser is
none (#54224)
add 744d3ff19ac [refine](cast) Remove the rollback logic from parsing
complex types. (#54314)
add f4683f39a27 [feat](Variant) add column property for variant and multi
indexes (#54269)
add 0efd0607511 [feat](Variant) Add Schema Templates Syntax and Parsing
(#54293)
add af92f108988 [fix](test) fix test_routine_load_job_schedule unstable
(#54341)
add d54ef27bc22 [Fix](mow) Should use rowset's schema when calculate
delete bitmaps between segments (#54351)
add 40b94231b63 [fix](array) Fix array distance functions (#54348)
add d3833e4d206 [fix](test) Force meta sync to avoid stale meta data on
follower fe when mv rewrite (#54296)
add c3fcc413750 [feat](cloud) Write and recycle commit_index and
drop_index log (#53796)
add ae7c54126a2 [fix](case) remove global variable declarations in
compaction test [f… (#54360)
add 512a50751c1 [Chore](nereids) Remove DropRepositoryStmt (#53420)
add 66f10bf37dd [Chore](nereids) Remove ShowColumnStatsStmt (#54378)
add 2e7d57a10f4 [Chore](nereids) Remove AlterColocateGroupStmt (#54383)
add b604a2a3685 [feature](cast)Implement complex type cast. (#54347)
add 97bb87d3e1e [fix](case) check task info message less strict (#54362)
add b01c5f6d478 [refactor](nereids)allow use 'mv_' as column's prefix name
(#54025)
add 674e2c21cfe [fix](compile) Compile failed on arm due to no member
named 'fallback' in namespace 'simdjson' (#54308)
add b0faa609d52 [fix](mow) fix check delete bitmap for mow tables with seq
column (#51763)
add 11ff81dc9c5 [refine](cast) Delete the useless code in function cast
(#54408)
add 7ebe2b30e61 [fix](nereids) fix bug in
StatsCalculator.disableJoinReorderIfStatsInvalid when rowCount is not aviable
(#53834)
add 7a8297318d3 [Chore](nereids) Remove CreateCatalogStmt (#54389)
add 0d6d6d82473 [Chore](nereids) Remove ShowCreateMTMVStmt (#54380)
add 533a117aa4f [fix](filecache) warm up download data less than actual
(#54363)
add bf1cfe0e83d [Fix](cast) fix wrong cast from string to datetime and add
cases (#54357)
add 0447daa52ee [Chore](nereids) Remove DropFunctionStmt (#54381)
add 79c31d224a5 [Bug](ipv6) fix fe can't parse ipv4-mapped type to ipv6
(#54391)
add 39a6660076b [metrics](warmup) add some metrics for warmup jobs (#52991)
add 6951299e0f6 [fix](vcg) use "vcg cancel" as cancel message for warm up
jobs (#53751)
add 3f685619079 [chore](agg) Reduce template parameters to avoid template
instantiation bloat (#54336)
add 6b19a44c6cc [fix](test) make test_writer_fault_injection do not
affected by other cases (#54369)
add 5a6df4eda70 [fix](case) remove global variable declarations in load
(#54418)
add 6291f3fe057 [fix](variant) change session var for
disable_variant_flatten_nested to enable_variant_flatten_nested (#54413)
add 7ab11dc7e3e [Chore](nereids) remove AlterWorkloadGroupStmt (#54387)
add bf1894771e9 [Chore](nereids) remove CreateWorkloadSchedPolicyStmt
(#54388)
add c022fa93b35 [feat](Variant) support variant sparse feature and schema
template with multi indexes (part 6) (#54358)
add 1aa560c7456 [fix](constant propagation) don't rewrite mark join
condition (#54423)
add bf8079d19ae [fix](statistics)Fix drop expired stats. (#54424)
add a43e85a58c9 [fix](txn lazy commit) fix multi table load error with txn
lazy commit (#54322)
add f2649c464ce [Chore](agg) adjust corr/corvar series function symbols
and some other change (#54376)
add 6045cebe790 [opt](mtmv) Should not mv rewrite when point query short
circuit (#54187)
add f1e4e66d0c1 [feature](nereids) support explain command return empty
string to test planner performance (#54422)
add 8376177f07e [feature](bm25) add inverted index bm25 score (#53980)
add 290dc2a05ed [opt](warm up) support delaying compaction commit until
rowset warm-up finishes (#54416)
add 84d74d3e8fc [fix](sc) retry on network error
add c30ddf4ea43 fix review
add fe33e2e0fca fix
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 (b0e1ffafe0c)
\
N -- N -- N refs/heads/sc_retry_net (fe33e2e0fca)
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:
.../cloud/cloud_engine_calc_delete_bitmap_task.cpp | 4 +-
be/src/cloud/cloud_internal_service.cpp | 38 +-
be/src/cloud/cloud_meta_mgr.cpp | 19 +-
be/src/cloud/cloud_warm_up_manager.cpp | 51 +-
be/src/cloud/cloud_warm_up_manager.h | 10 +-
be/src/cloud/config.cpp | 6 +
be/src/cloud/config.h | 11 +
be/src/common/consts.h | 1 +
be/src/index-tools/index_tool.cpp | 15 +-
be/src/io/cache/block_file_cache_downloader.cpp | 9 +-
be/src/io/fs/s3_file_reader.cpp | 9 +
be/src/olap/base_tablet.cpp | 34 +-
be/src/olap/base_tablet.h | 3 +-
be/src/olap/calc_delete_bitmap_executor.cpp | 6 +-
be/src/olap/calc_delete_bitmap_executor.h | 2 +-
be/src/olap/collection_similarity.cpp | 115 ++
be/src/olap/collection_similarity.h | 55 +
be/src/olap/collection_statistics.cpp | 241 +++
be/src/olap/collection_statistics.h | 92 +
be/src/olap/compaction.cpp | 3 +-
be/src/olap/iterators.h | 4 +
be/src/olap/rowset/beta_rowset_reader.cpp | 2 +
be/src/olap/rowset/rowset.h | 4 +-
be/src/olap/rowset/rowset_meta.h | 2 +-
be/src/olap/rowset/rowset_reader_context.h | 4 +
be/src/olap/rowset/segcompaction.cpp | 4 +-
be/src/olap/rowset/segment_v2/column_reader.cpp | 10 +-
be/src/olap/rowset/segment_v2/column_reader.h | 18 +-
be/src/olap/rowset/segment_v2/column_writer.cpp | 29 +-
be/src/olap/rowset/segment_v2/column_writer.h | 6 +-
.../olap/rowset/segment_v2/index_file_reader.cpp | 12 +-
be/src/olap/rowset/segment_v2/index_file_reader.h | 16 +-
.../olap/rowset/segment_v2/index_file_writer.cpp | 2 +-
be/src/olap/rowset/segment_v2/index_iterator.h | 15 +-
.../term_query.cpp => index_query_context.h} | 29 +-
be/src/olap/rowset/segment_v2/index_reader.h | 12 +-
.../olap/rowset/segment_v2/index_reader_helper.h | 67 +
be/src/olap/rowset/segment_v2/index_writer.cpp | 124 ++
.../{inverted_index_writer.h => index_writer.h} | 15 +-
.../inverted_index/analyzer/analyzer.cpp | 8 +-
.../inverted_index/query/conjunction_query.cpp | 95 +-
.../inverted_index/query/conjunction_query.h | 20 +-
.../inverted_index/query/disjunction_query.cpp | 78 +-
.../inverted_index/query/disjunction_query.h | 15 +-
.../inverted_index/query/phrase_edge_query.cpp | 13 +-
.../inverted_index/query/phrase_edge_query.h | 7 +-
.../inverted_index/query/phrase_prefix_query.cpp | 16 +-
.../inverted_index/query/phrase_prefix_query.h | 6 +-
.../inverted_index/query/phrase_query.cpp | 113 +-
.../segment_v2/inverted_index/query/phrase_query.h | 23 +-
.../inverted_index/query/prefix_query.cpp | 12 +-
.../segment_v2/inverted_index/query/prefix_query.h | 7 +-
.../rowset/segment_v2/inverted_index/query/query.h | 7 +
.../inverted_index/query/query_helper.cpp | 73 +
.../query/{prefix_query.h => query_helper.h} | 35 +-
.../segment_v2/inverted_index/query/query_info.h | 10 +-
.../inverted_index/query/regexp_query.cpp | 16 +-
.../segment_v2/inverted_index/query/regexp_query.h | 7 +-
.../segment_v2/inverted_index/query/term_query.cpp | 64 +
.../query/{disjunction_query.h => term_query.h} | 21 +-
.../inverted_index/query_v2/term_query.cpp | 2 +-
.../inverted_index/similarity/bm25_similarity.cpp | 122 ++
.../inverted_index/similarity/bm25_similarity.h | 68 +
.../similarity.h} | 29 +-
.../segment_v2/inverted_index/util/mock_iterator.h | 56 +-
.../term_query.cpp => util/string_helper.h} | 27 +-
.../segment_v2/inverted_index/util/term_iterator.h | 50 +-
.../inverted_index/util/term_position_iterator.h | 20 +-
.../olap/rowset/segment_v2/inverted_index_common.h | 5 +
.../segment_v2/inverted_index_compaction.cpp | 12 +-
.../rowset/segment_v2/inverted_index_compaction.h | 13 +-
.../rowset/segment_v2/inverted_index_iterator.cpp | 39 +-
.../rowset/segment_v2/inverted_index_iterator.h | 9 +-
.../rowset/segment_v2/inverted_index_reader.cpp | 255 ++-
.../olap/rowset/segment_v2/inverted_index_reader.h | 104 +-
.../rowset/segment_v2/inverted_index_searcher.cpp | 5 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 1317 ++++++-------
.../olap/rowset/segment_v2/inverted_index_writer.h | 147 +-
be/src/olap/rowset/segment_v2/segment.cpp | 3 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 60 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 7 +
.../variant/variant_column_writer_impl.cpp | 15 +-
.../rowset/segment_v2/variant_stats_calculator.cpp | 3 +-
be/src/olap/rowset_builder.cpp | 8 +-
be/src/olap/tablet_meta.cpp | 19 +
be/src/olap/tablet_reader.cpp | 2 +
be/src/olap/tablet_reader.h | 3 +
be/src/olap/tablet_schema.cpp | 239 ++-
be/src/olap/tablet_schema.h | 86 +-
be/src/olap/task/index_builder.cpp | 6 +-
be/src/olap/task/index_builder.h | 7 +-
be/src/olap/txn_manager.cpp | 3 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 16 +
be/src/pipeline/exec/operator.h | 5 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 5 +-
be/src/service/backend_service.cpp | 4 +-
be/src/util/jsonb_parser_simd.h | 6 +-
be/src/util/string_parser.hpp | 1 +
.../aggregate_function_approx_top_k.cpp | 6 +-
.../aggregate_function_approx_top_sum.cpp | 11 +-
.../aggregate_function_collect.cpp | 5 +-
.../aggregate_function_corr.cpp | 19 +-
.../aggregate_functions/aggregate_function_corr.h | 1 +
.../aggregate_function_count.cpp | 4 +-
.../aggregate_function_count_by_enum.cpp | 8 +-
.../aggregate_function_covar.cpp | 4 +-
.../aggregate_function_group_array_intersect.cpp | 2 +-
.../aggregate_function_min_max.cpp | 2 +-
.../aggregate_functions/aggregate_function_null.h | 99 +-
be/src/vec/aggregate_functions/factory_helpers.h | 34 +-
be/src/vec/aggregate_functions/helpers.h | 40 +-
be/src/vec/common/schema_util.cpp | 876 +++++----
be/src/vec/common/schema_util.h | 122 +-
.../serde/data_type_date_or_datetime_serde.cpp | 30 +-
.../serde/data_type_date_or_datetime_serde.h | 2 +
.../serde/data_type_datetimev2_serde.cpp | 30 +-
.../data_types/serde/data_type_datev2_serde.cpp | 29 +-
.../data_types/serde/data_type_nullable_serde.cpp | 6 +-
.../data_types/serde/data_type_struct_serde.cpp | 9 +-
.../vec/data_types/serde/data_type_time_serde.cpp | 29 +-
be/src/vec/exec/scan/olap_scanner.cpp | 61 +-
be/src/vec/exec/scan/olap_scanner.h | 1 +
be/src/vec/exprs/score_runtime.h | 64 +
be/src/vec/exprs/vexpr.h | 2 +-
be/src/vec/exprs/vexpr_context.h | 1 -
be/src/vec/exprs/vliteral.h | 2 +-
be/src/vec/exprs/vslot_ref.h | 2 +
.../vec/functions/array/function_array_distance.h | 20 +-
be/src/vec/functions/array/function_array_index.h | 4 +-
.../vec/functions/array/function_arrays_overlap.h | 2 +-
be/src/vec/functions/cast/cast_base.cpp | 11 -
be/src/vec/functions/cast/cast_base.h | 6 +-
.../vec/functions/cast/cast_to_datetimev2_impl.hpp | 7 +-
be/src/vec/functions/cast/cast_to_datev2_impl.hpp | 8 +-
be/src/vec/functions/cast/cast_to_time_impl.hpp | 93 +-
be/src/vec/functions/cast/cast_to_variant.h | 2 +-
be/src/vec/functions/cast/function_cast.cpp | 149 +-
be/src/vec/functions/function_ip.h | 3 +-
be/src/vec/functions/function_score.cpp | 74 +
be/src/vec/functions/function_tokenize.cpp | 42 +
be/src/vec/functions/function_tokenize.h | 6 +-
be/src/vec/functions/functions_comparison.h | 7 +-
be/src/vec/functions/in.h | 4 +-
be/src/vec/functions/match.cpp | 4 +-
be/src/vec/functions/simple_function_factory.h | 2 +
be/src/vec/json/path_in_data.cpp | 7 +-
be/src/vec/json/path_in_data.h | 7 +-
be/test/common/schema_util_test.cpp | 432 -----
be/test/olap/collection_similarity_test.cpp | 190 ++
be/test/olap/collection_statistics_test.cpp | 545 ++++++
.../rowset/segment_v2/index_reader_helper_test.cpp | 371 ++++
.../compaction/index_compaction_test.cpp | 6 +-
.../compaction/util/index_compaction_utils.cpp | 40 +-
.../query/conjunction_query_test.cpp | 142 ++
.../query/disjunction_query_test.cpp | 117 ++
.../query/phrase_edge_query_test.cpp | 58 +-
.../query/phrase_prefix_query_test.cpp | 56 +-
.../inverted_index/query/phrase_query_test.cpp | 64 +-
.../inverted_index/query/query_helper_test.cpp | 273 +++
.../inverted_index/query/regexp_query_test.cpp | 98 +-
.../similarity/bm25_similarity_test.cpp | 265 +++
.../inverted_index/string_helper_test.cpp | 157 ++
.../segment_v2/inverted_index_array_test.cpp | 42 +-
.../segment_v2/inverted_index_file_writer_test.cpp | 7 -
.../segment_v2/inverted_index_reader_test.cpp | 344 ++--
.../segment_v2/inverted_index_writer_test.cpp | 115 +-
be/test/olap/tablet_schema_index_test.cpp | 101 +
be/test/olap/tablet_schema_test.cpp | 854 +++++++++
be/test/vec/common/schema_util_rowset_test.cpp | 635 +++++++
be/test/vec/common/schema_util_test.cpp | 1926 ++++++++++++++++++++
be/test/vec/function/cast/cast_test.h | 89 +-
be/test/vec/function/cast/cast_to_date_test.cpp | 198 +-
.../vec/function/cast/cast_to_datetime_test.cpp | 199 +-
be/test/vec/function/cast/cast_to_time_test.cpp | 94 +-
be/test/vec/function/function_is_null_test.cpp | 16 +-
be/test/vec/function/function_test_util.h | 8 +-
be/test/vec/function/function_tokenize_test.cpp | 220 +++
be/test/vec/jsonb/path_in_data_test.cpp | 250 +++
cloud/src/meta-service/meta_service_partition.cpp | 83 +-
cloud/src/meta-service/meta_service_txn.cpp | 1 +
cloud/src/meta-service/txn_lazy_committer.cpp | 9 +-
cloud/src/recycler/checker.cpp | 20 +-
cloud/src/recycler/checker.h | 5 +-
cloud/src/recycler/recycler.cpp | 23 +
cloud/src/recycler/recycler_operation_log.cpp | 34 +-
cloud/test/meta_service_operation_log_test.cpp | 341 +++-
cloud/test/recycler_operation_log_test.cpp | 174 ++
cloud/test/recycler_test.cpp | 23 +-
cloud/test/txn_lazy_commit_test.cpp | 89 +
contrib/clucene | 2 +-
.../docker-compose/mysql/init/03-create-table.sql | 7 +
.../java/org/apache/doris/catalog/ScalarType.java | 40 +-
.../main/java/org/apache/doris/catalog/Type.java | 28 +-
.../org/apache/doris/catalog/VariantField.java | 135 ++
.../java/org/apache/doris/catalog/VariantType.java | 165 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 2 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 20 +
fe/fe-core/src/main/cup/sql_parser.cup | 58 +-
.../doris/alter/MaterializedViewHandler.java | 36 +-
.../doris/analysis/AlterColocateGroupStmt.java | 87 -
.../doris/analysis/AlterWorkloadGroupStmt.java | 86 -
.../java/org/apache/doris/analysis/CastExpr.java | 2 -
.../apache/doris/analysis/CreateCatalogStmt.java | 129 --
.../apache/doris/analysis/CreateFunctionStmt.java | 833 ---------
.../analysis/CreateWorkloadSchedPolicyStmt.java | 130 --
.../apache/doris/analysis/DropFunctionStmt.java | 97 -
.../apache/doris/analysis/DropRepositoryStmt.java | 61 -
.../org/apache/doris/analysis/IPv6Literal.java | 6 +-
.../org/apache/doris/analysis/MVColumnItem.java | 68 +-
.../apache/doris/analysis/ShowColumnStatsStmt.java | 285 ---
.../apache/doris/analysis/ShowCreateMTMVStmt.java | 95 -
.../org/apache/doris/backup/BackupHandler.java | 8 +-
.../apache/doris/catalog/AggregateFunction.java | 22 +-
.../doris/catalog/BuiltinScalarFunctions.java | 2 +
.../apache/doris/catalog/ColocateTableIndex.java | 62 -
.../main/java/org/apache/doris/catalog/Column.java | 92 +-
.../main/java/org/apache/doris/catalog/Env.java | 57 +-
.../main/java/org/apache/doris/catalog/Index.java | 15 +-
.../doris/catalog/MaterializedIndexMeta.java | 90 +-
.../java/org/apache/doris/catalog/OlapTable.java | 8 +-
.../org/apache/doris/catalog/ScalarFunction.java | 8 +-
.../java/org/apache/doris/catalog/TableIf.java | 2 +-
.../apache/doris/cloud/CacheHotspotManager.java | 6 +-
.../java/org/apache/doris/common/FeNameFormat.java | 3 -
.../apache/doris/common/util/PropertyAnalyzer.java | 38 +
.../apache/doris/datasource/CatalogFactory.java | 10 -
.../org/apache/doris/datasource/CatalogMgr.java | 10 -
.../apache/doris/datasource/InternalCatalog.java | 12 +-
.../doris/datasource/jdbc/JdbcExternalCatalog.java | 4 +
.../doris/datasource/jdbc/JdbcExternalTable.java | 16 +
.../doris/datasource/jdbc/client/JdbcClient.java | 7 +
.../datasource/jdbc/client/JdbcMySQLClient.java | 24 +
.../main/java/org/apache/doris/load/DeleteJob.java | 17 +-
.../apache/doris/load/loadv2/IngestionLoadJob.java | 8 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 5 +-
.../glue/translator/PhysicalPlanTranslator.java | 20 +
.../doris/nereids/jobs/executor/Rewriter.java | 6 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 70 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +
.../mv/InitMaterializationContextHook.java | 5 +
.../nereids/rules/expression/check/CheckCast.java | 100 +-
.../expression/rules/FoldConstantRuleOnBE.java | 7 +
.../LogicalOlapScanToPhysicalOlapScan.java | 9 +-
.../nereids/rules/rewrite/CheckScoreUsage.java | 74 +
.../nereids/rules/rewrite/ConstantPropagation.java | 29 +-
.../doris/nereids/rules/rewrite/InitJoinOrder.java | 45 +-
.../nereids/rules/rewrite/PruneOlapScanTablet.java | 9 +-
.../rewrite/PushDownScoreTopNIntoOlapScan.java | 180 ++
.../rules/rewrite/UnequalPredicateInfer.java | 2 +-
.../rules/rewrite/VariantSubPathPruning.java | 2 +-
.../doris/nereids/stats/StatsCalculator.java | 8 +-
.../trees/expressions/functions/agg/Corr.java | 16 +-
.../expressions/functions/agg/CorrWelford.java | 4 +-
.../trees/expressions/functions/agg/Covar.java | 16 +-
.../trees/expressions/functions/agg/CovarSamp.java | 16 +-
.../functions/generator/ExplodeVariantArray.java | 4 +-
.../functions/scalar/CosineDistance.java | 5 +-
.../expressions/functions/scalar/ElementAt.java | 4 +-
.../expressions/functions/scalar/InnerProduct.java | 5 +-
.../expressions/functions/scalar/L1Distance.java | 5 +-
.../expressions/functions/scalar/L2Distance.java | 5 +-
.../scalar/{L1Distance.java => Score.java} | 44 +-
.../trees/expressions/literal/IPv6Literal.java | 22 +-
.../trees/expressions/literal/JsonLiteral.java | 10 +
.../expressions/visitor/ScalarFunctionVisitor.java | 5 +
.../plans/commands/CreateFunctionCommand.java | 50 +-
.../commands/CreateMaterializedViewCommand.java | 30 +-
.../trees/plans/commands/DeleteFromCommand.java | 6 +-
.../trees/plans/logical/LogicalOlapScan.java | 59 +-
.../physical/PhysicalLazyMaterializeOlapScan.java | 4 +-
.../trees/plans/physical/PhysicalOlapScan.java | 41 +-
.../org/apache/doris/nereids/types/DataType.java | 29 +-
.../apache/doris/nereids/types/VariantField.java | 122 ++
.../apache/doris/nereids/types/VariantType.java | 105 +-
.../doris/planner/HashDistributionPruner.java | 28 +-
.../org/apache/doris/planner/OlapScanNode.java | 38 +-
.../java/org/apache/doris/planner/Planner.java | 5 +
.../main/java/org/apache/doris/qe/DdlExecutor.java | 23 +-
.../java/org/apache/doris/qe/SessionVariable.java | 62 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 50 -
.../resource/workloadgroup/WorkloadGroupMgr.java | 5 -
.../WorkloadSchedPolicyMgr.java | 11 -
.../apache/doris/statistics/OlapAnalysisTask.java | 12 +-
.../apache/doris/statistics/StatisticsCleaner.java | 8 +-
.../doris/statistics/util/StatisticsUtil.java | 7 +-
.../main/java/org/apache/doris/task/PushTask.java | 25 +-
.../org/apache/doris/alter/AlterJobV2Test.java | 10 +-
.../doris/alter/MaterializedViewHandlerTest.java | 4 +-
.../org/apache/doris/backup/BackupHandlerTest.java | 3 +-
.../java/org/apache/doris/catalog/ColumnTest.java | 20 +
.../org/apache/doris/catalog/RefreshDbTest.java | 15 +-
.../org/apache/doris/catalog/RefreshTableTest.java | 14 +-
.../org/apache/doris/common/FeNameFormatTest.java | 4 +-
.../apache/doris/datasource/ColumnPrivTest.java | 54 +-
.../doris/datasource/ExternalCatalogTest.java | 80 +-
.../doris/datasource/RefreshCatalogTest.java | 35 +-
.../datasource/hive/HiveDDLAndDMLPlanTest.java | 13 +-
.../datasource/iceberg/CreateIcebergTableTest.java | 6 +-
...bleNameComparedLowercaseMetaCacheFalseTest.java | 24 +-
...ableNameComparedLowercaseMetaCacheTrueTest.java | 24 +-
...TableNameStoredLowercaseMetaCacheFalseTest.java | 24 +-
...lTableNameStoredLowercaseMetaCacheTrueTest.java | 24 +-
.../datasource/property/PropertyConverterTest.java | 121 +-
.../apache/doris/external/hms/HmsCatalogTest.java | 18 +-
.../translator/PhysicalPlanTranslatorTest.java | 2 +-
.../mv/PointQueryShouldNotMvRewriteTest.java | 90 +
.../postprocess/MergeProjectPostProcessTest.java | 2 +-
.../PushDownFilterThroughProjectTest.java | 5 +-
.../rules/expression/check/CheckCastTest.java | 833 +++++++++
.../doris/nereids/trees/expressions/CastTest.java | 23 +
.../trees/expressions/literal/IPV6LiteralTest.java | 43 +
.../trees/plans/ExplainInsertCommandTest.java | 29 +-
.../doris/nereids/trees/plans/PlanEqualsTest.java | 6 +-
.../org/apache/doris/persist/ScalarTypeTest.java | 40 +
.../doris/planner/HashDistributionPrunerTest.java | 3 +-
.../org/apache/doris/planner/OlapScanNodeTest.java | 2 +
.../org/apache/doris/qe/HmsQueryCacheTest.java | 17 +-
.../apache/doris/statistics/MVStatisticsTest.java | 2 +-
.../doris/statistics/OlapAnalysisTaskTest.java | 4 +-
.../apache/doris/utframe/TestWithFeService.java | 9 +-
gensrc/proto/cloud.proto | 18 +-
gensrc/proto/internal_service.proto | 1 +
gensrc/thrift/PlanNodes.thrift | 2 +
regression-test/data/cast_p0/cast_to_datetime.out | Bin 5741 -> 5783 bytes
...compaction_agg_and_remove_pre_delete_bitmap.out | Bin 257 -> 358 bytes
.../data/datatype_p0/ip/test_ip_crud.out | Bin 1367 -> 1763 bytes
.../test_create_view_nereids.out | Bin 18250 -> 18763 bytes
.../test_mow_alter_seq_multi_segments.out} | Bin 235 -> 154 bytes
.../data/inverted_index_p0/test_bm25_score.out | Bin 0 -> 1378 bytes
.../data/mv_p0/varchar_length/varchar_length.out | Bin 372 -> 356 bytes
.../nereids_function_p0/scalar_function/Array1.out | Bin 33278821 -> 33278945
bytes
.../invalid_stats/invalid_stats_join_order.out | Bin 0 -> 587 bytes
.../agg_skew_rewrite/agg_skew_rewrite.out | Bin 7895 -> 7894 bytes
.../constant_propagation/constant_propagation.out | Bin 18315 -> 21556 bytes
.../data/nereids_syntax_p0/rollup/hll/hll.out | Bin 600 -> 545 bytes
.../rollup/hll_with_light_sc/hll_with_light_sc.out | Bin 615 -> 560 bytes
.../query_p0/aggregate/support_type/corr/corr.out | Bin 0 -> 177 bytes
.../support_type/corr_welford/corr_welford.out | Bin 0 -> 193 bytes
.../aggregate/support_type/count/count.out | Bin 0 -> 197 bytes
.../support_type/count_by_enum/count_by_enum.out | Bin 0 -> 231771 bytes
.../aggregate/support_type/covar/covar.out | Bin 0 -> 178 bytes
.../support_type/covar_samp/covar_samp.out | Bin 0 -> 174 bytes
.../show/test_show_create_materialized_view.out | Bin 373 -> 385 bytes
.../test_array_distance_functions.out | Bin 235 -> 654 bytes
.../data/rollup/test_materialized_view_hll.out | Bin 599 -> 544 bytes
.../test_materialized_view_hll_with_light_sc.out | Bin 614 -> 559 bytes
.../data/rollup_p0/test_materialized_view.out | Bin 1762 -> 1620 bytes
.../schema_change_modify_mv_column_type_agg.out | Bin 1365 -> 1350 bytes
.../schema_change_modify_mv_column_type.out | Bin 7285 -> 7123 bytes
.../schema_change_modify_mv_column_type2.out | Bin 6353 -> 6307 bytes
.../variant_p0/predefine/test_predefine_ddl.out | Bin 0 -> 313 bytes
.../org/apache/doris/regression/suite/Suite.groovy | 31 +
.../suites/auth_call/test_ddl_mv_auth.groovy | 6 +-
.../test_backup_restore_colocate.groovy | 4 +-
.../backup_restore/test_backup_restore_mv.groovy | 2 +-
.../test_backup_restore_mv_write.groovy | 10 +-
.../recover_with_schema_change.groovy | 6 +-
...rm_up_cluster_event_compaction_sync_wait.groovy | 375 ++++
...uster_event_compaction_sync_wait_timeout.groovy | 377 ++++
.../test_schema_change_with_compaction1.groovy | 1 +
.../test_schema_change_with_compaction10.groovy | 3 +-
.../test_schema_change_with_compaction11.groovy | 2 +-
.../test_schema_change_with_compaction2.groovy | 1 +
.../test_schema_change_with_compaction3.groovy | 5 +-
.../test_schema_change_with_compaction4.groovy | 5 +-
.../test_schema_change_with_compaction5.groovy | 5 +-
.../test_schema_change_with_compaction6.groovy | 5 +-
.../test_schema_change_with_compaction7.groovy | 5 +-
.../test_schema_change_with_compaction8.groovy | 1 +
.../test_schema_change_with_compaction9.groovy | 5 +-
...paction_agg_and_remove_pre_delete_bitmap.groovy | 70 +
.../correctness/test_mv_alias_table_name.groovy | 2 +-
.../test_ctas_mv/test_ctas_mv.groovy | 2 +-
.../test_inlineview_with_window_function.groovy | 2 +-
.../test_mv_case/test_mv_case.groovy | 4 +-
.../suites/datatype_p0/ip/test_ip_crud.groovy | 30 +
.../create_view_nereids/create_view_use_mv.groovy | 42 +-
.../test_create_view_nereids.groovy | 19 +-
.../test_generated_column_nereids.groovy | 2 +-
.../suites/ddl_p0/test_drop_view_nereids.groovy | 26 +-
.../delete_p0/test_delete_with_sync_mv.groovy | 2 +-
.../test_mysql_jdbc_catalog_table_comment.groovy | 121 ++
.../test_disable_move_memtable.groovy | 2 +-
.../test_index_bkd_writer_fault_injection.groovy | 6 +-
.../test_inverted_index_v3_fault_injection.groovy | 12 +-
.../test_mow_alter_seq_multi_segments.groovy | 94 +
...inverted_index_exception_fault_injection.groovy | 22 +-
.../test_writer_fault_injection.groovy | 8 +-
.../insert_p0/insert_group_commit_into.groovy | 2 +-
.../suites/insert_p0/transaction/txn_insert.groovy | 4 +-
.../test_add_drop_index_on_table_with_mv.groovy | 4 +-
.../inverted_index_p0/test_bm25_score.groovy | 172 ++
.../suites/javaudf_p0/test_javaudf_float.groovy | 2 +-
.../test_insert_with_aggregation_memtable.groovy | 2 +-
.../test_routine_load_job_schedule.groovy | 6 +-
.../load_p0/stream_load/test_json_load.groovy | 2 +-
.../suites/mtmv_p0/test_create_mv_mtmv.groovy | 2 +-
.../agg_have_dup_base/agg_have_dup_base.groovy | 2 +-
.../suites/mv_p0/agg_no_group/agg_no_group.groovy | 2 +-
.../diffrent_serialize/diffrent_serialize.groovy | 16 +-
.../mv_p0/agg_state/order_by/order_by.groovy | 2 +-
.../mv_p0/agg_state/test_agg_state_max_by.groovy | 16 +-
.../agg_use_key_direct/agg_use_key_direct.groovy | 2 +-
regression-test/suites/mv_p0/await/await.groovy | 36 +-
.../suites/mv_p0/case_ignore/case_ignore.groovy | 2 +-
.../mv_p0/contain_cast/mv_contains_cast.groovy | 10 +-
.../suites/mv_p0/count_star/count_star.groovy | 2 +-
.../suites/mv_p0/group_check/group_check.groovy | 8 +-
.../suites/mv_p0/join/rollback1/rollback1.groovy | 2 +-
regression-test/suites/mv_p0/k1s2m3/k1s2m3.groovy | 48 +-
.../mv_p0/k1s2m3_auto_inc/k1s2m3_auto_inc.groovy | 4 +-
.../multi_agg_with_same_slot.groovy | 4 +-
.../mv_p0/multi_slot_k123p/multi_slot_k123p.groovy | 2 +-
.../multi_slot_multi_mv/multi_slot_multi_mv.groovy | 4 +-
.../mv_ignore_predicate/mv_ignore_predicate.groovy | 2 +-
.../mv_p0/mv_negative/agg_negative_test.groovy | 36 +-
.../mv_p0/mv_negative/dup_negative_test.groovy | 26 +-
.../mv_p0/mv_negative/mor_negative_test.groovy | 26 +-
.../mv_p0/mv_negative/mow_negative_test.groovy | 26 +-
.../mv_p0/mv_percentile/mv_percentile.groovy | 2 +-
.../mv_with_force_drop/mv_with_force_drop.groovy | 2 +-
.../suites/mv_p0/mv_with_view/mv_with_view.groovy | 2 +-
.../suites/mv_p0/no_await/no_await.groovy | 36 +-
.../suites/mv_p0/null_insert/null_insert.groovy | 2 +-
.../mv_p0/routine_load_hll/routine_load_hll.groovy | 28 +-
.../routine_load_mapping.groovy | 6 +-
.../sql_default_limit/sql_default_limit.groovy | 2 +-
.../ssb/multiple_no_where/multiple_no_where.groovy | 4 +-
.../mv_p0/ssb/multiple_ssb/multiple_ssb.groovy | 36 +-
.../multiple_ssb_between.groovy | 32 +-
.../suites/mv_p0/ssb/q_1_1/q_1_1.groovy | 2 +-
.../suites/mv_p0/ssb/q_2_1/q_2_1.groovy | 4 +-
.../suites/mv_p0/ssb/q_3_1/q_3_1.groovy | 4 +-
.../suites/mv_p0/ssb/q_4_1/q_4_1.groovy | 4 +-
.../suites/mv_p0/ssb/q_4_1_r1/q_4_1_r1.groovy | 2 +-
.../suites/mv_p0/sum_count/sum_count.groovy | 8 +-
.../mv_p0/sum_divede_count/sum_devide_count.groovy | 2 +-
.../suites/mv_p0/test_28741/test_28741.groovy | 2 +-
.../test_approx_count_distinct.groovy | 2 +-
.../suites/mv_p0/test_base/test_base.groovy | 2 +-
.../mv_p0/test_casewhen/test_casewhen.groovy | 2 +-
.../mv_p0/test_create_mv/test_create_mv.groovy | 4 +-
.../test_create_mv_complex_type.groovy | 16 +-
.../test_drop_partition_from_index.groovy | 2 +-
.../test_dup_group_by_mv_abs.groovy | 2 +-
.../test_dup_group_by_mv_plus.groovy | 2 +-
.../mv_p0/test_dup_mv_abs/test_dup_mv_abs.groovy | 2 +-
.../mv_p0/test_dup_mv_bin/test_dup_mv_bin.groovy | 2 +-
.../test_dup_mv_bitmap_hash.groovy | 4 +-
.../mv_p0/test_dup_mv_div/test_dup_mv_div.groovy | 2 +-
.../test_dup_mv_expr_priority.groovy | 2 +-
.../mv_p0/test_dup_mv_json/test_dup_mv_json.groovy | 2 +-
.../mv_p0/test_dup_mv_plus/test_dup_mv_plus.groovy | 2 +-
.../test_dup_mv_repeat/test_dup_mv_repeat.groovy | 2 +-
.../mv_p0/test_dup_mv_year/test_dup_mv_year.groovy | 4 +-
.../test_duplicate_mv/test_duplicate_mv.groovy | 2 +-
.../test_insert_multi/test_insert_multi.groovy | 2 +-
.../suites/mv_p0/test_mv_dp/test_mv_dp.groovy | 2 +-
.../suites/mv_p0/test_mv_mor/test_mv_mor.groovy | 6 +-
.../suites/mv_p0/test_mv_mow/test_mv_mow.groovy | 6 +-
.../test_mv_partition/test_mv_partition.groovy | 4 +-
.../test_mv_useless/agg_invalid/agg_invalid.groovy | 12 +-
.../test_agg_mv_useless/test_agg_mv_useless.groovy | 6 +-
.../test_dup_mv_useless/test_dup_mv_useless.groovy | 10 +-
.../test_uniq_mv_useless.groovy | 4 +-
.../where_invalid/where_invalid.groovy | 8 +-
.../suites/mv_p0/test_ndv/test_ndv.groovy | 2 +-
.../suites/mv_p0/test_o2/test_o2.groovy | 2 +-
.../mv_p0/test_row_store/test_row_store.groovy | 2 +-
.../suites/mv_p0/test_substr/test_substr.groovy | 2 +-
.../mv_p0/test_tbl_name/test_tbl_name.groovy | 2 +-
.../mv_p0/test_upper_alias/test_upper_alias.groovy | 4 +-
.../test_user_activity/test_user_activity.groovy | 2 +-
regression-test/suites/mv_p0/unique/unique.groovy | 14 +-
.../mv_p0/unique_rewrite/unique_rewrite.groovy | 8 +-
.../testAggQueryOnAggMV1.groovy | 6 +-
.../testAggQueryOnAggMV10.groovy | 2 +-
.../testAggQueryOnAggMV11.groovy | 2 +-
.../testAggQueryOnAggMV2.groovy | 2 +-
.../testAggQueryOnAggMV3.groovy | 2 +-
.../testAggQuqeryOnAggMV5.groovy | 2 +-
.../testAggQuqeryOnAggMV6.groovy | 2 +-
.../testAggQuqeryOnAggMV7.groovy | 2 +-
.../testAggregateMVCalcAggFunctionQuery.groovy | 2 +-
.../testBitmapUnionInQuery.groovy | 2 +-
.../testCountDistinctToBitmap.groovy | 4 +-
.../testIncorrectMVRewriteInSubquery.groovy | 2 +-
.../testIncorrectRewriteCountDistinct.groovy | 2 +-
.../testJoinOnLeftProjectToJoin.groovy | 4 +-
.../mv_p0/ut/testNDVToHll/testNDVToHll.groovy | 2 +-
.../testOrderByQueryOnProjectView.groovy | 2 +-
.../ut/testProjectionMV1/testProjectionMV1.groovy | 2 +-
.../ut/testProjectionMV2/testProjectionMV2.groovy | 2 +-
.../ut/testProjectionMV3/testProjectionMV3.groovy | 2 +-
.../ut/testProjectionMV4/testProjectionMV4.groovy | 2 +-
.../ut/testQueryOnStar/testQueryOnStar.groovy | 2 +-
.../testSelectMVWithTableAlias.groovy | 2 +-
.../testSingleMVMultiUsage.groovy | 2 +-
.../mv_p0/ut/testSubQuery/testSubQuery.groovy | 2 +-
.../ut/testUnionDistinct/testUnionDistinct.groovy | 2 +-
.../mv_p0/varchar_length/varchar_length.groovy | 2 +-
.../suites/mv_p0/where/k123/k123.groovy | 4 +-
.../mv_p0/where/k123_nereids/k123_nereids.groovy | 8 +-
.../suites/mv_p0/where/mvljc/mvljc.groovy | 2 +-
.../authorization/column_authorization.groovy | 4 +-
.../create_table/test_create_table.groovy | 31 +-
.../suites/nereids_p0/hint/test_use_mv.groovy | 2 +-
.../insert_into_table/complex_insert.groovy | 2 +-
.../insert_into_table/insert_values.groovy | 2 +-
.../invalid_stats/invalid_stats_join_order.groovy | 75 +
.../show/test_nereids_show_alter_table.groovy | 4 +-
.../suites/nereids_p0/test_prune_tablet_mv.groovy | 12 +-
.../agg_skew_rewrite/agg_skew_rewrite.groovy | 1 +
.../constant_propagation.groovy | 57 +-
.../agg_optimize_when_uniform.groovy | 4 +-
.../mv/dml/insert/dml_insert_and_overwrite.groovy | 10 +-
.../mv/dml/outfile/dml_into_outfile.groovy | 12 +-
.../mv/join/inner/inner_join_x.groovy | 4 +-
.../mv/same_name/sync_async_same_name.groovy | 2 +-
.../single_table_without_aggregate.groovy | 26 +-
.../nereids_rules_p0/mv/ssb/mv_ssb_test.groovy | 8 +-
.../with_table_operator/with_table_operator.groovy | 2 +-
.../suites/nereids_syntax_p0/advance_mv.groovy | 8 +-
.../mv/aggregate/agg_sync_mv.groovy | 106 +-
.../mv/newMv/aggHaveDupBase.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/case_ignore.groovy | 2 +-
.../mv/newMv/dup_gb_mv_abs.groovy | 2 +-
.../mv/newMv/dup_gb_mv_plus.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_abs.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_bin.groovy | 2 +-
.../mv/newMv/dup_mv_bm_hash.groovy | 4 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_plus.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/dup_mv_year.groovy | 4 +-
.../nereids_syntax_p0/mv/newMv/multi_slot1.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/multi_slot2.groovy | 4 +-
.../nereids_syntax_p0/mv/newMv/multi_slot5.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/multi_slot6.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/mv_with_view.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/rollback1.groovy | 2 +-
.../mv/newMv/sum_devide_count.groovy | 2 +-
.../nereids_syntax_p0/mv/newMv/unique_mv.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/MVMultiUsage.groovy | 2 +-
.../suites/nereids_syntax_p0/mv/ut/MVWithAs.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggMVCalcAggFun.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV1.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV10.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV11.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV2.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV3.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV5.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV6.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/aggOnAggMV7.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/bitmapUnionIn.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/distinctQuery.groovy | 4 +-
.../nereids_syntax_p0/mv/ut/incMVReInSub.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/incRewriteCD.groovy | 2 +-
.../mv/ut/joinOnCalcToJoin.groovy | 4 +-
.../mv/ut/joinOnLeftPToJoin.groovy | 4 +-
.../suites/nereids_syntax_p0/mv/ut/onStar.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/onlyGroupBy.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/orderByOnPView.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/projectMV1.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/projectMV2.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/projectMV3.groovy | 2 +-
.../nereids_syntax_p0/mv/ut/projectMV4.groovy | 2 +-
.../suites/nereids_syntax_p0/mv/ut/subQuery.groovy | 2 +-
.../suites/nereids_syntax_p0/mv/ut/unionDis.groovy | 2 +-
.../suites/nereids_syntax_p0/rollup/bitmap.groovy | 2 +-
.../suites/nereids_syntax_p0/rollup/date.groovy | 8 +-
.../suites/nereids_syntax_p0/rollup/hll/hll.groovy | 2 +-
.../hll_with_light_sc/hll_with_light_sc.groovy | 2 +-
.../mv/aggregate/agg_sync_mv.groovy | 104 +-
.../test_should_not_mv_rewrite.groovy | 95 +
.../aggregate/support_type/corr/corr.groovy | 44 +-
.../support_type/corr_welford/corr_welford.groovy} | 46 +-
.../aggregate/support_type/count/count.groovy | 63 +
.../count_by_enum/count_by_enum.groovy | 50 +
.../aggregate/support_type/covar/covar.groovy | 40 +-
.../support_type/covar_samp/covar_samp.groovy | 40 +-
.../show/test_show_create_materialized_view.groovy | 2 +-
.../test_array_distance_functions.groovy | 64 +
.../rollup/test_materialized_view_bitmap.groovy | 2 +-
.../rollup/test_materialized_view_date.groovy | 8 +-
.../rollup/test_materialized_view_hll.groovy | 2 +-
...test_materialized_view_hll_with_light_sc.groovy | 2 +-
.../rollup_p0/test_create_mv_and_mtmv.groovy | 8 +-
.../suites/rollup_p0/test_materialized_view.groovy | 6 +-
.../rollup_p0/test_materialized_view_array.groovy | 2 +-
.../test_materialized_view_load_open.groovy | 8 +-
.../test_materialized_view_move_memtable.groovy | 8 +-
.../rollup_p0/test_materialized_view_struct.groovy | 2 +-
.../schema_change_modify_mv_column_type_agg.groovy | 2 +-
.../schema_change_modify_mv_column_type.groovy | 2 +-
.../schema_change_modify_mv_column_type2.groovy | 2 +-
.../test_agg_mv_schema_change.groovy | 4 +-
.../test_dup_mv_schema_change.groovy | 4 +-
.../schema_change_p0/test_rename_column.groovy | 2 +-
.../test_uniq_mv_schema_change.groovy | 4 +-
.../suites/statistics/test_analyze_mv.groovy | 137 +-
.../statistics/test_drop_cached_stats.groovy | 2 +-
.../test_schema_change_statistics.groovy | 2 +-
.../suites/statistics/test_select_mv.groovy | 30 +-
.../test_skip_agg_table_value_column.groovy | 38 +-
.../suites/statistics/test_update_rows_mv.groovy | 2 +-
.../test_schema_change_ck.groovy | 2 +-
.../test_partial_update_mow_with_sync_mv.groovy | 2 +-
.../load.groovy | 3 +-
.../suites/variant_p0/delete_update.groovy | 4 +-
.../suites/variant_p0/mv/multi_slot.groovy | 10 +-
regression-test/suites/variant_p0/nested.groovy | 2 +-
.../variant_p0/predefine/test_predefine_ddl.groovy | 38 +-
.../variant_p0/schema_change/schema_change.groovy | 4 +-
.../test_double_write_when_schema_change.groovy | 2 +-
613 files changed, 17623 insertions(+), 7119 deletions(-)
create mode 100644 be/src/olap/collection_similarity.cpp
create mode 100644 be/src/olap/collection_similarity.h
create mode 100644 be/src/olap/collection_statistics.cpp
create mode 100644 be/src/olap/collection_statistics.h
copy be/src/olap/rowset/segment_v2/{inverted_index/query_v2/term_query.cpp =>
index_query_context.h} (58%)
create mode 100644 be/src/olap/rowset/segment_v2/index_reader_helper.h
create mode 100644 be/src/olap/rowset/segment_v2/index_writer.cpp
copy be/src/olap/rowset/segment_v2/{inverted_index_writer.h => index_writer.h}
(91%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query/query_helper.cpp
copy be/src/olap/rowset/segment_v2/inverted_index/query/{prefix_query.h =>
query_helper.h} (51%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query/term_query.cpp
copy be/src/olap/rowset/segment_v2/inverted_index/query/{disjunction_query.h
=> term_query.h} (67%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/similarity/bm25_similarity.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/similarity/bm25_similarity.h
copy be/src/olap/rowset/segment_v2/inverted_index/{query/disjunction_query.h
=> similarity/similarity.h} (55%)
copy be/src/olap/rowset/segment_v2/inverted_index/{query_v2/term_query.cpp =>
util/string_helper.h} (58%)
create mode 100644 be/src/vec/exprs/score_runtime.h
create mode 100644 be/src/vec/functions/function_score.cpp
delete mode 100644 be/test/common/schema_util_test.cpp
create mode 100644 be/test/olap/collection_similarity_test.cpp
create mode 100644 be/test/olap/collection_statistics_test.cpp
create mode 100644 be/test/olap/rowset/segment_v2/index_reader_helper_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query/conjunction_query_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query/disjunction_query_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query/query_helper_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/similarity/bm25_similarity_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/string_helper_test.cpp
create mode 100644 be/test/olap/tablet_schema_test.cpp
create mode 100644 be/test/vec/common/schema_util_rowset_test.cpp
create mode 100644 be/test/vec/common/schema_util_test.cpp
create mode 100644 be/test/vec/function/function_tokenize_test.cpp
create mode 100644 be/test/vec/jsonb/path_in_data_test.cpp
create mode 100644
fe/fe-common/src/main/java/org/apache/doris/catalog/VariantField.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AlterColocateGroupStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AlterWorkloadGroupStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateCatalogStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateFunctionStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateWorkloadSchedPolicyStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DropFunctionStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DropRepositoryStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowColumnStatsStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateMTMVStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CheckScoreUsage.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushDownScoreTopNIntoOlapScan.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{L1Distance.java
=> Score.java} (55%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/types/VariantField.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/mv/PointQueryShouldNotMvRewriteTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/literal/IPV6LiteralTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/persist/ScalarTypeTest.java
copy
regression-test/data/{query_p0/sql_functions/array_functions/test_array_distance_functions.out
=> fault_injection_p0/test_mow_alter_seq_multi_segments.out} (51%)
create mode 100644 regression-test/data/inverted_index_p0/test_bm25_score.out
create mode 100644
regression-test/data/nereids_p0/join/invalid_stats/invalid_stats_join_order.out
create mode 100644
regression-test/data/query_p0/aggregate/support_type/corr/corr.out
create mode 100644
regression-test/data/query_p0/aggregate/support_type/corr_welford/corr_welford.out
create mode 100644
regression-test/data/query_p0/aggregate/support_type/count/count.out
create mode 100644
regression-test/data/query_p0/aggregate/support_type/count_by_enum/count_by_enum.out
create mode 100644
regression-test/data/query_p0/aggregate/support_type/covar/covar.out
create mode 100644
regression-test/data/query_p0/aggregate/support_type/covar_samp/covar_samp.out
create mode 100644
regression-test/data/variant_p0/predefine/test_predefine_ddl.out
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_cluster_event_compaction_sync_wait.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/multi_cluster/warm_up/cluster/test_warm_up_cluster_event_compaction_sync_wait_timeout.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/test_mysql_jdbc_catalog_table_comment.groovy
create mode 100644
regression-test/suites/fault_injection_p0/test_mow_alter_seq_multi_segments.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_bm25_score.groovy
create mode 100644
regression-test/suites/nereids_p0/join/invalid_stats/invalid_stats_join_order.groovy
create mode 100644
regression-test/suites/point_query_p0/test_should_not_mv_rewrite.groovy
copy be/src/olap/rowset/segment_v2/inverted_index/query_v2/term_query.cpp =>
regression-test/suites/query_p0/aggregate/support_type/corr/corr.groovy (54%)
copy regression-test/suites/{mv_p0/agg_state/order_by/order_by.groovy =>
query_p0/aggregate/support_type/corr_welford/corr_welford.groovy} (54%)
create mode 100644
regression-test/suites/query_p0/aggregate/support_type/count/count.groovy
create mode 100644
regression-test/suites/query_p0/aggregate/support_type/count_by_enum/count_by_enum.groovy
copy be/src/olap/rowset/segment_v2/inverted_index/query_v2/term_query.cpp =>
regression-test/suites/query_p0/aggregate/support_type/covar/covar.groovy (58%)
copy be/src/olap/rowset/segment_v2/inverted_index/query_v2/term_query.cpp =>
regression-test/suites/query_p0/aggregate/support_type/covar_samp/covar_samp.groovy
(57%)
copy be/src/olap/rowset/segment_v2/inverted_index/query/disjunction_query.h =>
regression-test/suites/variant_p0/predefine/test_predefine_ddl.groovy (51%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
