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 bbd6cb02964 add TRecCTEScanNode
discard dddf13a90c3 add result_expr_lists to TRecCTENode
discard 0bcccb27959 update thrift
discard bbd908f3040 update thrift
discard 3e98f973f2a add rec cte thrift struct
add 1ce7bf0d46f [fix](coordinator) Fix wrong bucket assignments by nereids
coordinator (#56201)
add 84cb785d863 [fix](iceberg) Fix classloader usage in the Iceberg system
table scanner (#56150)
add 7f9b130c1d3 [fix](nereids) runtime filter generation bug for topn lazy
materialization (#56137)
add 3e9b5600c0e [chore](test) improve coverage of function_jsonb.cpp
(#56151)
add d9e5a115acb [chore](task) set tablet id in create finish req and skip
warn for drop (#56178)
add 598073fef26 [Bug](type) add PGenericType for varbinary type (#56188)
add 058e31d3f70 [fix](nereids)useless common sub expression is inferred
for aggregation (#55815)
add a64e6a3fb2b [fix](test) fix test_routine_load_alter case fail (#56206)
add b776be4fbd7 [enhance](metric)add metrics for statistics/mtmv/sql
cache/plan (#55617)
add ac8b1b15020 [test](exchange) set _send_multi_blocks only false (#56211)
add 56d6863f31a [enhance](mtmv)log snapshot after task finish (#56198)
add 1edd28f2a68 [fix](nereids) fix bugs about convert hot value from
string type to date type (#56185)
add e602e48e30b [Fix](Catalog)S3A: Support assuming IAM role via
ProfileCredentialsProvider (#56213)
add f0f26d7c7da [fix](script) Fix recycler cannot find `core-site.xml` and
`hdfs-site.xml` (#56248)
add 972941b0c15 [fix](prepare statement)Prepare stage only explain sql to
get output slots. (#56224)
add 643caa7f5c9 [fix](count) fix wrong count push down logic (#56182)
add f8fac2d2a15 [fix](multi-catalog) should set initedScanRangeLocations
after getScanRangeLocations (#56245)
add 03c3afd3c1a [improvement](load) improve load strict mode (#55902)
add 99d000bbdd5 [fix](cloud) make recycle_snapshot_meta_and_data public
(#56240)
add 1364d3670e3 [Feat](Snapshot) Support Snapshot MS Http Interface
(#56202)
add 23acc85a58a [fix](cases) add load ddl test cases (#56263)
add 242444b2ecc [Refactor](function) Throw exception rather than return
null for datetime function error handling (#56079)
add 6131f4633a2 [fix](function) incorrect result of json_extract with path
'**' (#56226)
add d7c9e5ec3a0 [fix](file writer) fix value of s3 bytes written bvar
incorrect (#56262)
add 4717a022fe4 [fix](test) Reduce cache cleanup interval to fix flaky
test (#56253)
add 79ddf566cc9 [Chore](auto-pick)4.0.x autopick (#56282)
add 9076cc3a96e [opt](exec) opt the row id fetcher performance (#56222)
add d46a04ea0c2 [feature](function) add is_ipv4/is_ipv6 (#56255)
add 41aeb12ffcc [fix](nereids)fix tableNameInfo is null in tableRefInfo
(#56219)
add 317d5601acb [opt](ai) detail optimization for AI Funcion (#55762)
add d61d2cbfa57 [fix](nereids) fix unstable test of sql cache (#56264)
add dd4c598e769 [Fix](datetime) fix wrong implicit microsecond digits
after reducing precision of datetime (#53659)
add 8d9c5d65176 [enhance](mtmv)Base table changes should not cause nested
MTMV to schema change status (#56244)
add 9b39be28eeb [fix](docker case) Fix warm up case failed due to schema
change (#56252)
add cf536ab068d [fix](regression) fix unstable case cse.groovy (#56227)
add cf84078447e [fix](case) test_csv_with_header (#56107)
add f4d164d547d [fix](nereids)prevent null exception in ShowTableCommand
(#56239)
add 0fbab818735 [Fix](s3) Fix hdfs will throw an exception if the URL
verification fails (#56268)
add a793b19ef35 [fix](es) Handle object type in Elasticsearch mapping when
table is empty (#56152)
add fca7aff86ef [fix](olap) A crash caused by an incorrect storage type in
the IN predicate (#56309)
add ebd27d8e883 [fix](github) force use text diff for .out files (#56330)
add 2148a6d60b3 [fix] (agg_strategy) fix result wrong when the
multi_distinct_func and count distinct multi expr exists same time (#56271)
add 8470c2f4151 [feature](info) Append RunningTasks into BE info (#56277)
add cd475b224b1 [opt](paimon) Optimize Paimon Time Travel Implementation
and Fix Schema Consistency Issues (#56023)
add af71338d043 [fix](cloud) recycle orphan partitions (#56306)
add db09cef4009 [Chore](errmsg) Avoid extra error stacktrace for error in
scanner (#56335)
add 616eba6d050 [opt](inverted index) add debug logs (#56280)
add 4fc6bdb569e [fix](function) fix convert_tz function fe time_zone range
problem (#56228)
add 8fad28d108c [fix](function) A crash caused by nullptr in
json_exists_path (#56331)
add 441d45f7490 [fix](inverted index) fix boolean query for NOT operator
(#56329)
add 8b1618fea18 [Chore](errmsg) refine error message of str_to_date
(#56349)
add f66069adf9e [fix](ci) performance enable_sql_cache=false (#56285)
add cfd990d0775 [ci](branch-4.0) adjust pipeline for 4.0 (#56296)
add b022236337e [log](minor) Add debug logs (#56339)
add 840a32aad99 [chore](test)Icebebrg test uses doris's fileio (#56193)
add 54f7b735a7f [opt](query-progress) add more log to debug (#56333)
add ec2a6f63f1f [opt](iceberg) opt the error msg of iceberg scan node
(#56327)
add a39b6433da3 [chore](cloud) Add check snapshot for checker (#56290)
add c73d225f396 [feat](streaming job) Introduce streaming job for
incremental load (#56175)
add a4a4c4a34c0 [feat](txn) Add txn write amplification brpc metrics
(#55544)
add 6aa8e6ef268 [feat](snapshot) clone instance return image url (#56310)
add 2ac4fd5c1b1 [feat](snapshot) modify cloud snapshot commands (#56293)
add 73c006aab59 [metrics](warmup) add bvar for skipped warmup rowsets
(#56301)
add be3ba367a22 [opt](warmup) make warm_up_rowset async (#55236)
add 011b55b3495 [fix](filecache) microbench crash when FileBufferBuilder
(#56204)
add 01451ada116 [fix](cloud) Rowset meta save reference instance id
(#56291)
add 57bd84a4f21 [fix](cloud) create_instance notify refresh instance
(#56341)
add 8274895972f [fix](load) fix s3 load check failed when no source file
found (#56319)
add 1c7c7b2400e [improve](bin) do not chmod if current user has x and r
privilige (#56351)
add 35a06509319 [fix](test) Fix recycler test for hdfs and kerberos config
(#56357)
add 7946376c74f [fix](case) bug (#56364)
add 9840b20a0a7 [fix](case) bug with same table in same db (#56363)
add 110543e8c01 [fix](case) bug (#56362)
add 228e5fc62fe [fix](case) fix ingestion load cases (#55361) (#56359)
add 319bc7d5f6d [chore](jsonb) Remove unused code from ObjectVal (#56334)
add 54a81965e03 [chore](type) remove to_string from DataType part I
(#56197)
add 8b18f2d5b05 [ci](fix) fix 4.0.x auto pick (#56385)
add 8ee6089278b [Refactor](util) Remove date_cast utils (#56343)
add a076fea62af [feature](function) support MySQL dialect of function
substr and position (#55914)
add fbe93b92186 [Chore](log) Fix wrong warning logs (#56394)
add edfe2171885 [fix](nereids) tpcds query64 shape unstable (#55920)
add c89de1cfefa [fix](test) add order by items in test_json_function
(#56347)
add 5edc39ab0a2 [fix](routine load) delete redundant thrift field (#56302)
add f0124d97ac1 [Bug](datetype) add PGenericType for varbinary type
(#56375)
add 5d682f924e7 [refactor](load) replace table data dump with single-line
JSON format (#56073)
add 9d6926874ca [Chore](debug) add rf merger info to
PipelineFragmentContext::debug_string() (#56405)
add 7202586c058 [feat](catalog)AWS Glue supports S3 access via IAM
AssumeRole. (#56311)
add 2e02321f436 [fix](test) fix paimon dlf rest catalog case (#56381)
add 70ac9f7b1b1 [fix](inverted index) support dict_compression
configuration for variant type (#56399)
add 982e1bb5ba4 [fix](function) fix error Agg Function histogram(boolean)
is not implemented (#56398)
add 9f9f1eb3ec3 [Feature](func) Support function MAKE_SET (#56367)
add 92651f70842 [improve](snapshot) Modify some snapshot interface (#56393)
add 9f7c277eb65 [fix](mysql) optimize some error handling logic (#56416)
add 32312dcc14b [opt](fe) rewrite json/explode functions in
ExpressionAnalyzer (#56396)
add bcf80760cd6 [chore](ci) rm arm pipeline (#56450)
add b7d59c86da3 [feat](cloud) Add clone chain reader (#56401)
add 1e738f46a30 [Fix](warmup) Fix coredump in
`CloudTablet::complete_rowset_segment_warmup` due to capture by reference
(#56395)
add 09baadf2059 [Improve](segment) Put Segment footer into index page
cache (#56382)
add 2ce15eb3b3b [chore](ubsan) fix some ubsan error (#55673)
add 67073096225 [Fix](url) fix wrong result in function parse_url (#56429)
add 8f80acc104d [regression-test](add)Add some test of date functions
throw error (#56358)
add 2d9a712b3e2 [feature](udf) support varbinary type in java-udf (#56181)
add af4db727eb1 [fix](checker) Txn is old due to scan too much kv (#56419)
add 33e4c009354 [fix](debug) Fix illegal access to runtime states (#56439)
add c43f1f1d6dc [Opt](cloud) use unordered_map to reduce meta lock held
time in `delete_expired_stale_rowsets` (#53467)
add 1e3ac70019a [feat](oss)Support DeltaLake VPC Endpoint Format (dlf /
deltalake-vpc) (#56473)
add 73590e6e0ec [refactor](compress) Unify the decompressin error msg
(#56299)
add ee8c1c4eae3 [fix](function) fix date_format fe too many string input
problem (#56241)
add 037328be6a1 [Enhancement](cast) Support backslash for datetime
strict-mode parsing in date part (#56437)
add 09c2c7ef0d8 [Chore](debug) add global rf merger info to
FragmentMgr::dump_pipeline_tasks (#56440)
add dda1892f67e [Chore](regression) add keepalive to jdbc url (#56465)
add ec4d0e81df4 [improve](job) Modify the prompt for job creation failure
when there is no use db (#55422)
add 141f9424cc7 [fix](fe)fix fe info lost start time (#56451)
add 56d49623bb8 [fix](compile)fix thrift checkstyle compile error (#56354)
add c861de2c089 [fix](outfile) fix small file output with bz2 compression
(#56368)
add 3f441d990c3 [fix](cloud) Read delete bitmap v2 via clone chain reader
(#56461)
add c4732ca7088 [improve](cloud) unify snapshot properties to enum name
(#56337)
add b25929d2058 [fix](vcg) Fix vcg regression case due to pick code
(#56411)
add 9e4411d0f1a [opt] Session var experimental_enable_virtual_slot_for_cse
(#56340)
add a73e16a53ad [fix](docker)Add a line break before the configuration.
(#56471)
add 2c680c3364f [Fix]Fix drop index and build index running same time
(#56470)
add f072dd961bd [opt](partition) process auto partition name when its
length exceeds 50 (#56304)
add d043cfe2080 [fix](load) fix multi byte char load (#56353)
add c1f28b73d52 [fix](nereids) fix broker load planner don't support multi
file group (#56372)
add 226fd1da8be [fix](ann index) Fix range search failed (#56407)
add 352cb3618f2 [refine](check)If the return of function does not match,
directly report an error. (#56488)
add 3ed73418e38 [fix](recycler) Fix recycler cases (#56511)
add 2323fa4024e [fix](case) fix insert_group_commit_into (#56501)
add 0b4fc49e07d [opt](iceberg) add unity catalog test file (#55214)
add 64395bc1f78 [fix](sql cache) fix sql cache use legacy cache when use
some special session variables and audit log's HitSqlCache not working (#56434)
add 3da8f9810ab [fix](top rf) fix external table top rf lack of
consideration of `nulls first` conditions. (#56392)
add 07450dd06b8 [case](outfile) fixed outfile for s3load (#55980)
add f11b80c8b0e [fix](snapshot) show the snapshot count (#56491)
add 60d82ee88b0 [fix](regression) use qt_order in
tpch_sf0.1_p1/sql/cse.groovy to make case stable (#56512)
add 6528b31b12f [fix](union) fix distribute exprs of union operator
(#56449)
add d258d9bc59c [opt](variant) add column cache for variant sparse column
(#56159)
add a8b8b94d515 [enhancement](wg) ignore properties key case during create
or alter (#56531)
add 3787e8780f1 [feature](cast)Support try-cast (#56171)
add cd4f5b0fc80 [chore](type) remove to_string from DataType part II
(#56402)
add 371dd014790 [fix](bvar) Fix bvar leak after schema change job in be
failed (#56207)
add 83c70204595 [Bug](profile) move watcher.stop() into locked code block
(#56462)
add ab64537fbd0 [fix](array) fix function size for const param (#56432)
add ba7aa3beea7 [regression-test](case) fix
point_query_p0/test_point_query.groovy (#56534)
add 243f0bb477b [feature](func) Support MID function (#56446)
add da542766950 [fix](nereids)fix bug in row_store_flags order for lazy
materialization (#56454)
add e27ceb316bd [fix](nereids) push down filter throw set operation shoud
not change regulator output (#56366)
add b4a025a2c09 [fix](UT) LoadManagerTest::testSerializationNormal
remove the streaming_label_keep_max_second set (#56428)
add d6fb13731d5 [fix](case) fix cloud_delete_bitmap/test_load (#56536)
add 6b80c995a6c [chore](ci)Remove unnecessary branches (#56544)
add de0e79cf22c [improvement](tvf load) Add fast fail in Tvf load (#56273)
add f251e4ce015 [fix](case) Fix unreasonable assert for recycler case
(#56546)
add b1cd542f9f7 [Chore](debug) fix RuntimeFilterMgr::debug_string format
(#56563)
add ceea05282bc [fix](filecache) fix crash when clear file cache (#56170)
add 3b0cf8e3c37 [fix](filecache) fix filecache microbench bvar (#56360)
add 33380d77895 [fix](restore) Fix `tableSample` is null when restore
alias table (#56565)
add a22522db373 [fix](nereids) fix copy into fail with no where expression
(#56549)
add 44e438f5851 [fix](load) fix execute copy task fail (#56551)
add 85dd64161c9 [typo](tvf & decompression) add case "lz4" -> "lz4frame"
(#56316)
add 151cb7218d9 [Enhancement](json load) Set jsonload's default behavior
to be read_json_by_line (#55861)
add 7ccddc94d42 [Fix](case) try fix
`test_warmup_delay_compaction_query_tolerance` (#56553)
add 98af3eed70a [feat](load) alias compute_group to cloud_cluster (#53031)
add f8670a4c2b6 [chore](load) optimize the display order of show load
(#56513)
add 2523fbd3781 [fix](cloud) Fill schema table cluster_snapshots (#56575)
add 48ff53b39b2 [chore](compile) make gcc compiler happy (#56606)
add 791b6685b34 [bug](column) fix unnest_nullable could not handle const
column size (#56472)
add 484731e28ae [fix](insert) fix insert into statistic never update
(#56412)
add 108bb49a512 [bug](topn) fix partition topn data distribution should be
hash shuffle in two phase (#56542)
add 55c19fc654a [fix](array-union) Update ArrayUnion for behavior (#56443)
add 97d8f23e4ab [opt](nereids) set topn_lazy_materialization_threshold to
1024 (#56297)
add 7a74f845eca [fix](java udf) fix possible deadlock when udf closed in
bprc (#55302)
add fa6d210f218 [Feature](varbinary) Extend the digest function for
VarBinary type (#56497)
add b65d9d05789 [opt](inverted index) Update the clucene version (#56578)
add 376806f8d04 [Opt](MergeIO) make read slice size is configurable
(#55936)
add dfa8ba24e32 [fix](nereids) legacy expr clone need update
nullableFromNereids (#56552)
add ad311b8af7e [feature](function) support from/to_hex fucntion (#56410)
add 6ed6be25a9d [opt](nereids) optimize bs downgrade alg. (#56279)
add 615ec034c3f [feat](case when) replace null with false for case when
condition (#56424)
add 1c457b0b966 [Fix](case) Fix `test_rename_compute_group` due to vcg pr
pick (#54106) (#56558)
add 70b40d3f883 [opt](nereids)invoke validator after topn lazy
materialization processor if feDebug is on (#56344)
add 313ad6b727f [Chore](nereids) delete ddlStmt (#56478)
add a107fc928e6 [fix](nereids) set correct hot value after analyze job
(#56403)
add 4e4b2966923 [improvement](timezone) Set the default value of the
timezone in streamload to global time_zone (#56365)
add 086eb62d6ad [feat](ObjectStorage)Relax endpoint validation for private
object storage (#56579)
add 7f4daa287ef [feat](snapshot) recycle support abort multipart upload
(#56628)
add 381fe9e7977 [fix](cloud) Fix e-230 not retry in cloud (#56567)
add 9ef11f02f11 [fix](cloud) Fix domain user set default cluster report
err (#56032)
add b4260872c4d [chore](cloud) Add enable_multi_version_status &
enable_cluster_snapshot config (#56614)
add 3f3b2a0c4c8 [fix](profile) add SafeStringBuilder to avoid OOM in
profile building​ (#56545)
add 6ac1cbd5d86 [feat](snapshot) record upload id in snapshot (#56626)
add 379ed80c61b [feat](snapshot) fe support multi part upload (#56487)
add d25a7ff31ff [feat](cloud) Add check mvcc meta rowset key for checker
(#56463)
add afccfd74213 [Enhancement](nereids) optimize tableRefInfo and move
TableNameInfo, ParititionNamesInfo to public package (#56305)
add 5e94158f309 [chore](test) Only fuzzy spill variables in P0 tests
(#56554)
add 8889c7491ed [metrics](ann index) Metrics for in-memory ann index
(#56649)
add 0894906e720 [opt](inverted index) update clucene version (#56624)
add 9e28f007441 [fix](range search) Fix ann range search prepare failed
(#56621)
add e200cd71ed7 [fix](load)fix the error msg with stack (#56640)
add 289e6283531 [fix](func)fix for nested type in function param which has
datetime or decimal (#56625)
add 0ea052c42a9 [fix] remove useless const_cast and explain const_cast for
vec (1) (#56587)
add 5331b4bd977 [opt](inverted index) add BitmapQuery for boolean query
composition (#56408)
add fd55055e06f [fix](case)fix unstable external pipeline case. (#56618)
add bc4427db28e [chore](github)Add branch protection rules for the 4.0
branch (#56674)
add 64bfb86f3e4 [fix](filecache) flaky test_lru_persist regression (#56650)
add 9cb7ba8daf8 [Fix](warmup) Fix wrongly skip download task for warmup
job when rowsets have multi segments (#56663)
add 8e53a731ec8 [fix](schema_change) fix incorrect cache usage of schema
change expr leading to schema errors (#56602)
add 9acfc53add1 [fix](cloud-ut)fix bvar kv test count error (#56666)
add cc36b378c19 [bugfix](counter) fix read uncompressed counter is wrong
(#56677)
add 53b9434f085 [fix](regression) fix regression (#56676)
add 9584ce3bd4e [feature](inverted index) introduce search function for
inverted index (#56139)
add c76ff7b61b8 [opt](catalog) support nested namespaces of iceberg
(#56415)
add 3b0e67fd881 [Chore](runtime-filter) add more rf merger info to debug
string and add release_undone_filters logic (#56632)
add 34a27a375b2 [fix](inverted index) Fix NULL bitmap handling in MATCH OR
queries (#56699)
add 155cd67531d [fix](search) add restriction for search function (#56706)
add a3d1080e87d [test](search) add more regression case (#56704)
add 300dc60c864 [feature](search) add exact dsl for search function
(#56710)
add aca98e160ab [fix](mulit-az) fix missing virtual CG to physical CG
routing bug (#56678)
add e80eaf6c540 [fix](nereids) fix copy into fail when enable debug log
(#56698)
add a5b03d3f792 [fix](groupcommit) remove NDEBUG for groupcommit's memory
tracker (#56577)
add 9d1e2dc4831 [fix](case) do not use same table name (#56714)
add 50b4c42a184 [fix](test) check cloud mode in enableStorageVault (#56709)
add b9c48f4c51b [feat][iceberg] Support Iceberg Meta Procedure
implementations (#56257)
add e52956bb3e4 [fix](shuffle) EOF iff all channels done (#56731)
new e1d5c5f566a add rec cte thrift struct
new c61af12899e update thrift
new 23c6411a6ff update thrift
new 0f6b521d78e add result_expr_lists to TRecCTENode
new a70802f8897 add TRecCTEScanNode
new 8237d8267b0 recursive cte fe part
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 (bbd6cb02964)
\
N -- N -- N refs/heads/dev_rec (8237d8267b0)
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 6 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:
.asf.yaml | 23 +
.gitattributes | 2 +-
.github/workflows/auto-cherry-pick.yml | 28 +-
.github/workflows/comment-to-trigger-teamcity.yml | 24 +-
be/CMakeLists.txt | 4 -
be/src/agent/task_worker_pool.cpp | 38 +-
be/src/cloud/cloud_meta_mgr.cpp | 36 +-
be/src/cloud/cloud_meta_mgr.h | 5 +
be/src/cloud/cloud_schema_change_job.cpp | 14 +-
be/src/cloud/cloud_snapshot_mgr.cpp | 2 +-
be/src/cloud/cloud_tablet.cpp | 11 +-
be/src/cloud/cloud_warm_up_manager.cpp | 84 +-
be/src/cloud/cloud_warm_up_manager.h | 6 +
be/src/cloud/config.cpp | 2 +
be/src/cloud/config.h | 2 +
be/src/cloud/pb_convert.cpp | 12 +
be/src/common/config.cpp | 2 +-
be/src/common/config.h | 2 +-
be/src/exec/decompressor.cpp | 36 +-
be/src/exec/rowid_fetcher.cpp | 201 +-
be/src/exec/rowid_fetcher.h | 7 +-
be/src/exec/schema_scanner.cpp | 6 +
.../schema_cluster_snapshot_properties_scanner.cpp | 102 +
.../schema_cluster_snapshot_properties_scanner.h} | 44 +-
.../schema_cluster_snapshots_scanner.cpp | 269 ++
.../schema_cluster_snapshots_scanner.h} | 43 +-
.../exec/schema_scanner/schema_scanner_helper.cpp | 2 +-
be/src/exec/schema_scanner/schema_scanner_helper.h | 5 +-
.../exec/schema_scanner/schema_tablets_scanner.cpp | 11 +-
be/src/http/action/http_stream.cpp | 1 +
be/src/http/action/stream_load.cpp | 42 +-
be/src/http/http_common.h | 1 +
be/src/io/cache/block_file_cache.cpp | 12 +
be/src/io/cache/block_file_cache.h | 6 +-
be/src/io/cache/file_cache_lru_tool.cpp | 1 -
be/src/io/fs/buffered_reader.cpp | 4 +-
be/src/io/fs/buffered_reader.h | 11 +-
be/src/io/fs/s3_file_writer.cpp | 1 +
be/src/io/tools/file_cache_microbench.cpp | 97 +-
be/src/olap/base_tablet.cpp | 27 +-
be/src/olap/cumulative_compaction_policy.cpp | 8 +-
be/src/olap/cumulative_compaction_policy.h | 5 +-
.../cumulative_compaction_time_series_policy.cpp | 8 +-
.../cumulative_compaction_time_series_policy.h | 3 +-
be/src/olap/data_dir.cpp | 4 +-
be/src/olap/field.h | 4 +
be/src/olap/in_list_predicate.h | 6 +
be/src/olap/iterators.h | 4 -
be/src/olap/olap_server.cpp | 2 +-
be/src/olap/rowset/rowset_meta.h | 3 +-
.../olap/rowset/segment_v2/ann_index/ann_index.cpp | 9 +
.../olap/rowset/segment_v2/ann_index/ann_index.h | 3 +-
.../segment_v2/ann_index/faiss_ann_index.cpp | 13 +-
.../rowset/segment_v2/ann_index/faiss_ann_index.h | 2 +
be/src/olap/rowset/segment_v2/column_reader.h | 1 +
.../{scorer.h => bitmap_query/bitmap_query.h} | 33 +-
.../query_v2/bitmap_query/bitmap_scorer.h | 96 +
.../query_v2/bitmap_query/bitmap_weight.h | 49 +
.../query_v2/boolean_query/boolean_query.h | 26 +-
.../query_v2/boolean_query/boolean_weight.h | 244 +-
.../query_v2/buffered_union_scorer.cpp | 327 +-
.../query_v2/buffered_union_scorer.h | 71 +-
.../inverted_index/query_v2/composite_reader.h | 25 +-
.../query_v2/intersection_scorer.cpp | 362 +-
.../inverted_index/query_v2/intersection_scorer.h | 78 +-
.../query_v2/match_all_docs_scorer.h | 100 +
.../segment_v2/inverted_index/query_v2/scorer.h | 34 +-
.../query_v2/term_query/term_query.h | 13 +-
.../query_v2/term_query/term_scorer.h | 64 +-
.../query_v2/term_query/term_weight.h | 59 +-
.../segment_v2/inverted_index/query_v2/weight.h | 27 +-
.../rowset/segment_v2/inverted_index_iterator.cpp | 14 +-
.../rowset/segment_v2/inverted_index_iterator.h | 7 +-
.../rowset/segment_v2/inverted_index_query_type.h | 22 +-
.../olap/rowset/segment_v2/inverted_index_reader.h | 12 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 2 +-
be/src/olap/rowset/segment_v2/segment.cpp | 37 +-
be/src/olap/rowset/segment_v2/segment.h | 10 +-
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 68 +-
be/src/olap/rowset/segment_v2/segment_iterator.h | 3 +
.../variant/sparse_column_extract_iterator.h | 84 +-
.../variant/sparse_column_merge_iterator.cpp | 9 +-
.../variant/sparse_column_merge_iterator.h | 18 +-
.../segment_v2/variant/variant_column_reader.cpp | 67 +-
.../segment_v2/variant/variant_column_reader.h | 132 +-
be/src/olap/tablet.cpp | 25 +-
be/src/olap/tablet.h | 2 +-
be/src/olap/tablet_meta.cpp | 107 +-
be/src/olap/tablet_meta.h | 36 +-
be/src/olap/task/engine_clone_task.cpp | 2 +-
be/src/olap/version_graph.cpp | 199 +-
be/src/olap/version_graph.h | 225 +-
be/src/pipeline/dependency.cpp | 2 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 3 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 15 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 11 +-
.../exec/group_commit_block_sink_operator.cpp | 6 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 4 +-
.../pipeline/exec/partition_sort_sink_operator.h | 6 +-
be/src/pipeline/exec/union_sink_operator.cpp | 7 +-
be/src/pipeline/pipeline.cpp | 4 +-
be/src/pipeline/pipeline.h | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 80 +-
be/src/pipeline/pipeline_fragment_context.h | 38 +-
be/src/pipeline/pipeline_task.cpp | 16 +-
be/src/pipeline/pipeline_task.h | 6 +-
be/src/runtime/exec_env.h | 2 +-
be/src/runtime/exec_env_init.cpp | 4 +-
be/src/runtime/fold_constant_executor.cpp | 30 +-
be/src/runtime/fragment_mgr.cpp | 38 +-
be/src/runtime/fragment_mgr.h | 1 +
be/src/runtime/query_context.cpp | 5 +
.../routine_load/routine_load_task_executor.cpp | 19 +
be/src/runtime/runtime_state.cpp | 31 +-
be/src/runtime/runtime_state.h | 8 +-
be/src/runtime/stream_load/stream_load_context.cpp | 4 +-
.../runtime/stream_load/stream_load_executor.cpp | 1 +
be/src/runtime_filter/runtime_filter.h | 2 +-
be/src/runtime_filter/runtime_filter_mgr.cpp | 186 +-
be/src/runtime_filter/runtime_filter_mgr.h | 11 +
be/src/util/bitmap_expr_calculation.h | 13 +-
be/src/util/block_compression.cpp | 5 +-
be/src/util/counts.h | 7 +-
be/src/util/datetype_cast.hpp | 114 -
be/src/util/doris_metrics.cpp | 11 +
be/src/util/doris_metrics.h | 5 +
be/src/util/jni-util.cpp | 28 +-
be/src/util/jni_native_method.cpp | 85 +-
be/src/util/jni_native_method.h | 11 +-
be/src/util/jsonb_document.cpp | 22 +-
be/src/util/jsonb_document.h | 92 +-
be/src/util/load_util.cpp | 4 +-
be/src/util/quantile_state.cpp | 2 +-
be/src/util/quantile_state.h | 2 +-
be/src/util/string_parser.hpp | 6 +-
be/src/util/uid_util.cpp | 11 +
be/src/util/url_parser.cpp | 2 +-
.../vec/aggregate_functions/aggregate_function.h | 4 +
.../aggregate_function_ai_agg.h | 17 +
.../aggregate_functions/aggregate_function_avg.h | 19 +-
.../aggregate_function_bitmap.h | 12 +-
.../aggregate_function_distinct.h | 3 +
.../aggregate_function_group_array_intersect.h | 9 +-
.../aggregate_function_histogram.cpp | 9 +-
.../aggregate_function_java_udaf.h | 3 +-
.../aggregate_function_orthogonal_bitmap.h | 11 +-
.../aggregate_function_percentile.h | 4 +-
.../aggregate_function_percentile_reservoir.h | 2 +
.../aggregate_function_quantile_state.h | 8 +-
.../aggregate_functions/aggregate_function_rpc.h | 6 +
.../aggregate_function_sequence_match.h | 3 +
.../aggregate_functions/aggregate_function_sort.h | 1 +
.../aggregate_functions/aggregate_function_sum.h | 11 +-
.../aggregate_function_window_funnel.h | 2 +
be/src/vec/columns/column_varbinary.cpp | 15 -
be/src/vec/columns/column_varbinary.h | 4 -
be/src/vec/columns/column_vector.h | 6 +-
be/src/vec/core/block.cpp | 79 +
be/src/vec/core/block.h | 4 +
be/src/vec/core/column_with_type_and_name.cpp | 13 +-
be/src/vec/core/column_with_type_and_name.h | 2 +-
be/src/vec/data_types/data_type.cpp | 36 +-
be/src/vec/data_types/data_type.h | 18 +-
be/src/vec/data_types/data_type_agg_state.h | 13 -
be/src/vec/data_types/data_type_array.cpp | 57 -
be/src/vec/data_types/data_type_array.h | 3 -
be/src/vec/data_types/data_type_bitmap.cpp | 12 -
be/src/vec/data_types/data_type_bitmap.h | 10 -
be/src/vec/data_types/data_type_date.cpp | 35 -
be/src/vec/data_types/data_type_date.h | 13 +-
.../data_types/data_type_date_or_datetime_v2.cpp | 95 +-
.../vec/data_types/data_type_date_or_datetime_v2.h | 48 +-
be/src/vec/data_types/data_type_date_time.cpp | 47 -
be/src/vec/data_types/data_type_date_time.h | 25 +-
be/src/vec/data_types/data_type_decimal.cpp | 67 -
be/src/vec/data_types/data_type_decimal.h | 7 +-
be/src/vec/data_types/data_type_factory.cpp | 3 +
be/src/vec/data_types/data_type_hll.cpp | 14 -
be/src/vec/data_types/data_type_hll.h | 3 -
be/src/vec/data_types/data_type_ipv4.cpp | 28 -
be/src/vec/data_types/data_type_ipv4.h | 10 -
be/src/vec/data_types/data_type_ipv6.cpp | 25 -
be/src/vec/data_types/data_type_ipv6.h | 11 -
be/src/vec/data_types/data_type_jsonb.cpp | 22 -
be/src/vec/data_types/data_type_jsonb.h | 3 -
be/src/vec/data_types/data_type_map.cpp | 45 -
be/src/vec/data_types/data_type_map.h | 2 -
be/src/vec/data_types/data_type_nullable.cpp | 31 +-
be/src/vec/data_types/data_type_nullable.h | 2 -
be/src/vec/data_types/data_type_number.cpp | 57 -
be/src/vec/data_types/data_type_number.h | 8 -
be/src/vec/data_types/data_type_number_base.cpp | 54 +-
be/src/vec/data_types/data_type_number_base.h | 37 +-
be/src/vec/data_types/data_type_quantilestate.cpp | 10 -
be/src/vec/data_types/data_type_quantilestate.h | 5 -
be/src/vec/data_types/data_type_string.cpp | 18 -
be/src/vec/data_types/data_type_string.h | 3 -
be/src/vec/data_types/data_type_struct.cpp | 35 -
be/src/vec/data_types/data_type_struct.h | 2 -
be/src/vec/data_types/data_type_time.cpp | 26 +-
be/src/vec/data_types/data_type_time.h | 18 +-
be/src/vec/data_types/data_type_varbinary.cpp | 18 -
be/src/vec/data_types/data_type_varbinary.h | 3 -
be/src/vec/data_types/data_type_variant.cpp | 12 -
be/src/vec/data_types/data_type_variant.h | 2 -
.../data_types/serde/data_type_bitmap_serde.cpp | 11 +
.../vec/data_types/serde/data_type_bitmap_serde.h | 2 +
.../vec/data_types/serde/data_type_hll_serde.cpp | 8 +
be/src/vec/data_types/serde/data_type_hll_serde.h | 2 +
.../data_types/serde/data_type_nullable_serde.cpp | 6 +-
.../serde/data_type_quantilestate_serde.h | 7 +
.../data_types/serde/data_type_varbinary_serde.cpp | 6 +
.../data_types/serde/data_type_varbinary_serde.h | 2 +
be/src/vec/exec/format/json/new_json_reader.cpp | 2 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 13 +-
be/src/vec/exec/jni_connector.cpp | 31 +-
be/src/vec/exec/scan/file_scanner.cpp | 23 +-
be/src/vec/exec/scan/olap_scanner.cpp | 26 +-
be/src/vec/exec/scan/olap_scanner.h | 3 +
be/src/vec/exprs/vcast_expr.cpp | 132 +-
be/src/vec/exprs/vcast_expr.h | 37 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 154 +-
be/src/vec/exprs/vexpr.cpp | 13 +-
be/src/vec/exprs/vexpr.h | 3 +-
be/src/vec/exprs/vsearch.cpp | 170 +
.../function_convert_tz.cpp => exprs/vsearch.h} | 32 +-
be/src/vec/exprs/vtopn_pred.h | 45 +
be/src/vec/functions/ai/ai_adapter.h | 188 +-
be/src/vec/functions/ai/ai_functions.h | 6 +-
be/src/vec/functions/array/function_array_nary.h | 2 +-
.../vec/functions/array/function_array_range.cpp | 2 +-
be/src/vec/functions/cast/cast_to_date.h | 55 +-
.../cast/cast_to_date_or_datetime_impl.hpp | 11 +-
.../vec/functions/cast/cast_to_datetimev2_impl.hpp | 10 +-
be/src/vec/functions/cast/cast_to_datev2_impl.hpp | 10 +-
be/src/vec/functions/cast/cast_to_time_impl.hpp | 5 +-
be/src/vec/functions/cast/function_cast.cpp | 6 +-
be/src/vec/functions/date_time_transforms.h | 192 +-
be/src/vec/functions/datetime_errors.h | 130 +
be/src/vec/functions/function.cpp | 112 +-
be/src/vec/functions/function.h | 19 +-
be/src/vec/functions/function_convert_tz.cpp | 302 +-
be/src/vec/functions/function_convert_tz.h | 358 --
.../function_date_or_datetime_computation.h | 203 +-
.../function_date_or_datetime_to_something.h | 72 +-
.../function_date_or_datetime_to_string.cpp | 90 +-
.../function_date_or_datetime_to_string.h | 112 -
.../vec/functions/function_datetime_floor_ceil.cpp | 444 ++-
.../functions/function_datetime_string_to_string.h | 85 +-
be/src/vec/functions/function_hash.cpp | 12 +
be/src/vec/functions/function_hex.cpp | 29 +-
be/src/vec/functions/function_java_udf.cpp | 46 +-
be/src/vec/functions/function_java_udf.h | 3 +
be/src/vec/functions/function_jsonb.cpp | 291 +-
...estamp.cpp => function_other_types_to_date.cpp} | 819 ++---
be/src/vec/functions/function_search.cpp | 599 ++++
be/src/vec/functions/function_search.h | 176 +
be/src/vec/functions/function_size.cpp | 6 +-
be/src/vec/functions/function_string.cpp | 137 +-
be/src/vec/functions/function_string.h | 268 +-
be/src/vec/functions/function_varbinary.cpp | 153 +
be/src/vec/functions/functions_comparison.h | 4 +-
be/src/vec/functions/functions_geo.cpp | 2 +-
be/src/vec/functions/minus.cpp | 2 +-
be/src/vec/functions/simple_function_factory.h | 9 +-
be/src/vec/functions/string_hex_util.h | 84 +
be/src/vec/functions/time_of_function.cpp | 4 -
be/src/vec/olap/vcollect_iterator.cpp | 4 -
be/src/vec/runtime/time_value.h | 17 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 27 +
be/src/vec/runtime/vdata_stream_recvr.h | 2 +
be/src/vec/runtime/vdatetime_value.h | 15 +-
be/src/vec/sink/tablet_sink_hash_partitioner.cpp | 4 +-
be/src/vec/sink/vdata_stream_sender.cpp | 13 +
be/src/vec/sink/vdata_stream_sender.h | 1 +
be/src/vec/sink/vrow_distribution.cpp | 5 +-
be/src/vec/sink/vrow_distribution.h | 2 +-
be/src/vec/sink/vtablet_block_convertor.cpp | 70 +-
be/src/vec/sink/vtablet_block_convertor.h | 11 +-
be/src/vec/sink/vtablet_finder.cpp | 4 +-
be/src/vec/sink/writer/vmysql_table_writer.cpp | 21 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 4 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 4 +-
be/src/vec/utils/util.hpp | 14 +
be/test/ai/aggregate_function_ai_agg_test.cpp | 80 +
be/test/ai/ai_adapter_test.cpp | 99 +-
be/test/ai/embed_test.cpp | 6 +-
be/test/cloud/cloud_meta_mgr_test.cpp | 22 +-
...ma_cluster_snapshot_properties_scanner_test.cpp | 50 +
.../schema_cluster_snapshots_scanner_test.cpp | 67 +
.../test_data/parquet_scanner/dict-decoder.txt | 32 +-
.../test_data/parquet_scanner/type-decoder.txt | 28 +-
...mev2_0_to_string.out => TimeV2_0_to_string.out} | 0
..._0_to_string_2.out => TimeV2_0_to_string_2.out} | 0
..._0_to_string_3.out => TimeV2_0_to_string_3.out} | 0
...ring_batch.out => TimeV2_0_to_string_batch.out} | 0
...mev2_5_to_string.out => TimeV2_5_to_string.out} | 0
..._5_to_string_2.out => TimeV2_5_to_string_2.out} | 0
..._5_to_string_3.out => TimeV2_5_to_string_3.out} | 0
...ring_batch.out => TimeV2_5_to_string_batch.out} | 0
...mev2_6_to_string.out => TimeV2_6_to_string.out} | 0
..._6_to_string_2.out => TimeV2_6_to_string_2.out} | 0
..._6_to_string_3.out => TimeV2_6_to_string_3.out} | 0
...ring_batch.out => TimeV2_6_to_string_batch.out} | 0
.../vec/data_types/timev2_to_string.out | 28 -
.../vec/data_types/timev2_to_string_2.out | 28 -
.../vec/data_types/timev2_to_string_3.out | 28 -
.../vec/data_types/timev2_to_string_batch.out | 28 -
.../compaction_delete_bitmap_calculator_test.cpp | 4 +-
be/test/olap/delete_handler_test.cpp | 2 +-
.../inverted_index/query_v2/boolean_query_test.cpp | 325 +-
.../query_v2/buffered_union_scorer_test.cpp | 224 ++
.../query_v2/intersection_scorer_test.cpp | 253 ++
.../segment_v2/inverted_index_reader_test.cpp | 102 +
.../variant_column_writer_reader_test.cpp | 24 +-
.../olap/vector_search/ann_range_search_test.cpp | 2 +-
.../operator/streaming_agg_operator_test.cpp | 6 +-
be/test/vec/columns/column_varbinary_test.cpp | 20 -
be/test/vec/columns/common_column_test.h | 101 +-
be/test/vec/core/block_test.cpp | 19 +
.../vec/core/column_with_type_and_name_test.cpp | 7 +-
be/test/vec/data_types/data_type_bitmap_test.cpp | 49 -
..._v2_test.cpp => data_type_datetime_v2_test.cpp} | 0
be/test/vec/data_types/data_type_hll_test.cpp | 49 -
.../data_types/data_type_quantile_state_test.cpp | 32 -
be/test/vec/data_types/data_type_struct_test.cpp | 2 +-
.../serde/data_type_from_string_test.cpp | 6 +-
.../data_types/serde/data_type_to_string_test.cpp | 8 +-
.../serde/data_type_write_to_jsonb_test.cpp | 12 +-
.../exec/format/parquet/parquet_thrift_test.cpp | 2 +
be/test/vec/exprs/try_cast_expr_test.cpp | 247 ++
be/test/vec/exprs/vsearch_expr_test.cpp | 1395 ++++++++
be/test/vec/function/cast/cast_to_date_test.cpp | 7 +-
.../vec/function/cast/cast_to_datetime_test.cpp | 8 +-
be/test/vec/function/cast/cast_to_string.cpp | 2 +-
be/test/vec/function/function_convert_tz_test.cpp | 59 -
be/test/vec/function/function_hash_test.cpp | 58 +
be/test/vec/function/function_jsonb_test.cpp | 85 +-
be/test/vec/function/function_search_test.cpp | 1686 ++++++++++
be/test/vec/function/function_string_test.cpp | 124 +
be/test/vec/function/function_test_util.cpp | 40 +-
be/test/vec/function/function_test_util.h | 4 +-
.../vec/function/function_throw_exception_test.cpp | 38 +
be/test/vec/function/function_time_test.cpp | 663 ++--
be/test/vec/jsonb/jsonb_document_test.cpp | 66 +
bin/start_be.sh | 6 +-
build.sh | 6 -
cloud/script/start.sh | 7 +-
cloud/src/common/bvars.cpp | 24 +
cloud/src/common/bvars.h | 368 +++
cloud/src/common/config.h | 12 +
cloud/src/meta-service/meta_service.cpp | 167 +-
cloud/src/meta-service/meta_service.h | 28 +
cloud/src/meta-service/meta_service_helper.h | 4 +-
cloud/src/meta-service/meta_service_http.cpp | 151 +
cloud/src/meta-service/meta_service_job.cpp | 36 +-
cloud/src/meta-service/meta_service_partition.cpp | 13 +-
cloud/src/meta-service/meta_service_resource.cpp | 217 +-
cloud/src/meta-service/meta_service_snapshot.cpp | 44 +-
.../src/meta-service/meta_service_tablet_stats.cpp | 4 +-
cloud/src/meta-service/meta_service_tablet_stats.h | 4 +-
cloud/src/meta-service/meta_service_txn.cpp | 168 +-
cloud/src/meta-service/txn_lazy_committer.cpp | 18 +-
cloud/src/meta-service/txn_lazy_committer.h | 5 +
cloud/src/meta-store/CMakeLists.txt | 1 +
cloud/src/meta-store/clone_chain_reader.cpp | 1249 +++++++
.../{meta_reader.h => clone_chain_reader.h} | 129 +-
cloud/src/meta-store/keys.cpp | 13 +-
cloud/src/meta-store/keys.h | 8 +
cloud/src/meta-store/mem_txn_kv.cpp | 4 +-
cloud/src/meta-store/meta_reader.cpp | 209 +-
cloud/src/meta-store/meta_reader.h | 52 +-
cloud/src/recycler/checker.cpp | 46 +-
cloud/src/recycler/checker.h | 22 +
cloud/src/recycler/checker_snapshot.cpp | 88 +
cloud/src/recycler/hdfs_accessor.cpp | 7 +
cloud/src/recycler/hdfs_accessor.h | 2 +
cloud/src/recycler/obj_storage_client.h | 3 +
cloud/src/recycler/recycler.cpp | 43 +-
cloud/src/recycler/recycler.h | 10 +-
cloud/src/recycler/s3_accessor.cpp | 17 +
cloud/src/recycler/s3_accessor.h | 2 +
cloud/src/recycler/s3_obj_client.cpp | 24 +
cloud/src/recycler/s3_obj_client.h | 3 +
cloud/src/recycler/storage_vault_accessor.h | 2 +
cloud/src/resource-manager/resource_manager.cpp | 40 +-
cloud/src/resource-manager/resource_manager.h | 8 +
cloud/src/snapshot/snapshot_manager.cpp | 76 +
cloud/src/snapshot/snapshot_manager.h | 21 +
cloud/test/CMakeLists.txt | 10 +
cloud/test/bvars_test.cpp | 129 +
cloud/test/clone_chain_reader_test.cpp | 2133 ++++++++++++
cloud/test/keys_test.cpp | 52 +
cloud/test/meta_reader_test.cpp | 140 +
cloud/test/meta_service_job_test.cpp | 224 ++
cloud/test/meta_service_test.cpp | 326 +-
cloud/test/meta_service_versioned_read_test.cpp | 31 +-
cloud/test/mock_accessor.h | 7 +
cloud/test/recycle_versioned_keys_test.cpp | 148 +-
cloud/test/recycler_test.cpp | 57 +
cloud/test/rpc_kv_bvar_test.cpp | 78 +
contrib/clucene | 2 +-
.../be/resource/be_disaggregated_entrypoint.sh | 1 +
docker/runtime/be/resource/be_entrypoint.sh | 1 +
.../fe/resource/fe_disaggregated_entrypoint.sh | 1 +
docker/runtime/fe/resource/fe_entrypoint.sh | 1 +
.../ms/resource/ms_disaggregated_entrypoint.sh | 1 +
.../elasticsearch/scripts/es_init.sh | 2 +
.../scripts/index/es7_test_object.json | 16 +
.../scripts/create_preinstalled_scripts/run81.hql | 48 +
.../create_preinstalled_scripts/iceberg/run20.sql | 2 +
.../create_preinstalled_scripts/paimon/run09.sql | 24 +-
.../docker-compose/mysql/init/03-create-table.sql | 4 +
.../docker-compose/mysql/init/04-insert.sql | 1 +
.../doris/iceberg/IcebergSysTableJniScanner.java | 60 +-
.../doris/common/jni/utils/JNINativeMethod.java | 17 +-
.../doris/common/jni/utils/JavaUdfDataType.java | 5 +
.../org/apache/doris/common/jni/utils/OffHeap.java | 42 +
.../apache/doris/common/jni/vec/ColumnType.java | 9 +-
.../apache/doris/common/jni/vec/VectorColumn.java | 129 +-
.../java/org/apache/doris/udf/BaseExecutor.java | 44 +
.../org/apache/doris/jdbc/BaseJdbcExecutor.java | 6 +-
.../java/org/apache/doris/catalog/ScalarType.java | 4 +-
.../main/java/org/apache/doris/catalog/Type.java | 1 +
.../main/java/org/apache/doris/common/Config.java | 11 +
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 7 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 31 +-
.../org/apache/doris/nereids/search/SearchLexer.g4 | 95 +
.../apache/doris/nereids/search/SearchParser.g4 | 52 +
.../ConfigurationAWSCredentialsProvider.java | 23 +-
.../amazonaws/glue/catalog/util/AWSGlueConfig.java | 2 +
.../main/java/org/apache/doris/alter/Alter.java | 2 +-
.../java/org/apache/doris/alter/RollupJobV2.java | 11 +-
.../apache/doris/alter/SchemaChangeHandler.java | 3 +-
.../org/apache/doris/alter/SchemaChangeJobV2.java | 10 +-
.../analysis/AbstractBackupTableRefClause.java | 15 +-
.../org/apache/doris/analysis/BaseViewStmt.java | 75 -
.../apache/doris/analysis/BuildIndexClause.java | 2 +-
.../java/org/apache/doris/analysis/CastExpr.java | 11 +-
.../org/apache/doris/analysis/CreateMTMVStmt.java | 69 -
.../org/apache/doris/analysis/CreateTableStmt.java | 377 ---
.../main/java/org/apache/doris/analysis/Expr.java | 6 +
.../java/org/apache/doris/analysis/IndexDef.java | 2 +-
.../apache/doris/analysis/InvertedIndexUtil.java | 2 +-
.../org/apache/doris/analysis/LateralViewRef.java | 50 -
.../org/apache/doris/analysis/LockTablesStmt.java | 81 -
.../apache/doris/analysis/PartitionExprUtil.java | 6 +-
.../doris/analysis/ReplacePartitionClause.java | 2 +-
.../org/apache/doris/analysis/SchemaTableType.java | 5 +-
.../org/apache/doris/analysis/SearchPredicate.java | 312 ++
.../java/org/apache/doris/analysis/SlotRef.java | 2 +-
.../java/org/apache/doris/analysis/TableRef.java | 34 -
.../org/apache/doris/analysis/TryCastExpr.java | 137 +
.../org/apache/doris/analysis/TupleDescriptor.java | 9 +-
.../java/org/apache/doris/analysis/UseStmt.java | 86 -
.../org/apache/doris/backup/BackupHandler.java | 6 +-
.../java/org/apache/doris/backup/BackupJob.java | 2 +-
.../org/apache/doris/backup/BackupJobInfo.java | 4 +-
.../doris/catalog/BuiltinScalarFunctions.java | 18 +-
.../java/org/apache/doris/catalog/Database.java | 29 +
.../main/java/org/apache/doris/catalog/Env.java | 22 +-
.../java/org/apache/doris/catalog/EnvFactory.java | 8 +
.../doris/catalog/InternalSchemaInitializer.java | 2 +-
.../org/apache/doris/catalog/MetadataViewer.java | 2 +-
.../RecursiveCteTempTable.java} | 12 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 22 +
.../java/org/apache/doris/catalog/TableIf.java | 10 +-
.../doris/cloud/analysis/UseCloudClusterStmt.java | 109 -
.../doris/cloud/catalog/CloudEnvFactory.java | 9 +
.../cloud/catalog/CloudInstanceStatusChecker.java | 35 +-
.../apache/doris/cloud/catalog/CloudReplica.java | 26 +-
.../doris/cloud/catalog/CloudTabletRebalancer.java | 6 +-
.../doris/cloud/load/CopyLoadPendingTask.java | 5 +
.../apache/doris/cloud/rpc/MetaServiceClient.java | 11 +
.../apache/doris/cloud/rpc/MetaServiceProxy.java | 9 +
.../doris/cloud/snapshot/CloudSnapshotHandler.java | 12 +
.../apache/doris/cloud/storage/AzureRemote.java | 9 +
.../apache/doris/cloud/storage/DefaultRemote.java | 147 +
.../org/apache/doris/cloud/storage/MockRemote.java | 8 +
.../org/apache/doris/cloud/storage/RemoteBase.java | 11 +
.../transaction/CloudGlobalTransactionMgr.java | 14 +
.../apache/doris/cloud/transaction/TxnUtil.java | 37 +
.../java/org/apache/doris/common/FeNameFormat.java | 26 +-
.../doris/common/cache/NereidsSqlCacheManager.java | 10 +-
.../apache/doris/common/proc/BackendsProcDir.java | 5 +-
.../doris/common/profile/ExecutionProfile.java | 5 +-
.../org/apache/doris/common/profile/Profile.java | 36 +-
.../doris/common/profile/ProfileManager.java | 25 +-
.../doris/common/profile/RuntimeProfile.java | 29 +-
.../doris/common/profile/SummaryProfile.java | 49 +-
.../java/org/apache/doris/common/util/S3Util.java | 59 +
.../doris/common/util/SafeStringBuilder.java | 79 +
.../java/org/apache/doris/common/util/Util.java | 4 +
.../org/apache/doris/datasource/CatalogIf.java | 2 +-
.../apache/doris/datasource/ExternalCatalog.java | 2 +-
.../apache/doris/datasource/FileQueryScanNode.java | 2 +-
.../apache/doris/datasource/InternalCatalog.java | 2 +-
.../org/apache/doris/datasource/es/EsUtil.java | 2 +
.../doris/datasource/hive/source/HiveScanNode.java | 3 +
.../iceberg/IcebergDLFExternalCatalog.java | 2 +-
.../datasource/iceberg/IcebergMetadataOps.java | 74 +-
.../iceberg/action/BaseIcebergAction.java | 2 +-
.../action/IcebergCherrypickSnapshotAction.java | 47 +-
.../action/IcebergExpireSnapshotsAction.java | 2 +-
.../iceberg/action/IcebergFastForwardAction.java | 52 +-
.../action/IcebergOptimizeActionFactory.java | 2 +-
.../action/IcebergRewriteDataFilesAction.java | 2 +-
.../action/IcebergRollbackToSnapshotAction.java | 49 +-
.../action/IcebergRollbackToTimestampAction.java | 56 +-
.../action/IcebergSetCurrentSnapshotAction.java | 75 +-
.../datasource/iceberg/source/IcebergScanNode.java | 17 +-
.../datasource/paimon/PaimonExternalTable.java | 27 +-
.../apache/doris/datasource/paimon/PaimonUtil.java | 221 +-
.../datasource/paimon/source/PaimonScanNode.java | 36 +-
.../doris/datasource/property/ParamRules.java | 51 +
.../fileformat/JsonFileFormatProperties.java | 18 +-
.../metastore/AWSGlueMetaStoreBaseProperties.java | 18 +-
.../metastore/HMSGlueMetaStoreProperties.java | 16 +-
.../metastore/IcebergGlueMetaStoreProperties.java | 32 +-
.../property/metastore/IcebergRestProperties.java | 7 +-
.../storage/AbstractS3CompatibleProperties.java | 48 +-
.../property/storage/HdfsPropertiesUtils.java | 12 +-
.../datasource/property/storage/OSSProperties.java | 13 +-
.../datasource/property/storage/S3Properties.java | 34 +-
.../doris/datasource/systable/IcebergSysTable.java | 6 +-
.../doris/datasource/systable/PaimonSysTable.java | 6 +-
.../datasource/systable/PartitionsSysTable.java | 6 +-
.../apache/doris/datasource/systable/SysTable.java | 6 +-
.../datasource/tvf/source/MetadataScanNode.java | 1 +
.../main/java/org/apache/doris/fs/FileSystem.java | 14 +
.../LockTableInfo.java => fs/GlobListResult.java} | 54 +-
.../java/org/apache/doris/fs/obj/S3ObjStorage.java | 98 +-
.../org/apache/doris/fs/remote/S3FileSystem.java | 8 +
.../WarmUpItem.java => info/BaseTableRefInfo.java} | 37 +-
.../commands => }/info/PartitionNamesInfo.java | 7 +-
.../plans/commands => }/info/TableNameInfo.java | 55 +-
.../java/org/apache/doris/info/TableRefInfo.java | 189 ++
.../doris/info/TableValuedFunctionRefInfo.java | 80 +
.../doris/insertoverwrite/InsertOverwriteUtil.java | 2 +-
.../org/apache/doris/job/base/AbstractJob.java | 20 +-
.../main/java/org/apache/doris/job/base/Job.java | 7 +
.../doris/job/base/JobExecutionConfiguration.java | 19 +-
.../base/JobProperties.java} | 4 +-
.../org/apache/doris/job/common/FailureReason.java | 71 +
.../org/apache/doris/job/common/JobStatus.java | 12 +-
.../java/org/apache/doris/job/common/TaskType.java | 3 +-
.../doris/job/executor/DispatchTaskHandler.java | 3 +-
.../doris/job/executor/TimerJobSchedulerTask.java | 3 +-
.../doris/job/extensions/insert/InsertJob.java | 35 +-
.../doris/job/extensions/insert/InsertTask.java | 1 +
.../insert/streaming/StreamingInsertJob.java | 530 +++
.../insert/streaming/StreamingInsertTask.java | 247 ++
.../insert/streaming/StreamingJobProperties.java | 94 +
.../streaming/StreamingJobSchedulerTask.java | 159 +
.../insert/streaming/StreamingJobStatistic.java} | 30 +-
.../StreamingTaskTxnCommitAttachment.java | 80 +
.../apache/doris/job/extensions/mtmv/MTMVJob.java | 4 +
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 13 +-
.../org/apache/doris/job/manager/JobManager.java | 73 +-
.../doris/job/manager/StreamingTaskManager.java | 55 +
.../CancelStmt.java => job/offset/Offset.java} | 6 +-
.../doris/job/offset/SourceOffsetProvider.java | 85 +
.../job/offset/SourceOffsetProviderFactory.java | 48 +
.../offset/s3/S3Offset.java} | 31 +-
.../job/offset/s3/S3SourceOffsetProvider.java | 188 ++
.../apache/doris/job/scheduler/JobScheduler.java | 6 +-
.../job/scheduler/StreamingTaskScheduler.java | 117 +
.../main/java/org/apache/doris/load/ExportJob.java | 3 -
.../doris/load/loadv2/BrokerLoadPendingTask.java | 2 +
.../apache/doris/load/loadv2/InsertLoadJob.java | 28 +-
.../org/apache/doris/load/loadv2/LoadManager.java | 58 +-
.../apache/doris/load/loadv2/LoadStatistic.java | 24 +-
.../java/org/apache/doris/master/MasterImpl.java | 8 +-
.../org/apache/doris/master/ReportHandler.java | 13 +-
.../java/org/apache/doris/metric/MetricRepo.java | 357 +-
.../java/org/apache/doris/mtmv/MTMVJobManager.java | 2 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 4 +-
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 26 +
.../java/org/apache/doris/mysql/MysqlProto.java | 58 +-
.../mysql/privilege/AccessControllerManager.java | 2 +-
.../apache/doris/mysql/privilege/UserProperty.java | 18 +-
.../org/apache/doris/nereids/CascadesContext.java | 51 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 13 +-
.../org/apache/doris/nereids/StatementContext.java | 27 +-
.../glue/translator/ExpressionTranslator.java | 36 +
.../glue/translator/PhysicalPlanTranslator.java | 189 +-
.../glue/translator/PlanTranslatorContext.java | 15 +-
.../doris/nereids/jobs/executor/Analyzer.java | 3 +
.../doris/nereids/jobs/executor/Rewriter.java | 2 +
.../nereids/load/NereidsLoadPlanInfoCollector.java | 60 +-
.../nereids/load/NereidsLoadingTaskPlanner.java | 63 +-
.../nereids/load/NereidsStreamLoadPlanner.java | 12 +-
.../doris/nereids/load/NereidsStreamLoadTask.java | 4 +
.../java/org/apache/doris/nereids/memo/Group.java | 10 +-
.../apache/doris/nereids/memo/GroupExpression.java | 2 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 116 +-
.../apache/doris/nereids/pattern/MemoPatterns.java | 24 +
.../post/ProjectAggregateExpressionsForCse.java | 18 +-
.../post/materialize/LazyMaterializeTopN.java | 14 +
.../properties/ChildOutputPropertyDeriver.java | 12 +
.../properties/ChildrenPropertiesRegulator.java | 3 +-
.../org/apache/doris/nereids/rules/RuleSet.java | 4 +
.../org/apache/doris/nereids/rules/RuleType.java | 4 +
.../doris/nereids/rules/analysis/AnalyzeCTE.java | 111 +-
.../nereids/rules/analysis/BindExpression.java | 5 -
.../doris/nereids/rules/analysis/BindRelation.java | 27 +-
.../doris/nereids/rules/analysis/BindSink.java | 4 +-
.../nereids/rules/analysis/CheckSearchUsage.java | 130 +
.../nereids/rules/analysis/CollectRelation.java | 11 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 8 +-
.../nereids/rules/analysis/NormalizeAggregate.java | 19 +-
.../nereids/rules/analysis/SubExprAnalyzer.java | 4 +-
.../mv/AbstractMaterializedViewRule.java | 15 +-
.../rules/expression/ExpressionNormalization.java | 2 -
.../rules/expression/ExpressionOptimization.java | 2 +
.../rules/expression/ExpressionRuleType.java | 16 +-
.../nereids/rules/expression/check/CheckCast.java | 10 +-
.../expression/rules/FoldConstantRuleOnBE.java | 6 +
.../expression/rules/FoldConstantRuleOnFE.java | 11 +
.../expression/rules/JsonFunctionRewrite.java | 177 -
.../rules/expression/rules/PartitionPruner.java | 18 +
.../rules/ReplaceNullWithFalseForCond.java | 131 +
...RecursiveCteScanToPhysicalRecursiveCteScan.java | 42 +
.../LogicalRecursiveCteToPhysicalRecursiveCte.java | 39 +
.../nereids/rules/rewrite/AdjustNullable.java | 17 +
.../doris/nereids/rules/rewrite/CTEInline.java | 31 +-
.../doris/nereids/rules/rewrite/ColumnPruning.java | 106 +
.../rules/rewrite/DistinctAggregateRewriter.java | 2 +-
.../nereids/rules/rewrite/EliminateFilter.java | 38 +-
.../LogicalResultSinkToShortCircuitPointQuery.java | 4 +-
.../rewrite/PushDownFilterThroughSetOperation.java | 65 +-
.../PushDownVirtualColumnsIntoOlapScan.java | 11 +
.../rules/rewrite/RewriteSearchToSlots.java | 157 +
.../doris/nereids/stats/ExpressionEstimation.java | 19 +-
.../doris/nereids/stats/FilterEstimation.java | 24 +
.../doris/nereids/stats/StatsCalculator.java | 29 +
.../trees/copier/LogicalPlanDeepCopier.java | 23 +
.../doris/nereids/trees/expressions/Cast.java | 8 +-
.../nereids/trees/expressions/Placeholder.java | 4 +-
.../trees/expressions/SearchExpression.java | 113 +
.../doris/nereids/trees/expressions/TryCast.java | 99 +
.../{generator => }/RewriteWhenAnalyze.java | 6 +-
.../functions/agg/MultiDistinctCount.java | 30 +-
.../functions/agg/MultiDistinctGroupConcat.java | 26 +-
.../functions/agg/MultiDistinctSum.java | 26 +-
.../functions/agg/MultiDistinctSum0.java | 23 +-
.../functions/agg/MultiDistinction.java | 1 -
.../executable/DateTimeExtractAndTransform.java | 157 +-
.../functions/executable/StringArithmetic.java | 29 +-
.../generator/ExplodeJsonArrayDouble.java | 3 +-
.../generator/ExplodeJsonArrayDoubleOuter.java | 3 +-
.../functions/generator/ExplodeJsonArrayInt.java | 3 +-
.../generator/ExplodeJsonArrayIntOuter.java | 3 +-
.../functions/generator/ExplodeJsonArrayJson.java | 3 +-
.../generator/ExplodeJsonArrayJsonOuter.java | 3 +-
.../generator/ExplodeJsonArrayString.java | 3 +-
.../generator/ExplodeJsonArrayStringOuter.java | 3 +-
.../functions/generator/ExplodeSplit.java | 3 +-
.../functions/generator/ExplodeSplitOuter.java | 3 +-
.../expressions/functions/scalar/ConvertTz.java | 13 +-
.../trees/expressions/functions/scalar/Date.java | 4 +-
.../expressions/functions/scalar/DateFormat.java | 11 +-
.../expressions/functions/scalar/DateTrunc.java | 16 +-
.../trees/expressions/functions/scalar/DateV2.java | 5 +-
.../expressions/functions/scalar/DayCeil.java | 4 +-
.../expressions/functions/scalar/DayFloor.java | 4 +-
.../scalar/{ToDateV2.java => FromBinary.java} | 22 +-
.../expressions/functions/scalar/FromDays.java | 4 +-
.../functions/scalar/FromIso8601Date.java | 5 +-
.../functions/scalar/FromMicrosecond.java | 5 +-
.../functions/scalar/FromMillisecond.java | 5 +-
.../expressions/functions/scalar/FromSecond.java | 5 +-
.../expressions/functions/scalar/FromUnixtime.java | 4 +-
.../expressions/functions/scalar/HourCeil.java | 4 +-
.../expressions/functions/scalar/HourFloor.java | 4 +-
.../trees/expressions/functions/scalar/If.java | 15 +
.../expressions/functions/scalar/JsonArray.java | 16 +-
.../functions/scalar/JsonArrayIgnoreNull.java | 17 +-
.../expressions/functions/scalar/JsonInsert.java | 20 +-
.../expressions/functions/scalar/JsonObject.java | 20 +-
.../expressions/functions/scalar/JsonReplace.java | 20 +-
.../expressions/functions/scalar/JsonSet.java | 20 +-
.../functions/scalar/JsonbExtractBigint.java | 10 +-
.../functions/scalar/JsonbExtractBool.java | 10 +-
.../functions/scalar/JsonbExtractDouble.java | 10 +-
.../functions/scalar/JsonbExtractInt.java | 10 +-
.../functions/scalar/JsonbExtractLargeint.java | 10 +-
.../functions/scalar/JsonbExtractString.java | 10 +-
.../expressions/functions/scalar/LastDay.java | 7 +-
.../expressions/functions/scalar/MakeDate.java | 14 +-
.../functions/scalar/{Sm3sum.java => MakeSet.java} | 35 +-
.../trees/expressions/functions/scalar/Md5.java | 4 +-
.../trees/expressions/functions/scalar/Md5Sum.java | 4 +-
.../expressions/functions/scalar/MinuteCeil.java | 5 +-
.../expressions/functions/scalar/MinuteFloor.java | 5 +-
.../expressions/functions/scalar/MonthCeil.java | 4 +-
.../expressions/functions/scalar/MonthFloor.java | 4 +-
.../expressions/functions/scalar/NextDay.java | 5 +-
.../functions/scalar/PreparePlaceholder.java | 73 -
.../expressions/functions/scalar/QuarterCeil.java | 4 +-
.../expressions/functions/scalar/QuarterFloor.java | 5 +-
.../scalar/{JsonbExtractBool.java => Search.java} | 68 +-
.../functions/scalar/SearchDslParser.java | 556 ++++
.../expressions/functions/scalar/SecondCeil.java | 4 +-
.../expressions/functions/scalar/SecondFloor.java | 4 +-
.../trees/expressions/functions/scalar/Sha1.java | 5 +-
.../trees/expressions/functions/scalar/Sha2.java | 5 +-
.../trees/expressions/functions/scalar/Sm3.java | 4 +-
.../trees/expressions/functions/scalar/Sm3sum.java | 4 +-
.../expressions/functions/scalar/StrToDate.java | 20 +-
.../scalar/{ToDateV2.java => ToBinary.java} | 22 +-
.../trees/expressions/functions/scalar/ToDate.java | 4 +-
.../expressions/functions/scalar/ToDateV2.java | 4 +-
.../trees/expressions/functions/scalar/ToJson.java | 2 +
.../expressions/functions/scalar/ToMonday.java | 6 +-
.../functions/scalar/UnixTimestamp.java | 28 +-
.../expressions/functions/scalar/WeekCeil.java | 5 +-
.../expressions/functions/scalar/WeekFloor.java | 5 +-
.../expressions/functions/scalar/XxHash32.java | 4 +-
.../expressions/functions/scalar/XxHash64.java | 4 +-
.../expressions/functions/scalar/YearCeil.java | 5 +-
.../expressions/functions/scalar/YearFloor.java | 5 +-
.../expressions/literal/StringLikeLiteral.java | 4 +-
.../expressions/visitor/ExpressionVisitor.java | 11 +
.../expressions/visitor/ScalarFunctionVisitor.java | 25 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 12 +-
.../WarmUpItem.java => PrepareCommandPlanner.java} | 36 +-
.../commands/AdminCancelRepairTableCommand.java | 4 +-
.../plans/commands/AdminCompactTableCommand.java | 2 +-
...java => AdminCreateClusterSnapshotCommand.java} | 14 +-
.../plans/commands/AdminRepairTableCommand.java | 4 +-
...ava => AdminSetAutoClusterSnapshotCommand.java} | 56 +-
...minSetClusterSnapshotFeatureSwitchCommand.java} | 61 +-
.../commands/AdminSetPartitionVersionCommand.java | 2 +-
.../plans/commands/AdminSetTableStatusCommand.java | 2 +-
.../commands/AdminShowClusterSnapshotCommand.java | 126 -
.../plans/commands/AlterColumnStatsCommand.java | 4 +-
.../trees/plans/commands/AlterJobCommand.java | 136 +
.../trees/plans/commands/AlterTableCommand.java | 2 +-
.../plans/commands/AlterTableStatsCommand.java | 4 +-
.../plans/commands/AlterWorkloadGroupCommand.java | 8 +-
.../plans/commands/AlterWorkloadPolicyCommand.java | 8 +-
.../trees/plans/commands/AnalyzeTableCommand.java | 4 +-
.../trees/plans/commands/BackupCommand.java | 2 +-
.../plans/commands/CancelAlterTableCommand.java | 2 +-
.../plans/commands/CancelBuildIndexCommand.java | 2 +-
.../plans/commands/CleanQueryStatsCommand.java | 2 +-
.../trees/plans/commands/CreateJobCommand.java | 12 +
.../commands/CreateMaterializedViewCommand.java | 4 +-
.../trees/plans/commands/CreatePolicyCommand.java | 2 +-
.../plans/commands/CreateWorkloadGroupCommand.java | 9 +-
.../commands/CreateWorkloadPolicyCommand.java | 9 +-
.../trees/plans/commands/DescribeCommand.java | 20 +-
.../plans/commands/DropCachedStatsCommand.java | 2 +-
.../trees/plans/commands/DropCatalogCommand.java | 2 +-
.../commands/DropMaterializedViewCommand.java | 2 +-
.../trees/plans/commands/DropRowPolicyCommand.java | 2 +-
.../trees/plans/commands/DropStatsCommand.java | 4 +-
.../trees/plans/commands/DropTableCommand.java | 2 +-
.../trees/plans/commands/DropViewCommand.java | 2 +-
.../trees/plans/commands/ExecuteCommand.java | 8 +
.../trees/plans/commands/ExplainCommand.java | 7 +
.../nereids/trees/plans/commands/LoadCommand.java | 90 +-
.../trees/plans/commands/LockTablesCommand.java | 2 +-
.../trees/plans/commands/OptimizeTableCommand.java | 4 +-
.../plans/commands/RecoverPartitionCommand.java | 2 +-
.../trees/plans/commands/RecoverTableCommand.java | 2 +-
.../trees/plans/commands/RestoreCommand.java | 2 +-
.../trees/plans/commands/ResumeJobCommand.java | 9 +-
.../trees/plans/commands/ShowAnalyzeCommand.java | 2 +-
.../trees/plans/commands/ShowClustersCommand.java | 47 +-
.../commands/ShowColumnHistogramStatsCommand.java | 2 +-
.../plans/commands/ShowColumnStatsCommand.java | 4 +-
.../trees/plans/commands/ShowColumnsCommand.java | 2 +-
.../ShowCreateMaterializedViewCommand.java | 2 +-
.../plans/commands/ShowCreateTableCommand.java | 2 +-
.../plans/commands/ShowCreateViewCommand.java | 2 +-
.../trees/plans/commands/ShowDataCommand.java | 2 +-
.../trees/plans/commands/ShowDataSkewCommand.java | 2 +-
.../trees/plans/commands/ShowDatabasesCommand.java | 2 +-
.../trees/plans/commands/ShowIndexCommand.java | 2 +-
.../plans/commands/ShowIndexStatsCommand.java | 2 +-
.../plans/commands/ShowPartitionsCommand.java | 2 +-
.../plans/commands/ShowQueryStatsCommand.java | 2 +-
.../commands/ShowQueuedAnalyzeJobsCommand.java | 2 +-
.../commands/ShowReplicaDistributionCommand.java | 2 +-
.../plans/commands/ShowReplicaStatusCommand.java | 4 +-
.../trees/plans/commands/ShowTableCommand.java | 5 +-
.../plans/commands/ShowTableStatsCommand.java | 4 +-
.../plans/commands/ShowTableStatusCommand.java | 2 +-
.../commands/ShowTabletsFromTableCommand.java | 4 +-
.../trees/plans/commands/ShowViewCommand.java | 2 +-
.../trees/plans/commands/TruncateTableCommand.java | 4 +-
.../trees/plans/commands/WarmUpClusterCommand.java | 36 +-
.../trees/plans/commands/info/AddColumnOp.java | 3 +-
.../trees/plans/commands/info/AlterMTMVInfo.java | 1 +
.../plans/commands/info/AlterMTMVPropertyInfo.java | 1 +
.../plans/commands/info/AlterMTMVRefreshInfo.java | 1 +
.../plans/commands/info/AlterMTMVRenameInfo.java | 1 +
.../plans/commands/info/AlterMTMVReplaceInfo.java | 1 +
.../trees/plans/commands/info/AlterTableOp.java | 1 +
.../trees/plans/commands/info/AlterViewInfo.java | 3 +-
.../trees/plans/commands/info/BaseViewInfo.java | 5 +
.../trees/plans/commands/info/BuildIndexOp.java | 4 +-
.../plans/commands/info/CancelMTMVTaskInfo.java | 1 +
.../trees/plans/commands/info/CopyFromDesc.java | 5 +-
.../trees/plans/commands/info/CopyIntoInfo.java | 6 +-
.../trees/plans/commands/info/CreateIndexOp.java | 1 +
.../trees/plans/commands/info/CreateJobInfo.java | 71 +-
.../trees/plans/commands/info/CreateMTMVInfo.java | 4 +
.../trees/plans/commands/info/CreateTableInfo.java | 4 +
.../plans/commands/info/CreateTableLikeInfo.java | 1 +
.../trees/plans/commands/info/CreateViewInfo.java | 3 +-
.../trees/plans/commands/info/DropIndexOp.java | 1 +
.../trees/plans/commands/info/DropMTMVInfo.java | 1 +
.../trees/plans/commands/info/IndexDefinition.java | 1 +
.../trees/plans/commands/info/LockTableInfo.java | 1 +
.../trees/plans/commands/info/PauseMTMVInfo.java | 1 +
.../trees/plans/commands/info/RefreshMTMVInfo.java | 1 +
.../plans/commands/info/ReplacePartitionOp.java | 1 +
.../trees/plans/commands/info/ResumeMTMVInfo.java | 1 +
.../plans/commands/info/ShowCreateMTMVInfo.java | 1 +
.../trees/plans/commands/info/TableRefInfo.java | 99 -
.../trees/plans/commands/info/WarmUpItem.java | 2 +
.../commands/insert/AbstractInsertExecutor.java | 9 +-
.../commands/insert/InsertIntoTableCommand.java | 12 +
.../insert/InsertOverwriteTableCommand.java | 1 +
.../trees/plans/commands/insert/InsertUtils.java | 37 +-
.../plans/commands/insert/OlapInsertExecutor.java | 16 +-
.../plans/commands/load/MysqlDataDescription.java | 4 +-
.../commands/optimize/BaseOptimizeAction.java | 4 +-
.../plans/commands/optimize/OptimizeAction.java | 4 +-
.../commands/optimize/OptimizeActionFactory.java | 2 +-
.../commands/refresh/RefreshTableCommand.java | 2 +-
.../distribute/worker/job/AssignedJobBuilder.java | 93 +
.../distribute/worker/job/BucketScanSource.java | 24 +
.../worker/job/UnassignedJobBuilder.java | 13 +
.../worker/job/UnassignedRecursiveCteScanJob.java | 62 +
.../job/UnassignedScanBucketOlapTableJob.java | 101 +-
.../trees/plans/logical/LogicalRecursiveCte.java | 419 +++
.../plans/logical/LogicalRecursiveCteScan.java | 66 +
.../trees/plans/logical/LogicalResultSink.java | 6 +
.../trees/plans/logical/LogicalSqlCache.java | 6 +
.../trees/plans/logical/LogicalSubQueryAlias.java | 31 +-
.../plans/physical/PhysicalLazyMaterialize.java | 5 +-
.../trees/plans/physical/PhysicalRecursiveCte.java | 251 ++
.../plans/physical/PhysicalRecursiveCteScan.java | 85 +
.../trees/plans/visitor/CommandVisitor.java | 35 +-
.../nereids/trees/plans/visitor/PlanVisitor.java | 10 +
.../trees/plans/visitor/RelationVisitor.java | 10 +
.../org/apache/doris/nereids/types/DataType.java | 19 +-
.../org/apache/doris/nereids/util/DateUtils.java | 199 ++
.../apache/doris/nereids/util/ExpressionUtils.java | 16 -
.../java/org/apache/doris/nereids/util/Utils.java | 2 +-
.../java/org/apache/doris/persist/AlterMTMV.java | 2 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 9 +-
.../org/apache/doris/planner/FileLoadScanNode.java | 23 +-
.../org/apache/doris/planner/HashJoinNode.java | 6 +-
.../org/apache/doris/planner/JoinNodeBase.java | 6 +-
.../org/apache/doris/planner/OlapScanNode.java | 13 +-
.../org/apache/doris/planner/RecursiveCteNode.java | 52 +
.../apache/doris/planner/RecursiveCteScanNode.java | 113 +
.../apache/doris/planner/TableFunctionNode.java | 2 -
.../java/org/apache/doris/qe/AuditLogHelper.java | 39 +
.../org/apache/doris/qe/ConnectContextUtil.java | 55 +
.../java/org/apache/doris/qe/ConnectProcessor.java | 69 +-
.../java/org/apache/doris/qe/GlobalVariable.java | 12 +
.../org/apache/doris/qe/MysqlConnectProcessor.java | 50 +-
.../org/apache/doris/qe/NereidsCoordinator.java | 19 +-
.../java/org/apache/doris/qe/SessionVariable.java | 117 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 84 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 15 +-
.../org/apache/doris/qe/cache/CacheAnalyzer.java | 13 +-
.../java/org/apache/doris/qe/cache/SqlCache.java | 4 +-
.../resource/computegroup/ComputeGroupMgr.java | 10 +-
.../apache/doris/service/FrontendServiceImpl.java | 90 +-
.../apache/doris/statistics/AnalysisManager.java | 11 +-
.../doris/statistics/AnalysisTaskWrapper.java | 8 +
.../apache/doris/statistics/BaseAnalysisTask.java | 4 +
.../org/apache/doris/statistics/ColStatsData.java | 2 +-
.../apache/doris/statistics/ColumnStatistic.java | 6 +-
.../apache/doris/statistics/StatisticalType.java | 2 +
.../org/apache/doris/statistics/Statistics.java | 10 +-
.../statistics/StatisticsMetricCollector.java | 138 +
.../doris/statistics/StatisticsRepository.java | 2 +-
.../doris/statistics/util/StatisticsUtil.java | 2 +-
.../main/java/org/apache/doris/system/Backend.java | 10 +
.../apache/doris/system/FrontendHbResponse.java | 2 +-
.../ExternalFileTableValuedFunction.java | 21 +-
.../apache/doris/transaction/TransactionState.java | 9 +-
.../org/apache/doris/alter/IndexChangeJobTest.java | 2 +-
.../apache/doris/analysis/SearchPredicateTest.java | 260 ++
.../org/apache/doris/backup/BackupHandlerTest.java | 4 +-
.../org/apache/doris/backup/BackupJobTest.java | 4 +-
.../org/apache/doris/catalog/CreateViewTest.java | 8 +
.../org/apache/doris/catalog/RefreshTableTest.java | 2 +-
.../org/apache/doris/common/FeNameFormatTest.java | 147 +-
.../common/profile/ProfilePersistentTest.java | 15 +-
.../doris/common/profile/ProfileStructureTest.java | 3 +-
.../apache/doris/common/profile/ProfileTest.java | 3 +-
.../common/profile/RuntimeProfileMergeTest.java | 5 +-
.../doris/common/profile/RuntimeProfileTest.java | 5 +-
.../doris/common/util/SafeStringBuilderTest.java | 134 +
.../doris/datasource/property/ParamRulesTest.java | 34 +-
.../fileformat/JsonFileFormatPropertiesTest.java | 2 +-
.../AWSGlueMetaStoreBasePropertiesTest.java | 14 +-
.../datasource/property/metastore/HMSGlueIT.java | 49 +
.../metastore/HMSGlueMetaStorePropertiesTest.java | 2 +-
.../property/metastore/IcebergGlueIT.java | 51 +
.../IcebergS3TablesMetaStorePropertiesTest.java | 8 +-
.../IcebergUnityCatalogRestCatalogTest.java | 155 +
.../property/storage/COSPropertiesTest.java | 6 +-
.../property/storage/OBSPropertyTest.java | 2 +-
.../property/storage/OSSPropertiesTest.java | 36 +-
.../property/storage/S3PropertiesTest.java | 38 +-
.../doris/datasource/systable/SysTableTest.java | 3 +-
.../tvf/source/MetadataScanNodeTest.java | 166 +
.../apache/doris/load/loadv2/LoadManagerTest.java | 1 -
.../java/org/apache/doris/metric/MetricsTest.java | 105 +
.../org/apache/doris/mysql/MysqlProtoTest.java | 9 -
.../doris/nereids/parser/NereidsParserTest.java | 126 +
.../nereids/parser/VarBinaryLiteralParserTest.java | 92 +-
.../rules/analysis/CheckSearchUsageTest.java | 295 ++
.../expression/ExpressionRewriteTestHelper.java | 13 +-
.../nereids/rules/expression/FoldConstantTest.java | 47 +-
.../rules/ReplaceNullWithFalseForCondTest.java | 146 +
.../nereids/rules/rewrite/EliminateFilterTest.java | 24 -
.../PushDownFilterThroughSetOperationTest.java | 280 ++
.../PushDownVirtualColumnsIntoOlapScanTest.java | 81 +-
.../rules/rewrite/RewriteSearchToSlotsTest.java | 269 ++
.../doris/nereids/stats/FilterEstimationTest.java | 15 +
.../trees/expressions/SearchExpressionTest.java | 250 ++
.../nereids/trees/expressions/TryCastTest.java | 377 +++
.../functions/scalar/SearchDslParserTest.java | 253 ++
.../expressions/functions/scalar/SearchTest.java | 175 +
.../trees/plans/CreateTableCommandTest.java | 37 +
.../AdminCancelRepairTableCommandTest.java | 6 +-
... => AdminCreateClusterSnapshotCommandTest.java} | 12 +-
.../commands/AdminRepairTableCommandTest.java | 6 +-
...=> AdminSetAutoClusterSnapshotCommandTest.java} | 29 +-
...etClusterSnapshotFeatureSwitchCommandTest.java} | 11 +-
.../AdminSetPartitionVersionCommandTest.java | 2 +-
.../AdminShowClusterSnapshotCommandTest.java | 101 -
.../commands/AlterColumnStatsCommandTest.java | 4 +-
.../plans/commands/AlterTableCommandTest.java | 2 +-
.../plans/commands/AlterTableStatsCommandTest.java | 4 +-
.../plans/commands/AnalyzeTableCommandTest.java | 4 +-
.../trees/plans/commands/BackupCommandTest.java | 6 +-
.../commands/CancelAlterTableCommandTest.java | 2 +-
.../commands/CancelBuildIndexCommandTest.java | 2 +-
.../plans/commands/CleanQueryStatsCommandTest.java | 2 +-
.../plans/commands/DropCachedStatsCommandTest.java | 2 +-
.../commands/DropMaterializedViewCommandTest.java | 2 +-
.../plans/commands/DropRowPolicyCommandTest.java | 2 +-
.../trees/plans/commands/DropStatsCommandTest.java | 4 +-
.../trees/plans/commands/MysqlLoadCommandTest.java | 4 +-
.../trees/plans/commands/RestoreCommandTest.java | 6 +-
.../trees/plans/commands/ShowDataCommandTest.java | 2 +-
.../trees/plans/commands/ShowIndexCommandTest.java | 2 +-
.../plans/commands/ShowIndexStatsCommandTest.java | 2 +-
.../plans/commands/ShowPartitionsCommandTest.java | 2 +-
.../plans/commands/ShowQueryStatsCommandTest.java | 2 +-
.../commands/ShowReplicaStatusCommandTest.java | 6 +-
.../plans/commands/ShowTableStatsCommandTest.java | 4 +-
.../commands/ShowTabletsFromTableCommandTest.java | 4 +-
.../plans/commands/TruncateTableCommandTest.java | 4 +-
.../plans/commands/WarmUpClusterCommandTest.java | 2 +-
.../doris/planner/JoinCostEvaluationTest.java | 4 +-
.../doris/plugin/audit/AuditLogBuilderTest.java | 44 +-
.../org/apache/doris/qe/ConnectContextTest.java | 179 +-
.../java/org/apache/doris/qe/ShowExecutorTest.java | 2 +-
.../doris/statistics/AnalysisManagerTest.java | 2 +-
.../doris/utframe/DemoMultiBackendsTest.java | 8 +-
.../apache/doris/utframe/TestWithFeService.java | 2 +-
fe/pom.xml | 2 +-
gensrc/proto/cloud.proto | 58 +-
gensrc/proto/olap_file.proto | 2 +
gensrc/proto/types.proto | 1 +
gensrc/thrift/Descriptors.thrift | 2 +
gensrc/thrift/Exprs.thrift | 26 +-
gensrc/thrift/MasterService.thrift | 2 +
gensrc/thrift/Opcodes.thrift | 1 +
gensrc/thrift/PaloInternalService.thrift | 1 +
gensrc/thrift/PlanNodes.thrift | 2 +-
.../cast_between_datetime.out} | 11 +-
regression-test/data/cast_p0/cast_to_datetime.out | 10 +-
regression-test/data/cast_p0/cast_to_time.out | 15 +
.../recycler/test_recycler_with_truncate_table.out | 1 -
.../test_from_millisecond_microsecond.out | 32 +-
.../data/correctness/test_str_to_date.out | 20 -
.../data/correctness_p0/test_time_round.out | 17 -
.../data/datatype_p0/date/test_from_unixtime.out | 16 -
.../test_global_timezone_streamload2.csv | 2 +
.../data/datatype_p0/datetimev2/test_tz_load.out | 25 +
.../one_level_nestedtypes_with_s3data.out | 495 +--
.../test_nested_types_insert_into_with_s3.out | 20 +-
...e_functions.out => doc_date_functions_test.out} | 42 +-
.../data/export_p0/test_outfile_csv_compress.out | 60 +
.../data/external_table_p0/es/test_es_query.out | 12 +
.../hive/test_hive_get_schema_from_table.out | 2 +-
.../hive/test_hive_topn_rf_null.out | 489 +++
.../action/test_iceberg_optimize_actions.out | 67 +
.../iceberg_and_internal_nested_namespace.out | 128 +
.../iceberg/test_iceberg_optimize_count.out | 12 +
.../select/test_mysql_all_types_select.out | 8 +
.../select/test_mysql_varbinary_with_udf.out | 26 +
.../paimon/paimon_time_travel.out | 98 +
.../external_table_p0/tvf/test_file_tvf_hdfs.out | 1 +
.../data/external_table_p0/tvf/test_hdfs_tvf.out | 1 +
.../external_table_p0/tvf/test_s3_tvf_globlist.out | 35 +
.../iceberg/test_glue_rest_s3tables.out | 33 -
...te_insert.out => test_s3tables_glue_insert.out} | 0
...out => test_s3tables_glue_insert_overwrite.out} | 0
...ut => test_s3tables_glue_insert_partitions.out} | 0
.../paimon/test_paimon_dlf_rest_catalog.out | 8 +-
.../cast/test_try_cast.out} | 15 +-
.../insert_group_commit_into_max_filter_ratio.out | 1 -
.../streaming_job/test_streaming_insert_job.out | 22 +
.../test_broker_load_multi_filegroup.out} | 7 +-
.../http_stream/test_group_commit_http_stream.out | 3 +
.../test_insert_strict_mode_and_filter_ratio.out | 92 +
.../data/load_p0/load_ddl/full_columns_data.csv | 0
.../load_ddl/test_load_ddl_hidden_column.csv | 1 +
.../test_load_ddl_hidden_column_with_func.csv | 1 +
.../load_ddl/test_load_ddl_unavaliable_column.csv | 1 +
.../load_p0/mysql_load/test_decimal_overflow.csv | 10 +
...est_mysql_load_strict_mode_and_filter_ratio.out | 114 +
.../data/load_p0/mysql_load/test_no_partition.csv | 10 +
.../data/load_p0/mysql_load/test_not_number.csv | 10 +
.../data/load_p0/mysql_load/test_null_number.csv | 10 +
...t_routine_load_strict_mode_and_filter_ratio.out | 40 +
.../stream_load/data_by_array_MultiLine.json | 6 +
.../load_p0/stream_load/data_by_array_oneLine.json | 1 +
.../data/load_p0/stream_load/data_by_line.json | 4 +
.../load_p0/stream_load/data_by_multiArray.json | 2 +
.../stream_load/load_json_null_to_nullable.out | 9 +-
.../data/load_p0/stream_load/test_char.json | 2 +-
.../data/load_p0/stream_load/test_compress.csv.lz4 | Bin 48 -> 80 bytes
.../load_p0/stream_load/test_decimal_overflow.csv | 10 +
.../data/load_p0/stream_load/test_json.csv | 4 +
.../data/load_p0/stream_load/test_no_partition.csv | 10 +
.../data/load_p0/stream_load/test_not_number.csv | 10 +
.../data/load_p0/stream_load/test_null_number.csv | 10 +
.../stream_load/test_stream_load_json.out} | 15 +-
...st_stream_load_strict_mode_and_filter_ratio.out | 114 +
.../data/load_p0/tvf/test_tvf_lz4_compress.out | 21 +
.../tvf/test_tvf_strict_mode_and_filter_ratio.out | 71 +
.../test_base_alter_col_type_multi_level_mtmv.out | 2 +-
.../test_base_drop_col_multi_level_mtmv.out | 2 +-
.../mtmv_p0/test_base_drop_multi_level_mtmv.out | 2 +-
.../test_base_rename_col_multi_level_mtmv.out | 2 +-
.../mtmv_p0/test_base_rename_multi_level_mtmv.out | 2 +-
.../mtmv_p0/test_base_replace_multi_level_mtmv.out | 4 +-
.../data/mtmv_p0/test_multi_level_mtmv.out | 2 +-
.../data/nereids_function_p0/scalar_function/A.out | 6 +
.../data/nereids_function_p0/scalar_function/P.out | 534 +++
.../data/nereids_function_p0/scalar_function/S.out | 378 ++-
.../data/nereids_function_p0/scalar_function/U.out | 58 -
.../fold_constant/fe_constant_cast_to_date.out | 3 +
.../fold_constant/fe_constant_cast_to_datetime.out | 3 +
.../expression/fold_constant/fe_try_cast.out} | 19 +-
.../fold_constant_string_arithmatic.out | 202 ++
.../nereids_p0/insert_into_table/insert_values.out | 1 +
.../join/initial_join_order/initial_join_order.out | 4 +
.../test_clone_legacy_nullable_from_nereids.out} | 0
.../sql_functions/array_functions/sql/q04.out | 115 +
.../datetime_functions/test_date_function.out | 43 -
.../stats/col_stats/hot_value_str_to_date.out | 4 +
.../nereids_rules_p0/agg_strategy/agg_strategy.out | 22 +
.../agg_strategy/physical_agg_regulator.out | 8 +-
.../unique_function/agg_with_unique_function.out | 18 +-
.../data/prepared_stmt_p0/prepared_stmt.out | 4 +
.../binary_functions/test_binary_hex_function.out | 83 +
.../bitmap_functions/test_bitmap_and.out} | 18 +-
.../test_in_no_concurrent.out} | 22 +-
.../conditional_functions/test_json_parse.out | 48 +
.../datetime_functions/test_date_floor_ceil.out | 69 -
.../datetime_functions/test_date_function.out | 84 +-
.../datetime_functions/test_from_iso8601_date.out | 114 -
.../ip_functions/test_is_ip_string_functions.out | 62 +
.../sql_functions/json_functions/json_search.out | 21 +
.../json_functions/test_json_exists_path.out | 124 +
.../json_functions/test_json_extract.out | 203 +-
.../json_functions/test_json_function.out | 22 +-
.../size_funciton/test_size_function.out | 12 +
.../string_functions/test_string_function.out | 139 +
.../sql_functions/struct_functions/sql/q02.out | 73 +
.../query_p0/topn_lazy/row_store/row_store.out | 9 +
.../data/search/test_search_boundary_cases.out | 56 +
.../data/search/test_search_dsl_syntax.out | 410 +++
.../test_search_exact_basic.out} | 12 +-
.../data/search/test_search_exact_lowercase.out | 32 +
.../data/search/test_search_exact_match.out | 71 +
.../data/search/test_search_exact_multi_index.out | 28 +
.../data/search/test_search_function.out | 66 +
.../data/search/test_search_inverted_index.out | 111 +
.../data/search/test_search_null_regression.out | 73 +
.../data/search/test_search_null_semantics.out | 151 +
.../data/search/test_search_usage_restrictions.out | 20 +
.../search/test_search_vs_match_consistency.out | 205 ++
.../data/shape_check/ssb_sf100/shape/q4.3.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query15.out | 10 +-
.../shape_check/tpcds_sf100/rf_prune/query18.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query19.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query24.out | 12 +-
.../shape_check/tpcds_sf100/rf_prune/query26.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query29.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query30.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query33.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query44.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query45.out | 10 +-
.../shape_check/tpcds_sf100/rf_prune/query54.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query56.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query58.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query6.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query60.out | 10 +-
.../shape_check/tpcds_sf100/rf_prune/query61.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query64.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query68.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query72.out | 4 +
.../shape_check/tpcds_sf100/rf_prune/query76.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query83.out | 12 +-
.../shape_check/tpcds_sf100/rf_prune/query85.out | 10 +-
.../shape_check/tpcds_sf100/rf_prune/query91.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query15.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query18.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query19.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query24.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query26.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query29.out | 10 +-
.../data/shape_check/tpcds_sf100/shape/query30.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query33.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query44.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query45.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query54.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query56.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query58.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query6.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query60.out | 10 +-
.../data/shape_check/tpcds_sf100/shape/query61.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query64.out | 10 +-
.../data/shape_check/tpcds_sf100/shape/query68.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query72.out | 4 +
.../data/shape_check/tpcds_sf100/shape/query76.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query83.out | 12 +-
.../data/shape_check/tpcds_sf100/shape/query85.out | 10 +-
.../data/shape_check/tpcds_sf100/shape/query91.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query13.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query19.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query44.out | 4 +-
.../tpcds_sf1000/bs_downgrade_shape/query54.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query56.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query6.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query61.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query68.out | 4 +-
.../tpcds_sf1000/bs_downgrade_shape/query91.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query19.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query44.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query54.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query56.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query6.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query61.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query68.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query76.out | 15 +-
.../data/shape_check/tpcds_sf1000/hint/query85.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query91.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query13.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query19.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query24.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query44.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query46.out | 16 +-
.../shape_check/tpcds_sf1000/shape/query54.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query56.out | 2 +-
.../data/shape_check/tpcds_sf1000/shape/query6.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query61.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query64.out | 84 +-
.../shape_check/tpcds_sf1000/shape/query68.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query72.out | 4 +
.../shape_check/tpcds_sf1000/shape/query76.out | 15 +-
.../shape_check/tpcds_sf1000/shape/query85.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query91.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query54.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query72.out | 22 +-
.../data/shape_check/tpch_sf1000/hint/q15.out | 2 +-
.../data/shape_check/tpch_sf1000/hint/q8.out | 2 +-
.../data/shape_check/tpch_sf1000/rf_prune/q15.out | 6 +-
.../data/shape_check/tpch_sf1000/rf_prune/q8.out | 2 +-
.../data/shape_check/tpch_sf1000/shape/q15.out | 8 +-
.../data/shape_check/tpch_sf1000/shape/q8.out | 2 +-
.../spill/q67_test_data_distribution.out} | 0
regression-test/data/tpch_sf0.1_p1/sql/cse.out | 27 +
.../org/apache/doris/regression/Config.groovy | 11 +-
.../regression/action/StreamLoadAction.groovy | 11 +-
.../org/apache/doris/regression/suite/Suite.groovy | 4 +
.../org/apache/doris/regression/util/Hdfs.groovy | 20 +-
.../java/org/apache/doris/udf/VarBinaryTest.java | 21 +-
.../java/org/apache/doris/udf/VarBinaryTest2.java | 17 +-
regression-test/pipeline/common/teamcity-utils.sh | 13 +-
regression-test/pipeline/performance/compile.sh | 2 +-
.../pipeline/performance/conf/session_variables | 0
.../performance/conf/session_variables.sql | 1 +
regression-test/pipeline/performance/deploy.sh | 3 +
regression-test/pipeline/performance/prepare.sh | 4 +-
.../pipeline/performance/run-clickbench.sh | 6 +-
regression-test/pipeline/performance/run-load.sh | 10 +-
regression-test/pipeline/performance/run-tpcds.sh | 6 +-
regression-test/pipeline/performance/run-tpch.sh | 6 +-
regression-test/pipeline/vault_p0/prepare.sh | 4 +-
.../plugins/cloud_recycler_plugin.groovy | 320 +-
.../bloom_filter_p0/test_bloom_filter_hit.groovy | 1 +
.../suites/cast_p0/cast_between_datetime.groovy | 33 +-
.../suites/cast_p0/cast_to_datetime.groovy | 9 +
regression-test/suites/cast_p0/cast_to_time.groovy | 10 +
.../cloud_p0/auth/test_set_default_cluster.groovy | 15 +
...test_warm_up_cluster_event_schema_change.groovy | 6 +-
...test_warm_up_cluster_periodic_add_new_be.groovy | 1 +
.../multi_cluster/test_no_cluster_hits.groovy | 2 +
.../default_vcg_auto_failover.groovy | 1 +
.../load_trigger_failover.groovy | 1 +
.../standby_disable_compaction.groovy | 1 +
.../virtual_compute_group/test_vcg.groovy | 16 +-
.../virtual_compute_group/test_vcg_metrics.groovy | 2 +-
.../use_default_vcg_read_write.groovy | 1 +
.../use_vcg_read_write.groovy | 3 +-
.../use_vcg_read_write_routine_load.groovy | 1 +
.../use_vcg_read_write_s3_load.groovy | 1 +
.../use_vcg_read_write_unhealthy_node_50.groovy | 5 +-
.../virtual_compute_group/vcg_auto_failover.groovy | 5 +-
.../vcg_auto_failover_manual_failback.groovy | 5 +-
.../suites/cloud_p0/node_mgr/test_ms_api.groovy | 8 +-
.../cloud_p0/query_retry/test_retry_e-230.groovy | 1 +
..._warmup_delay_compaction_query_tolerance.groovy | 9 +-
.../suites/cloud_p0/recycler/test_checker.groovy | 107 +-
.../suites/cloud_p0/recycler/test_recycler.groovy | 9 +-
.../recycler/test_recycler_inverted_index.groovy | 2 +-
.../test_recycler_with_internal_copy.groovy | 2 +-
.../cloud_p0/snapshot/test_snapshot_command.groovy | 25 +-
.../test_from_millisecond_microsecond.groovy | 59 +-
.../suites/correctness/test_str_to_date.groovy | 49 +-
.../suites/correctness/test_timev2_fold.groovy | 8 +
...est_colocate_join_with_different_tablets.groovy | 3479 ++++++++++++++++++++
.../test_ctas_mv/test_ctas_mv.groovy | 2 +
.../test_inlineview_with_window_function.groovy | 2 +
.../test_mv_case/test_mv_case.groovy | 2 +
.../test_select_with_predicate_like.groovy | 2 +
.../suites/correctness_p0/test_time_round.groovy | 28 +-
.../csv_header_p0/test_csv_with_header.groovy | 84 +-
.../datatype_p0/date/test_from_unixtime.groovy | 19 +-
.../datatype_p0/datetimev2/test_tz_load.groovy | 229 ++
.../suites/datatype_p0/decimalv3/test_load.groovy | 3 +-
.../one_level_nestedtypes_with_s3data.groovy | 3 +-
..._nested_types_insert_into_with_agg_table.groovy | 10 +
..._nested_types_insert_into_with_dup_table.groovy | 10 +
...sted_types_insert_into_with_unique_table.groovy | 20 +
.../test_nested_types_insert_into_with_s3.groovy | 3 +
...test_nestedtypes_csv_insert_into_with_s3.groovy | 1 +
...est_nestedtypes_json_insert_into_with_s3.groovy | 1 +
regression-test/suites/ddl_p0/test_ctas.groovy | 8 +-
.../suites/demo_p0/test_lru_persist.groovy | 6 +-
.../sql-manual/sql-functions/doc_date_error.groovy | 473 +++
...tions.groovy => doc_date_functions_test.groovy} | 111 +-
.../suites/export/test_array_export.groovy | 28 +-
.../outfile/csv/test_outfile_csv_map_type.groovy | 2 +
.../parquet/test_outfile_parquet_map_type.groovy | 2 +
.../export_p0/test_outfile_csv_compress.groovy | 47 +
.../export_p0/test_outfile_orc_map_type.groovy | 2 +
.../external_table_p0/es/test_es_query.groovy | 2 +
.../hive/ddl/test_hive_write_type.groovy | 4 +-
.../hive/test_hive_get_schema_from_table.groovy | 6 +-
.../hive/test_hive_topn_rf_null.groovy | 78 +
.../hive/write/test_hive_ctas_to_doris.groovy | 11 +-
.../action/test_iceberg_optimize_actions.groovy | 393 ++-
.../iceberg_and_internal_nested_namespace.groovy | 298 ++
.../iceberg/test_iceberg_optimize_count.groovy | 12 +-
.../test_iceberg_partition_evolution.groovy | 2 +-
.../jdbc/test_jdbc_query_pg.groovy | 30 +-
.../select/test_mysql_all_types_select.groovy | 4 +-
.../select/test_mysql_varbinary_with_udf.groovy | 70 +
.../paimon/paimon_time_travel.groovy | 119 +-
.../tvf/test_file_tvf_hdfs.groovy | 6 +-
.../tvf/test_hdfs_parquet_group4.groovy | 4 +-
.../tvf/test_hdfs_parquet_group5.groovy | 4 +-
.../tvf/test_hdfs_parquet_group6.groovy | 6 +-
.../external_table_p0/tvf/test_hdfs_tvf.groovy | 6 +-
.../tvf/test_s3_tvf_globlist.groovy | 54 +
.../hive/test_parquet_complex_cross_page.groovy | 2 +
...les.groovy => test_s3tables_glue_insert.groovy} | 21 +-
... => test_s3tables_glue_insert_overwrite.groovy} | 16 +-
...=> test_s3tables_glue_insert_partitions.groovy} | 22 +-
.../iceberg/test_s3tables_insert_overwrite.groovy | 7 +-
.../iceberg/test_s3tables_write_insert.groovy | 7 +-
.../iceberg/test_s3tables_write_partitions.groovy | 5 +
.../paimon/test_paimon_dlf_rest_catalog.groovy | 8 +-
.../iceberg_on_hms_and_filesystem_and_dlf.groovy | 5 +-
.../test_disable_move_memtable.groovy | 4 +-
.../suites/function_p0/cast/test_try_cast.groovy | 102 +
.../insert_p0/insert_group_commit_into.groovy | 4 +
...nsert_group_commit_into_max_filter_ratio.groovy | 4 +-
.../suites/insert_p0/test_struct_insert.groovy | 1 +
.../test_complex_or_null_semantics.groovy | 240 ++
.../test_cross_field_or_with_null.groovy | 192 ++
.../test_inverted_index_v3.groovy | 28 +
.../test_match_or_null_semantics.groovy | 160 +
.../test_search_or_null_semantics.groovy | 195 ++
.../test_dup_table_inverted_index.groovy | 8 +-
.../streaming_job/test_streaming_insert_job.groovy | 159 +
.../test_broker_load_multi_filegroup.groovy | 89 +
...t_domain_connection_and_ak_sk_correction.groovy | 2 +-
.../broker_load/test_s3_load_with_no_file.groovy | 74 +
.../test_group_commit_http_stream.groovy | 7 +-
.../http_stream/test_http_stream_properties.groovy | 2 +-
.../ingestion_load/test_ingestion_load.groovy | 2 +-
.../test_ingestion_load_alter_column.groovy | 11 +-
.../test_ingestion_load_alter_partition.groovy | 11 +-
.../test_ingestion_load_drop_table.groovy | 4 +-
.../test_ingestion_load_multi_table.groovy | 4 +-
.../test_ingestion_load_with_partition.groovy | 2 +-
.../load_p0/insert/test_insert_statistic.groovy | 111 +
...test_insert_strict_mode_and_filter_ratio.groovy | 487 +++
.../data/load_ddl_basic_data_json_by_line.json | 0
.../load_p0/load_ddl/ddl/agg_tbl_basic_create.sql | 58 +
.../load_p0/load_ddl/ddl/agg_tbl_basic_drop.sql | 1 +
.../ddl/test_load_ddl_hidden_column_create.sql | 21 +
.../ddl/test_load_ddl_hidden_column_drop.sql | 1 +
.../test_load_ddl_unavaliable_column_create.sql | 19 +
.../ddl/test_load_ddl_unavaliable_column_drop.sql | 1 +
.../suites/load_p0/load_ddl/test_load_ddl.groovy | 216 ++
.../test_routine_load_advanced_mapping.groovy | 202 ++
.../test_stream_load_advanced_mapping.groovy | 327 ++
..._mysql_load_strict_mode_and_filter_ratio.groovy | 365 ++
.../routine_load/data/test_decimal_overflow.csv | 10 +
.../routine_load/data/test_no_partition.csv | 10 +
.../load_p0/routine_load/data/test_not_number.csv | 10 +
.../data/test_strict_mode_and_filter_ratio.csv | 10 +
.../routine_load/test_routine_load_alter.groovy | 6 +-
...outine_load_strict_mode_and_filter_ratio.groovy | 411 +++
.../routine_load/test_routine_load_with_sc.groovy | 1 +
.../load_p0/spark_load/test_spark_load.groovy | 1 +
.../stream_load/load_json_null_to_nullable.groovy | 15 +-
.../test_json_load_default_behavior.groovy | 511 +++
.../test_s3_bytes_written_metrics.groovy | 80 +
.../load_p0/stream_load/test_stream_load.groovy | 1 +
.../stream_load/test_stream_load_json.groovy | 56 +
...stream_load_strict_mode_and_filter_ratio.groovy | 526 +++
.../load_p0/tvf/test_tvf_error_column.groovy | 6 +-
.../suites/load_p0/tvf/test_tvf_error_data.groovy | 12 +
.../suites/load_p0/tvf/test_tvf_fast_fail.groovy | 217 ++
.../load_p0/tvf/test_tvf_lz4_compress.groovy | 233 ++
.../test_tvf_strict_mode_and_filter_ratio.groovy | 312 ++
...est_base_alter_col_type_multi_level_mtmv.groovy | 2 +-
.../test_base_drop_col_multi_level_mtmv.groovy | 2 +-
.../mtmv_p0/test_base_drop_multi_level_mtmv.groovy | 2 +-
.../test_base_rename_col_multi_level_mtmv.groovy | 2 +-
.../test_base_rename_multi_level_mtmv.groovy | 2 +-
.../test_base_replace_multi_level_mtmv.groovy | 2 +-
.../mv_p0/mv_negative/agg_negative_test.groovy | 2 +
.../mv_p0/mv_negative/dup_negative_test.groovy | 2 +
.../mv_p0/mv_negative/mor_negative_test.groovy | 2 +
.../mv_p0/mv_negative/mow_negative_test.groovy | 2 +
.../suites/mv_p0/test_o2/test_o2.groovy | 2 +
.../suites/mv_p0/test_tcu/test_tcu.groovy | 16 +-
.../suites/nereids_function_p0/load.groovy | 8 +-
.../nereids_function_p0/scalar_function/A.groovy | 39 +-
.../nereids_function_p0/scalar_function/P.groovy | 134 +
.../nereids_function_p0/scalar_function/S.groovy | 28 +-
.../nereids_function_p0/scalar_function/U.groovy | 20 +-
.../cache/parse_sql_from_sql_cache.groovy | 2 +
.../fold_constant/fe_constant_cast_to_date.groovy | 5 +-
.../fe_constant_cast_to_datetime.groovy | 5 +-
.../expression/fold_constant/fe_try_cast.groovy | 52 +
.../fold_constant_date_arithmatic.groovy | 13 +-
.../fold_constant/fold_constant_nullable.groovy | 2 +-
.../fold_constant_string_arithmatic.groovy | 166 +-
.../insert_into_table/complex_insert.groovy | 2 +
.../insert_into_table/insert_values.groovy | 4 +-
.../test_clone_legacy_nullable_from_nereids.groovy | 71 +
.../recursive_cte/test_recursive_cte.groovy | 102 +
.../nereids_p0/show/test_nereids_show_views.groovy | 57 +
.../sql_functions/array_functions/sql/q04.sql | 128 +
.../datetime_functions/test_date_function.groovy | 31 +-
.../stats/col_stats/hot_value_analyze_sync.groovy | 30 +-
.../stats/col_stats/hot_value_str_to_date.groovy | 60 +
.../test_select_with_predicate_like.groovy | 3 +-
.../agg_strategy/agg_strategy.groovy | 23 +
.../nereids_rules_p0/agg_strategy/load.groovy | 2 +-
.../agg_strategy/physical_agg_regulator.groovy | 4 +-
.../constant_propagation.groovy | 1 +
.../mv/date_trunc/mv_with_date_trunc.groovy | 10 +-
.../union_all_compensate.groovy | 2 +
.../union_rewrite_grace_big.groovy | 2 +
.../partition_prune/always_mono_func.groovy | 2 +-
.../multi_column_range_partition.groovy | 8 +-
.../partition_prune/test_convert_tz.groovy | 9 +-
...une_mono.groovy => test_date_prune_mono.groovy} | 2 +-
.../partition_prune/test_date_trunc_prune.groovy | 2 +-
.../suites/nereids_syntax_p0/any_value.groovy | 1 +
.../suites/nereids_syntax_p0/array_compare.groovy | 2 +-
.../nereids_syntax_p0/inpredicate_with_list.groovy | 2 +-
.../nereids_syntax_p0/test_cast_datetime.groovy | 2 +
.../suites/nereids_tpch_p0/tpch/agg_cse.groovy | 15 +
.../test_auto_partition_behavior.groovy | 9 +-
.../test_col_data_type_boundary.groovy | 2 +
.../suites/point_query_p0/test_point_query.groovy | 6 +-
regression-test/suites/postgres/load.groovy | 4 +
.../suites/prepared_stmt_p0/prepared_stmt.groovy | 29 +
.../aggregate/aggregate_max_min_by_test.groovy | 2 +
.../test_binary_hex_function.groovy | 56 +
.../bitmap_functions/test_bitmap_and.groovy | 102 +
.../test_in_no_concurrent.groovy | 67 +
.../conditional_functions/test_json_parse.groovy | 27 +-
.../datetime_functions/test_date_floor_ceil.groovy | 76 +-
.../datetime_functions/test_date_function.groovy | 96 +-
.../test_from_iso8601_date.groovy | 167 +-
.../test_binary_for_digest.groovy | 146 +
.../test_is_ip_string_functions.groovy | 23 +-
.../json_functions/json_search.groovy | 39 +-
.../json_functions/test_json_exists_path.groovy | 212 ++
.../json_functions/test_json_extract.groovy | 111 +-
.../json_functions/test_json_function.groovy | 50 +-
.../size_funciton/test_size_function.groovy | 6 +-
.../string_functions/test_string_function.groovy | 86 +
.../sql_functions/struct_functions/sql/q02.sql | 72 +
.../query_p0/system/test_query_sys_tables.groovy | 2 +-
.../test_select_with_predicate_like.groovy | 35 -
.../query_p0/topn_lazy/row_store/row_store.groovy | 126 +
.../suites/query_p0/topn_lazy/topn_lazy.groovy | 9 +-
.../adjust_virtual_slot_nullable.groovy | 1 +
.../char_type_shrink_before_project.groovy | 1 +
.../expr_with_runtime_return_type.groovy | 1 +
.../fix_array_type_and_lambda_func.groovy | 1 +
.../return_in_advance_if_block_is_empty.groovy | 1 +
.../virtual_slot_ref/virtual_slot_ref_basic.groovy | 1 +
.../suites/query_profile/profile_size_limit.groovy | 164 +
.../test_agg_schema_key_change_modify1.groovy | 1 +
.../test_alter_rollup_table.groovy | 136 +
.../test_dup_schema_key_change_modify1.groovy | 1 +
.../test_schema_reordering_dup.groovy | 1 +
.../test_schema_reordering_unique.groovy | 2 +
.../test_unique_schema_key_change_modify.groovy | 1 +
regression-test/suites/search/README.md | 30 +
.../search/test_search_boundary_cases.groovy | 196 ++
.../suites/search/test_search_dsl_syntax.groovy | 315 ++
.../suites/search/test_search_exact_basic.groovy | 55 +
.../search/test_search_exact_lowercase.groovy | 69 +
.../suites/search/test_search_exact_match.groovy | 115 +
.../search/test_search_exact_multi_index.groovy | 70 +
.../suites/search/test_search_function.groovy | 163 +
.../search/test_search_inverted_index.groovy | 204 ++
.../search/test_search_null_regression.groovy | 190 ++
.../search/test_search_null_semantics.groovy | 397 +++
.../search/test_search_usage_restrictions.groovy | 176 +
.../search/test_search_vs_match_consistency.groovy | 434 +++
.../tpcds_sf100/noStatsRfPrune/query64.groovy | 5 +-
.../tpcds_sf100/no_stats_shape/query64.groovy | 3 +-
.../tpcds_sf100/rf_prune/query64.groovy | 1 +
.../shape_check/tpcds_sf100/rf_prune/query8.groovy | 1 +
.../shape_check/tpcds_sf100/shape/query64.groovy | 3 +-
.../shape_check/tpcds_sf100/shape/query8.groovy | 1 +
.../tpcds_sf1000/bs_downgrade_shape/query8.groovy | 1 +
.../shape_check/tpcds_sf1000/hint/query64.groovy | 3 +
.../shape_check/tpcds_sf1000/hint/query8.groovy | 1 +
.../shape_check/tpcds_sf1000/shape/query64.groovy | 1 +
.../shape_check/tpcds_sf1000/shape/query8.groovy | 1 +
.../tpcds_sf10t_orc/shape/query64.groovy | 1 +
.../statistics/test_drop_stats_and_truncate.groovy | 4 +
.../suites/statistics/test_hot_value.groovy | 15 +-
.../spill/q67_test_data_distribution.groovy | 69 +
.../suites/tpch_sf0.1_p1/sql/cse.groovy | 11 +-
.../cloud_delete_bitmap/test_load.groovy | 10 +-
1469 files changed, 55920 insertions(+), 12227 deletions(-)
create mode 100644
be/src/exec/schema_scanner/schema_cluster_snapshot_properties_scanner.cpp
copy be/src/{util/jni_native_method.h =>
exec/schema_scanner/schema_cluster_snapshot_properties_scanner.h} (51%)
create mode 100644
be/src/exec/schema_scanner/schema_cluster_snapshots_scanner.cpp
copy be/src/{util/jni_native_method.h =>
exec/schema_scanner/schema_cluster_snapshots_scanner.h} (55%)
copy be/src/olap/rowset/segment_v2/inverted_index/query_v2/{scorer.h =>
bitmap_query/bitmap_query.h} (54%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/bitmap_query/bitmap_scorer.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/bitmap_query/bitmap_weight.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/match_all_docs_scorer.h
delete mode 100644 be/src/util/datetype_cast.hpp
delete mode 100644 be/src/vec/data_types/data_type_number.cpp
create mode 100644 be/src/vec/exprs/vsearch.cpp
copy be/src/vec/{functions/function_convert_tz.cpp => exprs/vsearch.h} (50%)
create mode 100644 be/src/vec/functions/datetime_errors.h
delete mode 100644 be/src/vec/functions/function_convert_tz.h
delete mode 100644 be/src/vec/functions/function_date_or_datetime_to_string.h
rename be/src/vec/functions/{function_timestamp.cpp =>
function_other_types_to_date.cpp} (63%)
create mode 100644 be/src/vec/functions/function_search.cpp
create mode 100644 be/src/vec/functions/function_search.h
create mode 100644 be/src/vec/functions/function_varbinary.cpp
create mode 100644 be/src/vec/functions/string_hex_util.h
create mode 100644
be/test/exec/schema_scanner/schema_cluster_snapshot_properties_scanner_test.cpp
create mode 100644
be/test/exec/schema_scanner/schema_cluster_snapshots_scanner_test.cpp
rename be/test/expected_result/vec/data_types/{timev2_0_to_string.out =>
TimeV2_0_to_string.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_0_to_string_2.out =>
TimeV2_0_to_string_2.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_0_to_string_3.out =>
TimeV2_0_to_string_3.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_0_to_string_batch.out =>
TimeV2_0_to_string_batch.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string.out =>
TimeV2_5_to_string.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string_2.out =>
TimeV2_5_to_string_2.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string_3.out =>
TimeV2_5_to_string_3.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_5_to_string_batch.out =>
TimeV2_5_to_string_batch.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string.out =>
TimeV2_6_to_string.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string_2.out =>
TimeV2_6_to_string_2.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string_3.out =>
TimeV2_6_to_string_3.out} (100%)
rename be/test/expected_result/vec/data_types/{timev2_6_to_string_batch.out =>
TimeV2_6_to_string_batch.out} (100%)
delete mode 100644 be/test/expected_result/vec/data_types/timev2_to_string.out
delete mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_2.out
delete mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_3.out
delete mode 100644
be/test/expected_result/vec/data_types/timev2_to_string_batch.out
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/buffered_union_scorer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/intersection_scorer_test.cpp
rename be/test/vec/data_types/{data_type_time_v2_test.cpp =>
data_type_datetime_v2_test.cpp} (100%)
create mode 100644 be/test/vec/exprs/try_cast_expr_test.cpp
create mode 100644 be/test/vec/exprs/vsearch_expr_test.cpp
delete mode 100644 be/test/vec/function/function_convert_tz_test.cpp
create mode 100644 be/test/vec/function/function_search_test.cpp
create mode 100644 cloud/src/meta-store/clone_chain_reader.cpp
copy cloud/src/meta-store/{meta_reader.h => clone_chain_reader.h} (74%)
create mode 100644 cloud/src/recycler/checker_snapshot.cpp
create mode 100644 cloud/test/bvars_test.cpp
create mode 100644 cloud/test/clone_chain_reader_test.cpp
create mode 100644
docker/thirdparties/docker-compose/elasticsearch/scripts/index/es7_test_object.json
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/create_preinstalled_scripts/run81.hql
create mode 100644
docker/thirdparties/docker-compose/iceberg/scripts/create_preinstalled_scripts/iceberg/run20.sql
create mode 100644
fe/fe-core/src/main/antlr4/org/apache/doris/nereids/search/SearchLexer.g4
create mode 100644
fe/fe-core/src/main/antlr4/org/apache/doris/nereids/search/SearchParser.g4
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/BaseViewStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMTMVStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateTableStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/LockTablesStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SearchPredicate.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/TryCastExpr.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/UseStmt.java
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/EmptyStmt.java =>
catalog/RecursiveCteTempTable.java} (74%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/cloud/analysis/UseCloudClusterStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/util/SafeStringBuilder.java
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/commands/info/LockTableInfo.java
=> fs/GlobListResult.java} (50%)
copy
fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/commands/info/WarmUpItem.java
=> info/BaseTableRefInfo.java} (53%)
rename fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/commands
=> }/info/PartitionNamesInfo.java (93%)
rename fe/fe-core/src/main/java/org/apache/doris/{nereids/trees/plans/commands
=> }/info/TableNameInfo.java (79%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/info/TableRefInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/info/TableValuedFunctionRefInfo.java
copy fe/fe-core/src/main/java/org/apache/doris/{analysis/CancelStmt.java =>
job/base/JobProperties.java} (91%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/common/FailureReason.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingInsertJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingInsertTask.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingJobSchedulerTask.java
rename fe/fe-core/src/main/java/org/apache/doris/{analysis/ShowStmt.java =>
job/extensions/insert/streaming/StreamingJobStatistic.java} (64%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/extensions/insert/streaming/StreamingTaskTxnCommitAttachment.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/manager/StreamingTaskManager.java
rename fe/fe-core/src/main/java/org/apache/doris/{analysis/CancelStmt.java =>
job/offset/Offset.java} (87%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/offset/SourceOffsetProvider.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/offset/SourceOffsetProviderFactory.java
rename
fe/fe-core/src/main/java/org/apache/doris/{analysis/UnsupportedStmt.java =>
job/offset/s3/S3Offset.java} (55%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/offset/s3/S3SourceOffsetProvider.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/job/scheduler/StreamingTaskScheduler.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/CheckSearchUsage.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/JsonFunctionRewrite.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/expression/rules/ReplaceNullWithFalseForCond.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalRecursiveCteScanToPhysicalRecursiveCteScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalRecursiveCteToPhysicalRecursiveCte.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteSearchToSlots.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/SearchExpression.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/TryCast.java
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/{generator
=> }/RewriteWhenAnalyze.java (84%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{ToDateV2.java
=> FromBinary.java} (77%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{Sm3sum.java
=> MakeSet.java} (66%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/PreparePlaceholder.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{JsonbExtractBool.java
=> Search.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/SearchDslParser.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/{ToDateV2.java
=> ToBinary.java} (78%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/{commands/info/WarmUpItem.java
=> PrepareCommandPlanner.java} (51%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{AdminBackupClusterSnapshotCommand.java
=> AdminCreateClusterSnapshotCommand.java} (90%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{AdminSetClusterSnapshotCommand.java
=> AdminSetAutoClusterSnapshotCommand.java} (71%)
rename
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/{AdminShowClusterSnapshotPropertiesCommand.java
=> AdminSetClusterSnapshotFeatureSwitchCommand.java} (50%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AdminShowClusterSnapshotCommand.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/AlterJobCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/TableRefInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/UnassignedRecursiveCteScanJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalRecursiveCte.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalRecursiveCteScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalRecursiveCte.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalRecursiveCteScan.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/RecursiveCteNode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/RecursiveCteScanNode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsMetricCollector.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/SearchPredicateTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/common/util/SafeStringBuilderTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/HMSGlueIT.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergGlueIT.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/property/metastore/IcebergUnityCatalogRestCatalogTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/tvf/source/MetadataScanNodeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/analysis/CheckSearchUsageTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/expression/rules/ReplaceNullWithFalseForCondTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PushDownFilterThroughSetOperationTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/RewriteSearchToSlotsTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/SearchExpressionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/TryCastTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/SearchDslParserTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/SearchTest.java
rename
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/{AdminBackupClusterSnapshotCommandTest.java
=> AdminCreateClusterSnapshotCommandTest.java} (87%)
rename
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/{AdminSetClusterSnapshotCommandTest.java
=> AdminSetAutoClusterSnapshotCommandTest.java} (78%)
rename
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/{AdminShowClusterSnapshotPropertiesCommandTest.java
=> AdminSetClusterSnapshotFeatureSwitchCommandTest.java} (85%)
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/AdminShowClusterSnapshotCommandTest.java
copy
regression-test/data/{query_p0/sql_functions/ip_functions/test_is_ip_string_functions.out
=> cast_p0/cast_between_datetime.out} (73%)
create mode 100644
regression-test/data/datatype_p0/datetimev2/test_global_timezone_streamload2.csv
create mode 100644 regression-test/data/datatype_p0/datetimev2/test_tz_load.out
rename regression-test/data/doc/sql-manual/sql-functions/{date_functions.out
=> doc_date_functions_test.out} (97%)
create mode 100644
regression-test/data/external_table_p0/hive/test_hive_topn_rf_null.out
create mode 100644
regression-test/data/external_table_p0/iceberg/iceberg_and_internal_nested_namespace.out
create mode 100644
regression-test/data/external_table_p0/jdbc/type_test/select/test_mysql_varbinary_with_udf.out
create mode 100644
regression-test/data/external_table_p0/tvf/test_s3_tvf_globlist.out
delete mode 100644
regression-test/data/external_table_p2/iceberg/test_glue_rest_s3tables.out
copy
regression-test/data/external_table_p2/iceberg/{test_s3tables_write_insert.out
=> test_s3tables_glue_insert.out} (100%)
copy
regression-test/data/external_table_p2/iceberg/{test_s3tables_insert_overwrite.out
=> test_s3tables_glue_insert_overwrite.out} (100%)
copy
regression-test/data/external_table_p2/iceberg/{test_s3tables_write_partitions.out
=> test_s3tables_glue_insert_partitions.out} (100%)
copy
regression-test/data/{cloud_p0/recycler/test_recycler_with_truncate_table.out
=> function_p0/cast/test_try_cast.out} (65%)
create mode 100644
regression-test/data/job_p0/streaming_job/test_streaming_insert_job.out
copy
regression-test/data/{external_table_p0/iceberg/action/test_iceberg_optimize_actions.out
=> load_p0/broker_load/test_broker_load_multi_filegroup.out} (66%)
create mode 100644
regression-test/data/load_p0/insert/test_insert_strict_mode_and_filter_ratio.out
copy docker/thirdparties/docker-compose/kafka/scripts/basic_data.csv =>
regression-test/data/load_p0/load_ddl/full_columns_data.csv (100%)
create mode 100644
regression-test/data/load_p0/load_ddl/test_load_ddl_hidden_column.csv
create mode 100644
regression-test/data/load_p0/load_ddl/test_load_ddl_hidden_column_with_func.csv
create mode 100644
regression-test/data/load_p0/load_ddl/test_load_ddl_unavaliable_column.csv
create mode 100644
regression-test/data/load_p0/mysql_load/test_decimal_overflow.csv
create mode 100644
regression-test/data/load_p0/mysql_load/test_mysql_load_strict_mode_and_filter_ratio.out
create mode 100644
regression-test/data/load_p0/mysql_load/test_no_partition.csv
create mode 100644 regression-test/data/load_p0/mysql_load/test_not_number.csv
create mode 100644 regression-test/data/load_p0/mysql_load/test_null_number.csv
create mode 100644
regression-test/data/load_p0/routine_load/test_routine_load_strict_mode_and_filter_ratio.out
create mode 100644
regression-test/data/load_p0/stream_load/data_by_array_MultiLine.json
create mode 100644
regression-test/data/load_p0/stream_load/data_by_array_oneLine.json
create mode 100644 regression-test/data/load_p0/stream_load/data_by_line.json
create mode 100644
regression-test/data/load_p0/stream_load/data_by_multiArray.json
create mode 100644
regression-test/data/load_p0/stream_load/test_decimal_overflow.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_json.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_no_partition.csv
create mode 100644 regression-test/data/load_p0/stream_load/test_not_number.csv
create mode 100644
regression-test/data/load_p0/stream_load/test_null_number.csv
copy
regression-test/data/{cloud_p0/recycler/test_recycler_with_truncate_table.out
=> load_p0/stream_load/test_stream_load_json.out} (51%)
create mode 100644
regression-test/data/load_p0/stream_load/test_stream_load_strict_mode_and_filter_ratio.out
create mode 100644 regression-test/data/load_p0/tvf/test_tvf_lz4_compress.out
create mode 100644
regression-test/data/load_p0/tvf/test_tvf_strict_mode_and_filter_ratio.out
copy
regression-test/data/{query_p0/sql_functions/ip_functions/test_is_ip_string_functions.out
=> nereids_p0/expression/fold_constant/fe_try_cast.out} (52%)
create mode 100644
regression-test/data/nereids_p0/expression/fold_constant/fold_constant_string_arithmatic.out
copy regression-test/data/{datatype_p0/bitmap/test_bitmap_const.out =>
nereids_p0/legacy/test_clone_legacy_nullable_from_nereids.out} (100%)
create mode 100644
regression-test/data/nereids_p0/sql_functions/array_functions/sql/q04.out
create mode 100644
regression-test/data/nereids_p0/stats/col_stats/hot_value_str_to_date.out
create mode 100644
regression-test/data/query_p0/sql_functions/binary_functions/test_binary_hex_function.out
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=> query_p0/sql_functions/bitmap_functions/test_bitmap_and.out} (60%)
copy regression-test/data/{load_p0/stream_load/load_json_null_to_nullable.out
=> query_p0/sql_functions/conditional_functions/test_in_no_concurrent.out} (63%)
create mode 100644
regression-test/data/query_p0/sql_functions/json_functions/test_json_exists_path.out
create mode 100644
regression-test/data/query_p0/sql_functions/struct_functions/sql/q02.out
create mode 100644
regression-test/data/query_p0/topn_lazy/row_store/row_store.out
create mode 100644 regression-test/data/search/test_search_boundary_cases.out
create mode 100644 regression-test/data/search/test_search_dsl_syntax.out
copy
regression-test/data/{external_table_p2/paimon/test_paimon_dlf_rest_catalog.out
=> search/test_search_exact_basic.out} (52%)
create mode 100644 regression-test/data/search/test_search_exact_lowercase.out
create mode 100644 regression-test/data/search/test_search_exact_match.out
create mode 100644
regression-test/data/search/test_search_exact_multi_index.out
create mode 100644 regression-test/data/search/test_search_function.out
create mode 100644 regression-test/data/search/test_search_inverted_index.out
create mode 100644 regression-test/data/search/test_search_null_regression.out
create mode 100644 regression-test/data/search/test_search_null_semantics.out
create mode 100644
regression-test/data/search/test_search_usage_restrictions.out
create mode 100644
regression-test/data/search/test_search_vs_match_consistency.out
copy regression-test/data/{tpcds_sf1_unique_ck_p1/spill/q67.out =>
tpcds_sf1_unique_p1/spill/q67_test_data_distribution.out} (100%)
copy fe/fe-core/src/main/java/org/apache/doris/analysis/DdlStmt.java =>
regression-test/java-udf-src/src/main/java/org/apache/doris/udf/VarBinaryTest.java
(69%)
rename fe/fe-core/src/main/java/org/apache/doris/analysis/EmptyStmt.java =>
regression-test/java-udf-src/src/main/java/org/apache/doris/udf/VarBinaryTest2.java
(69%)
delete mode 100644 regression-test/pipeline/performance/conf/session_variables
create mode 100644
regression-test/pipeline/performance/conf/session_variables.sql
copy be/src/olap/rowset/segment_v2/inverted_index/query_v2/weight.h =>
regression-test/suites/cast_p0/cast_between_datetime.groovy (57%)
create mode 100644
regression-test/suites/datatype_p0/datetimev2/test_tz_load.groovy
create mode 100644
regression-test/suites/doc/sql-manual/sql-functions/doc_date_error.groovy
rename
regression-test/suites/doc/sql-manual/sql-functions/{date_functions.groovy =>
doc_date_functions_test.groovy} (95%)
create mode 100644
regression-test/suites/external_table_p0/hive/test_hive_topn_rf_null.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/iceberg_and_internal_nested_namespace.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/type_test/select/test_mysql_varbinary_with_udf.groovy
create mode 100644
regression-test/suites/external_table_p0/tvf/test_s3_tvf_globlist.groovy
rename
regression-test/suites/external_table_p2/iceberg/{test_glue_rest_s3tables.groovy
=> test_s3tables_glue_insert.groovy} (98%)
copy
regression-test/suites/external_table_p2/iceberg/{test_s3tables_insert_overwrite.groovy
=> test_s3tables_glue_insert_overwrite.groovy} (98%)
copy
regression-test/suites/external_table_p2/iceberg/{test_s3tables_write_partitions.groovy
=> test_s3tables_glue_insert_partitions.groovy} (87%)
create mode 100644 regression-test/suites/function_p0/cast/test_try_cast.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_complex_or_null_semantics.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_cross_field_or_with_null.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_match_or_null_semantics.groovy
create mode 100644
regression-test/suites/inverted_index_p0/test_search_or_null_semantics.groovy
create mode 100644
regression-test/suites/job_p0/streaming_job/test_streaming_insert_job.groovy
create mode 100644
regression-test/suites/load_p0/broker_load/test_broker_load_multi_filegroup.groovy
create mode 100644
regression-test/suites/load_p0/broker_load/test_s3_load_with_no_file.groovy
create mode 100644
regression-test/suites/load_p0/insert/test_insert_statistic.groovy
create mode 100644
regression-test/suites/load_p0/insert/test_insert_strict_mode_and_filter_ratio.groovy
copy
docker/thirdparties/docker-compose/kafka/scripts/basic_data_json_by_line.json
=>
regression-test/suites/load_p0/load_ddl/data/load_ddl_basic_data_json_by_line.json
(100%)
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/agg_tbl_basic_create.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/agg_tbl_basic_drop.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_hidden_column_create.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_hidden_column_drop.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_unavaliable_column_create.sql
create mode 100644
regression-test/suites/load_p0/load_ddl/ddl/test_load_ddl_unavaliable_column_drop.sql
create mode 100644 regression-test/suites/load_p0/load_ddl/test_load_ddl.groovy
create mode 100644
regression-test/suites/load_p0/load_ddl/test_routine_load_advanced_mapping.groovy
create mode 100644
regression-test/suites/load_p0/load_ddl/test_stream_load_advanced_mapping.groovy
create mode 100644
regression-test/suites/load_p0/mysql_load/test_mysql_load_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_decimal_overflow.csv
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_no_partition.csv
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_not_number.csv
create mode 100644
regression-test/suites/load_p0/routine_load/data/test_strict_mode_and_filter_ratio.csv
create mode 100644
regression-test/suites/load_p0/routine_load/test_routine_load_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_json_load_default_behavior.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_s3_bytes_written_metrics.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_json.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_stream_load_strict_mode_and_filter_ratio.groovy
create mode 100644 regression-test/suites/load_p0/tvf/test_tvf_fast_fail.groovy
create mode 100644
regression-test/suites/load_p0/tvf/test_tvf_lz4_compress.groovy
create mode 100644
regression-test/suites/load_p0/tvf/test_tvf_strict_mode_and_filter_ratio.groovy
create mode 100644
regression-test/suites/nereids_p0/expression/fold_constant/fe_try_cast.groovy
create mode 100644
regression-test/suites/nereids_p0/legacy/test_clone_legacy_nullable_from_nereids.groovy
create mode 100644
regression-test/suites/nereids_p0/recursive_cte/test_recursive_cte.groovy
create mode 100644
regression-test/suites/nereids_p0/show/test_nereids_show_views.groovy
create mode 100644
regression-test/suites/nereids_p0/sql_functions/array_functions/sql/q04.sql
rename fe/fe-core/src/main/java/org/apache/doris/analysis/DdlStmt.java =>
regression-test/suites/nereids_p0/stats/col_stats/hot_value_analyze_sync.groovy
(52%)
create mode 100644
regression-test/suites/nereids_p0/stats/col_stats/hot_value_str_to_date.groovy
rename
regression-test/suites/nereids_rules_p0/partition_prune/{test_date_function_prune_mono.groovy
=> test_date_prune_mono.groovy} (99%)
create mode 100644
regression-test/suites/query_p0/sql_functions/binary_functions/test_binary_hex_function.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/bitmap_functions/test_bitmap_and.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/conditional_functions/test_in_no_concurrent.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/encryption_digest/test_binary_for_digest.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/json_functions/test_json_exists_path.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/struct_functions/sql/q02.sql
delete mode 100644
regression-test/suites/query_p0/test_select_with_predicate_like.groovy
create mode 100644
regression-test/suites/query_p0/topn_lazy/row_store/row_store.groovy
create mode 100644
regression-test/suites/query_profile/profile_size_limit.groovy
create mode 100644
regression-test/suites/schema_change_p0/test_alter_rollup_table.groovy
create mode 100644 regression-test/suites/search/README.md
create mode 100644
regression-test/suites/search/test_search_boundary_cases.groovy
create mode 100644 regression-test/suites/search/test_search_dsl_syntax.groovy
create mode 100644 regression-test/suites/search/test_search_exact_basic.groovy
create mode 100644
regression-test/suites/search/test_search_exact_lowercase.groovy
create mode 100644 regression-test/suites/search/test_search_exact_match.groovy
create mode 100644
regression-test/suites/search/test_search_exact_multi_index.groovy
create mode 100644 regression-test/suites/search/test_search_function.groovy
create mode 100644
regression-test/suites/search/test_search_inverted_index.groovy
create mode 100644
regression-test/suites/search/test_search_null_regression.groovy
create mode 100644
regression-test/suites/search/test_search_null_semantics.groovy
create mode 100644
regression-test/suites/search/test_search_usage_restrictions.groovy
create mode 100644
regression-test/suites/search/test_search_vs_match_consistency.groovy
create mode 100644
regression-test/suites/tpcds_sf1_unique_p1/spill/q67_test_data_distribution.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
