This is an automated email from the ASF dual-hosted git repository.
starocean999 pushed a change to branch dev_rec
in repository https://gitbox.apache.org/repos/asf/doris.git
discard aa680e5c127 update fe code
discard c94b717b92e fix fe plan
discard c94e85b20c9 fix some bug in fe
discard 379f7c7a6be recursive cte fe part
discard 24a7585fde6 add TRecCTEScanNode
discard 061083ced87 add result_expr_lists to TRecCTENode
discard ddb9501dabc update thrift
discard 9b4c8904629 update thrift
discard 5d0a8bffda5 add rec cte thrift struct
add 7ce60da00f8 [fix](cloud) Fix /get_snapshot_property result (#57067)
add 50123ad8a83 [opt](function) Enhance the handling of a single
struct-type argument in the EXPLODE function (#57050)
add 71480ff12ab [fix](cloud) Return error if migrate to versioned
keys/compact snapsh… (#57066)
add 35f7fab36b4 [env](case) remove disable pipeline engine case (#57046)
add 19cf4c4a4e1 [feature](function) support json_hash function (#56962)
add af9fb9d82e4 [refine](type)use new type dispatch (#56990)
add 6b41b1ba55c [fix](cache) fix incorrectly incrementing s3_read_counter
(#55805)
add b3ff40587b7 [Chore](runtime-filter) catch Exception from runtime
filter rpc (#57085)
add b276af3bb68 [Fix](autoinc) Fix wrong auto inc value after FE do
checkpoint and restart (#57104)
add e2cb3d6b877 [enhancement](filecache) add wait time for other
downloader in profile (#57090)
add 82d5a3aac83 [fix](cloud) Fix /set_snapshot_property property names
(#57099)
add bb121e30810 [chore](external catalog) deprecated lakesoul external
catalog (#56843)
add 175e6ebcc38 [chore](inverted index) remove duplicate code in
comparison evaluate index (#57115)
add 26aacf428d2 [opt](ann index) omp_threads_limit working better & minor
change for observability (#56796)
add 1b6476e3840 [enhance](job) delay load task schedule when transaction
fail (#57092)
add c1e72907efd [chore](search) remove useless params (#57117)
add 3e3efb572f6 [Fix](job) fix streaming job block when fe restart (#57103)
add e46317fdbb6 [function](mask) mask_last/first second parameter can be
non-const (#57062)
add 2794fcc9c90 [fix](case) add query to force sync rowset meta (#56949)
add 5c610cd4b96 [opt](inverted index) Add built_in_analyzer parser alias
and modify custom analyzer logic (#57055)
add 26645e9da84 [fix] remove useless const_cast and explain const_cast for
vec (2) (#56464)
add ab1a05a4d07 [mem](jemalloc) Improve memory reuse efficiency and reduce
page faults to change jemalloc conf (#57076)
add ad7fc73265f [fix](docker) readiness-modify for http code (#57113)
add f34b8c1a1b7 [enhance](job) support adaptive batch param for routine
load job (#56930)
add 9e6926909ed [Enhancement](grammar) Support omit auto keyword for auto
range partition (#57060)
add 017f9e49c72 [fix](catalog)Disable Hadoop FileSystem cache for
multi-configurationobject storage catalogs (#57063)
add 04e333b442b [fix](parquet) incorrect skip files when returning eof
(#57071)
add 72bcfd6d2fe [opt](ann index) Support product quantization (#56954)
add fa36b1c6cc2 [feature](mtmv)create mtmv can use view (#56423)
add e08709fba10 [chore](cloud) support notifing itself to refresh instance
(#57107)
add f06196e9a24 [chore](regression) fix java home inconsistency (#57095)
add f27070c2d13 [fix](load) fix load plan when using WHERE clause with
CompoundPredicate (#57128)
add 0dfdfcd1a01 [fix](filecache) fix flaky case
populate_empty_cache_with_normal (#57091)
add 5ef4666eb13 [Bug](cloud restore) Fix npe in show restore command after
fe restart (#57051)
add d24e675cb1a [Fix](column) Fix
`ColumnFixedLengthObject::{insert_many_continuous_binary_data,
insert_many_strings}` (#57164)
add e51d64d7ffd [chore](compile) fix macos compile be failed (#57150)
add 5f0a8c68ded [fix](inverted index) remove shadow prefix when matching
index columns in schema change (#57006)
add b36f517e1a6 [Feature](varbinary) add length, from_base64_binary,
to_base64_bianry, sub_binary for VarBinary type (#56648)
add 87a53626d48 [Exec](Cache) Support condition cache in Apache doris
(#55534)
add 0f82adf9856 [chore](cloud) Make key info declaration more clear
(#57034)
add 7be788844c8 [Enhancement] add column_uid and schema_version field for
table schema open api (#56919)
add b99f8e972ed [Fix](ai) Fix the wrong check in AI_FILTER (#56960)
add 69d48801dc4 [fix](docker) update node to v14 in docker compilation
image (#56029)
add 322546caf2e [fix](nereids)fix sync mv parse error if it contains sql
KEYWORD (#57052)
add 7945b29db60 [fix](nullable) Fix nullable property for array (#57179)
add 33db05e5c1e [fix](nereids)set RuntimeFilterInfo only on BE which is
merge node (#57108)
new 1c2f794b65c add rec cte thrift struct
new 81d4379e9dd update thrift
new 9df14a5054b update thrift
new 863ce3b8d9a add result_expr_lists to TRecCTENode
new 803998ec4ff add TRecCTEScanNode
new 8c9e05a7ff5 recursive cte fe part
new fbefef551c3 fix some bug in fe
new b08823a00db fix fe plan
new d2b4d504313 update fe code
new bd7cbfb4e2f update fe
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 (aa680e5c127)
\
N -- N -- N refs/heads/dev_rec (bd7cbfb4e2f)
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.
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/common/config.cpp | 22 +-
be/src/common/config.h | 6 +-
be/src/io/cache/block_file_cache_profile.cpp | 3 +
be/src/io/cache/block_file_cache_profile.h | 1 +
be/src/io/cache/cached_remote_file_reader.cpp | 8 +-
be/src/io/cache/file_cache_common.h | 1 +
be/src/io/io_common.h | 1 +
be/src/olap/inverted_index_parser.cpp | 15 +-
be/src/olap/inverted_index_parser.h | 1 +
be/src/olap/iterators.h | 24 +-
be/src/olap/olap_common.h | 4 +
be/src/olap/parallel_scanner_builder.cpp | 75 +++-
be/src/olap/parallel_scanner_builder.h | 4 +-
be/src/olap/push_handler.cpp | 9 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 16 +
be/src/olap/rowset/rowset_reader_context.h | 2 +
.../olap/rowset/segment_v2/ann_index/ann_index.h | 14 +-
.../segment_v2/ann_index/ann_index_writer.cpp | 4 +-
.../rowset/segment_v2/ann_index/ann_index_writer.h | 2 +
.../segment_v2/ann_index/faiss_ann_index.cpp | 136 ++++++-
.../rowset/segment_v2/ann_index/faiss_ann_index.h | 51 +--
be/src/olap/rowset/segment_v2/condition_cache.cpp | 52 +++
be/src/olap/rowset/segment_v2/condition_cache.h | 135 +++++++
.../inverted_index/analysis_factory_mgr.cpp | 57 ++-
.../inverted_index/analysis_factory_mgr.h | 8 +-
.../inverted_index/analyzer/basic/basic_analyzer.h | 2 +-
.../char_filter/empty_char_filter_factory.h | 61 +++
.../empty_token_filter_factory.h} | 43 +--
.../tokenizer/basic/basic_tokenizer.cpp | 36 +-
.../tokenizer/basic/basic_tokenizer.h | 12 +-
.../tokenizer/basic/basic_tokenizer_factory.h | 18 +-
.../tokenizer/empty/empty_tokenizer_factory.h | 72 ++++
be/src/olap/rowset/segment_v2/row_ranges.h | 14 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 101 ++++-
be/src/olap/rowset/segment_v2/segment_iterator.h | 9 +-
be/src/olap/tablet_reader.cpp | 1 +
be/src/olap/tablet_reader.h | 2 +
be/src/olap/tablet_schema.h | 1 +
be/src/pipeline/exec/olap_scan_operator.cpp | 6 +-
be/src/pipeline/exec/olap_scan_operator.h | 4 +
be/src/pipeline/exec/scan_operator.cpp | 20 +-
be/src/pipeline/exec/scan_operator.h | 13 +-
be/src/runtime/exec_env.h | 3 +
be/src/runtime/exec_env_init.cpp | 11 +-
be/src/runtime/memory/cache_policy.h | 5 +
be/src/service/internal_service.cpp | 28 +-
be/src/util/doris_metrics.cpp | 11 +
be/src/util/doris_metrics.h | 5 +
be/src/util/jsonb_document.cpp | 20 +
be/src/util/jsonb_document.h | 3 +
be/src/vec/columns/column_const.h | 7 +-
be/src/vec/columns/column_fixed_length_object.h | 4 +-
be/src/vec/columns/column_varbinary.h | 8 +
be/src/vec/common/pod_array.h | 5 +
be/src/vec/common/string_view.h | 2 +
be/src/vec/core/call_on_type_index.h | 250 ++++++------
be/src/vec/data_types/data_type_factory.cpp | 4 +-
be/src/vec/exec/format/column_type_convert.cpp | 3 +-
be/src/vec/exec/format/csv/csv_reader.cpp | 9 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 16 +-
be/src/vec/exec/format/orc/vorc_reader.h | 10 +-
.../format/parquet/byte_stream_split_decoder.cpp | 2 +
.../format/parquet/fix_length_dict_decoder.hpp | 2 +
.../exec/format/parquet/fix_length_plain_decoder.h | 2 +
.../exec/format/parquet/parquet_column_convert.cpp | 3 +-
.../exec/format/parquet/parquet_column_convert.h | 8 +-
be/src/vec/exec/format/parquet/parquet_pred_cmp.h | 2 +-
be/src/vec/exec/format/parquet/schema_desc.cpp | 2 +-
be/src/vec/exec/format/parquet/schema_desc.h | 4 +-
.../parquet/vparquet_column_chunk_reader.cpp | 2 +-
.../format/parquet/vparquet_column_chunk_reader.h | 2 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 35 +-
.../exec/format/parquet/vparquet_column_reader.h | 24 +-
.../exec/format/parquet/vparquet_file_metadata.h | 1 +
.../exec/format/parquet/vparquet_group_reader.cpp | 7 +-
.../exec/format/parquet/vparquet_group_reader.h | 4 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 16 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 4 +-
be/src/vec/exec/format/table/iceberg_reader.cpp | 14 +-
be/src/vec/exec/format/table/iceberg_reader.h | 3 +-
.../vec/exec/format/table/lakesoul_jni_reader.cpp | 3 +
be/src/vec/exec/format/table/lakesoul_jni_reader.h | 3 +
be/src/vec/exec/jni_connector.cpp | 28 +-
be/src/vec/exec/jni_connector.h | 8 +-
be/src/vec/exec/scan/file_scanner.cpp | 14 +-
be/src/vec/exec/scan/file_scanner.h | 1 +
be/src/vec/exec/scan/olap_scanner.cpp | 7 +-
be/src/vec/exprs/table_function/vexplode_v2.cpp | 71 ++--
be/src/vec/exprs/vbitmap_predicate.h | 3 +
be/src/vec/exprs/vbloom_predicate.cpp | 7 +
be/src/vec/exprs/vbloom_predicate.h | 2 +
be/src/vec/exprs/vdirect_in_predicate.h | 2 +
be/src/vec/exprs/vexpr.cpp | 19 +
be/src/vec/exprs/vexpr.h | 2 +
be/src/vec/exprs/vexpr_context.cpp | 5 +-
be/src/vec/exprs/vexpr_context.h | 2 +
be/src/vec/exprs/vin_predicate.h | 2 +
be/src/vec/exprs/vlambda_function_call_expr.h | 2 +
be/src/vec/exprs/vlambda_function_expr.h | 2 +
be/src/vec/exprs/vliteral.cpp | 5 +
be/src/vec/exprs/vliteral.h | 2 +
be/src/vec/exprs/vruntimefilter_wrapper.h | 2 +
be/src/vec/exprs/vslot_ref.cpp | 9 +
be/src/vec/exprs/vslot_ref.h | 3 +
be/src/vec/functions/ai/ai_functions.h | 6 +-
.../array/function_array_contains_all.cpp | 131 +------
.../vec/functions/array/function_array_distinct.h | 76 +---
.../vec/functions/array/function_array_element.h | 104 +----
.../array/function_array_enumerate_uniq.cpp | 78 +---
be/src/vec/functions/array/function_array_index.h | 76 +---
be/src/vec/functions/array/function_array_remove.h | 76 +---
.../vec/functions/array/function_arrays_overlap.h | 120 +-----
be/src/vec/functions/function_coalesce.cpp | 77 +---
be/src/vec/functions/function_fake.cpp | 6 +-
be/src/vec/functions/function_json_hash.cpp | 104 +++++
be/src/vec/functions/function_map.cpp | 128 +------
be/src/vec/functions/function_search.cpp | 17 +-
be/src/vec/functions/function_search.h | 4 +-
be/src/vec/functions/function_string.cpp | 2 +
be/src/vec/functions/function_string.h | 43 ++-
be/src/vec/functions/function_totype.h | 81 ++--
be/src/vec/functions/function_varbinary.cpp | 136 ++++++-
be/src/vec/functions/function_varbinary.h | 53 +++
be/src/vec/functions/functions_comparison.h | 23 +-
be/src/vec/functions/if.cpp | 19 +-
be/src/vec/functions/least_greast.cpp | 204 +---------
be/src/vec/functions/simple_function_factory.h | 2 +
be/src/vec/utils/varbinaryop_subbinary.h | 119 ++++++
be/test/io/cache/block_file_cache_test.cpp | 2 +-
.../inverted_index/analysis_factory_mgr_test.cpp | 249 ++++++++++++
.../tokenizer/basic_tokenizer_factory_test.cpp | 152 +++++---
.../columns/column_fixed_length_object_test.cpp | 22 +-
be/test/vec/function/function_hash_test.cpp | 23 +-
be/test/vec/function/function_string_test.cpp | 68 ++--
be/test/vec/function/function_test_util.cpp | 4 +-
be/test/vec/function/function_test_util.h | 32 +-
be/test/vec/function/function_varbinary_test.cpp | 426 +++++++++++++++++++++
be/test/vec/function/table_function_test.cpp | 46 +--
build.sh | 6 +-
cloud/src/meta-service/meta_service_helper.h | 2 +-
cloud/src/meta-service/meta_service_http.cpp | 34 +-
cloud/src/meta-service/meta_service_resource.cpp | 30 +-
cloud/src/meta-store/keys.h | 106 ++---
cloud/src/snapshot/snapshot_manager.cpp | 6 +-
cloud/test/meta_server_test.cpp | 6 +-
conf/be.conf | 2 +-
docker/compilation/Dockerfile | 10 +-
.../runtime/be/resource/be_disaggregated_probe.sh | 33 +-
fe/be-java-extensions/lakesoul-scanner/pom.xml | 1 +
.../apache/doris/lakesoul/LakeSoulJniScanner.java | 4 +
.../org/apache/doris/lakesoul/LakeSoulUtils.java | 4 +
.../apache/doris/lakesoul/arrow/ArrowUtils.java | 4 +
.../lakesoul/arrow/LakeSoulArrowJniScanner.java | 4 +
fe/be-java-extensions/pom.xml | 3 +-
.../main/java/org/apache/doris/common/Config.java | 6 +
fe/fe-core/pom.xml | 5 +-
.../main/java/org/apache/doris/alter/Alter.java | 9 +-
.../doris/analysis/AnnIndexPropertiesChecker.java | 54 ++-
.../java/org/apache/doris/analysis/IndexDef.java | 5 +-
.../apache/doris/analysis/InvertedIndexUtil.java | 21 +-
.../doris/catalog/AutoIncrementGenerator.java | 2 +-
.../doris/catalog/BuiltinScalarFunctions.java | 9 +
.../main/java/org/apache/doris/catalog/Index.java | 9 +-
.../main/java/org/apache/doris/catalog/MTMV.java | 34 +-
.../apache/doris/cloud/backup/CloudRestoreJob.java | 1 +
.../apache/doris/datasource/CatalogFactory.java | 4 +-
.../apache/doris/datasource/InternalCatalog.java | 9 +-
.../lakesoul/LakeSoulExternalCatalog.java | 40 +-
.../lakesoul/LakeSoulExternalDatabase.java | 4 +
.../datasource/lakesoul/LakeSoulExternalTable.java | 4 +
.../doris/datasource/lakesoul/LakeSoulUtils.java | 4 +
.../lakesoul/source/LakeSoulScanNode.java | 4 +
.../datasource/lakesoul/source/LakeSoulSplit.java | 4 +
.../storage/AbstractS3CompatibleProperties.java | 45 ++-
.../datasource/property/storage/COSProperties.java | 5 +
.../datasource/property/storage/GCSProperties.java | 5 +
.../property/storage/MinioProperties.java | 5 +
.../datasource/property/storage/OBSProperties.java | 5 +
.../datasource/property/storage/OSSProperties.java | 5 +
.../datasource/property/storage/S3Properties.java | 10 +-
.../doris/httpv2/rest/TableSchemaAction.java | 80 +++-
.../doris/indexpolicy/BasicTokenizerValidator.java | 22 +-
.../org/apache/doris/indexpolicy/IndexPolicy.java | 6 +-
.../apache/doris/indexpolicy/IndexPolicyMgr.java | 13 +-
.../indexpolicy/LowerCaseTokenFilterValidator.java | 43 ---
...zerValidator.java => NoOperationValidator.java} | 10 +-
.../insert/streaming/StreamingInsertJob.java | 1 +
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 63 +--
.../job/offset/s3/S3SourceOffsetProvider.java | 5 +-
.../job/scheduler/StreamingTaskScheduler.java | 23 +-
.../load/routineload/KafkaRoutineLoadJob.java | 3 +-
.../doris/load/routineload/KafkaTaskInfo.java | 21 +-
.../doris/load/routineload/RoutineLoadJob.java | 8 +-
.../load/routineload/RoutineLoadTaskInfo.java | 12 +-
.../load/routineload/RoutineLoadTaskScheduler.java | 4 +-
.../MTMVAnalyzeQueryInfo.java} | 34 +-
.../org/apache/doris/mtmv/MTMVHookService.java | 14 +
.../java/org/apache/doris/mtmv/MTMVJobManager.java | 9 +
.../org/apache/doris/mtmv/MTMVPartitionInfo.java | 19 +
.../org/apache/doris/mtmv/MTMVPartitionUtil.java | 8 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 261 ++++++++++++-
.../doris/mtmv/MTMVRefreshPartitionSnapshot.java | 6 +-
.../java/org/apache/doris/mtmv/MTMVRelation.java | 34 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 99 ++++-
.../org/apache/doris/mtmv/MTMVRewriteUtil.java | 2 +-
.../java/org/apache/doris/mtmv/MTMVService.java | 18 +-
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 10 +-
.../org/apache/doris/nereids/CascadesContext.java | 8 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 2 +-
.../org/apache/doris/nereids/StatementContext.java | 33 ++
.../glue/translator/PhysicalPlanTranslator.java | 8 -
.../executor/TableCollectAndHookInitializer.java | 16 +-
.../nereids/load/NereidsLoadPlanInfoCollector.java | 15 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 13 +-
.../nereids/properties/RequestPropertyDeriver.java | 11 +
.../doris/nereids/rules/analysis/AnalyzeCTE.java | 15 +-
.../nereids/rules/analysis/BindExpression.java | 22 +-
.../doris/nereids/rules/analysis/BindRelation.java | 5 +
.../rules/analysis/CollectOneLevelRelation.java | 4 +-
.../nereids/rules/analysis/CollectRelation.java | 19 +-
.../mv/InitMaterializationContextHook.java | 24 +-
.../exploration/mv/MaterializedViewUtils.java | 13 +-
.../doris/nereids/rules/rewrite/CTEInline.java | 8 +-
.../expressions/functions/generator/Explode.java | 7 +-
.../functions/generator/ExplodeOuter.java | 7 +-
.../functions/generator/ExplodeVariantArray.java | 7 +-
.../scalar/{Length.java => FromBase64Binary.java} | 30 +-
.../scalar/{Length.java => JsonHash.java} | 33 +-
.../trees/expressions/functions/scalar/Length.java | 5 +-
.../expressions/functions/scalar/MaskFirstN.java | 8 -
.../expressions/functions/scalar/MaskLastN.java | 8 -
.../scalar/{MaskFirstN.java => SubBinary.java} | 61 +--
.../scalar/{Length.java => ToBase64Binary.java} | 23 +-
.../expressions/visitor/ScalarFunctionVisitor.java | 20 +
.../plans/commands/UpdateMvByPartitionCommand.java | 6 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 174 +--------
.../trees/plans/commands/info/IndexDefinition.java | 5 +-
.../plans/distribute/worker/BackendWorker.java | 2 +-
.../trees/plans/logical/LogicalCheckPolicy.java | 17 +
.../org/apache/doris/planner/RecursiveCteNode.java | 18 +-
.../java/org/apache/doris/qe/SessionVariable.java | 57 ++-
.../qe/runtime/RuntimeFiltersThriftBuilder.java | 15 +-
.../doris/qe/runtime/ThriftPlansBuilder.java | 48 ++-
.../doris/tablefunction/MetadataGenerator.java | 29 +-
.../doris/catalog/AutoIncrementGeneratorTest.java | 178 +++++++++
.../property/storage/COSPropertiesTest.java | 16 +
.../property/storage/GCSPropertiesTest.java | 18 +
.../property/storage/OBSPropertyTest.java | 18 +
.../property/storage/OSSPropertiesTest.java | 18 +
.../property/storage/S3PropertiesTest.java | 17 +
.../apache/doris/mtmv/MTMVPartitionUtilTest.java | 2 +-
.../org/apache/doris/mtmv/MTMVPlanUtilTest.java | 226 ++++++++++-
.../apache/doris/mtmv/MTMVRelationManagerTest.java | 42 +-
.../org/apache/doris/mtmv/MTMVRelationTest.java | 117 ++++++
.../apache/doris/mtmv/MTMVSchemaChangeTest.java | 94 +++++
.../java/org/apache/doris/mtmv/MTMVTaskTest.java | 3 +-
.../test/java/org/apache/doris/mtmv/MTMVTest.java | 5 +-
.../org/apache/doris/nereids/util/PlanChecker.java | 6 +-
.../apache/doris/utframe/TestWithFeService.java | 7 +
gensrc/thrift/PaloInternalService.thrift | 5 +-
gensrc/thrift/PlanNodes.thrift | 2 +
.../product_quantization.out} | 7 +-
.../data/correctness_p0/test_mask_function.out | 48 +--
.../data/correctness_p0/test_probe_clean.out | 6 -
.../analyzer/test_custom_analyzer2.out | 16 +
regression-test/data/jsonb_p0/test_json_hash.out | 49 +++
.../broker_load/test_s3_load_with_where.out | 18 +
.../load_p0/insert/test_insert_move_memtable.out | 29 --
.../data/mtmv_p0/test_create_mtmv_with_view.out | 30 ++
.../mtmv_p0/test_create_mtmv_with_view_alter.out | 19 +
.../test_create_mtmv_with_view_alter_table.out | 19 +
.../test_create_mtmv_with_view_commit.out} | 6 +-
.../test_create_mtmv_with_view_cte.out} | 7 +-
.../mtmv_p0/test_create_mtmv_with_view_mtmv.out | 20 +
.../mtmv_p0/test_create_mtmv_with_view_pct.out | 21 +
.../mtmv_p0/test_create_mtmv_with_view_rollup.out | 9 +
...mtmv.out => test_limit_partition_view_mtmv.out} | 0
.../data/mtmv_p0/test_view_hive_mtmv.out | 28 ++
.../data/query_p0/cache/condition_cache.out | 121 ++++++
.../sql_functions/table_function/explode.out | 16 +
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.out | 283 --------------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.out | 59 ---
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.out | 10 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.out | 153 --------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.out | 317 ---------------
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.out | 9 -
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.out | 38 --
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.out | 103 -----
.../data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.out | 205 ----------
.../data/ssb_sf0.1_p1/sql/pipelinex_q1.1.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q1.2.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q1.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q2.1.out | 43 ---
.../data/ssb_sf0.1_p1/sql/pipelinex_q2.2.out | 11 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q2.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.1.out | 28 --
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.2.out | 51 ---
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.3.out | 4 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q3.4.out | 3 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q4.1.out | 8 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q4.2.out | 3 -
.../data/ssb_sf0.1_p1/sql/pipelinex_q4.3.out | 3 -
.../regression/util/RoutineLoadTestUtils.groovy | 152 ++++++++
.../ann_index_p0/product_quantization.groovy | 107 ++++++
.../suites/ann_index_p0/scalar_quantization.groovy | 6 +-
.../cloud_p0/query_retry/test_retry_e-230.groovy | 1 -
.../spark_connector/spark_connector_arrow.groovy | 11 +-
.../spark_connector_read_type.groovy | 11 +-
...est_distinct_streaming_agg_local_shuffle.groovy | 3 -
.../correctness_p0/test_grouping_sets_empty.groovy | 5 -
.../correctness_p0/test_mask_function.groovy | 16 +-
.../suites/correctness_p0/test_probe_clean.groovy | 21 -
.../hive/test_parquet_nested_types.groovy | 8 +-
...st_skip_index_compaction_fault_injection.groovy | 3 +
.../flink_connector_p0/flink_connector.groovy | 10 +-
.../flink_connector_syncdb.groovy | 11 +-
.../flink_connector_p0/flink_connector_type.groovy | 10 +-
.../test_ngram_bloomfilter_index_change.groovy | 3 +-
.../analyzer/test_custom_analyzer2.groovy | 62 +++
.../test_streaming_job_schedule_task_error.groovy | 94 +++++
.../suites/jsonb_p0/test_json_hash.groovy | 116 ++++++
.../broker_load/test_s3_load_with_where.groovy | 205 ++++++++++
.../insert/test_insert_move_memtable.groovy | 119 ------
.../test_routine_load_adaptive_param.groovy | 91 +++++
.../test_routine_load_delay_schedule.groovy | 83 ++++
.../suites/mtmv_p0/test_build_mtmv.groovy | 15 -
.../mtmv_p0/test_create_mtmv_with_view.groovy | 112 ++++++
.../test_create_mtmv_with_view_alter.groovy | 94 +++++
.../test_create_mtmv_with_view_alter_table.groovy | 103 +++++
.../test_create_mtmv_with_view_commit.groovy | 69 ++++
.../mtmv_p0/test_create_mtmv_with_view_cte.groovy | 92 +++++
.../mtmv_p0/test_create_mtmv_with_view_mtmv.groovy | 126 ++++++
.../mtmv_p0/test_create_mtmv_with_view_pct.groovy | 103 +++++
.../test_create_mtmv_with_view_rollup.groovy | 81 ++++
.../mtmv_p0/test_limit_partition_view_mtmv.groovy | 254 ++++++++++++
.../suites/mtmv_p0/test_view_hive_mtmv.groovy | 98 +++++
.../test_mv_with_keyword.groovy | 67 ++++
.../session_variable/test_default_limit.groovy | 8 +-
.../conditional_functions/test_nullif.groovy | 10 +-
.../test_auto_partition_behavior.groovy | 26 +-
.../suites/query_p0/cache/condition_cache.groovy | 290 ++++++++++++++
.../query_p0/join/test_join_result_count.groovy | 3 -
.../join/test_partitioned_hash_join.groovy | 2 +-
.../schema_table/test_active_queries.groovy | 15 -
.../schema_table/test_backend_active_tasks.groovy | 15 -
.../session_variable/test_default_limit.groovy | 8 +-
.../array_functions/test_array_map_function.groovy | 8 -
.../binary_functions/test_binary_function.groovy | 128 +++++++
.../bitmap_functions/test_bitmap_function.groovy | 26 --
.../conditional_functions/test_nullif.groovy | 10 +-
.../sql_functions/table_function/explode.groovy | 22 ++
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql | 24 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql | 24 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql | 25 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql | 24 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql | 27 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql | 26 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql | 29 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql | 27 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql | 33 --
.../ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql | 29 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql | 24 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql | 24 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql | 25 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql | 26 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql | 27 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql | 26 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql | 28 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql | 28 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql | 30 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql | 30 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql | 30 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql | 31 --
.../suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql | 29 --
regression-test/suites/variant_p0/nested.groovy | 2 +-
379 files changed, 8194 insertions(+), 4755 deletions(-)
create mode 100644 be/src/olap/rowset/segment_v2/condition_cache.cpp
create mode 100644 be/src/olap/rowset/segment_v2/condition_cache.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/char_filter/empty_char_filter_factory.h
copy
be/src/olap/rowset/segment_v2/inverted_index/{tokenizer/basic/basic_tokenizer.h
=> token_filter/empty_token_filter_factory.h} (51%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/tokenizer/empty/empty_tokenizer_factory.h
create mode 100644 be/src/vec/functions/function_json_hash.cpp
create mode 100644 be/src/vec/functions/function_varbinary.h
create mode 100644 be/src/vec/utils/varbinaryop_subbinary.h
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/analysis_factory_mgr_test.cpp
create mode 100644 be/test/vec/function/function_varbinary_test.cpp
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/LowerCaseTokenFilterValidator.java
rename
fe/fe-core/src/main/java/org/apache/doris/indexpolicy/{KeywordTokenizerValidator.java
=> NoOperationValidator.java} (83%)
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/rules/analysis/CollectOneLevelRelation.java
=> mtmv/MTMVAnalyzeQueryInfo.java} (50%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Length.java
=> FromBase64Binary.java} (74%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Length.java
=> JsonHash.java} (64%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{MaskFirstN.java
=> SubBinary.java} (56%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Length.java
=> ToBase64Binary.java} (75%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/AutoIncrementGeneratorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVRelationTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVSchemaChangeTest.java
rename regression-test/data/{ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.out =>
ann_index_p0/product_quantization.out} (57%)
create mode 100644
regression-test/data/inverted_index_p0/analyzer/test_custom_analyzer2.out
create mode 100644 regression-test/data/jsonb_p0/test_json_hash.out
create mode 100644
regression-test/data/load_p0/broker_load/test_s3_load_with_where.out
delete mode 100644
regression-test/data/load_p0/insert/test_insert_move_memtable.out
create mode 100644 regression-test/data/mtmv_p0/test_create_mtmv_with_view.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_alter.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_alter_table.out
rename regression-test/data/{ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.out =>
mtmv_p0/test_create_mtmv_with_view_commit.out} (64%)
rename regression-test/data/{ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.out =>
mtmv_p0/test_create_mtmv_with_view_cte.out} (63%)
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_mtmv.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_pct.out
create mode 100644
regression-test/data/mtmv_p0/test_create_mtmv_with_view_rollup.out
copy regression-test/data/mtmv_p0/{test_limit_partition_mtmv.out =>
test_limit_partition_view_mtmv.out} (100%)
create mode 100644 regression-test/data/mtmv_p0/test_view_hive_mtmv.out
create mode 100644 regression-test/data/query_p0/cache/condition_cache.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.out
delete mode 100644
regression-test/data/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.1.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.2.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q1.3.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.1.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.2.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q2.3.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.1.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.2.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.3.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q3.4.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.1.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.2.out
delete mode 100644 regression-test/data/ssb_sf0.1_p1/sql/pipelinex_q4.3.out
create mode 100644
regression-test/framework/src/main/groovy/org/apache/doris/regression/util/RoutineLoadTestUtils.groovy
create mode 100644
regression-test/suites/ann_index_p0/product_quantization.groovy
create mode 100644
regression-test/suites/inverted_index_p0/analyzer/test_custom_analyzer2.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/test_streaming_job_schedule_task_error.groovy
create mode 100644 regression-test/suites/jsonb_p0/test_json_hash.groovy
create mode 100644
regression-test/suites/load_p0/broker_load/test_s3_load_with_where.groovy
delete mode 100644
regression-test/suites/load_p0/insert/test_insert_move_memtable.groovy
create mode 100644
regression-test/suites/load_p0/routine_load/test_routine_load_adaptive_param.groovy
create mode 100644
regression-test/suites/load_p0/routine_load/test_routine_load_delay_schedule.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_alter.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_alter_table.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_commit.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_cte.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_mtmv.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_pct.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_create_mtmv_with_view_rollup.groovy
create mode 100644
regression-test/suites/mtmv_p0/test_limit_partition_view_mtmv.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_view_hive_mtmv.groovy
create mode 100644
regression-test/suites/mv_p0/test_mv_with_keyword/test_mv_with_keyword.groovy
create mode 100755 regression-test/suites/query_p0/cache/condition_cache.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/binary_functions/test_binary_function.groovy
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.1.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.2.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q1.3.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.1.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.2.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q2.3.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.1.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.2.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.3.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q3.4.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.1.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.2.sql
delete mode 100644
regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_flat_q4.3.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.1.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.2.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q1.3.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.1.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.2.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q2.3.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.1.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.2.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.3.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q3.4.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.1.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.2.sql
delete mode 100644 regression-test/suites/ssb_sf0.1_p1/sql/pipelinex_q4.3.sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
