You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/01/18 04:04:28 UTC
(doris) branch branch-2.1 updated (9ea80dbc773 -> 2ccb69dbedd)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 9ea80dbc773 [bugfix](core) try close will release query context and the log will core
add 9a7c15b6358 [fix](log) PipelineFragmentContext has already been destoried in try_close_task before logging it #29237
add aa4b3d02f13 [bug]https://github.com/apache/doris/issues/29149 (#29155)
add e91f6cb0695 [chore](docs) straight_join is not supported (#28268)
add 6aaa8298700 [fix](Nereids) connection_id() should return bigint type (#29287)
add 10368a71a47 [fix][security]security optimize for executable binary file doris_be access should be restricted (#29303)
add 5b503e0a7b2 [chore] remove and add collaborators (#29286)
add ac636a2abae [fix](nereids) partition prunner evaluates "not x=const" on single node range #29164
add fcc4cfb9009 [Fix](Variant) add more info before crash in serialization (#29344)
add cc6013bfab4 [fix](partial update) Fix error message when doing strict mode partial update on a table with column that is non-nullable and has no default value #29218
add 3661c316c91 Revert "[improvement](create tablet) backend create tablet round robin among disks (#23218)" (#29347)
add 74202fe7e28 [Enhancement] support user custom defined privite settings,xml for build fe (#29015)
add f92c0acba0a [Bug] When using the hive catalog the hive table name is uppercase, the Doris query is reported wrong #29058 (#29059)
add 4634c723d7f [fix](move-memtable) only check missing tablets when commit info is not empty (#29326)
add 6c74313f602 [Fix](ut)(show) added UT cases for show backup stmt (#28604)
add bbf58c5aa42 [improve](move-memtable) cancel load rapidly when stream close wait (#29322)
add 9a90c1cd57c [improve](move-memtable)add multi replica fault injection (#29348)
add cc40cdf2d45 [improve](load) don't limit add_segment running count in load stream (#29332)
add 3c6c6529978 [Fix](schema change) disable convert light schema change (#28205) (#29300)
add b07ce175de4 Revert "[fix](move-memtable) only check missing tablets when commit i… (#29352)
add 5985d216f33 [feature](mtmv)support cancel mtmv task command (#29252)
add 01a0f0915ff [fix](mtmv)fix insert overwrite will generate garbage temporary partition when restarting FE (#29075)
add 3d59f24403b [fix](compatibility) add some keywords (#29251)
add 216b53058d3 [doc](mtmv)mtmv doc (#27549)
add 738abac9eda [minor](context) duplicate query context in fragment ctx (#29364)
add 4cbbd25d8c9 [fix](ctx) manager the lifecycle of connection context (#29346)
add cec69f4cbd3 [Enhancement](wal) Add timout for wal memory back pressure (#29178)
add 7cb32395994 [fix](sink) add writting restriction for OlapTableSinkV2Operator (#29340)
add b7487430da1 Revert "[improve](move-memtable) cancel load rapidly when stream close wait (#29322)" (#29371)
add 90b2ee90b22 [nereids] consider numNulls in filter estimation (#29184)
add bf6488e5189 [fix](doc) show catalog example output fix (#29150)
add f6443efe1af [doc](fix)fix kill doc error and add example (#29313)
add eac96005b33 [Fix](Job)Concurrency may result in event loss (#29385)
add 4581618b09e [improvement](disk) pick disk randomly when usage is less than 0.7 (#29368)
add 2ed122b787f [improvement](task exec context) add parent class HasTaskExecutionCtx to own the task ctx (#29388)
add c07e3b7b47d [feature](Nereids): eliminate left outer join by unique (#28853)
add 706463781c3 [refactor](group commit) refactor group commit wal code (#29375)
add 4692a62e476 [fix](planner)nullable info of agg node's intermediate and output slots should be same (#29315)
add b3f69211b73 [refactor](wal) move group commit load content length to runtime state (#29188)
add d474d4e701c [Bug](rollup) fallback and disable tulpe when rollup select failed on old planner (#29226)
add 04abcc12454 [cases](index compaction)Add index compaction cases (#29393)
add 3eca457edd0 [fix](statistics)Fix set partition loaded replayer try to write edit log bug (#29395)
add af39217d149 [improve](agg)support push down min/max on unique table (#29242)
add f2fa62f5242 [minor](Nereids): cleanup code (#29413)
add 243b075eef8 [improve](move-memtable) report failed tablets with status (#29351)
add 9490d5e9a26 [Debug](Variant) sanitize variant in `write_column_to_mysql` (#29380)
add 5db496d8449 [Improve](Variant) make output stable (#29389)
add d54cde51ba4 [fix](group commit) fix http stream group commit begin a txn (#29399)
add 69524ccf98f [improve](group commit) Group commit support commit by data size (#29428)
add 69a01e0cf5c [improve](move-memtable) skip load stream stub close wait when cancel (#29427)
add 797238cbb71 [fix](merge-on-write) fix schema change may result in delete bitmap incorrect (#29386)
add 1edf5b31b61 [Regression-test](wal) Add fault injection case for wal mem back pressure (#29298)
add f54f79515c7 [Bug](fix) str_to_date "" should be null (#29402)
add 298d0c6904b [Chore](Notice)Update Notice year (#29415)
add 97234a64853 [Enhancement](inverted index) strictly checkout inverted index properties (#29421)
add cdf2bb24a4f [fix](Nereids) topn runtime filter only support simplest case (#29312)
add 358995e4ac5 [Chore](sort) fix block used after it was moved(#29416)
add 2578f61451a [Chore](ci)Temporarily cancel the mandatory restrictions of shellCheck (#29440)
add 83d36927b3a [Choricals] (ci) Temporarily cancel the mandatory restrictions on the 2.0 branch shellCheck (#29442)
add 3a8ae590ecb [fix](pipelineX) Fix unexpected OOM on pipelineX (#29436)
add b3da9bad3e9 [fix](move-memtable) fix load stream stub fault injection test (#29431)
add 067a9a3a225 [opt](ES catalog)Add more description for limitations of docvalue_scan (#29420)
add 14e7eb76243 [Opt](rf) Opt broadcast join remote runtime filter merge and wait (#29439)
add be1d9c33589 [fix](memory) Fix mem tracker web page notice #29361
add 1e8bb751825 [improve](move-memtable) add log on idle timeout (#29438)
add 08353f60278 [Enhance](fe) Iceberg table in HMS catalog supports broker scan (#28107)
add fab1a627fcd [fix](scan) _insert_data_normal should catch exception when BlockReader::_unique_key_next_block (#29426)
add 5eb38301ddc [Chore](CI)Re-configure branch-2.0 shell-check as a required check (#29448)
add c0db8533afb [fix](load) fix single replica load with auto partition
add dbf61005dff change boost thirdparty url to offical archives.boost.io (#29401)
add 1fbbff32b21 [fix](pipelinex) coredump caused by VRuntimeFilterSlots::_is_global was not set (#29446)
add 79eb575d7cc [Improvement](nereids)Support ODBC table for new planner. (#29129)
add 2a9b4a0f768 [enhancement](paimon)support predict for null and notnull (#29134)
add 12286f0a63d [docs][hive-transactional-tables] Add hive transactional tables documents. (#29369)
add 193b7518aba [enhancement](nereids)throw readable exception when meet missing column in agg's output (#29243)
add 28ff349381c [doc](fix)invalid character 。 in en docs (#29355)
add 329d57fdd7c [regression](move-memtable) test LoadStream on_idle_timeout (#29354)
add e3c9f535dc8 [refactor](wal) refactor some wal code (#29434)
add b2a28fcfaac [fix](ci) exclude case load_stream_fault_injection (#29465)
add 44628d37c84 Enable minmax push down for unique table while doing analyze. (#29462)
add d19530c4c28 [Fix](Nereids) fix leading hint dealing with big brace (#29405)
add 2386a1ce5a4 [fix](docs)Fix description for error code 1051 #27751 (#27977)
add 49a3bab399e [fix](nereids) fix aggregate function roll up when expression arguments is not equals (#29256)
add c84cd30223c [pipelineX](fix) Fix query cancel timeout (#29460)
add bd8113f4243 [bugfix](scannerscheduler) should minus num_of_scanners before check should schedule #28926 (#29331)
add d93812d23f9 [fix](auditloader) support audit table millisecond and fix stmt truncated by '\r' (#29479)
add d6cb2d6d5c0 [improvement](compaction) start 1 cumu compaction thread each disk by default (#29430)
add afaefa3a9e7 [regression](decimalv2) add schema change test case for decimalv2 (#29474)
add 0d0b9d64dd7 [improve](move-memtable) add move memtable too many segments fault injection (#29342)
add 3888a7cc0be [fix](group_commit) Fix check auth error when relaying wal (#29461)
add 3b7d5feb84c fix: en doc list partition column must be NOT NULL (#29414)
add 4ba4767eef2 [improvement](scan) make global runtime filter support in-list filter (#29394)
add 5e39cdf053c [doc](nereids)Add query rewrite by materialized view feature summary and desc doc (#29370)
add b26f3c37bd1 [Bug](config) set enabe_agg_state to need forward (#29454)
add d8a08dad902 [Bug](mark-join) fix wrong result on mark join + other conjunct (#29321)
add bfe65565d80 [feature](paimon)support native reader (#29339)
add 329d20df3b2 [fix](regression) spare .testfile to make disk checker happy when injecting fault (#29477)
add f28dbc702c7 [bugfix](scanner done) should not set process status to query context (#29512)
add 3cfc1507b27 [doc](mv) add mv docs to sidebar (#29506)
add e0e34b8f930 [doc](fix) fix dead link of mv doc (#29530)
add 441fb49345e [Bug](load) fix load failed on stream load tvf into agg state (#28420)
add abd9000368a [Feat](Nereids) add distribute hint to leading hint (#28562)
add 6ae2a11d07e [ci](case) exclude case test_dump_image (#29539)
add 92533d544f9 [LOG](exec) Add timer for hostname_to_ip (#29497)
add 43b19fd99e3 [docs](timezone) refactor docs of timezone
add d8ad6ebff2c [enhancement](disk) log disk path when creating tablet (#29464)
add 7a4ef901100 [Improve](regresstests)add test cases for array functions (#28492)
add 96acef908a6 [fix](move-memtable) check eos when close stream (#29547)
add 35150bbc222 [improve](move-memtable) log rpc failures in stream file writer (#29267)
add 6a836a53df5 [feature](mv) add mv rewrite info to explain (#29153)
add bfd23e30f62 [improve](load) handle EAGAIN in load stream (#29437)
add 99edbaf3cf1 [improve](move-memtable) add stream sink file writer finalize fault injection (#29552)
add 9aafcb18bd9 [fix](move-memtable) disable move memtable when light schema change is false (#29362)
add c1ddcc5751f [opt](config) create custom conf dir if not exists (#29391)
add 08f2b83b810 [fix](profile) Fix row distribution timer in loadv1 (#29495)
add a04911a93f7 [fix](pipelinex) coredump caused by null pointer of Dependency::_shared_state (#29559)
add d56765126b5 [fix](test)Fix index_compaction unstable cases (#29499)
add c0f63915f79 [chore](test) make configuartion of parallel scan be fuzzy (#29356)
add 8c40f04f2ba [Opt](parquet-reader) Opt `ColumnSelectVector::set_run_length_null_map()` in parquet reader. (#28954) (#29527)
add baec2657dd3 [fix](Nereids) should cast NOT's child to boolean when analyze (#29433)
add 46ccbebfb0b [improve](function) get result from constant_col when expr is const (#29403)
add f3bbc7b8762 [enchancement](delete) fix delete stmt return error with fold on be (#28557)
add fb13943a108 [Fix](Variant) fix heap use after free when updating tablet schema (#29554)
add 64696829d14 [fix](Nereids) mark join should not eliminate join when child is empty (#29409)
add 39887a5cbf4 [ut](fe) remove useless and unsatbale tests (#29555)
add e8e1a6ff039 [refactor](fold) refactor fold executor could get error status (#29541)
add abbe4542e54 fix result not stable for test_show_statistic_proc (#29523)
add d86277c2c22 [optimize](cooldown)Improved filtering conditions for cooldown tablet (#27338)
add 0eee560f945 [enhancement](Nereids): add test for push filter through operator (#27294)
add bf4e6787955 [Docs](Community)Use the standard ASF Code of Conduct template (#29586)
add 77fbbf63ed4 [test](Nereids): add more test for eliminate inner join by fk (#29390)
add fa4721125e8 [Fix](show data) Inverted index size not added to data size after index build (#29568)
add e2e9b9d8a35 [improve](insert-into) record rows info in log for check (#29581)
add 132ff6c6ded [opt](Nereids) add float type signature for sum aggregate function (#29503)
add 2b3e75bb272 [fix](Nereids) exists should not return null (#29435)
add 67b9d38d831 [fix](delete) fix incorrect tablet schema of delete predicate rowset (#29536)
add eea62199204 [improvement](group commit) Add an option of enable relay wal on all regression test (#28757)
add 2a6150b057d [optimize](cooldown)If cooldowned_rowsets is empty, there is no need to follow the logic of traversing the files (#27324)
add 7402fee1fcf [feature](function) support ip function ipv6_string_to_num(_or_default, _or_null), inet6_aton (#28361)
add f40cce14063 [Fix](partition) Skip rowset partition id eq 0 smaller than config wh… (#29510)
add 7a0734dbd60 [feature](Nereids): InferPredicates support In (#29458)
add 88323c73fd4 [Fix](wal) Fix update wal dir core (#29583)
add 0ae449f7328 [ci](perf) integration clickbench test into new performance pipeline (#29429)
add 05d1f4f71d8 [fix](planner) Fix table sample not take effect (#29594)
add a0c3ddf902b [fix](memory) Fix LRUCacheType::NUMBER charge (#29588)
add cbcb81f3813 [FIX](complextype)fix compare_at base function support nested types (#29297)
add 8908a347bcc [fix](nereids)need do type coercion after simplify comparasion predicate (#29546)
add 5789b7e3801 [fix](jin) add datetimev2 precision (#29528)
add 2c888667ed3 [improvement](function) standardize some ip functions' signatures #29614
add 75efdd6e1fa [fix](http) throw RejectedExecutionException to prevent http hanging by Future (#29607)
add cc7b9480cfa [fix](polixy)support drop policy for user or role (#29488)
add 911635fac61 [feature](nereids) judge if the join is at bottom of join cluster (#29383)
add 612e0631ace Do not collect min max for agg table value columns while doing sample analyze. (#29483)
add cd67edef900 [fix](docs) fix chinese description for error code 1051 (#29480)
add e62573448a2 [fix](snapshot) Restore convert rowset meta tablet id (#29478)
add bdc69a41751 [fix](nereids)index type should be converted to upper case for later comparasion (#29524)
add 720bee7c1ee [improve](stream-load) choose stream load coordinator by round robin (#28915)
add 2adb0fcc50b [opt](hive) support orc generated from hive 1.x for all file scan node (#28806)
add 85dd606fd10 [fix](group_commit) Fix group_commit ut (#29587)
add db17f5fe791 [improve](move-memtbale) enable move memtable in routine load (#28974)
add 1ae23a32063 [Fix](group commit) Fix wal mem back pressure fault injection case (#29493)
add 28f18a33ea4 [improve](config) print value in error message (#29207)
add 99754d74606 [improve](routine-load) remove maximum limit of routine load max_batch_interval (#29071)
add 8c9908c7b4f [feature](script) Add check_jvm_xmx for `start_fe.sh` (#28989)
add d61fec3ff8b (feature)(LOG) Support to change be vlog level dynamically using http (#28785)
add 3f988e1b7f0 [improvement](doris compose) regression test auto install doris compose requirements (#29012)
add b0cac0014d1 [enhance](FS) Improve FS error code (#29432)
add 734b258e159 [feature](create table) show create table print storage medium (#29080)
add df43b671dee [case](regression) Backup & restore with view (#29573)
add e1ff439e638 [chore](thirdparty) update vectorscan to 5.7.11 (#29623)
add eb4c389b0b0 [feature](function) support ip functions isipv4string and isipv6string (#28556)
add b31028196ca Revert "[feature](script) Add check_jvm_xmx for `start_fe.sh` (#28989)" (#29630)
add e7b5f796640 [Fix](group commit) Fix wal mem back pressure fault injection case (#29625)
add 0b731800a09 [enhancement](group_commit) refector wal manager code (#29560)
add eb2b22bff1b [improve](cooldown) skip empty tablet (#29620)
add 2d89b7aed46 [fix](tablet sched) disable disk balance for single replica (#29576)
add 1ea51e9f20d [Feature](group commit) Support table property "group commit data bytes" (#29484)
add 17cf4ab2c13 [case](regression) streamload publish timeout (#29457)
add 8e49aab7ba9 [fix](case) Update test_stream_load.groovy (#29551)
add c497f749cef [debug](timeout) debug select timeout (#29627)
add c58d18147b0 [refactor](resultwriter) rename append_block to write method is more meaningful (#29635)
add 0bdd0079262 [improve](insert-into) add log when instance mark and done (#29636)
add e556536de1e [Refactor](join) split SetHashTableVariants out from HashTableVariants (#29519)
add 59d7f64360b [Fix](Nereids) fix pipelineX distribute expr list with child output expr ids (#29621)
add 767de7afe86 Revert "[feature](pipelineX) control exchange sink by memory usage (#28814)" (#29652)
add e2ccca6290e [pipelineX](bug) Fix runtime filter timeout (#29738)
add 3675e0302c6 [fix](nereids) generate correct order for runtime filter when contains NullSafeEquals hash condition (#29726)
add fae7a395de7 [Bug](FS) Fix S3FileSystem::file_size_impl #29720
add 443b79d6ba0 [pipelineX](bug) Fix correctness problem using multiple BE (#29765)
add 01a91a482e0 [pipelineX](fix) fix StreamingAggSource crash due to empty data block (#29769)
add 223e4665141 [fix](insert-into) fix insert into lose data (#29802)
add 9ef4e49307e [bugfix](scannerdeadloop) there is a dead loop in scanner ctx (#29794)
add 53f15213087 [feature](inverted index)Support failover when index compaction failed (#29553)
add 9791a63212f [opt](match_phrase) Optimizing match_phrase with a new algorithm (#29444)
add ddaa645a4fe [improvement](statistics) Force to use zonemap for collecting string type min max. (#29631)
add 847898bf268 [fix](Nereids) delete using should support sql without where (#29518)
add 971bc804ac5 [fix](Nereids) update and delete may produce exprs with same exprid (#29656)
add 0126b09c114 [fix](Nereids): fix shape of eliminate_inner regression test (#29613)
add b59a8c93651 [feature](Nereids): refresh view hypergraph after inferring join (#29469)
add 97ed06a92cf [regression-test](Variant) fix unstable case (#29648)
add c9e2f1934a4 [opt](file cache) make the cache queue percentage configurable (#29537)
add eea657a6106 [rf](nereids)prune rf for external db according to jump count (#29634)
add c10bcb666d9 [Fix](Nereids) change log level of warning of converting error to debug (#29660)
add 3cd1c7745ab [fix](jdbc catalog) Fix the precision of decimal type mapping to 0 (#29407)
add 78fc38f53eb [typo](docs) fix the unit of default value of thrift_connect_timeout_seconds (#29626)
add 30e46ee5adb [Fix](Job)Fixed the problem of not deleting JOB during DROP JOB metadata playback (#29543)
add 8fc9c18c850 [improvement](jdbc catalog) Put the jdbc connection pool parameters into catalog properties (#29195)
add a2da434e3b7 [refactor](Nereids): refactor PredicatePropagation & support to infer Equal Condition (#29644)
add 54d2528c69d [Fix](Nereids) fix fe ut failed cause of getting statement context (#29683)
add 40badbf5c5b Fix analyze empty external NPE bug. (#29675)
add 28dca66c062 Fix BE UT macOS compile (#29663)
add 2ca90b2bf10 [Refactor](dialect) Add sql dialect converter plugins (#28890)
add aa4de6f39af (feature)[pipelineX]Make operator_id negative in pipelineX (#29649)
add 9f73f77d125 [fix](pipeline) incorrect result caused by missing output block of union operator (#29677)
add 0b51532dfc5 [doc](release) update release process related to maven (#29467)
add 75631c89fa6 [Fix](thirdparty) fix that BE can not start when use JDK17 (#29570)
add 1ca4d8bf10b [improve](docs) add Flink write metrics doc (#29578)
add 87023d3b7ac [Fix](inverted index) fix memory leak in inverted index when encountering fault (#29676)
add 1d834571ab5 [doc](fix) K8s doc modify catalog and add helm doc (#29604)
add 161134913da [fix](regression-test) fix non stable case test_unique_table_like (#29643)
add 0a55376a488 [fix](regression-test) fix non stable case test_bitmap_index (#29592)
add d50c8b6d3ac [Improvement](nereids) Query rewrite by mv support bitmap_union and bitmap_union_count roll up (#29418)
add 28695249eaf [Fix](nereids) Fix partition check failure (#29642)
add 0c7c9485b6a [Fix](nereids) Fix get ralated partition table when nodata (#29453)
add 028e59efab0 [refactor](Nereids): unify all `replaceNamedExpressions` (#28228)
add 87a6def8621 [Fix](index tool) fix inverted index tool memory leak (#29701)
add 78aabc34925 [session](shared) disable shared scan in default (#29703)
add 2959219b4d8 [Enhancement](wal) Add fault injection case for wal back pressure (#29689)
add bff7f3f9801 [fix](regression) change reference of s3 in p1 via getS3url #29693
add 374c6387880 [improvement](executor) improve readability and efficiency of the checks (#29696)
add 7357ca62af7 [improvement](statistics)Only write editlog for manual analyze task, don't need to do so for auto tasks. #29685
add be56bf06cf8 [feature](function) support ip function named is_ip_address_in_range(addr, cidr) (#29681)
add 34fe5ee38b6 [feat](Nereids) support show constraint command (#29667)
add fda001b6d35 [Improvement](nereids) Support join derivation when mv rewrite (#29609)
add abb7640d37b [debug](timeout) add more log in scanner ctx to find timeout problem #29704
add e4707154fa5 [opt](statistics) create or update table stats after alter column stats.
add da182a8b6f5 [feature](nereids)print nereids node id in explain (#29238)
add aec373e2a06 [fix](regression) remove a buggy fault-injection case which make BE crash (#29673)
add 67986a8a6f8 [fix](case) external case, specify networks (#29699)
add 9cbb55d49bb [fix](Nereids) create double literal when create decimal literal failed (#28959)
add 7738eca6daf [Bug](stream-load) fix stream load failed on table with rollup (#29665)
add b7a819bd245 [Fix](typo) Fix analyzeGroupCommitDataBytes typo #29640
add 0a853be3d12 [fix](storage medium) show create table don't print empty storage medium #29650
add 7a75cde77db [fix](schemachange) Fixed the issue of incorrect log information when distribution columns are compared inconsistently (#27013)
add a5a63856be7 [chore](case) update regression-test README #29031
add 2d04b72b5df [opt](case) Update test_hive_query_cache.groovy (#29694)
add aa22698fe7d [fix](case) fix unstable case by add def before variable define (#29082)
add f8aba3faaec [Enhancement](index tool) refine inverted index tool code (#29717)
add c16a5315136 [FIX](regresstest)delete replicate create table numbers #29722
add 48f58510a8c [refactor](tabletwriter) make tablet writer's rpc callback safe, could exit any time (#29684)
add 463a7ab2128 [Performance](exec) opt the exchange performance (#29579)
add 94ebf9d7f67 [test](regression-test) forbid test_load_stream_stub_failure_injection #29728
add 2c449515439 [fix](planner)only allow null safe equal when both children are nullable (#29470)
add d5311119228 [test](regression-test) forbid test_index_failure_injection (#29741)
add 71b017efeee [typo](docs) fix invalid url (#29471)
add fe5b0e98801 [FIX](struct)fix struct literal in fe const fold with field name #29735
add 7287c0ca15b [Opt](exec)(multi-catalog) Opt date type reading. (#29571)
add ff7f09fe1f8 [fix](executor) Fe publish topic info tcp leak (#29739)
add fc4ca712ed6 [bugfix](core) using weak ptr in data stream receiver to avoid runtime state is deconstructed (#29410)
add ca75c9b8aba add more logs to debug timeout
add a94f2564e31 [fix] (schema change) ignore the error of repeatedly writing rowset during schema change (#29733)
add 883d6dfc733 [fix](planner)strip trailing zeros for decimal literal if the precision larger than max decimal precision in doris (#29737)
add e17809a684d [fix](nereids)logicalhaving is in wrong place after logicalagg and logicalwindow (#29463)
add 38c225f76c7 [fix](nereids) generate correct order for runtime filter when contains NullSafeEquals hash condition (#29726)
add 542cfb37b04 [ci](perf) adjust performance pipeline (#29622)
add 7db65f3f6c2 [tools] update tpcds tools query (#29745)
add bd4ef638f13 [fix](invert index) fix match_phrase_prefix memory leak (#29774)
add 3e9cd3a8b96 [minor](jdbc) fix wrong log and add more info (#29557)
add ddf2e8d3dd2 [feature](Nereids): merge topNs (#28246)
add 5d0732fcf42 [typo](docker thirdparties) Modify script prompt information error (#29770)
add 697a6a4ba25 [Refactor](admin-stmt) rename some `admin-show` statestmt (#29492)
add f8d3b209115 [improve](fmt) use format_to and FMT_COMPILE to speed up write data #29682
add a244f11da2b [fix](statistics)Fix alter column stats not forward to master bug (#29786)
add 99c8e47518b [fix](nereids) fix regression case "nereids_p0/runtimefilter" (#29776)
add 8fd1ce4a2e2 [Enhancement](inverted index) refact some inverted index writer code to make more effieciency (#29602)
add 2e90c457b6f [fix](move-memtable) don't fail if success tablets to one BE is less than quorum (#29754)
add 81d6775b7bc [Cleanup](Nereids): delete useless `ddlSql` to avoid wrong usage (#29788)
add 7c7dbf15bcc [feature](merge-cloud) Decouple Tablet/TabletManager/TxnManager from global StorageEngine instance (#29736)
add 0d16ec73457 [improvement](cooldown) do not cooldown tablet without cold data (#29690)
add 81680383e6e [UT](wal) Add wal dirs info be ut (#29759)
add c7968480ac9 [fix](move-memtable) fix use-after-free in LoadStreamReplyHandler (#29791)
add f0eb23a4967 [fix](insert-into) fix insert into lose data (#29802)
add 4a98db2d473 [fix](Nereids): add def in test (#29796)
add a94343c5f9c [fix](planner) Fix table sample not take effect if exist conjunct #29814
add 17a2b89945b [runtimeFilter](nereids) expand runtime filter by join condition by default (#29633)
add 0d691c638b3 [Feature](profile)Support report runtime workload statistics #29591
add ba1ecf43903 [pipelineX](profile) refine scan profile (#29801)
add 58f8994f5d5 [Fix](core) Fix initializing the WalManager could prevent the BE from starting (#29688)
add 33b8311d5f0 [Improvement](runtime-filter) build runtime filter before build hash table on join build probe (#29727)
add 542a8010418 [typo](doc) optimization show processlist (#28342)
add 771c66c034d [docs](typo)Update flink-doris-connector.md (#29834)
add e93a16ac6ec [fix](Nereids) support complex literal cast in fe (#29599)
add 3cf95d0fdfb [Improvement](execute) optimize for ColumnNullable's serialize_vec/deserialize_vec (#28788)
add 068367063fa [Improvement](function) optimization for substr with ascii string (#29799)
add 8c0b046ad41 [case](wal)Add wal backpressure case (#29725)
add c9a949130b6 [Case](wal) Add wal group commit sink case with low disk space fault injection (#29731)
add 18f850c94f3 [enhance](auto-partition) forbid null column for auto partition (#29749)
add f02fb5d49e8 [fix](vec) wrong implementation of operator <=> of Field (#29743)
add 885d8b28ba7 [fix](Nerids): fix function deps when check unique and not null #29797
add 22c134fa0ab [fix](rowset-reader) direct mode shouldn't use merge iterator (#29678)
add eed72a101ef [fix](Nereids) decimalv3 cast in fe produce wrong data (#29808)
add 4d97f8ea750 [enhance](function) support two special format for str_to_date (#29823)
add 8ba1eb0b028 [feature](mtmv) task tvf add queryId (#29671)
add ed3c8bba87c [fix](auth)remove the key when priv is empty (#29522)
add f67a00ffbb9 [opt](nereids) prune runtime redundant filters (#29828)
add d3721455b03 [Session](rf) Change the default min size of bf runtime filter (#29837)
add ebfbe0c8dd2 [opt](information_schema) support information_schema in external catalog (#28919)
add f94ff21eefd [ci](perf) adjust threshold (#29856)
add 407a4a285d4 [improve](load) reduce logs from memtable memory limiter (#29840)
add a4f29193f64 [pipelineX](fix) Fix incorrect runtime filter (#29860)
add cbffdbb8bfe [bug](group_commit) fix relay wal problem on materialized-view (#29848)
add fc5dc1c2855 [config](move-memtable) set default load_stream_per_node to 20 (#29822)
add 42c21f7eda1 [regression](conf) enable test_stream_stub_fault_injection (#29830)
add 53639a01fed [Fix] (schema change) fix the bug that non light schema change tables can rename column (#29850)
add 89995402dd0 [regression](conf) enable load_stream_fault_injection (#29829)
add 0d6ab3c68c1 [chore](regression test) check disk is good (#29740)
add d525f576e19 [improve] Use lru cache to count the number of column in tablet schema to control memory (#29668)
add ad986a78ae1 [Fix](executor)Fix Grayscale upgrade be code dump when report statistics #29843
add d494674ff49 [opt](parquet-reader) Opt parquet decimal type reading. (#29825)
add ad2c13e009e [Optimize](kill-query)Support the scanners exits as soon as possible when kill query #29803
add 2a51750abdb [fix](dynamic partition) fix dynamic partition storage medium not working (#29490)
add 3ef1229635f [docs](query-accel) refine several statements in docs (#29716)
add acda8d2129d [feature](profile )merge of profiles can be disabled by profile level. #29861
add 17183410511 [pipelineX](fix) Fix correctness problem due to local hash shuffle (#29881)
add 5ef84283458 [Refactor](executor)refactor workload group log fron WARNING to INFO #29878
add a3144915351 [Fix](inverted index) fix array inverted index builder error (#29869)
add 2a778588456 [fix](move-memtable) check all streams for failed reason (#29877)
add 3b25e69311c [bug](rf) fix invalid type for runtime filters when result column is const (#29851)
add 99024ad7bd7 [fix](move-memtable) check eos for already closed streams (#29734)
add 62064a86bf1 [test](ut) added UT cases for show create load stmt (#29564)
add e4e57e9b053 [chore](removelogs) remove debug query timeout logs
add 60f6436f26c [fix](schema cache) adjust the destruction order of _tablet_schema_cache and storage engine (#29923)
add 7a6475eeee0 [deps](hadoop) update hadoop on BE side to 3.3.6 (#29939)
add 12af86176a6 [fix](class-loader) fix class loader conflict on BE side (#29942)
add de3fdc7d08a [chore](Fix) Fix uninitilized buffer in read_cluster_id() (#29949)
add a34ac7f73ab [asf] remove some collaborators
add 5f1b888a24f add 2.1.0-rc04 tag
new 06a6477275a [test](regression-test) move test_alter_user.groovy to run nonConcurrent, for it has set global operation (#29772)
new f79ec8ea7e9 [test](regression-test) fix case bug suites/export/test_array_export.groovy (#29783)
new fd4795dacee [opt](Nereids) add graph sql function and one arg truncate (#29864)
new ee66f1563e5 [fix](Nereids) fix rf push down union (#29847)
new 41875a0bf5e [fix](move-memtable) check segment id in add_segment (#29898)
new 88eab1b4b97 [doc](hight-concurrent-point-query) Improve and supplement hight-concurrent-point-query documentation (#29396)
new e7b221ba66e [fix](be-ut) Fix unstable test cases (#29896)
new 19987354329 [Improvement](function) enable ipv6_num_to_string function to support handling of IPv6 type (#29886)
new 12f936558eb [fix](doc) spell errors fixes for debug-point-action (#28152)
new 1e225b56abb [fix](doc)Added english translation for monitoring Metric description page (#28435)
new e417128fb95 [bug](bitmap) should return error status when execute failed (#29841)
new d47adbb81f0 [Fix](nereids) Fix cte rewrite by mv failure and predicates compensation by mistake (#29820)
new b3e37b3efa1 [unit test](statistics)Add unit test case for auto analyze. #29904
new 9d3a017706a [fix](doriswriter)Fix the problem that specifying multiple loadurls does not take effect #29865
new 1dc0c74ad98 [improvement](statistics)Stop analyze quickly after user close auto analyze. #29809
new 8b4ffcc8f73 [typo](docs) fix typo of outfile and export md (#29804)
new e1a12cf2228 [improvement](auth)Not allowed to operate internal_schema database (#29790)
new 6598b4f7c87 [fix](http) fix exception when querying map data through http #29686
new 7b301195378 [improve](multi-table-load) pause job when can not find table #29870
new d127527af39 [feat](meta) Reuse HMS statistics analyzed by Spark engine for Analyze Task. (#28525)
new 56f0dc77fe3 [doc](unique key) update description for unique key in data model doc (#28902)
new 91e546cfe34 [deps](hadoop) upgrade hadoop deps to 3.3.4.6 (#29908)
new c92648cb273 [ut](meta) added unit test for frontend service impl (#28455)
new 115815739ce [bugfix](fe) add check for leg/lead function params (#29617)
new 0b16938b7f4 [Fix](Nereids) Fix datatype length wrong when string contains chinese (#29885)
new bbfc3d037e1 [doc](auto-inc) Add user oriented doc for auto increment column (#29230)
new a69ce49b07d [fix](Nereids) adjust min/max stats for cast function if types are comparable (#28166)
new 7c493b08c5d [refactor](dialect) make http sql converter plugin and audit loader as builtin plugin (#29692)
new e3a1138da73 [fix](migrate disk) fix tablet disk migration timeout too large (#29895)
new c599cf311dc [fix](migrate) migrate check old tablet had deleted (#29909)
new 612186e657d [doc](sql-dialect)(audit) add doc for sql dialect and audit plugin (#29775)
new e5c8192d478 [ut](stats) Added tests for JDBC analysis tasks (#28591)
new d48c8a1dcea [test](ut) added UT cases for show partitions external table (#29565)
new a974e968410 [community](tool) add a tool to pick pr from one branch to another (#29764)
new 620cfc3cd7c [fix](move-memtable) set idle timeout equal to load timeout (#29839)
new a836f418542 [enhance](serde)update slice reserve and deduce slice back usage #29879
new 5e697990a88 [bugfix](timeout) serving_blocks_num may cause timeout, try to fix it (#29912)
new 25428bd7fb2 [fix](kerberos) fix BE kerberos ccache renew, optimize kerbero options (#29291)
new 7309061db45 [pipelineX](improvement) Adjust local exchange strategy (#29915)
new 615d94bbc72 [log](insertadd log in parse insert into values data (#29903)
new 74e4486c653 [fix](partition) Add more log for single replica load when partition id eq 0 (#28707)
new 2bb83f76210 [fix](schema cache) adjust the destruction order of _tablet_schema_cache and storage engine (#29923)
new 4efc8647de0 [deps](hadoop) update hadoop on BE side to 3.3.6 (#29939)
new 8ca807578f7 [fix](migrate disk) fix migrate disk lost data during publish version (#29887)
new 4b4fd1a290d [improvement](log) add txn log (#28875)
new 9773fef4a14 [fix](class-loader) fix class loader conflict on BE side (#29942)
new fd59a3e3a86 [chore](Fix) Fix uninitilized buffer in read_cluster_id() (#29949)
new c8845c9e07a [opt](scanner) Improve the efficiency of TOPN opt (#29937)
new fd66ce09289 [enhancement](docs) Clarify the requirement for JDK exact version 8 in install guide (#29921)
new 7a574df9fc4 [fix](pipelineX) fix multi be may be missing profiles #29914
new 54d23e0f8e7 [typo](docs) fix default value display exception (#29859)
new b47e289560b [refactor](Nereids): avoid ConnectContext.get() ASAP to improve proformance (#29952)
new 3f20e28f3d5 [doc](jvm) Correct the jvm parameters of be (#29958)
new b7b8e593921 [opt](scanner) use buffered queue to avoid acquiring locks frequently (#29938)
new 97955da749f [enhancement](fe-memory) support label num threshold to reduce fe memory consumption (#22889)
new e35b26f4fc5 [feature](auditlog)Add runtime cpu time/peak memory metric (#29925)
new 05a65b9f81a [improve](join) remove join probe dependency of wait rf publish finish #29792
new f6dc6ea13ba [improvement](catalog) Escape characters for columns in recovery predicate pushdown in SQL (#29854)
new be893d792cd [fix](jni) fix jni_reader function name get_nex_block to get_next_block (#29943)
new 9282ff8e568 [asf] remove some collaborators (#29967)
new ffc6f58e850 [pipelineX](fix) Fix incorrect partition number (#29963)
new e09118eb9c4 extract agg in struct info node (#29853)
new 9e30a67a2ab [Improve](topn opt) avoid crash when rpc returned row contains duplicated row entry (#29872)
new b99b9efda80 [fix](Nereids) top-n with top project should hit top-n opt (#29971)
new 94bfa6e46de [fix](Nereids): fix wrong api calling (#29977)
new c9cf9ab8411 [pipelineX](improvement) Improve data distribution for streaming agg (#29969)
new d5dcdf3e077 [Improve](array) support array_enumerate_uniq and array_suffle for nereids (#29936)
new 8433169e5ee [test](regression-test) fix case bug, add 'order by' to make it stable (#29981)
new 0ea5f0f5de4 [fix](Nereids): fix offset in PlanTranslator (#29789)
new 43597afe2ce [bugfix](core) writer status is read and write concurrently and will core by use after free (#29982)
new 66513d57f99 [feature](function) support ip function named ipv6_cidr_to_range(addr, cidr) (#29812)
new 0afb4561cdc [chore](ci) replace clickbench pipeline to performance pipeline (#29929)
new c7d3b833c5b [fix](ci) Update .asf.yaml (#30004)
new ece5f8e86c2 [pipelineX](fix) Fix input data distribution for distinct streaming agg (#29980)
new 2bf8c51baaf [test](regression) Add debug level log of editlog for p0 p1 (#29992)
new fd5d986239b [fix](regression-test) fix err log limit test global impact for setting param (#29993)
new f7e12605a2e [fix](Nereids): fix NPE InferPredicates (#29978)
new 779ed259724 [fix](scan) crashing caused by unlocked reading of tablet (#30005)
new ce2e84e9a6c [fix](nereids)need validate auto partition columns in DDL (#29985)
new 8240c4e225d [Enhance](tools) change SSB perf tests to standardize behavior (#30002)
new 2297a5b6fce [doc](statistics)Update docs for statistics (#29926)
new 07de535c4cc [fix](Nereids) should not fold constant when do ordinal group by (#29976)
new 4d6de1f181c [opt](invert index) optimize the code structure of inverted index queries (#29771)
new e1bcdc35fdd (fix)[group-commit] Fix some group commit case (#30008)
new 22978726e3b [opt](nereids) if column stats are unknown, 10-20 table-join optimization use cascading instead of dphyp (#29902)
new 3c502f64446 [fix](case) add sync after streamload (#30009)
new 08db92a49a6 [fix](regression) spare .testfile to make disk checker happy when injecting fault (#30012)
new f53d2c28cbb [improvement](catalog) fix jdbc mysql catalog to_date fun pushdown (#29900)
new 75cafa8672b [enhancement](jdbc catalog) Enhance function pushdown of Jdbc Oracle Catalog (#29972)
new 55a0f900035 [fix](jobs)fix create task int job (#30011)
new d3bf23d70da [chore](removelogs) remove debug query timeout logs (#30006)
new 6ce9c67383d [fix](Nereids) struct type coercion call wrong api (#30018)
new d11e797d4cf [fix](decimal) fix wrong decimal overflow caused by uninitialized nested column of null value (#29960)
new 4bf4239d7aa [feature](Nereids): optimize logical group expression in dphyp (#30000)
new 74991c4af2d [bugfix](paimon)support native and jni to read paimon for minio/cos #29933
new 168afdb965c [fix](disk balance) Change disk rebalance unpick time to configurable (#28949)
new 2916745cf22 [Chore](arm) Support auto-SIMD on arm and refactor compilation docs (#29956)
new 4e41e1d7976 [feat](Nereids) persist constraint in table (#29767)
new a0355a65808 [opt](scanner) optimize the number of threads of scanners, follow up #28640 (#30030)
new d101234be13 [fix](test) fix disableDebugPointForAllBEs do not execute (#30023)
new f7a340a2dfe [improve](move-memtable) add cancel method to load stream stub (#29994)
new e693249f5b2 [fix](Nereids) remove useless substr of string like type cast (#29997)
new f98f790a806 [chore](test) update delete complex type case to make Nereids happy (#30022)
new 8090a395bdb change sessionvariable.java style
new 2fa511f80e7 [improve](multi-table-load) avoid plan and execute too many plan at once (#29951)
new d658a44cefb [improvement](catalog) Change the push-down parameters of the predicate function of the table query SQL into variables (#30028)
new 2dcdf07dd41 [Feature](profile)Support active_queries TVF (#29999)
new d20103cad45 [fix](compatibility) remove cluster prefix in user property info (#30078)
new 9714a3c8739 [fix](regression) fault injection may cause fd to be closed twice (#30070)
new f0a4ec5f857 [pipelineX](fix) Fix runtime filter dependency DCHECK failed (#30038)
new 3f2a794c2ec [refactor](insert) remove unused insert code in FE #29924
new b758286b575 [doc](Variant) add doc for Variant type (#28951)
new 3deee146805 [fix](Nereids): find hash condition after infer predicate (#30026)
new 6ef9ed08aad [fix](multi-table-load) fix multi table load can not finish (#29957)
new 2ca3c821351 [fix](fe ut) fix unstable TabletRepairAndBalanceTest (#30041)
new b0c49024cb7 [Feature](materialized-view) support match function with alias in materialized-view (#30025)
new d4195b3cc01 [fix](Nereids): fix enable mv rewrite is useless in dphyp (#30042)
new e73c0f40779 [fix](fe) Fix drop table write too many times editlog (#29966)
new 7e3ed8a19a6 [fix](index_tool) fix index_tool compile error (#30049)
new 48d7c1b1edd [test](regression-test) fix case, compatible with 3 replicas. (#29905)
new dcc9cf9dd3d [config](Nereids): add SessionVariable to control nereids timeout (#30048)
new e894911cdaa [function](char) change char function behaviour same with mysql (#30034)
new 143df9f414b [typo](docs) fix typo (#30031)
new ade720470dd [Improve](config)delete confused config for nested complex type (#29988)
new 44ba9e102cd [feature](statistics)support statistics for iceberg/paimon/hudi table (#29868)
new 30378f9bbc6 [Chore](config) remove some unused config (#29983)
new 65b5a5436ad [minor](Nereids): remove useless method isMysqlCompatibleDatabase (#30064)
new 990d5d86643 [cleanup](insert-into) clean up some insert into log (#30063)
new 8a0a6bf8565 [Fix](typo) Fix group commit regression test typo (#30057)
new 7e821f3d66e [Performance](Join) Support all match one logic (#30019)
new 7d1b3d47047 [feature](statistics, metadata)Meta data place holder for statistics (#29867)
new 4608bcd7bf5 [fix](ut) fixed test cases failure for showCreateFunction (#28593)
new d554d5478c8 [improvement](fe) skip attach profile during send fragment (#30085)
new c1722a6ab02 [Fix](schema change) fix tablet meta write race (#30081)
new 0ccd706a300 [Enhancement](Jdbc Catalog) Map Jdbc Catalog JSON Type to String for Improved Performance and Compatibility (#30035)
new 2ccb69dbedd [Feature](materialized-view) support some case unmached to materialized-view (#30036)
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 (9ea80dbc773)
\
N -- N -- N refs/heads/branch-2.1 (2ccb69dbedd)
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 136 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 | 11 +-
.github/workflows/comment-to-trigger-teamcity.yml | 28 +-
.licenserc.yaml | 2 +-
CODE_OF_CONDUCT.md | 97 +-
NOTICE.txt | 2 +-
be/CMakeLists.txt | 10 +
be/cmake/thirdparty.cmake | 1 +
be/src/agent/be_exec_version_manager.h | 4 +-
be/src/agent/cgroup_cpu_ctl.cpp | 2 +-
be/src/agent/task_worker_pool.cpp | 15 +-
be/src/agent/workload_group_listener.cpp | 4 +-
be/src/clucene | 2 +-
be/src/common/config.cpp | 61 +-
be/src/common/config.h | 51 +-
be/src/common/daemon.cpp | 13 +
be/src/common/daemon.h | 1 +
be/src/common/status.h | 10 +-
be/src/exec/data_sink.cpp | 32 +-
be/src/exec/data_sink.h | 8 -
be/src/exec/exec_node.cpp | 21 +-
be/src/exec/exec_node.h | 15 +-
be/src/exec/rowid_fetcher.cpp | 15 +-
be/src/exec/schema_scanner.cpp | 9 +
be/src/exec/schema_scanner.h | 4 +
be/src/exprs/bloom_filter_func.h | 47 +-
be/src/exprs/runtime_filter.cpp | 57 +-
be/src/exprs/runtime_filter.h | 6 +-
be/src/exprs/runtime_filter_slots.h | 27 +-
be/src/gutil/strings/numbers.cc | 13 +-
be/src/http/action/adjust_log_level.cpp | 55 +
be/src/http/action/adjust_log_level.h | 37 +
be/src/http/action/http_stream.cpp | 28 +-
be/src/http/action/stream_load.cpp | 26 +-
be/src/http/default_path_handlers.cpp | 26 +-
be/src/http/utils.cpp | 2 +-
be/src/index-tools/index_tool.cpp | 103 +-
be/src/io/cache/block/block_file_cache_settings.h | 3 -
be/src/io/fs/broker_file_system.cpp | 47 +-
be/src/io/fs/broker_file_system.h | 5 -
be/src/io/fs/broker_file_writer.cpp | 5 -
be/src/io/fs/broker_file_writer.h | 4 -
be/src/io/fs/err_utils.cpp | 54 +
be/src/io/fs/err_utils.h | 10 +
be/src/io/fs/file_system.cpp | 6 -
be/src/io/fs/file_system.h | 4 -
be/src/io/fs/file_writer.h | 5 -
be/src/io/fs/hdfs_file_system.cpp | 64 +-
be/src/io/fs/hdfs_file_system.h | 15 +-
be/src/io/fs/hdfs_file_writer.cpp | 5 -
be/src/io/fs/hdfs_file_writer.h | 4 -
be/src/io/fs/local_file_reader.cpp | 16 +-
be/src/io/fs/local_file_system.cpp | 126 +-
be/src/io/fs/local_file_system.h | 18 +-
be/src/io/fs/local_file_writer.cpp | 110 +-
be/src/io/fs/local_file_writer.h | 3 +-
be/src/io/fs/multi_table_pipe.cpp | 43 +-
be/src/io/fs/multi_table_pipe.h | 22 +-
be/src/io/fs/remote_file_system.cpp | 16 -
be/src/io/fs/remote_file_system.h | 15 -
be/src/io/fs/s3_file_reader.cpp | 16 +-
be/src/io/fs/s3_file_system.cpp | 176 +-
be/src/io/fs/s3_file_system.h | 15 +-
be/src/io/fs/s3_file_writer.cpp | 71 +-
be/src/io/fs/s3_file_writer.h | 5 +-
be/src/io/fs/stream_sink_file_writer.cpp | 64 +-
be/src/io/fs/stream_sink_file_writer.h | 8 -
be/src/io/hdfs_builder.cpp | 64 +-
be/src/io/hdfs_builder.h | 6 +-
be/src/olap/base_tablet.cpp | 1 -
be/src/olap/cold_data_compaction.cpp | 2 +-
be/src/olap/compaction.cpp | 93 +-
be/src/olap/data_dir.cpp | 67 +-
be/src/olap/data_dir.h | 15 +-
be/src/olap/delta_writer.cpp | 10 +-
be/src/olap/file_header.h | 10 +-
be/src/olap/lru_cache.cpp | 8 +-
be/src/olap/lru_cache.h | 4 +-
be/src/olap/memtable_memory_limiter.cpp | 33 +-
be/src/olap/memtable_memory_limiter.h | 7 +-
be/src/olap/olap_server.cpp | 257 +-
be/src/olap/options.cpp | 44 +-
be/src/olap/options.h | 14 +-
be/src/olap/parallel_scanner_builder.cpp | 5 +-
be/src/olap/rowset/beta_rowset.cpp | 4 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 2 +-
be/src/olap/rowset/rowset.h | 11 +
be/src/olap/rowset/rowset_meta.cpp | 38 +-
be/src/olap/rowset/rowset_meta.h | 10 +
be/src/olap/rowset/rowset_meta_manager.cpp | 16 +-
be/src/olap/rowset/rowset_meta_manager.h | 4 +-
be/src/olap/rowset/segment_creator.cpp | 9 +-
.../inverted_index/query/conjunction_query.cpp | 18 +-
.../inverted_index/query/conjunction_query.h | 32 +-
.../inverted_index/query/disjunction_query.cpp | 10 +-
.../inverted_index/query/disjunction_query.h | 27 +-
.../inverted_index/query/phrase_prefix_query.cpp | 27 +-
.../inverted_index/query/phrase_prefix_query.h | 31 +-
.../inverted_index/query/phrase_query.cpp | 205 ++
.../segment_v2/inverted_index/query/phrase_query.h | 70 +
.../inverted_index/query/prefix_query.cpp | 4 +-
.../segment_v2/inverted_index/query/prefix_query.h | 6 +-
.../rowset/segment_v2/inverted_index/query/query.h | 51 +
.../inverted_index/query/query_factory.h | 53 +
.../inverted_index/query/regexp_query.cpp | 19 +-
.../segment_v2/inverted_index/query/regexp_query.h | 18 +-
.../rowset/segment_v2/inverted_index_cache.cpp | 29 +-
.../segment_v2/inverted_index_compaction.cpp | 16 +-
.../inverted_index_compound_directory.cpp | 32 +-
.../segment_v2/inverted_index_compound_directory.h | 8 +-
.../rowset/segment_v2/inverted_index_reader.cpp | 92 +-
.../olap/rowset/segment_v2/inverted_index_reader.h | 21 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 141 +-
.../olap/rowset/segment_v2/inverted_index_writer.h | 2 +
be/src/olap/rowset/segment_v2/segment_writer.cpp | 26 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 27 +-
be/src/olap/schema_change.cpp | 135 +-
be/src/olap/schema_change.h | 6 +-
be/src/olap/snapshot_manager.cpp | 16 +-
be/src/olap/storage_engine.cpp | 113 +-
be/src/olap/storage_engine.h | 3 +-
be/src/olap/tablet.cpp | 323 +--
be/src/olap/tablet.h | 37 +-
be/src/olap/tablet_manager.cpp | 45 +-
be/src/olap/tablet_manager.h | 4 +-
be/src/olap/tablet_meta.cpp | 11 +
be/src/olap/tablet_reader.cpp | 6 +
be/src/olap/tablet_schema_cache.cpp | 81 +-
be/src/olap/tablet_schema_cache.h | 39 +-
be/src/olap/task/engine_clone_task.cpp | 11 +-
be/src/olap/task/engine_publish_version_task.cpp | 28 +-
be/src/olap/task/engine_storage_migration_task.cpp | 28 +-
be/src/olap/task/engine_storage_migration_task.h | 3 +-
be/src/olap/task/index_builder.cpp | 73 +-
be/src/olap/txn_manager.cpp | 67 +-
be/src/olap/txn_manager.h | 4 +-
be/src/olap/utils.cpp | 14 +-
be/src/olap/wal/wal_dirs_info.cpp | 230 ++
be/src/olap/wal/wal_dirs_info.h | 84 +
be/src/olap/wal/wal_info.cpp | 46 +
be/src/olap/wal/wal_info.h | 38 +
be/src/olap/wal/wal_manager.cpp | 537 +++++
be/src/olap/wal/wal_manager.h | 135 ++
be/src/olap/wal/wal_reader.cpp | 118 +
be/src/olap/wal/wal_reader.h | 48 +
be/src/olap/wal/wal_table.cpp | 360 +++
be/src/olap/wal/wal_table.h | 71 +
be/src/olap/wal/wal_writer.cpp | 116 +
be/src/olap/wal/wal_writer.h | 53 +
be/src/olap/wal_dirs_info.cpp | 225 --
be/src/olap/wal_dirs_info.h | 85 -
be/src/olap/wal_info.cpp | 41 -
be/src/olap/wal_info.h | 38 -
be/src/olap/wal_manager.cpp | 522 ----
be/src/olap/wal_manager.h | 128 -
be/src/olap/wal_reader.cpp | 118 -
be/src/olap/wal_reader.h | 47 -
be/src/olap/wal_table.cpp | 390 ---
be/src/olap/wal_table.h | 78 -
be/src/olap/wal_writer.cpp | 112 -
be/src/olap/wal_writer.h | 59 -
be/src/pipeline/exec/aggregation_sink_operator.cpp | 3 +-
be/src/pipeline/exec/aggregation_sink_operator.h | 16 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 3 +-
.../distinct_streaming_aggregation_sink_operator.h | 9 +
be/src/pipeline/exec/exchange_sink_buffer.cpp | 10 +-
be/src/pipeline/exec/exchange_sink_buffer.h | 1 -
be/src/pipeline/exec/exchange_sink_operator.cpp | 16 +-
be/src/pipeline/exec/exchange_sink_operator.h | 11 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 4 +-
be/src/pipeline/exec/exchange_source_operator.h | 5 -
be/src/pipeline/exec/hashjoin_build_sink.cpp | 60 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 12 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 16 +-
be/src/pipeline/exec/hashjoin_probe_operator.h | 10 +-
be/src/pipeline/exec/olap_table_sink_v2_operator.h | 2 +-
be/src/pipeline/exec/operator.h | 21 -
be/src/pipeline/exec/result_file_sink_operator.cpp | 13 +-
be/src/pipeline/exec/result_file_sink_operator.h | 2 -
be/src/pipeline/exec/result_sink_operator.cpp | 5 +-
be/src/pipeline/exec/scan_operator.cpp | 80 +-
be/src/pipeline/exec/scan_operator.h | 20 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 71 +-
be/src/pipeline/exec/set_sink_operator.cpp | 2 +-
be/src/pipeline/exec/set_source_operator.cpp | 25 +-
be/src/pipeline/exec/sort_sink_operator.cpp | 8 +-
be/src/pipeline/exec/sort_sink_operator.h | 9 +-
.../exec/streaming_aggregation_sink_operator.h | 2 +-
.../exec/streaming_aggregation_source_operator.cpp | 9 +-
be/src/pipeline/exec/union_source_operator.cpp | 16 +-
be/src/pipeline/pipeline.h | 12 +-
be/src/pipeline/pipeline_fragment_context.cpp | 5 +-
be/src/pipeline/pipeline_fragment_context.h | 16 +-
be/src/pipeline/pipeline_task.cpp | 44 +-
be/src/pipeline/pipeline_task.h | 32 +-
be/src/pipeline/pipeline_x/dependency.h | 5 +-
.../local_exchange/local_exchange_sink_operator.h | 20 +-
.../pipeline_x/local_exchange/local_exchanger.cpp | 20 +-
be/src/pipeline/pipeline_x/operator.cpp | 14 +-
be/src/pipeline/pipeline_x/operator.h | 20 +-
.../pipeline_x/pipeline_x_fragment_context.cpp | 76 +-
.../pipeline_x/pipeline_x_fragment_context.h | 13 +-
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 37 +-
be/src/pipeline/pipeline_x/pipeline_x_task.h | 6 +-
be/src/pipeline/task_scheduler.cpp | 15 +-
be/src/runtime/block_spill_manager.cpp | 2 +-
be/src/runtime/buffer_control_block.cpp | 4 +-
be/src/runtime/buffer_control_block.h | 19 +-
be/src/runtime/descriptors.cpp | 14 +-
be/src/runtime/descriptors.h | 10 +
be/src/runtime/exec_env.h | 6 +
be/src/runtime/exec_env_init.cpp | 34 +-
be/src/runtime/fold_constant_executor.cpp | 77 +-
be/src/runtime/fold_constant_executor.h | 9 +-
be/src/runtime/fragment_mgr.cpp | 89 +-
be/src/runtime/group_commit_mgr.cpp | 155 +-
be/src/runtime/group_commit_mgr.h | 74 +-
be/src/runtime/large_int_value.h | 6 +-
be/src/runtime/load_channel.cpp | 10 +-
be/src/runtime/load_channel.h | 2 +
be/src/runtime/load_stream.cpp | 106 +-
be/src/runtime/load_stream.h | 18 +-
be/src/runtime/load_stream_writer.cpp | 1 -
be/src/runtime/memory/cache_policy.h | 5 +-
be/src/runtime/memory/mem_tracker.h | 9 +
be/src/runtime/memory/mem_tracker_limiter.cpp | 14 +-
be/src/runtime/plan_fragment_executor.cpp | 77 +-
be/src/runtime/plan_fragment_executor.h | 18 +-
be/src/runtime/query_context.cpp | 38 +-
be/src/runtime/query_context.h | 12 +
be/src/runtime/query_statistics.cpp | 32 +-
be/src/runtime/query_statistics.h | 50 +-
be/src/runtime/result_writer.h | 3 +-
.../routine_load/routine_load_task_executor.cpp | 5 +-
be/src/runtime/runtime_filter_mgr.cpp | 10 +-
be/src/runtime/runtime_query_statistics_mgr.cpp | 183 ++
be/src/runtime/runtime_query_statistics_mgr.h | 66 +
be/src/runtime/runtime_state.cpp | 7 +-
be/src/runtime/runtime_state.h | 16 +-
be/src/runtime/snapshot_loader.cpp | 30 +-
be/src/runtime/stream_load/stream_load_context.h | 2 +
be/src/runtime/tablets_channel.cpp | 2 +
be/src/runtime/tablets_channel.h | 8 +
be/src/runtime/task_execution_context.h | 26 +-
be/src/runtime/task_group/task_group_manager.cpp | 20 +-
be/src/service/backend_service.cpp | 2 +-
be/src/service/http_service.cpp | 4 +
be/src/service/internal_service.cpp | 26 +-
be/src/service/point_query_executor.cpp | 2 +-
be/src/util/date_func.cpp | 9 +-
be/src/util/debug_points.h | 14 +
be/src/util/mysql_row_buffer.cpp | 14 +-
be/src/util/network_util.cpp | 12 +-
be/src/util/os_util.cpp | 15 +-
be/src/util/simd/vstring_function.h | 57 +-
.../aggregate_functions/aggregate_function_null.h | 30 +-
.../aggregate_functions/aggregate_function_sort.h | 2 +-
be/src/vec/columns/column.h | 6 +-
be/src/vec/columns/column_array.cpp | 35 +-
be/src/vec/columns/column_array.h | 7 +-
be/src/vec/columns/column_const.h | 4 +-
be/src/vec/columns/column_decimal.cpp | 4 +-
be/src/vec/columns/column_dummy.h | 2 -
be/src/vec/columns/column_map.cpp | 35 +
be/src/vec/columns/column_map.h | 9 +-
be/src/vec/columns/column_nullable.cpp | 29 +-
be/src/vec/columns/column_nullable.h | 3 +-
be/src/vec/columns/column_object.cpp | 47 +-
be/src/vec/columns/column_object.h | 5 +
be/src/vec/columns/column_string.cpp | 4 +-
be/src/vec/columns/column_struct.cpp | 15 +
be/src/vec/columns/column_struct.h | 6 +-
be/src/vec/columns/subcolumn_tree.h | 19 +
be/src/vec/common/format_ip.cpp | 3 -
be/src/vec/common/format_ip.h | 1 +
be/src/vec/common/hash_table/hash_map.h | 34 +-
be/src/vec/common/hash_table/hash_map_context.h | 62 +-
.../vec/common/hash_table/hash_table_set_probe.h | 24 +-
be/src/vec/common/ipv6_to_binary.h | 69 +
be/src/vec/common/memcpy_small.h | 9 +-
be/src/vec/common/pod_array.h | 8 +
be/src/vec/common/schema_util.cpp | 43 +-
be/src/vec/common/sort/heap_sorter.cpp | 5 +-
be/src/vec/common/sort/partition_sorter.cpp | 2 +-
be/src/vec/common/sort/sorter.cpp | 6 +-
be/src/vec/common/sort/sorter.h | 2 +-
be/src/vec/common/typeid_cast.h | 9 +-
be/src/vec/core/block.cpp | 49 +-
be/src/vec/core/block.h | 5 +-
be/src/vec/core/block_spill_writer.cpp | 2 +-
be/src/vec/core/column_with_type_and_name.cpp | 25 +
be/src/vec/core/column_with_type_and_name.h | 13 +-
be/src/vec/core/field.h | 2 +-
be/src/vec/core/sort_cursor.h | 10 +-
be/src/vec/data_types/data_type.h | 78 +-
be/src/vec/data_types/data_type_decimal.cpp | 92 +-
be/src/vec/data_types/data_type_ipv4.cpp | 1 -
be/src/vec/data_types/data_type_nullable.cpp | 121 +-
be/src/vec/data_types/data_type_nullable.h | 1 -
be/src/vec/data_types/data_type_number_base.cpp | 95 +-
be/src/vec/data_types/data_type_string.cpp | 189 +-
be/src/vec/data_types/get_least_supertype.cpp | 4 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 6 +-
.../data_types/serde/data_type_object_serde.cpp | 2 +
.../exec/format/arrow/arrow_pip_input_stream.cpp | 1 -
.../vec/exec/format/arrow/arrow_stream_reader.cpp | 1 -
be/src/vec/exec/format/avro/avro_jni_reader.cpp | 2 +-
be/src/vec/exec/format/jni_reader.cpp | 2 +-
be/src/vec/exec/format/orc/vorc_reader.cpp | 24 +-
be/src/vec/exec/format/orc/vorc_reader.h | 24 +-
.../exec/format/parquet/fix_length_plain_decoder.h | 29 +-
.../exec/format/parquet/parquet_column_convert.h | 175 +-
be/src/vec/exec/format/parquet/parquet_common.cpp | 16 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 12 +-
.../exec/format/parquet/vparquet_column_reader.h | 4 +-
be/src/vec/exec/format/table/hudi_jni_reader.cpp | 2 +-
.../exec/format/table/max_compute_jni_reader.cpp | 2 +-
be/src/vec/exec/format/table/paimon_reader.cpp | 2 +-
be/src/vec/exec/format/wal/wal_reader.cpp | 55 +-
be/src/vec/exec/format/wal/wal_reader.h | 20 +-
be/src/vec/exec/jni_connector.cpp | 16 +-
be/src/vec/exec/jni_connector.h | 2 +-
be/src/vec/exec/join/process_hash_table_probe.h | 4 +-
.../vec/exec/join/process_hash_table_probe_impl.h | 185 +-
be/src/vec/exec/join/vhash_join_node.cpp | 58 +-
be/src/vec/exec/join/vhash_join_node.h | 108 +-
be/src/vec/exec/scan/new_jdbc_scanner.cpp | 5 +
be/src/vec/exec/scan/new_olap_scan_node.cpp | 15 -
be/src/vec/exec/scan/new_olap_scan_node.h | 2 -
be/src/vec/exec/scan/new_olap_scanner.cpp | 1 -
be/src/vec/exec/scan/pip_scanner_context.h | 109 +-
be/src/vec/exec/scan/scanner_context.cpp | 304 +--
be/src/vec/exec/scan/scanner_context.h | 60 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 74 +-
be/src/vec/exec/scan/scanner_scheduler.h | 4 +-
be/src/vec/exec/scan/vfile_scanner.cpp | 21 +-
be/src/vec/exec/scan/vscan_node.cpp | 37 +-
be/src/vec/exec/scan/vscan_node.h | 28 +-
be/src/vec/exec/scan/vscanner.cpp | 7 +
be/src/vec/exec/scan/vscanner.h | 22 +-
be/src/vec/exec/vexchange_node.cpp | 17 +-
be/src/vec/exec/vexchange_node.h | 4 -
be/src/vec/exec/vjdbc_connector.cpp | 24 +-
be/src/vec/exec/vjdbc_connector.h | 5 +
be/src/vec/exec/vset_operation_node.cpp | 115 +-
be/src/vec/exec/vset_operation_node.h | 16 +-
be/src/vec/exec/vsort_node.cpp | 2 +-
be/src/vec/exprs/vcase_expr.cpp | 3 +
be/src/vec/exprs/vcast_expr.cpp | 7 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 4 +
be/src/vec/exprs/vexpr.cpp | 8 +
be/src/vec/exprs/vexpr.h | 5 +
be/src/vec/exprs/vin_predicate.cpp | 3 +
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 16 +-
be/src/vec/functions/function.cpp | 132 +-
be/src/vec/functions/function.h | 28 +-
be/src/vec/functions/function_bitmap.cpp | 21 +-
be/src/vec/functions/function_bitmap_variadic.cpp | 4 +-
be/src/vec/functions/function_cast.h | 213 +-
be/src/vec/functions/function_coalesce.cpp | 2 +-
be/src/vec/functions/function_encryption.cpp | 5 +-
be/src/vec/functions/function_hex.cpp | 2 +-
be/src/vec/functions/function_ifnull.h | 3 +-
be/src/vec/functions/function_ip.cpp | 16 +-
be/src/vec/functions/function_ip.h | 647 ++++-
be/src/vec/functions/function_quantile_state.cpp | 6 +-
be/src/vec/functions/function_reverse.h | 5 +-
be/src/vec/functions/function_rpc.cpp | 2 +-
be/src/vec/functions/function_rpc.h | 2 +-
be/src/vec/functions/function_string.cpp | 11 +-
be/src/vec/functions/function_string.h | 240 +-
be/src/vec/functions/function_timestamp.cpp | 13 +-
be/src/vec/functions/functions_geo.cpp | 32 +-
be/src/vec/functions/functions_geo.h | 1 -
be/src/vec/functions/functions_logical.cpp | 5 +-
be/src/vec/functions/least_greast.cpp | 3 +-
be/src/vec/functions/like.cpp | 2 +-
be/src/vec/functions/nullif.cpp | 28 +-
be/src/vec/io/io_helper.h | 9 +-
be/src/vec/olap/block_reader.cpp | 23 +-
be/src/vec/olap/block_reader.h | 2 +-
be/src/vec/runtime/ip_address_cidr.h | 141 ++
be/src/vec/runtime/ipv4_value.h | 40 +-
be/src/vec/runtime/ipv6_value.h | 40 +-
be/src/vec/runtime/vdata_stream_mgr.cpp | 22 +-
be/src/vec/runtime/vdata_stream_mgr.h | 11 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 40 +-
be/src/vec/runtime/vdata_stream_recvr.h | 27 +-
be/src/vec/runtime/vdatetime_value.cpp | 57 +-
be/src/vec/runtime/vdatetime_value.h | 39 +-
be/src/vec/sink/async_writer_sink.h | 2 +-
be/src/vec/sink/group_commit_block_sink.cpp | 28 +-
be/src/vec/sink/group_commit_block_sink.h | 3 +-
be/src/vec/sink/load_stream_stub.cpp | 180 +-
be/src/vec/sink/load_stream_stub.h | 139 +-
be/src/vec/sink/load_stream_stub_pool.cpp | 16 -
be/src/vec/sink/load_stream_stub_pool.h | 2 +-
be/src/vec/sink/multi_cast_data_stream_sink.h | 3 +-
be/src/vec/sink/varrow_flight_result_writer.cpp | 2 +-
be/src/vec/sink/varrow_flight_result_writer.h | 2 +-
be/src/vec/sink/vdata_stream_sender.cpp | 39 +-
be/src/vec/sink/vdata_stream_sender.h | 27 +-
be/src/vec/sink/vmysql_result_writer.cpp | 2 +-
be/src/vec/sink/vmysql_result_writer.h | 2 +-
be/src/vec/sink/volap_table_sink.h | 1 -
be/src/vec/sink/vresult_file_sink.cpp | 15 +-
be/src/vec/sink/vresult_file_sink.h | 4 -
be/src/vec/sink/vresult_sink.cpp | 10 +-
be/src/vec/sink/vresult_sink.h | 3 -
be/src/vec/sink/vrow_distribution.cpp | 3 +-
be/src/vec/sink/vrow_distribution.h | 1 -
be/src/vec/sink/writer/async_result_writer.cpp | 8 +-
be/src/vec/sink/writer/async_result_writer.h | 14 +-
be/src/vec/sink/writer/vfile_result_writer.cpp | 2 +-
be/src/vec/sink/writer/vfile_result_writer.h | 2 +-
be/src/vec/sink/writer/vjdbc_table_writer.cpp | 7 +-
be/src/vec/sink/writer/vjdbc_table_writer.h | 2 +-
be/src/vec/sink/writer/vmysql_table_writer.cpp | 2 +-
be/src/vec/sink/writer/vmysql_table_writer.h | 2 +-
be/src/vec/sink/writer/vodbc_table_writer.cpp | 2 +-
be/src/vec/sink/writer/vodbc_table_writer.h | 2 +-
be/src/vec/sink/writer/vtablet_writer.cpp | 27 +-
be/src/vec/sink/writer/vtablet_writer.h | 5 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 68 +-
be/src/vec/sink/writer/vtablet_writer_v2.h | 4 +-
be/src/vec/sink/writer/vwal_writer.cpp | 61 +-
be/src/vec/sink/writer/vwal_writer.h | 67 +-
be/test/agent/task_worker_pool_test.cpp | 8 +-
be/test/http/stream_load_test.cpp | 2 +-
be/test/io/cache/file_block_cache_test.cpp | 76 +
be/test/io/fs/local_file_system_test.cpp | 837 +++----
.../olap/bitmap_filter_column_predicate_test.cpp | 5 +-
.../compaction_delete_bitmap_calculator_test.cpp | 5 +-
be/test/olap/cumulative_compaction_policy_test.cpp | 67 +-
...mulative_compaction_time_series_policy_test.cpp | 58 +-
be/test/olap/delete_bitmap_calculator_test.cpp | 5 +-
be/test/olap/delete_handler_test.cpp | 28 +-
be/test/olap/delta_writer_test.cpp | 6 +-
.../olap/engine_storage_migration_task_test.cpp | 10 +-
be/test/olap/lru_cache_test.cpp | 95 +-
be/test/olap/memtable_flush_executor_test.cpp | 8 +-
be/test/olap/memtable_memory_limiter_test.cpp | 8 +-
be/test/olap/olap_meta_test.cpp | 6 +-
be/test/olap/ordered_data_compaction_test.cpp | 7 +-
be/test/olap/path_gc_test.cpp | 4 +-
be/test/olap/primary_key_index_test.cpp | 5 +-
be/test/olap/remote_rowset_gc_test.cpp | 7 +-
be/test/olap/rowid_conversion_test.cpp | 7 +-
be/test/olap/rowset/beta_rowset_test.cpp | 7 +-
be/test/olap/rowset/rowset_meta_manager_test.cpp | 2 +-
be/test/olap/rowset/rowset_meta_test.cpp | 2 +-
.../olap/rowset/segment_v2/bitmap_index_test.cpp | 5 +-
.../bloom_filter_index_reader_writer_test.cpp | 5 +-
.../segment_v2/column_reader_writer_test.cpp | 5 +-
.../inverted_index_searcher_cache_test.cpp | 5 +-
.../rowset/segment_v2/ordinal_page_index_test.cpp | 5 +-
.../olap/rowset/segment_v2/zone_map_index_test.cpp | 5 +-
be/test/olap/segcompaction_test.cpp | 9 +-
be/test/olap/storage_engine_test.cpp | 6 +-
be/test/olap/tablet_cooldown_test.cpp | 33 +-
be/test/olap/tablet_mgr_test.cpp | 6 +-
be/test/olap/tablet_test.cpp | 11 +-
be/test/olap/txn_manager_test.cpp | 6 +-
be/test/olap/wal/wal_dirs_info_test.cpp | 132 +
be/test/olap/wal/wal_manager_test.cpp | 238 ++
be/test/olap/wal/wal_reader_writer_test.cpp | 142 ++
be/test/olap/wal_manager_test.cpp | 213 --
be/test/olap/wal_reader_writer_test.cpp | 142 --
be/test/runtime/load_stream_test.cpp | 15 +-
be/test/testutil/run_all_tests.cpp | 7 +-
be/test/vec/core/block_spill_test.cpp | 6 +-
.../serde/data_type_serde_mysql_test.cpp | 2 +-
be/test/vec/exec/parquet/parquet_thrift_test.cpp | 4 +-
be/test/vec/exec/vtablet_sink_test.cpp | 11 +-
be/test/vec/exec/vwal_scanner_test.cpp | 5 +-
be/test/vec/olap/vertical_compaction_test.cpp | 8 +-
be/test/vec/runtime/vdata_stream_test.cpp | 9 +-
bin/start_be.sh | 9 +-
build.sh | 13 +-
conf/be.conf | 4 +-
dist/NOTICE-dist.txt | 2 +-
docker/runtime/doris-compose/cluster.py | 5 +-
docker/runtime/doris-compose/command.py | 12 +-
.../docker-compose/iceberg/iceberg.env | 2 +-
.../docker-compose/iceberg/iceberg.yaml.tpl | 2 +
.../docker-compose/kafka/kafka.yaml.tpl | 12 +-
.../postgresql/init/02-create-table.sql | 7 +-
.../docker-compose/postgresql/init/04-insert.sql | 4 +
.../thirdparties/docker-compose/spark/spark.yaml | 11 +
docker/thirdparties/run-thirdparties-docker.sh | 2 +-
docs/dev.json | 8 +
docs/en/community/developer-guide/be-clion-dev.md | 4 +-
docs/en/community/developer-guide/be-vscode-dev.md | 7 +-
.../en/community/developer-guide/benchmark-tool.md | 8 +-
.../release-and-verify/release-complete.md | 9 +-
.../docs/admin-manual/cluster-management/fqdn.md | 2 +-
.../cluster-management/load-balancing.md | 4 +-
docs/en/docs/admin-manual/config/be-config.md | 48 +-
.../docs/admin-manual/config/fe-config-template.md | 14 +-
docs/en/docs/admin-manual/config/fe-config.md | 30 +-
.../docs/admin-manual/data-admin/delete-recover.md | 2 +-
.../http-actions/be/tablet-distribution.md | 2 +-
.../http-actions/fe/debug-point-action.md | 6 +-
.../http-actions/fe/query-profile-action.md | 2 +-
.../http-actions/fe/statistic-action.md | 2 +-
.../admin-manual/maint-monitor/doris-error-code.md | 3 +-
.../maint-monitor/monitor-metrics/metrics.md | 313 ++-
.../maint-monitor/tablet-repair-and-balance.md | 8 +-
docs/en/docs/admin-manual/privilege-ldap/ldap.md | 2 +-
docs/en/docs/advanced/alter-table/schema-change.md | 2 +-
docs/en/docs/advanced/auto-increment.md | 493 ++++
docs/en/docs/advanced/cold-hot-separation.md | 2 +-
docs/en/docs/advanced/partition/auto-partition.md | 9 +-
docs/en/docs/advanced/time-zone.md | 149 +-
docs/en/docs/advanced/variables.md | 6 +-
.../import/import-way/binlog-load-manual.md | 2 +-
.../import/import-way/spark-load-manual.md | 2 +-
docs/en/docs/data-table/data-model.md | 37 +-
docs/en/docs/data-table/data-partition.md | 3 +-
docs/en/docs/data-table/index/inverted-index.md | 12 +
docs/en/docs/ecosystem/audit-plugin.md | 50 +-
docs/en/docs/ecosystem/flink-doris-connector.md | 26 +-
docs/en/docs/ecosystem/kyuubi.md | 2 +-
.../remote-user-defined-aggregation-function.md | 6 +-
.../ecosystem/udf/java-user-defined-function.md | 2 +-
.../ecosystem/udf/remote-user-defined-function.md | 8 +-
docs/en/docs/get-starting/quick-start.md | 44 +-
.../docs/install/k8s-deploy/helm-chart-deploy.md | 108 +
.../operator-deploy.md} | 0
.../docs/install/source-install/compilation-arm.md | 659 ++---
.../docs/install/source-install/compilation-mac.md | 2 +-
docs/en/docs/install/standard-deployment.md | 14 +-
docs/en/docs/lakehouse/file.md | 2 +-
docs/en/docs/lakehouse/filecache.md | 2 +-
docs/en/docs/lakehouse/multi-catalog/es.md | 2 +
docs/en/docs/lakehouse/multi-catalog/hive.md | 21 +
docs/en/docs/lakehouse/multi-catalog/jdbc.md | 116 +-
.../docs/lakehouse/multi-catalog/multi-catalog.md | 14 +-
docs/en/docs/lakehouse/multi-catalog/paimon.md | 32 +-
docs/en/docs/lakehouse/sql-dialect.md | 71 +
.../async-materialized-view.md | 208 ++
.../query-async-materialized-view.md | 414 ++++
.../hight-concurrent-point-query.md | 56 +-
docs/en/docs/query-acceleration/hint/joinHint.md | 64 +
.../join-optimization/bucket-shuffle-join.md | 4 +-
.../join-optimization/colocation-join.md | 2 +-
docs/en/docs/query-acceleration/nereids.md | 4 +-
.../pipeline-execution-engine.md | 2 +-
docs/en/docs/query-acceleration/statistics.md | 20 +-
docs/en/docs/releasenotes/release-1.2.2.md | 2 +-
.../sql-functions/bitmap-functions/bitmap-count.md | 2 +-
.../date-time-functions/str-to-date.md | 10 +-
.../sql-functions/ip-functions/inet6-aton.md | 70 +
.../ip-functions/ipv4-num-to-string.md | 40 +-
.../ip-functions/ipv4-string-to-num-or-default.md | 38 +-
.../ip-functions/ipv4-string-to-num-or-null.md | 38 +-
.../ip-functions/ipv4-string-to-num.md | 22 +-
.../ip-functions/ipv6-num-to-string.md | 10 +-
.../ip-functions/ipv6-string-to-num-or-default.md | 75 +
.../ip-functions/ipv6-string-to-num-or-null.md | 75 +
.../ip-functions/ipv6-string-to-num.md | 70 +
.../sql-functions/json-functions/json-insert.md | 2 +-
.../table-functions/active_queries.md | 83 +
.../sql-functions/table-functions/jobs.md | 90 +
.../sql-functions/table-functions/mv_infos.md | 100 +
.../sql-functions/table-functions/queries.md | 79 -
.../sql-functions/table-functions/tasks.md | 106 +
.../Alter/ALTER-ASYNC-MATERIALIZED-VIEW.md | 75 +
.../Create/CREATE-ASYNC-MATERIALIZED-VIEW.md | 216 ++
.../Create/CREATE-TABLE.md | 4 +-
.../Drop/DROP-ASYNC-MATERIALIZED-VIEW.md | 68 +
.../Data-Definition-Statements/Drop/DROP-POLICY.md | 10 +-
.../Load/CREATE-ROUTINE-LOAD.md | 2 +-
.../Load/STREAM-LOAD.md | 10 +-
.../Manipulation/EXPORT.md | 2 +-
.../Manipulation/SELECT.md | 2 -
.../Data-Manipulation-Statements/OUTFILE.md | 4 +-
.../sql-reference/Data-Types/DATETIME.md | 35 +-
.../sql-manual/sql-reference/Data-Types/VARIANT.md | 359 +++
.../ADMIN-DIAGNOSE-TABLET.md | 57 -
.../ADMIN-REPAIR-TABLE.md | 2 +-
.../ADMIN-SET-CONFIG.md | 2 +-
.../ADMIN-SHOW-CONFIG.md | 77 -
.../ADMIN-SHOW-REPLICA-DISTRIBUTION.md | 66 -
.../ADMIN-SHOW-REPLICA-STATUS.md | 83 -
.../ADMIN-SHOW-TABLET-STORAGE-FORMAT.md | 54 -
.../Database-Administration-Statements/KILL.md | 39 +-
.../SET-VARIABLE.md | 22 +-
.../SHOW-CONFIG.md | 77 +
.../SHOW-REPLICA-DISTRIBUTION.md | 66 +
.../SHOW-REPLICA-STATUS.md | 83 +
.../SHOW-TABLET-DIAGNOSIS.md | 58 +
.../SHOW-TABLET-STORAGE-FORMAT.md | 58 +
.../sql-reference/Show-Statements/SHOW-BACKUP.md | 45 +-
.../sql-reference/Show-Statements/SHOW-CATALOGS.md | 22 +-
.../sql-reference/Show-Statements/SHOW-POLICY.md | 16 +-
.../Show-Statements/SHOW-PROCESSLIST.md | 2 +-
.../CANCEL-MATERIALIZED-VIEW-TASK.md | 56 +
.../Utility-Statements/PAUSE-MATERIALIZED-VIEW.md | 56 +
.../Utility-Statements/REFRESH-LDAP.md | 2 +-
.../REFRESH-MATERIALIZED-VIEW.md | 72 +
.../Utility-Statements/RESUME-MATERIALIZED-VIEW.md | 56 +
docs/sidebars.json | 61 +-
.../community/developer-guide/be-vscode-dev.md | 5 +
.../release-and-verify/release-complete.md | 9 +-
.../docs/admin-manual/cluster-management/fqdn.md | 2 +-
docs/zh-CN/docs/admin-manual/config/be-config.md | 47 +-
.../docs/admin-manual/config/fe-config-template.md | 14 +-
docs/zh-CN/docs/admin-manual/config/fe-config.md | 36 +-
.../docs/admin-manual/data-admin/delete-recover.md | 2 +-
.../admin-manual/maint-monitor/doris-error-code.md | 5 +-
.../maint-monitor/tablet-repair-and-balance.md | 8 +-
.../docs/advanced/alter-table/schema-change.md | 2 +-
docs/zh-CN/docs/advanced/auto-increment.md | 490 ++++
.../docs/advanced/partition/auto-partition.md | 9 +-
docs/zh-CN/docs/advanced/time-zone.md | 139 +-
docs/zh-CN/docs/advanced/variables.md | 10 +-
docs/zh-CN/docs/data-table/data-model.md | 32 +-
docs/zh-CN/docs/data-table/data-partition.md | 1 +
docs/zh-CN/docs/data-table/index/inverted-index.md | 14 +-
docs/zh-CN/docs/ecosystem/audit-plugin.md | 45 +-
docs/zh-CN/docs/ecosystem/flink-doris-connector.md | 20 +
.../ecosystem/udf/java-user-defined-function.md | 2 +-
.../docs/install/k8s-deploy/helm-chart-deploy.md | 105 +
.../operator-deploy.md} | 0
.../docs/install/source-install/compilation-arm.md | 670 ++---
docs/zh-CN/docs/lakehouse/filecache.md | 2 +-
docs/zh-CN/docs/lakehouse/multi-catalog/es.md | 1 +
docs/zh-CN/docs/lakehouse/multi-catalog/hive.md | 18 +
docs/zh-CN/docs/lakehouse/multi-catalog/jdbc.md | 116 +-
.../docs/lakehouse/multi-catalog/multi-catalog.md | 12 +-
docs/zh-CN/docs/lakehouse/multi-catalog/paimon.md | 32 +-
docs/zh-CN/docs/lakehouse/sql-dialect.md | 70 +
.../async-materialized-view.md | 209 ++
.../query-async-materialized-view.md | 393 +++
.../hight-concurrent-point-query.md | 61 +-
.../join-optimization/colocation-join.md | 2 +-
docs/zh-CN/docs/query-acceleration/nereids.md | 4 +-
.../pipeline-execution-engine.md | 4 +-
docs/zh-CN/docs/query-acceleration/statistics.md | 20 +-
docs/zh-CN/docs/releasenotes/release-2.0-Beta.md | 6 +-
docs/zh-CN/docs/releasenotes/release-2.0.0.md | 10 +-
.../date-time-functions/str-to-date.md | 10 +-
.../sql-functions/ip-functions/inet6-aton.md | 70 +
.../sql-functions/ip-functions/inet6-ntoa.md | 2 +-
.../ip-functions/ipv4-num-to-string.md | 40 +-
.../ip-functions/ipv4-string-to-num-or-default.md | 38 +-
.../ip-functions/ipv4-string-to-num-or-null.md | 38 +-
.../ip-functions/ipv4-string-to-num.md | 22 +-
.../ip-functions/ipv6-num-to-string.md | 12 +-
.../ip-functions/ipv6-string-to-num-or-default.md | 75 +
.../ip-functions/ipv6-string-to-num-or-null.md | 75 +
.../ip-functions/ipv6-string-to-num.md | 70 +
.../sql-functions/json-functions/json-insert.md | 2 +-
.../sql-functions/json-functions/json-replace.md | 2 +-
.../table-functions/active_queries.md | 83 +
.../sql-functions/table-functions/jobs.md | 90 +
.../sql-functions/table-functions/mv_infos.md | 100 +
.../sql-functions/table-functions/queries.md | 79 -
.../sql-functions/table-functions/tasks.md | 106 +
.../Alter/ALTER-ASYNC-MATERIALIZED-VIEW.md | 75 +
.../Create/CREATE-ASYNC-MATERIALIZED-VIEW.md | 215 ++
.../Drop/DROP-ASYNC-MATERIALIZED-VIEW.md | 68 +
.../Data-Definition-Statements/Drop/DROP-POLICY.md | 10 +-
.../Load/CREATE-ROUTINE-LOAD.md | 2 +-
.../Load/STREAM-LOAD.md | 13 +-
.../Manipulation/EXPORT.md | 2 +-
.../Manipulation/SELECT.md | 2 -
.../Data-Manipulation-Statements/OUTFILE.md | 4 +-
.../sql-reference/Data-Types/DATETIME.md | 35 +-
.../sql-manual/sql-reference/Data-Types/VARIANT.md | 367 +++
.../ADMIN-DIAGNOSE-TABLET.md | 57 -
.../ADMIN-REPAIR-TABLE.md | 2 +-
.../ADMIN-SET-CONFIG.md | 2 +-
.../ADMIN-SHOW-CONFIG.md | 77 -
.../ADMIN-SHOW-REPLICA-DISTRIBUTION.md | 66 -
.../ADMIN-SHOW-REPLICA-STATUS.md | 83 -
.../ADMIN-SHOW-TABLET-STORAGE-FORMAT.md | 54 -
.../Database-Administration-Statements/KILL.md | 37 +-
.../SET-VARIABLE.md | 22 +-
.../SHOW-CONFIG.md | 77 +
.../SHOW-REPLICA-DISTRIBUTION.md | 66 +
.../SHOW-REPLICA-STATUS.md | 83 +
.../SHOW-TABLET-DIAGNOSIS.md | 58 +
.../SHOW-TABLET-STORAGE-FORMAT.md | 59 +
.../sql-reference/Show-Statements/SHOW-BACKUP.md | 1 +
.../sql-reference/Show-Statements/SHOW-CATALOGS.md | 22 +-
.../sql-reference/Show-Statements/SHOW-POLICY.md | 16 +-
.../Show-Statements/SHOW-PROCESSLIST.md | 2 +-
.../CANCEL-MATERIALIZED-VIEW-TASK.md | 56 +
.../Utility-Statements/PAUSE-MATERIALIZED-VIEW.md | 56 +
.../Utility-Statements/REFRESH-LDAP.md | 2 +-
.../REFRESH-MATERIALIZED-VIEW.md | 72 +
.../Utility-Statements/RESUME-MATERIALIZED-VIEW.md | 56 +
.../doriswriter/DorisStreamLoadObserver.java | 10 +-
.../apache/doris/common/jni/vec/ColumnType.java | 14 +-
.../java/org/apache/doris/jdbc/JdbcDataSource.java | 5 -
.../apache/doris/jdbc/JdbcDataSourceConfig.java | 169 ++
.../java/org/apache/doris/jdbc/JdbcExecutor.java | 94 +-
.../org/apache/doris/paimon/PaimonJniScanner.java | 19 +
fe/be-java-extensions/preload-extensions/pom.xml | 2 +
.../org/apache/doris/catalog/PrimitiveType.java | 2 -
.../java/org/apache/doris/catalog/StructField.java | 2 +-
.../main/java/org/apache/doris/common/Config.java | 82 +-
.../java/org/apache/doris/common/ConfigBase.java | 1 +
.../org/apache/doris/common/FeMetaVersion.java | 6 +-
fe/fe-core/pom.xml | 6 -
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 4 +
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 18 +-
fe/fe-core/src/main/cup/sql_parser.cup | 106 +-
.../main/java/org/apache/doris/alter/Alter.java | 2 +
.../apache/doris/alter/SchemaChangeHandler.java | 1 +
.../org/apache/doris/alter/SchemaChangeJobV2.java | 21 +-
.../doris/analysis/AdminDiagnoseTabletStmt.java | 76 -
.../apache/doris/analysis/AdminShowConfigStmt.java | 87 -
.../analysis/AdminShowReplicaDistributionStmt.java | 86 -
.../doris/analysis/AdminShowReplicaStatusStmt.java | 165 --
.../analysis/AdminShowTabletStorageFormatStmt.java | 83 -
.../doris/analysis/AlterColumnStatsStmt.java | 5 -
.../doris/analysis/AlterDatabasePropertyStmt.java | 3 +-
.../doris/analysis/AlterDatabaseQuotaStmt.java | 3 +-
.../apache/doris/analysis/AlterDatabaseRename.java | 3 +-
.../apache/doris/analysis/AlterJobStatusStmt.java | 12 +
.../doris/analysis/AlterRoutineLoadStmt.java | 2 +-
.../org/apache/doris/analysis/AlterTableStmt.java | 2 +
.../java/org/apache/doris/analysis/Analyzer.java | 15 +-
.../org/apache/doris/analysis/ArrayLiteral.java | 16 +
.../org/apache/doris/analysis/BinaryPredicate.java | 4 +
.../org/apache/doris/analysis/BrokerLoadStmt.java | 125 -
.../java/org/apache/doris/analysis/CastExpr.java | 2 +-
.../org/apache/doris/analysis/CreateDbStmt.java | 3 +-
.../doris/analysis/CreateMaterializedViewStmt.java | 13 +-
.../doris/analysis/CreateRoutineLoadStmt.java | 4 +-
.../org/apache/doris/analysis/CreateTableStmt.java | 3 +-
.../org/apache/doris/analysis/DateLiteral.java | 8 +
.../org/apache/doris/analysis/DecimalLiteral.java | 16 +-
.../java/org/apache/doris/analysis/DeleteStmt.java | 8 +-
.../org/apache/doris/analysis/DescribeStmt.java | 4 +-
.../apache/doris/analysis/DiagnoseTabletStmt.java | 76 +
.../java/org/apache/doris/analysis/DropDbStmt.java | 7 +-
.../org/apache/doris/analysis/DropPolicyStmt.java | 35 +-
.../org/apache/doris/analysis/DropTableStmt.java | 3 +-
.../main/java/org/apache/doris/analysis/Expr.java | 27 +-
.../apache/doris/analysis/ExprSubstitutionMap.java | 6 +
.../org/apache/doris/analysis/FloatLiteral.java | 2 +-
.../org/apache/doris/analysis/FunctionName.java | 4 +
.../org/apache/doris/analysis/InlineViewRef.java | 11 +-
.../doris/analysis/InsertOverwriteTableStmt.java | 3 +
.../java/org/apache/doris/analysis/IntLiteral.java | 2 +-
.../apache/doris/analysis/InvertedIndexUtil.java | 99 +-
.../org/apache/doris/analysis/LargeIntLiteral.java | 2 +-
.../org/apache/doris/analysis/LiteralExpr.java | 12 +
.../analysis/ModifyTablePropertiesClause.java | 15 +
.../org/apache/doris/analysis/MysqlLoadStmt.java | 100 -
.../apache/doris/analysis/NativeInsertStmt.java | 128 +-
.../apache/doris/analysis/NumericLiteralExpr.java | 31 +
.../org/apache/doris/analysis/PartitionDesc.java | 7 +-
.../org/apache/doris/analysis/S3TvfLoadStmt.java | 437 ----
.../org/apache/doris/analysis/SchemaTableType.java | 1 -
.../org/apache/doris/analysis/ShowBackupStmt.java | 8 +-
.../org/apache/doris/analysis/ShowColumnStmt.java | 52 +-
.../org/apache/doris/analysis/ShowConfigStmt.java | 87 +
.../java/org/apache/doris/analysis/ShowDbStmt.java | 17 +-
.../org/apache/doris/analysis/ShowIndexStmt.java | 11 +-
.../analysis/ShowReplicaDistributionStmt.java | 86 +
.../doris/analysis/ShowReplicaStatusStmt.java | 165 ++
.../apache/doris/analysis/ShowTableStatsStmt.java | 2 +
.../apache/doris/analysis/ShowTableStatusStmt.java | 46 +-
.../org/apache/doris/analysis/ShowTableStmt.java | 15 +-
.../analysis/ShowTabletStorageFormatStmt.java | 83 +
.../apache/doris/analysis/ShowVariablesStmt.java | 2 +-
.../java/org/apache/doris/analysis/SlotRef.java | 31 +-
.../org/apache/doris/analysis/SparkLoadStmt.java | 99 -
.../org/apache/doris/analysis/StructLiteral.java | 29 +-
.../apache/doris/analysis/TruncateTableStmt.java | 3 +-
.../java/org/apache/doris/analysis/TypeDef.java | 11 -
.../org/apache/doris/analysis/UnifiedLoadStmt.java | 15 -
.../doris/catalog/BuiltinScalarFunctions.java | 30 +-
.../doris/catalog/BuiltinTableValuedFunctions.java | 4 +-
.../java/org/apache/doris/catalog/Database.java | 13 +-
.../java/org/apache/doris/catalog/DatabaseIf.java | 2 +-
.../doris/catalog/DynamicPartitionProperty.java | 11 +-
.../main/java/org/apache/doris/catalog/Env.java | 49 +-
.../doris/catalog/InternalSchemaInitializer.java | 82 +-
.../org/apache/doris/catalog/JdbcResource.java | 17 +-
.../java/org/apache/doris/catalog/JdbcTable.java | 31 +
.../java/org/apache/doris/catalog/MetaObject.java | 4 +-
.../org/apache/doris/catalog/MetadataViewer.java | 8 +-
.../doris/catalog/MysqlCompatibleDatabase.java | 5 -
.../java/org/apache/doris/catalog/OlapTable.java | 34 +-
.../main/java/org/apache/doris/catalog/Table.java | 33 +-
.../org/apache/doris/catalog/TableAttributes.java | 53 +
.../java/org/apache/doris/catalog/TableIf.java | 72 +-
.../org/apache/doris/catalog/TableProperty.java | 29 +
.../main/java/org/apache/doris/catalog/Tablet.java | 4 +
.../main/java/org/apache/doris/catalog/View.java | 5 -
.../doris/catalog/constraint/Constraint.java | 47 +-
.../catalog/constraint/ForeignKeyConstraint.java | 23 +-
.../catalog/constraint/PrimaryKeyConstraint.java | 14 +-
.../doris/catalog/constraint/TableIdentifier.java | 32 +-
.../doris/catalog/constraint/UniqueConstraint.java | 13 +-
.../doris/catalog/external/EsExternalTable.java | 5 -
.../doris/catalog/external/ExternalDatabase.java | 27 +-
.../doris/catalog/external/ExternalTable.java | 10 +
.../doris/catalog/external/HMSExternalTable.java | 54 +-
.../catalog/external/IcebergExternalTable.java | 9 +
.../doris/catalog/external/JdbcExternalTable.java | 10 +-
.../catalog/external/MaxComputeExternalTable.java | 5 -
.../catalog/external/PaimonExternalTable.java | 22 +-
.../doris/catalog/external/TestExternalTable.java | 5 -
.../org/apache/doris/clone/DiskRebalancer.java | 5 +
.../doris/clone/DynamicPartitionScheduler.java | 30 +-
.../java/org/apache/doris/clone/Rebalancer.java | 3 +-
.../java/org/apache/doris/clone/TabletChecker.java | 3 +-
.../org/apache/doris/common/ThreadPoolManager.java | 28 +-
.../apache/doris/common/proc/CatalogsProcDir.java | 10 +-
.../doris/common/profile/ExecutionProfile.java | 33 +-
.../org/apache/doris/common/profile/Profile.java | 20 +-
.../doris/common/publish/TopicPublisherThread.java | 17 +-
.../doris/common/util/InternalDatabaseUtil.java | 37 +
.../apache/doris/common/util/PropertyAnalyzer.java | 20 +
.../apache/doris/common/util/SQLDialectUtils.java | 183 --
.../org/apache/doris/datasource/CatalogIf.java | 6 +-
.../org/apache/doris/datasource/CatalogMgr.java | 1 +
.../apache/doris/datasource/ExternalCatalog.java | 40 +-
.../doris/datasource/ExternalSchemaCache.java | 5 +
.../apache/doris/datasource/InitDatabaseLog.java | 1 +
.../apache/doris/datasource/InternalCatalog.java | 45 +-
.../datasource/hive/event/AlterTableEvent.java | 3 +-
.../datasource/hive/event/CreateTableEvent.java | 3 +-
.../datasource/hive/event/MetastoreEvent.java | 4 +-
.../datasource/iceberg/broker/BrokerInputFile.java | 74 +
.../iceberg/broker/BrokerInputStream.java | 169 ++
.../datasource/iceberg/broker/IcebergBrokerIO.java | 80 +
.../infoschema/ExternalInfoSchemaDatabase.java | 55 +
.../infoschema/ExternalInfoSchemaTable.java | 53 +
.../doris/datasource/jdbc/JdbcExternalCatalog.java | 28 +-
.../doris/datasource/jdbc/client/JdbcClient.java | 39 +-
.../datasource/jdbc/client/JdbcClientConfig.java | 61 +
.../datasource/jdbc/client/JdbcMySQLClient.java | 8 +-
.../jdbc/client/JdbcPostgreSQLClient.java | 3 +-
.../paimon/PaimonFileExternalCatalog.java | 15 +
.../property/constants/PaimonProperties.java | 2 +
.../org/apache/doris/httpv2/rest/LoadAction.java | 63 +-
.../doris/httpv2/rest/QueryDetailAction.java | 63 -
.../org/apache/doris/httpv2/rest/ShowAction.java | 5 +-
.../apache/doris/httpv2/util/LoadSubmitter.java | 4 +-
.../doris/httpv2/util/StatementSubmitter.java | 3 +-
.../doris/insertoverwrite/InsertOverwriteLog.java | 81 +
.../insertoverwrite/InsertOverwriteManager.java | 194 ++
.../doris/insertoverwrite/InsertOverwriteTask.java | 96 +
.../doris/insertoverwrite/InsertOverwriteUtil.java | 133 +
.../org/apache/doris/job/base/AbstractJob.java | 6 +-
.../apache/doris/job/disruptor/TaskDisruptor.java | 2 +-
.../doris/job/extensions/insert/InsertJob.java | 7 +-
.../apache/doris/job/extensions/mtmv/MTMVJob.java | 43 +-
.../apache/doris/job/extensions/mtmv/MTMVTask.java | 47 +-
.../doris/job/extensions/mtmv/MTMVTaskContext.java | 9 +
.../org/apache/doris/job/manager/JobManager.java | 92 +-
.../org/apache/doris/journal/JournalEntity.java | 13 +
.../main/java/org/apache/doris/load/DeleteJob.java | 3 +-
.../org/apache/doris/load/GroupCommitManager.java | 10 +-
.../src/main/java/org/apache/doris/load/Load.java | 27 +-
.../org/apache/doris/load/StreamLoadRecordMgr.java | 6 +-
.../apache/doris/load/loadv2/BrokerLoadJob.java | 4 +-
.../org/apache/doris/load/loadv2/BulkLoadJob.java | 4 +-
.../org/apache/doris/load/loadv2/LoadManager.java | 73 +-
.../doris/load/routineload/KafkaTaskInfo.java | 1 +
.../doris/load/routineload/RoutineLoadJob.java | 20 +-
.../doris/load/routineload/RoutineLoadManager.java | 50 +-
.../load/routineload/RoutineLoadScheduler.java | 17 +-
.../org/apache/doris/load/sync/SyncChecker.java | 1 +
.../org/apache/doris/load/sync/SyncJobManager.java | 67 +-
.../master/PartitionInMemoryInfoCollector.java | 3 +-
.../org/apache/doris/master/ReportHandler.java | 7 +-
.../main/java/org/apache/doris/mtmv/MTMVCache.java | 7 +-
.../org/apache/doris/mtmv/MTMVHookService.java | 10 +
.../java/org/apache/doris/mtmv/MTMVJobManager.java | 8 +-
.../java/org/apache/doris/mtmv/MTMVPlanUtil.java | 18 +-
.../org/apache/doris/mtmv/MTMVRelationManager.java | 6 +
.../java/org/apache/doris/mtmv/MTMVService.java | 9 +
.../main/java/org/apache/doris/mtmv/MTMVUtil.java | 2 +-
.../org/apache/doris/mysql/privilege/Role.java | 3 +
.../doris/mysql/privilege/UserPropertyInfo.java | 3 +-
.../org/apache/doris/nereids/CascadesContext.java | 3 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 31 +-
.../org/apache/doris/nereids/StatementContext.java | 31 +-
.../org/apache/doris/nereids/cost/CostModelV1.java | 9 +-
.../org/apache/doris/nereids/cost/CostModelV2.java | 6 +
.../exceptions/DialectTransformException.java | 3 +-
.../nereids/exceptions/MetaNotFoundException.java | 74 +
.../exceptions/UnsupportedDialectException.java | 9 +-
.../glue/translator/PhysicalPlanTranslator.java | 203 +-
.../glue/translator/PlanTranslatorContext.java | 4 +
.../apache/doris/nereids/hint/DistributeHint.java | 76 +
.../java/org/apache/doris/nereids/hint/Hint.java | 4 +
.../org/apache/doris/nereids/hint/LeadingHint.java | 93 +-
.../java/org/apache/doris/nereids/jobs/Job.java | 7 +-
.../nereids/jobs/cascades/CostAndEnforcerJob.java | 5 -
.../jobs/cascades/OptimizeGroupExpressionJob.java | 30 +-
.../doris/nereids/jobs/executor/Analyzer.java | 2 +
.../doris/nereids/jobs/executor/Optimizer.java | 16 +-
.../doris/nereids/jobs/executor/Rewriter.java | 14 +-
.../joinorder/hypergraph/ConflictRulesMaker.java | 108 +
.../jobs/joinorder/hypergraph/HyperGraph.java | 79 +-
.../jobs/joinorder/hypergraph/edge/Edge.java | 16 +-
.../jobs/joinorder/hypergraph/edge/FilterEdge.java | 4 +
.../jobs/joinorder/hypergraph/edge/JoinEdge.java | 5 +
.../joinorder/hypergraph/node/StructInfoNode.java | 68 +
.../hypergraph/receiver/PlanReceiver.java | 140 +-
.../nereids/jobs/scheduler/SimpleJobScheduler.java | 12 +-
.../org/apache/doris/nereids/metrics/Event.java | 7 +-
.../doris/nereids/minidump/MinidumpUtils.java | 36 +-
.../nereids/parser/ComplexFnCallTransformer.java | 2 +-
.../org/apache/doris/nereids/parser/Dialect.java | 97 +
.../doris/nereids/parser/LogicalPlanBuilder.java | 85 +-
.../parser/LogicalPlanBuilderAssistant.java | 3 +-
.../apache/doris/nereids/parser/NereidsParser.java | 47 +-
.../apache/doris/nereids/parser/ParseDialect.java | 129 -
.../apache/doris/nereids/parser/ParserContext.java | 6 +-
.../parser/spark/DateTruncFnCallTransformer.java | 81 -
.../parser/spark/SparkSql3FnCallTransformers.java | 93 -
.../parser/spark/SparkSql3LogicalPlanBuilder.java | 88 -
.../parser/trino/DateDiffFnCallTransformer.java | 64 -
.../parser/trino/TrinoFnCallTransformers.java | 61 -
.../parser/trino/TrinoLogicalPlanBuilder.java | 329 ---
.../doris/nereids/parser/trino/TrinoParser.java | 102 -
.../processor/post/AddOffsetIntoDistribute.java | 41 +
.../nereids/processor/post/PlanPostProcessors.java | 4 +
.../processor/post/RuntimeFilterContext.java | 98 +-
.../processor/post/RuntimeFilterGenerator.java | 100 +-
.../processor/post/RuntimeFilterPruner.java | 64 +-
.../post/RuntimeFilterPrunerForExternalTable.java | 165 ++
.../doris/nereids/processor/post/TopNScanOpt.java | 66 +-
.../properties/ChildOutputPropertyDeriver.java | 6 +
.../doris/nereids/properties/DistributionSpec.java | 5 +-
.../nereids/properties/FunctionalDependencies.java | 5 +-
.../nereids/properties/RequestPropertyDeriver.java | 12 +-
.../org/apache/doris/nereids/rules/RuleSet.java | 10 +-
.../org/apache/doris/nereids/rules/RuleType.java | 7 +
.../nereids/rules/analysis/BindExpression.java | 4 +-
.../doris/nereids/rules/analysis/BindRelation.java | 5 +-
.../doris/nereids/rules/analysis/BindSink.java | 7 +-
.../nereids/rules/analysis/CheckAfterRewrite.java | 20 +-
.../rules/analysis/EliminateLogicalSelectHint.java | 4 +-
.../nereids/rules/analysis/FillUpMissingSlots.java | 5 -
.../nereids/rules/analysis/HavingToFilter.java | 34 +
.../nereids/rules/analysis/NormalizeAggregate.java | 264 +-
.../ResolveOrdinalInOrderByAndGroupBy.java | 12 +-
.../nereids/rules/analysis/SubqueryToApply.java | 3 +-
.../rules/exploration/join/InnerJoinLAsscom.java | 2 +-
.../exploration/join/InnerJoinLAsscomProject.java | 2 +-
.../exploration/join/InnerJoinLeftAssociate.java | 2 +-
.../join/InnerJoinLeftAssociateProject.java | 2 +-
.../exploration/join/InnerJoinRightAssociate.java | 2 +-
.../join/InnerJoinRightAssociateProject.java | 2 +-
.../rules/exploration/join/JoinCommute.java | 12 +-
.../rules/exploration/join/JoinExchange.java | 15 +-
.../exploration/join/JoinExchangeBothProject.java | 16 +-
.../exploration/join/JoinExchangeLeftProject.java | 16 +-
.../exploration/join/JoinExchangeRightProject.java | 16 +-
.../join/LogicalJoinSemiJoinTranspose.java | 4 +-
.../join/LogicalJoinSemiJoinTransposeProject.java | 8 +-
.../exploration/join/OuterJoinAssocProject.java | 2 +-
.../rules/exploration/join/OuterJoinLAsscom.java | 2 +-
.../exploration/join/OuterJoinLAsscomProject.java | 2 +-
.../join/PushDownProjectThroughInnerOuterJoin.java | 4 +-
.../join/PushDownProjectThroughSemiJoin.java | 4 +-
.../join/SemiJoinSemiJoinTranspose.java | 2 +-
.../join/SemiJoinSemiJoinTransposeProject.java | 2 +-
.../mv/AbstractMaterializedViewAggregateRule.java | 326 ++-
.../mv/AbstractMaterializedViewJoinRule.java | 9 +-
.../mv/AbstractMaterializedViewRule.java | 503 ++--
.../rules/exploration/mv/ComparisonResult.java | 26 +-
.../rules/exploration/mv/EquivalenceClass.java | 5 +
.../rules/exploration/mv/HyperGraphComparator.java | 190 +-
.../mv/LogicalCompatibilityContext.java | 33 +-
.../exploration/mv/MaterializationContext.java | 99 +
.../exploration/mv/MaterializedViewUtils.java | 18 +
.../nereids/rules/exploration/mv/Predicates.java | 194 +-
.../rules/exploration/mv/PredicatesSplitter.java | 3 +
.../nereids/rules/exploration/mv/StructInfo.java | 43 +-
.../exploration/mv/mapping/ExpressionMapping.java | 6 +
.../rules/exploration/mv/mapping/Mapping.java | 5 +
.../rules/exploration/mv/mapping/SlotMapping.java | 5 +
.../rules/expression/ExpressionRewrite.java | 2 +-
.../expression/rules/FoldConstantRuleOnFE.java | 2 +-
.../rules/expression/rules/FunctionBinder.java | 7 +-
.../rules/OneRangePartitionEvaluator.java | 2 +-
.../rules/expression/rules/SimplifyCastRule.java | 9 +-
.../rules/SimplifyComparisonPredicate.java | 20 +-
.../rules/implementation/AggregateStrategies.java | 175 +-
.../implementation/LogicalJoinToHashJoin.java | 2 +-
.../LogicalOdbcScanToPhysicalOdbcScan.java | 42 +
.../doris/nereids/rules/rewrite/CTEInline.java | 7 +-
.../rules/rewrite/EliminateEmptyRelation.java | 20 +-
.../nereids/rules/rewrite/EliminateFilter.java | 10 +-
.../nereids/rules/rewrite/EliminateJoinByFK.java | 6 +-
.../rules/rewrite/EliminateJoinByUnique.java | 48 +
.../nereids/rules/rewrite/ExistsApplyToJoin.java | 47 +-
.../rules/rewrite/ExtractFilterFromCrossJoin.java | 2 +-
.../rules/rewrite/FindHashConditionForJoin.java | 2 +-
.../doris/nereids/rules/rewrite/InApplyToJoin.java | 9 +-
.../nereids/rules/rewrite/InferPredicates.java | 15 +-
.../doris/nereids/rules/rewrite/MergeTopNs.java | 56 +
.../doris/nereids/rules/rewrite/OrExpansion.java | 6 +-
.../rules/rewrite/PredicatePropagation.java | 272 ++-
.../rules/rewrite/PullUpJoinFromUnionAll.java | 7 +-
.../nereids/rules/rewrite/PullUpPredicates.java | 4 +-
.../rules/rewrite/PushConjunctsIntoOdbcScan.java | 39 +
.../rules/rewrite/PushDownFilterThroughJoin.java | 2 +-
.../rules/rewrite/PushDownJoinOtherCondition.java | 2 +-
.../rules/rewrite/PushFilterInsideJoin.java | 2 +-
.../rewrite/PushProjectIntoOneRowRelation.java | 36 +-
.../doris/nereids/rules/rewrite/ReorderJoin.java | 22 +-
.../nereids/rules/rewrite/ScalarApplyToJoin.java | 7 +-
.../nereids/rules/rewrite/SemiJoinCommute.java | 2 +-
.../rewrite/TransposeSemiJoinLogicalJoin.java | 2 +-
.../TransposeSemiJoinLogicalJoinProject.java | 2 +-
.../mv/SelectMaterializedIndexWithAggregate.java | 9 +-
.../doris/nereids/stats/ExpressionEstimation.java | 64 +-
.../doris/nereids/stats/FilterEstimation.java | 61 +-
.../doris/nereids/stats/StatsCalculator.java | 66 +-
.../org/apache/doris/nereids/trees/TreeNode.java | 28 +
.../trees/copier/LogicalPlanDeepCopier.java | 15 +-
.../doris/nereids/trees/expressions/Any.java | 10 +
.../doris/nereids/trees/expressions/Cast.java | 2 +-
.../doris/nereids/trees/expressions/EqualTo.java | 4 -
.../nereids/trees/expressions/InPredicate.java | 11 +
.../functions/ComputeSignatureHelper.java | 3 +-
.../expressions/functions/agg/BitmapUnion.java | 8 +-
.../functions/agg/BitmapUnionCount.java | 8 +-
.../functions/agg/MultiDistinctSum.java | 5 +
.../trees/expressions/functions/agg/Sum.java | 2 +-
.../functions/scalar/ArrayEnumerateUniq.java | 73 +
.../expressions/functions/scalar/ArrayShuffle.java | 86 +
.../expressions/functions/scalar/ConnectionId.java | 4 +-
.../expressions/functions/scalar/CreateStruct.java | 8 +-
.../trees/expressions/functions/scalar/G.java | 69 +
.../functions/scalar/IPv6CIDRToRange.java | 79 +
.../functions/scalar/Ipv4NumToString.java | 6 +-
.../functions/scalar/Ipv4StringToNum.java | 6 +-
.../functions/scalar/Ipv4StringToNumOrDefault.java | 6 +-
.../functions/scalar/Ipv4StringToNumOrNull.java | 6 +-
.../functions/scalar/Ipv6NumToString.java | 11 +-
.../functions/scalar/Ipv6StringToNum.java | 66 +
.../functions/scalar/Ipv6StringToNumOrDefault.java | 66 +
.../functions/scalar/Ipv6StringToNumOrNull.java | 66 +
.../functions/scalar/IsIpAddressInRange.java | 67 +
.../expressions/functions/scalar/IsIpv4String.java | 67 +
.../expressions/functions/scalar/IsIpv6String.java | 67 +
.../expressions/functions/scalar/NonNullable.java | 10 +
.../expressions/functions/scalar/Nullable.java | 10 +
.../expressions/functions/scalar/Truncate.java | 18 +-
.../expressions/functions/table/ActiveQueries.java | 59 +
.../trees/expressions/functions/table/Queries.java | 59 -
.../trees/expressions/functions/window/Lag.java | 16 +-
.../trees/expressions/functions/window/Lead.java | 16 +-
.../functions/window/WindowFunction.java | 18 +-
.../trees/expressions/literal/ArrayLiteral.java | 6 +-
.../trees/expressions/literal/DecimalLiteral.java | 3 +-
.../expressions/literal/DecimalV3Literal.java | 4 +-
.../trees/expressions/literal/DoubleLiteral.java | 16 +-
.../trees/expressions/literal/FloatLiteral.java | 11 +-
.../expressions/literal/FractionalLiteral.java | 34 +
.../expressions/literal/IntegerLikeLiteral.java | 2 +-
.../nereids/trees/expressions/literal/Literal.java | 8 +
.../trees/expressions/literal/MapLiteral.java | 32 +-
.../trees/expressions/literal/NumericLiteral.java | 34 +
.../expressions/literal/StringLikeLiteral.java | 5 +-
.../trees/expressions/literal/StructLiteral.java | 56 +-
.../expressions/visitor/ScalarFunctionVisitor.java | 50 +
.../visitor/TableValuedFunctionVisitor.java | 4 +-
.../doris/nereids/trees/plans/AbstractPlan.java | 9 +-
.../doris/nereids/trees/plans/DistributeType.java | 72 +
.../apache/doris/nereids/trees/plans/JoinHint.java | 72 -
.../apache/doris/nereids/trees/plans/ObjectId.java | 5 -
.../org/apache/doris/nereids/trees/plans/Plan.java | 4 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 4 +
.../doris/nereids/trees/plans/algebra/Join.java | 25 +-
.../doris/nereids/trees/plans/algebra/Project.java | 13 +-
.../trees/plans/commands/AddConstraintCommand.java | 15 +-
.../plans/commands/CancelMTMVTaskCommand.java | 50 +
.../trees/plans/commands/DeleteFromCommand.java | 10 +
.../plans/commands/DeleteFromUsingCommand.java | 4 +-
.../plans/commands/DropConstraintCommand.java | 9 +-
.../trees/plans/commands/InsertExecutor.java | 38 +-
.../plans/commands/InsertIntoTableCommand.java | 18 +-
.../commands/InsertOverwriteTableCommand.java | 178 +-
.../plans/commands/ShowConstraintsCommand.java | 66 +
.../trees/plans/commands/UpdateCommand.java | 6 +-
.../trees/plans/commands/info/AlterMTMVInfo.java | 4 +-
.../plans/commands/info/CancelMTMVTaskInfo.java | 91 +
.../plans/commands/info/ColumnDefinition.java | 14 -
.../trees/plans/commands/info/CreateMTMVInfo.java | 101 +-
.../trees/plans/commands/info/CreateTableInfo.java | 27 +-
.../trees/plans/commands/info/DropMTMVInfo.java | 4 +-
.../trees/plans/commands/info/PauseMTMVInfo.java | 7 +
.../trees/plans/commands/info/RefreshMTMVInfo.java | 13 +-
.../trees/plans/commands/info/ResumeMTMVInfo.java | 7 +
.../nereids/trees/plans/logical/LogicalApply.java | 9 +-
.../nereids/trees/plans/logical/LogicalJoin.java | 52 +-
.../trees/plans/logical/LogicalOdbcScan.java | 104 +
.../trees/plans/logical/LogicalSchemaScan.java | 5 +-
.../nereids/trees/plans/logical/UsingJoin.java | 12 +-
.../trees/plans/physical/AbstractPhysicalJoin.java | 15 +-
.../trees/plans/physical/AbstractPhysicalPlan.java | 15 +-
.../trees/plans/physical/PhysicalDistribute.java | 45 +-
.../plans/physical/PhysicalHashAggregate.java | 5 +-
.../trees/plans/physical/PhysicalHashJoin.java | 39 +-
.../trees/plans/physical/PhysicalLimit.java | 5 +
.../plans/physical/PhysicalNestedLoopJoin.java | 7 +-
.../trees/plans/physical/PhysicalOdbcScan.java | 102 +
.../trees/plans/physical/PhysicalOlapScan.java | 7 +-
.../trees/plans/physical/PhysicalProject.java | 74 +-
.../trees/plans/physical/PhysicalSchemaScan.java | 10 +-
.../trees/plans/physical/RuntimeFilter.java | 23 +-
.../trees/plans/visitor/CommandVisitor.java | 10 +
.../plans/visitor/ExpressionLineageReplacer.java | 25 +-
.../trees/plans/visitor/RelationVisitor.java | 10 +
.../apache/doris/nereids/util/ExpressionUtils.java | 33 +
.../doris/nereids/util/ImmutableEqualSet.java | 106 +
.../nereids/util/ImmutableEquivalenceSet.java | 89 -
.../apache/doris/nereids/util/MutableState.java | 2 +
.../org/apache/doris/nereids/util/PlanUtils.java | 23 +-
.../doris/nereids/util/TypeCoercionUtils.java | 19 +-
.../java/org/apache/doris/nereids/util/Utils.java | 12 +
.../apache/doris/persist/AlterConstraintLog.java | 61 +
.../java/org/apache/doris/persist/EditLog.java | 62 +-
.../org/apache/doris/persist/OperationType.java | 11 +
.../org/apache/doris/persist/gson/GsonUtils.java | 28 +-
.../doris/persist/meta/MetaPersistMethod.java | 6 +
.../doris/persist/meta/PersistMetaModules.java | 3 +-
.../org/apache/doris/planner/AggregationNode.java | 1 +
.../org/apache/doris/planner/EmptySetNode.java | 1 -
.../apache/doris/planner/GroupCommitPlanner.java | 2 +
.../org/apache/doris/planner/HashJoinNode.java | 12 +-
.../org/apache/doris/planner/MysqlScanNode.java | 3 +-
.../org/apache/doris/planner/OlapScanNode.java | 29 +-
.../org/apache/doris/planner/OlapTableSink.java | 1 +
.../org/apache/doris/planner/OriginalPlanner.java | 11 +-
.../java/org/apache/doris/planner/PlanNode.java | 54 +-
.../org/apache/doris/planner/RuntimeFilter.java | 4 +
.../java/org/apache/doris/planner/ScanNode.java | 6 +-
.../org/apache/doris/planner/SchemaScanNode.java | 15 +-
.../apache/doris/planner/SingleNodePlanner.java | 4 +-
.../java/org/apache/doris/planner/SortNode.java | 7 +
.../apache/doris/planner/StreamLoadPlanner.java | 11 +-
.../planner/external/FederationBackendPolicy.java | 11 +-
.../doris/planner/external/FileQueryScanNode.java | 32 +-
.../doris/planner/external/HiveScanNode.java | 23 -
.../external/iceberg/IcebergMetadataCache.java | 17 +-
.../external/jdbc/JdbcFunctionPushDownRule.java | 30 +-
.../doris/planner/external/jdbc/JdbcScanNode.java | 50 +-
.../doris/planner/external/jdbc/JdbcTableSink.java | 28 +-
.../doris/planner/external/odbc/OdbcScanNode.java | 53 +-
.../external/paimon/PaimonPredicateConverter.java | 17 +-
.../planner/external/paimon/PaimonScanNode.java | 74 +-
.../planner/external/paimon/PaimonSource.java | 5 +
.../doris/planner/external/paimon/PaimonSplit.java | 26 +-
.../java/org/apache/doris/plugin/AuditEvent.java | 238 --
.../java/org/apache/doris/plugin/AuditPlugin.java | 2 +
.../doris/plugin/DialectConverterPlugin.java | 61 +
.../org/apache/doris/plugin/LoadAuditEvent.java | 130 -
.../java/org/apache/doris/plugin/PluginInfo.java | 3 +-
.../java/org/apache/doris/plugin/PluginMgr.java | 92 +-
.../apache/doris/plugin/StreamLoadAuditEvent.java | 144 --
.../org/apache/doris/plugin/audit/AuditEvent.java | 247 ++
.../doris/plugin/audit/AuditLoaderPlugin.java | 252 ++
.../apache/doris/plugin/audit/AuditLogBuilder.java | 163 ++
.../doris/plugin/audit/AuditStreamLoader.java | 182 ++
.../apache/doris/plugin/audit/LoadAuditEvent.java | 130 +
.../doris/plugin/audit/StreamLoadAuditEvent.java | 144 ++
.../plugin/dialect/HttpDialectConverterPlugin.java | 114 +
.../doris/plugin/dialect/HttpDialectUtils.java | 140 ++
.../org/apache/doris/policy/DropPolicyLog.java | 33 +-
.../java/org/apache/doris/policy/RowPolicy.java | 7 +
.../org/apache/doris/qe/AuditEventProcessor.java | 4 +-
.../java/org/apache/doris/qe/AuditLogBuilder.java | 164 --
.../java/org/apache/doris/qe/AuditLogHelper.java | 52 +-
.../java/org/apache/doris/qe/ConnectContext.java | 2 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 41 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 73 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 6 +
.../java/org/apache/doris/qe/GlobalVariable.java | 30 +-
.../main/java/org/apache/doris/qe/QeProcessor.java | 3 +
.../java/org/apache/doris/qe/QeProcessorImpl.java | 22 +
.../java/org/apache/doris/qe/SessionVariable.java | 155 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 61 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 52 +-
.../WorkloadRuntimeStatusMgr.java | 228 ++
.../org/apache/doris/rewrite/FunctionAlias.java | 59 +
.../doris/scheduler/disruptor/TaskDisruptor.java | 2 +-
.../apache/doris/service/FrontendServiceImpl.java | 186 +-
.../org/apache/doris/statistics/AnalysisInfo.java | 5 +-
.../doris/statistics/AnalysisInfoBuilder.java | 9 +-
.../apache/doris/statistics/AnalysisJobInfo.java | 54 +
.../apache/doris/statistics/AnalysisManager.java | 85 +-
.../apache/doris/statistics/AnalysisTaskInfo.java | 58 +
.../org/apache/doris/statistics/ColStatsData.java | 2 +-
.../doris/statistics/ExternalAnalysisTask.java | 263 ++
.../apache/doris/statistics/HMSAnalysisTask.java | 287 +--
.../doris/statistics/NewPartitionLoadedEvent.java | 57 +
.../apache/doris/statistics/OlapAnalysisTask.java | 13 +-
.../java/org/apache/doris/statistics/README.md | 46 +-
.../org/apache/doris/statistics/Statistics.java | 25 +-
.../doris/statistics/StatisticsAutoCollector.java | 29 +-
.../apache/doris/statistics/StatisticsBuilder.java | 10 +-
.../doris/statistics/StatisticsRepository.java | 8 +
.../apache/doris/statistics/TableStatsMeta.java | 7 +-
.../apache/doris/statistics/UpdateRowsEvent.java | 61 +
.../apache/doris/statistics/util/SimpleQueue.java | 65 -
.../doris/statistics/util/StatisticsUtil.java | 12 +-
.../ActiveQueriesTableValuedFunction.java | 98 +
.../ExternalFileTableValuedFunction.java | 6 +-
.../tablefunction/JobsTableValuedFunction.java | 10 +-
.../doris/tablefunction/MetadataGenerator.java | 115 +-
.../tablefunction/MetadataTableValuedFunction.java | 2 +-
.../tablefunction/QueriesTableValuedFunction.java | 93 -
.../doris/tablefunction/TableValuedFunctionIf.java | 4 +-
.../tablefunction/TasksTableValuedFunction.java | 10 +-
.../doris/transaction/DatabaseTransactionMgr.java | 72 +-
.../transaction/DbUsedDataQuotaInfoCollector.java | 3 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 1 +
.../doris/analysis/AdminShowReplicaTest.java | 159 --
.../doris/analysis/CancelExportStmtTest.java | 10 +-
.../apache/doris/analysis/CancelLoadStmtTest.java | 10 +-
.../analysis/CreateTableAsSelectStmtTest.java | 84 +-
.../apache/doris/analysis/DataDescriptionTest.java | 16 +-
.../apache/doris/analysis/DecimalLiteralTest.java | 7 +
.../org/apache/doris/analysis/DeleteStmtTest.java | 4 +-
.../org/apache/doris/analysis/InsertStmtTest.java | 3 -
.../org/apache/doris/analysis/MapLiteralTest.java | 4 +-
.../doris/analysis/RangePartitionPruneTest.java | 2 +-
.../apache/doris/analysis/S3TvfLoadStmtTest.java | 244 --
.../org/apache/doris/analysis/SelectStmtTest.java | 41 +-
.../apache/doris/analysis/ShowAlterStmtTest.java | 4 +-
.../apache/doris/analysis/ShowBackupStmtTest.java | 150 ++
.../doris/analysis/ShowCreateFunctionTest.java | 12 +-
.../doris/analysis/ShowCreateLoadStmtTest.java | 98 +
.../apache/doris/analysis/ShowExportStmtTest.java | 4 +-
.../apache/doris/analysis/ShowIndexStmtTest.java | 2 +-
.../apache/doris/analysis/ShowLoadStmtTest.java | 4 +-
.../doris/analysis/ShowPartitionsStmtTest.java | 188 +-
.../org/apache/doris/analysis/ShowReplicaTest.java | 159 ++
.../doris/analysis/ShowResourcesStmtTest.java | 2 +-
.../org/apache/doris/analysis/SqlModeTest.java | 4 +-
.../apache/doris/analysis/StructLiteralTest.java | 9 +-
.../org/apache/doris/catalog/CreateTableTest.java | 23 +
.../org/apache/doris/catalog/CreateViewTest.java | 7 +-
.../org/apache/doris/catalog/RefreshTableTest.java | 12 +
.../catalog/constraint/ConstraintPersistTest.java | 305 +++
.../org/apache/doris/clone/RebalancerTestUtil.java | 3 +-
.../doris/clone/TabletRepairAndBalanceTest.java | 4 +-
.../doris/common/util/SQLDialectUtilsTest.java | 86 -
.../doris/datasource/RefreshCatalogTest.java | 25 +-
.../job/base/JobExecutionConfigurationTest.java | 4 +-
.../apache/doris/load/loadv2/LoadManagerTest.java | 46 +-
.../load/routineload/RoutineLoadManagerTest.java | 43 +-
.../apache/doris/load/sync/SyncJobManagerTest.java | 36 +
.../org/apache/doris/mysql/MysqlServerTest.java | 143 --
.../apache/doris/nereids/DistributeHintTest.java | 149 ++
.../org/apache/doris/nereids/JoinHintTest.java | 149 --
.../joinorder/hypergraph/CompareOuterJoinTest.java | 6 +-
.../jobs/joinorder/hypergraph/InferJoinTest.java | 6 +-
.../joinorder/hypergraph/InferPredicateTest.java | 6 +-
.../joinorder/hypergraph/PullupExpressionTest.java | 6 +-
.../joinorder/joinhint/DistributeHintTest.java | 153 ++
.../jobs/joinorder/joinhint/JoinHintTest.java | 153 --
.../doris/nereids/parser/NereidsParserTest.java | 79 +-
.../doris/nereids/parser/ParserTestBase.java | 4 -
.../nereids/parser/spark/FnTransformTest.java | 89 -
.../nereids/parser/trino/FnTransformTest.java | 46 -
.../doris/nereids/parser/trino/QueryTest.java | 42 -
.../nereids/postprocess/TopNRuntimeFilterTest.java | 22 +-
.../properties/ChildOutputPropertyDeriverTest.java | 27 +-
.../properties/RequestPropertyDeriverTest.java | 7 +-
.../nereids/rules/analysis/CheckRowPolicyTest.java | 17 +-
.../rules/exploration/mv/HyperGraphAggTest.java | 98 +
.../exploration/mv/HyperGraphComparatorTest.java | 172 ++
.../exploration/mv/MaterializedViewUtilsTest.java | 49 +
.../rules/expression/ExpressionRewriteTest.java | 8 +-
.../expression/SimplifyArithmeticRuleTest.java | 18 +-
.../rules/SimplifyComparisonPredicateTest.java | 19 +
.../rules/rewrite/EliminateJoinByUniqueTest.java | 97 +
.../rewrite/FindHashConditionForJoinTest.java | 7 +-
.../nereids/rules/rewrite/InferPredicatesTest.java | 62 +-
.../nereids/rules/rewrite/MergeTopNsTest.java | 77 +
.../rules/rewrite/PredicatePropagationTest.java | 67 +
.../nereids/stats/ExpressionEstimationTest.java | 71 +
.../doris/nereids/stats/FilterEstimationTest.java | 207 +-
.../functions/ComputeSignatureHelperTest.java | 14 +-
.../doris/nereids/trees/plans/ConstraintTest.java | 10 +-
.../trees/plans/DeleteFromUsingCommandTest.java | 20 +-
.../doris/nereids/trees/plans/PlanEqualsTest.java | 7 +-
.../nereids/trees/plans/PlanToStringTest.java | 1 +
.../doris/nereids/util/HyperGraphBuilder.java | 9 +-
.../doris/nereids/util/LogicalPlanBuilder.java | 5 +-
.../org/apache/doris/nereids/util/PlanChecker.java | 1 -
.../nereids/util/TrinoDialectPlanParseChecker.java | 60 -
.../org/apache/doris/nereids/util/UtilsTest.java | 35 +
.../java/org/apache/doris/planner/PlannerTest.java | 6 +-
.../org/apache/doris/planner/QueryPlanTest.java | 78 +-
.../org/apache/doris/planner/RepeatNodeTest.java | 2 +-
.../doris/planner/TableFunctionPlanTest.java | 8 +-
.../org/apache/doris/plugin/DialectPluginTest.java | 76 +
.../apache/doris/plugin/HttpDialectUtilsTest.java | 92 +
.../java/org/apache/doris/plugin/PluginTest.java | 59 -
.../org/apache/doris/plugin/SimpleHttpServer.java | 108 +
.../apache/doris/plugin/TestDialectPlugin1.java | 42 +
.../apache/doris/plugin/TestDialectPlugin2.java | 46 +
.../java/org/apache/doris/policy/PolicyTest.java | 78 +-
.../apache/doris/qe/AuditEventProcessorTest.java | 5 +-
.../org/apache/doris/qe/OlapQueryCacheTest.java | 46 +-
.../ExtractCommonFactorsRuleFunctionTest.java | 6 +-
.../doris/service/FrontendServiceImplTest.java | 68 +-
.../doris/statistics/AnalysisManagerTest.java | 61 +-
.../apache/doris/statistics/ColStatsDataTest.java | 96 +
.../doris/statistics/HMSAnalysisTaskTest.java | 4 +-
.../doris/statistics/JdbcAnalysisTaskTest.java | 157 ++
.../doris/statistics/OlapAnalysisTaskTest.java | 2 +-
.../statistics/StatisticsAutoCollectorTest.java | 80 +
.../transaction/DatabaseTransactionMgrTest.java | 12 +-
.../org/apache/doris/utframe/SimpleHttpServer.java | 108 -
.../apache/doris/utframe/TestWithFeService.java | 11 +
fe/pom.xml | 12 +-
.../doris/plugin/audit/AuditLoaderPlugin.java | 10 +-
fe_plugins/pom.xml | 42 +-
fe_plugins/sparksql-converter/pom.xml | 132 +
.../src/main/assembly/plugin.conf | 18 +
.../src/main/assembly/plugin.properties | 23 +
.../src/main/assembly/zip.xml | 0
.../dialect/spark/DateTruncFnCallTransformer.java | 81 +
.../dialect/spark/SparkSql3FnCallTransformers.java | 95 +
.../dialect/spark/SparkSql3LogicalPlanBuilder.java | 88 +
.../spark/SparkSqlDialectConverterPlugin.java | 47 +
.../plugin/dialect/spark/FnTransformTest.java | 106 +
.../doris/plugin/dialect/spark/ParserTest.java | 64 +
fe_plugins/trino-converter/pom.xml | 159 ++
.../trino-converter/src/main/assembly/plugin.conf | 18 +
.../src/main/assembly/plugin.properties | 23 +
.../src/main/assembly/zip.xml | 0
.../dialect/trino/DateDiffFnCallTransformer.java | 64 +
.../dialect/trino/TrinoDialectConverterPlugin.java | 45 +
.../dialect/trino/TrinoFnCallTransformers.java | 62 +
.../dialect/trino/TrinoLogicalPlanBuilder.java | 330 +++
.../doris/plugin/dialect/trino/TrinoParser.java | 105 +
.../plugin/dialect/trino/FnTransformTest.java | 73 +
.../doris/plugin/dialect/trino/ParserTest.java | 66 +
gensrc/proto/internal_service.proto | 12 +-
gensrc/script/doris_builtins_functions.py | 48 +-
gensrc/script/gen_build_version.sh | 6 +-
gensrc/thrift/BackendService.thrift | 1 +
gensrc/thrift/Descriptors.thrift | 6 +-
gensrc/thrift/FrontendService.thrift | 10 +
gensrc/thrift/PaloInternalService.thrift | 7 +
gensrc/thrift/PlanNodes.thrift | 5 +
gensrc/thrift/Types.thrift | 6 +
regression-test/README.md | 15 +-
regression-test/conf/regression-conf.groovy | 1 +
.../backup_restore/test_backup_restore_with.out | 39 +
.../data/correctness/test_str_to_date.out | 18 +
.../data/correctness_p0/test_agg_materialize.out | 3 +
.../test_always_nullable_window_function.out | 40 +-
.../test_outer_join_with_null_value.out | 3 +
.../datatype_p0/datetimev2/test_tz_streamload.out | 3 +
.../datatype_p0/datetimev2/test_tz_streamload2.csv | 5 +-
.../test_array_element_at_and_slice.out | 352 +++
.../test_array_functions_array_intersect_sort.out | 193 ++
.../test_array_functions_array_join.out | 103 +
.../test_array_functions_array_with_const.out | 73 +
...t_array_functions_concat_compact_difference.out | 161 ++
.../test_array_functions_in_ck_case.out | 1043 ++++++++
.../test_array_push_pop_backfront.out | 181 ++
.../test_array_zip_array_enumerate_uniq.out | 25 +
regression-test/data/ddl_p0/test_create_view.out | 2 +-
.../data/empty_relation/eliminate_empty.out | 15 +-
.../iceberg/test_iceberg_statistics.out | 39 +
.../info_schema_db/test_info_schema_db.out | 226 ++
.../jdbc/test_doris_jdbc_catalog.out | 2 +-
.../jdbc/test_mariadb_jdbc_catalog.out | 106 +-
.../jdbc/test_mysql_jdbc_catalog.out | 130 +-
.../jdbc/test_mysql_jdbc_catalog_nereids.out | 88 +-
.../jdbc/test_oracle_jdbc_catalog.out | 2 +
.../jdbc/test_pg_jdbc_catalog.out | 2130 ++++++++--------
.../jdbc/test_sqlserver_jdbc_catalog.out | 1 +
.../paimon/test_paimon_catalog.out | 16 +-
.../paimon/test_paimon_statistics.out | 21 +
...ocal_tvf_with_complex_type_insertinto_doris.out | 3 -
.../hive/test_hive_hudi_statistics.out | 16 +
.../paimon/paimon_base_filesystem.out | 17 +
.../test_index_compaction_fault_injection.out | 291 +++
...st_index_compound_directory_fault_injection.out | 3 +
...test_low_wal_disk_space_fault_injection.csv.gz} | Bin
.../test_too_many_segments_fault_injection.out | 2 +
.../test_index_compaction_dup_keys.out | 123 +
.../test_index_compaction_unique_keys.out | 69 +
..._index_compaction_with_multi_index_segments.out | 105 +
.../load_p0/stream_load/test_publish_timeout.out | 4 +
.../test_migrate_disk_with_publish_version.out | 11 +
regression-test/data/mtmv_p0/test_build_mtmv.out | 3 +
.../data/mv_p0/agg_state/test_agg_state_max_by.out | 19 +
.../data/mv_p0/test_28741/test_28741.out | 4 +
.../data/mv_p0/test_substr/test_substr.out | 4 +
.../testAggQueryOnAggMV1/testAggQueryOnAggMV1.out | 10 +
.../data/nereids_function_p0/ip_functions.out | 77 +-
.../nereids_p0/aggregate/agg_window_project.out | 4 +
.../nereids_p0/cte/test_cte_filter_pushdown.out | 14 +-
.../eliminate_outer_join/eliminate_outer_join.out | 73 +-
.../nereids_p0/explain/test_pushdown_explain.out | 120 +
.../data/nereids_p0/hint/fix_leading.out | 21 +
.../data/nereids_p0/hint/test_leading.out | 1494 +++++++++++-
.../nereids_rules_p0/eager_aggregate/basic.out | 18 +-
.../eager_aggregate/basic_one_side.out | 18 +-
.../push_down_count_through_join.out | 40 +-
.../push_down_count_through_join_one_side.out | 32 +-
.../eager_aggregate/push_down_max_through_join.out | 16 +-
.../eager_aggregate/push_down_min_through_join.out | 16 +-
.../eager_aggregate/push_down_sum_through_join.out | 20 +-
.../push_down_sum_through_join_one_side.out | 16 +-
.../eliminate_not_null/eliminate_not_null.out | 4 +-
.../eliminate_outer_join/eliminate_outer_join.out | 164 +-
.../push_down_alias_through_join.out | 52 +-
.../push_down_expression_in_hash_join.out | 64 +-
.../push_down_filter_other_condition.out | 94 +-
.../filter_push_down/push_filter_through.out | 509 ++++
.../infer_set_operator_distinct.out | 200 +-
.../limit_push_down/limit_push_down.out | 36 +-
.../limit_push_down/order_push_down.out | 44 +-
.../mv/agg_with_roll_up/aggregate_with_roll_up.out | 118 +
.../aggregate_without_roll_up.out | 28 +
.../mv/join/dphyp_inner/inner_join_dphyp.out | 335 +++
.../mv/join/dphyp_outer/outer_join_dphyp.out | 297 +++
.../nereids_rules_p0/mv/join/inner/inner_join.out | 38 +
.../mv/join/left_outer/outer_join.out | 44 +
.../data/nereids_rules_p0/pkfk/eliminate_inner.out | 352 +++
.../predicate_infer/infer_predicate.out | 114 +-
.../push_down_top_n_through_union.out | 2 +-
.../transposeJoin/transposeSemiJoinAgg.out | 16 +-
regression-test/data/nereids_shape_check/load.out | 16 +-
.../data/nereids_ssb_shape_sf100_p0/shape/flat.out | 8 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q1.1.out | 4 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q1.2.out | 4 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q1.3.out | 4 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q2.1.out | 10 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q2.2.out | 10 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q2.3.out | 10 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q3.1.out | 12 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q3.2.out | 12 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q3.3.out | 10 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q3.4.out | 10 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q4.1.out | 16 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q4.2.out | 16 +-
.../data/nereids_ssb_shape_sf100_p0/shape/q4.3.out | 12 +-
.../data/nereids_syntax_p0/constraint.out | 10 +
.../data/nereids_syntax_p0/group_by_constant.out | 3 +
.../push_filter_through_ptopn.out | 10 +-
.../push_filter_through_window.out | 10 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query1.out | 20 +-
.../shape/query10.out | 22 +-
.../shape/query11.out | 28 +-
.../shape/query12.out | 12 +-
.../shape/query13.out | 16 +-
.../shape/query14.out | 80 +-
.../shape/query15.out | 14 +-
.../shape/query16.out | 14 +-
.../shape/query17.out | 24 +-
.../shape/query18.out | 24 +-
.../shape/query19.out | 16 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query2.out | 22 +-
.../shape/query20.out | 10 +-
.../shape/query21.out | 10 +-
.../shape/query22.out | 8 +-
.../shape/query23.out | 38 +-
.../shape/query24.out | 34 +-
.../shape/query25.out | 24 +-
.../shape/query26.out | 14 +-
.../shape/query27.out | 14 +-
.../shape/query28.out | 22 +-
.../shape/query29.out | 22 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query3.out | 8 +-
.../shape/query30.out | 22 +-
.../shape/query31.out | 30 +-
.../shape/query32.out | 8 +-
.../shape/query33.out | 46 +-
.../shape/query34.out | 12 +-
.../shape/query35.out | 28 +-
.../shape/query36.out | 14 +-
.../shape/query37.out | 10 +-
.../shape/query38.out | 26 +-
.../shape/query39.out | 16 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query4.out | 52 +-
.../shape/query40.out | 10 +-
.../shape/query41.out | 8 +-
.../shape/query42.out | 8 +-
.../shape/query43.out | 8 +-
.../shape/query44.out | 30 +-
.../shape/query45.out | 20 +-
.../shape/query46.out | 20 +-
.../shape/query47.out | 18 +-
.../shape/query48.out | 12 +-
.../shape/query49.out | 28 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query5.out | 60 +-
.../shape/query50.out | 10 +-
.../shape/query51.out | 85 +-
.../shape/query52.out | 8 +-
.../shape/query53.out | 61 +-
.../shape/query54.out | 62 +-
.../shape/query55.out | 8 +-
.../shape/query56.out | 38 +-
.../shape/query57.out | 18 +-
.../shape/query58.out | 133 +-
.../shape/query59.out | 22 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query6.out | 26 +-
.../shape/query60.out | 46 +-
.../shape/query61.out | 34 +-
.../shape/query62.out | 12 +-
.../shape/query63.out | 12 +-
.../shape/query64.out | 158 +-
.../shape/query65.out | 24 +-
.../shape/query66.out | 24 +-
.../shape/query67.out | 12 +-
.../shape/query68.out | 16 +-
.../shape/query69.out | 28 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query7.out | 14 +-
.../shape/query70.out | 20 +-
.../shape/query71.out | 28 +-
.../shape/query72.out | 34 +-
.../shape/query73.out | 14 +-
.../shape/query74.out | 28 +-
.../shape/query75.out | 28 +-
.../shape/query76.out | 26 +-
.../shape/query77.out | 38 +-
.../shape/query78.out | 14 +-
.../shape/query79.out | 14 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query8.out | 18 +-
.../shape/query80.out | 52 +-
.../shape/query81.out | 24 +-
.../shape/query82.out | 10 +-
.../shape/query83.out | 38 +-
.../shape/query84.out | 12 +-
.../shape/query85.out | 18 +-
.../shape/query86.out | 10 +-
.../shape/query87.out | 26 +-
.../shape/query88.out | 78 +-
.../shape/query89.out | 12 +-
.../nereids_tpcds_shape_sf1000_p0/shape/query9.out | 62 +-
.../shape/query90.out | 18 +-
.../shape/query91.out | 18 +-
.../shape/query92.out | 8 +-
.../shape/query93.out | 6 +-
.../shape/query94.out | 14 +-
.../shape/query95.out | 20 +-
.../shape/query96.out | 8 +-
.../shape/query97.out | 10 +-
.../shape/query98.out | 10 +-
.../shape/query99.out | 12 +-
.../constraints/query23.out | 96 +
.../noStatsRfPrune/query1.out | 18 +-
.../noStatsRfPrune/query10.out | 54 +-
.../noStatsRfPrune/query11.out | 22 +-
.../noStatsRfPrune/query12.out | 10 +-
.../noStatsRfPrune/query13.out | 14 +-
.../noStatsRfPrune/query14.out | 80 +-
.../noStatsRfPrune/query15.out | 14 +-
.../noStatsRfPrune/query16.out | 14 +-
.../noStatsRfPrune/query17.out | 24 +-
.../noStatsRfPrune/query18.out | 20 +-
.../noStatsRfPrune/query19.out | 16 +-
.../noStatsRfPrune/query2.out | 20 +-
.../noStatsRfPrune/query20.out | 10 +-
.../noStatsRfPrune/query21.out | 10 +-
.../noStatsRfPrune/query22.out | 8 +-
.../noStatsRfPrune/query23.out | 38 +-
.../noStatsRfPrune/query24.out | 24 +-
.../noStatsRfPrune/query25.out | 24 +-
.../noStatsRfPrune/query26.out | 12 +-
.../noStatsRfPrune/query27.out | 12 +-
.../noStatsRfPrune/query28.out | 22 +-
.../noStatsRfPrune/query29.out | 24 +-
.../noStatsRfPrune/query3.out | 8 +-
.../noStatsRfPrune/query30.out | 22 +-
.../noStatsRfPrune/query31.out | 28 +-
.../noStatsRfPrune/query32.out | 8 +-
.../noStatsRfPrune/query33.out | 40 +-
.../noStatsRfPrune/query34.out | 12 +-
.../noStatsRfPrune/query35.out | 50 +-
.../noStatsRfPrune/query36.out | 12 +-
.../noStatsRfPrune/query37.out | 12 +-
.../noStatsRfPrune/query38.out | 26 +-
.../noStatsRfPrune/query39.out | 16 +-
.../noStatsRfPrune/query4.out | 30 +-
.../noStatsRfPrune/query40.out | 10 +-
.../noStatsRfPrune/query41.out | 8 +-
.../noStatsRfPrune/query42.out | 8 +-
.../noStatsRfPrune/query43.out | 8 +-
.../noStatsRfPrune/query44.out | 127 +-
.../noStatsRfPrune/query45.out | 18 +-
.../noStatsRfPrune/query46.out | 20 +-
.../noStatsRfPrune/query47.out | 18 +-
.../noStatsRfPrune/query48.out | 12 +-
.../noStatsRfPrune/query49.out | 28 +-
.../noStatsRfPrune/query5.out | 34 +-
.../noStatsRfPrune/query50.out | 10 +-
.../noStatsRfPrune/query51.out | 85 +-
.../noStatsRfPrune/query52.out | 8 +-
.../noStatsRfPrune/query53.out | 59 +-
.../noStatsRfPrune/query54.out | 40 +-
.../noStatsRfPrune/query55.out | 8 +-
.../noStatsRfPrune/query56.out | 34 +-
.../noStatsRfPrune/query57.out | 18 +-
.../noStatsRfPrune/query58.out | 58 +-
.../noStatsRfPrune/query59.out | 49 +-
.../noStatsRfPrune/query6.out | 26 +-
.../noStatsRfPrune/query60.out | 40 +-
.../noStatsRfPrune/query61.out | 32 +-
.../noStatsRfPrune/query62.out | 12 +-
.../noStatsRfPrune/query63.out | 12 +-
.../noStatsRfPrune/query64.out | 181 +-
.../noStatsRfPrune/query65.out | 22 +-
.../noStatsRfPrune/query66.out | 24 +-
.../noStatsRfPrune/query67.out | 12 +-
.../noStatsRfPrune/query68.out | 20 +-
.../noStatsRfPrune/query69.out | 83 +-
.../noStatsRfPrune/query7.out | 12 +-
.../noStatsRfPrune/query70.out | 22 +-
.../noStatsRfPrune/query71.out | 20 +-
.../noStatsRfPrune/query72.out | 28 +-
.../noStatsRfPrune/query73.out | 14 +-
.../noStatsRfPrune/query74.out | 28 +-
.../noStatsRfPrune/query75.out | 28 +-
.../noStatsRfPrune/query76.out | 22 +-
.../noStatsRfPrune/query77.out | 42 +-
.../noStatsRfPrune/query78.out | 14 +-
.../noStatsRfPrune/query79.out | 14 +-
.../noStatsRfPrune/query8.out | 18 +-
.../noStatsRfPrune/query80.out | 34 +-
.../noStatsRfPrune/query81.out | 24 +-
.../noStatsRfPrune/query82.out | 12 +-
.../noStatsRfPrune/query83.out | 46 +-
.../noStatsRfPrune/query84.out | 14 +-
.../noStatsRfPrune/query85.out | 20 +-
.../noStatsRfPrune/query86.out | 10 +-
.../noStatsRfPrune/query87.out | 26 +-
.../noStatsRfPrune/query88.out | 78 +-
.../noStatsRfPrune/query89.out | 12 +-
.../noStatsRfPrune/query9.out | 62 +-
.../noStatsRfPrune/query90.out | 18 +-
.../noStatsRfPrune/query91.out | 20 +-
.../noStatsRfPrune/query92.out | 8 +-
.../noStatsRfPrune/query93.out | 6 +-
.../noStatsRfPrune/query94.out | 14 +-
.../noStatsRfPrune/query95.out | 70 +-
.../noStatsRfPrune/query96.out | 8 +-
.../noStatsRfPrune/query97.out | 10 +-
.../noStatsRfPrune/query98.out | 10 +-
.../noStatsRfPrune/query99.out | 12 +-
.../no_stats_shape/query1.out | 18 +-
.../no_stats_shape/query10.out | 54 +-
.../no_stats_shape/query11.out | 28 +-
.../no_stats_shape/query12.out | 10 +-
.../no_stats_shape/query13.out | 14 +-
.../no_stats_shape/query14.out | 80 +-
.../no_stats_shape/query15.out | 14 +-
.../no_stats_shape/query16.out | 14 +-
.../no_stats_shape/query17.out | 26 +-
.../no_stats_shape/query18.out | 20 +-
.../no_stats_shape/query19.out | 16 +-
.../no_stats_shape/query2.out | 20 +-
.../no_stats_shape/query20.out | 10 +-
.../no_stats_shape/query21.out | 10 +-
.../no_stats_shape/query22.out | 8 +-
.../no_stats_shape/query23.out | 38 +-
.../no_stats_shape/query24.out | 28 +-
.../no_stats_shape/query25.out | 26 +-
.../no_stats_shape/query26.out | 12 +-
.../no_stats_shape/query27.out | 12 +-
.../no_stats_shape/query28.out | 22 +-
.../no_stats_shape/query29.out | 26 +-
.../no_stats_shape/query3.out | 8 +-
.../no_stats_shape/query30.out | 22 +-
.../no_stats_shape/query31.out | 28 +-
.../no_stats_shape/query32.out | 8 +-
.../no_stats_shape/query33.out | 40 +-
.../no_stats_shape/query34.out | 12 +-
.../no_stats_shape/query35.out | 52 +-
.../no_stats_shape/query36.out | 12 +-
.../no_stats_shape/query37.out | 12 +-
.../no_stats_shape/query38.out | 26 +-
.../no_stats_shape/query39.out | 16 +-
.../no_stats_shape/query4.out | 38 +-
.../no_stats_shape/query40.out | 10 +-
.../no_stats_shape/query41.out | 8 +-
.../no_stats_shape/query42.out | 8 +-
.../no_stats_shape/query43.out | 8 +-
.../no_stats_shape/query44.out | 127 +-
.../no_stats_shape/query45.out | 18 +-
.../no_stats_shape/query46.out | 20 +-
.../no_stats_shape/query47.out | 18 +-
.../no_stats_shape/query48.out | 12 +-
.../no_stats_shape/query49.out | 28 +-
.../no_stats_shape/query5.out | 34 +-
.../no_stats_shape/query50.out | 10 +-
.../no_stats_shape/query51.out | 85 +-
.../no_stats_shape/query52.out | 8 +-
.../no_stats_shape/query53.out | 59 +-
.../no_stats_shape/query54.out | 56 +-
.../no_stats_shape/query55.out | 8 +-
.../no_stats_shape/query56.out | 34 +-
.../no_stats_shape/query57.out | 18 +-
.../no_stats_shape/query58.out | 54 +-
.../no_stats_shape/query59.out | 49 +-
.../no_stats_shape/query6.out | 26 +-
.../no_stats_shape/query60.out | 40 +-
.../no_stats_shape/query61.out | 32 +-
.../no_stats_shape/query62.out | 12 +-
.../no_stats_shape/query63.out | 12 +-
.../no_stats_shape/query64.out | 181 +-
.../no_stats_shape/query65.out | 22 +-
.../no_stats_shape/query66.out | 24 +-
.../no_stats_shape/query67.out | 12 +-
.../no_stats_shape/query68.out | 20 +-
.../no_stats_shape/query69.out | 83 +-
.../no_stats_shape/query7.out | 12 +-
.../no_stats_shape/query70.out | 22 +-
.../no_stats_shape/query71.out | 20 +-
.../no_stats_shape/query72.out | 28 +-
.../no_stats_shape/query73.out | 14 +-
.../no_stats_shape/query74.out | 34 +-
.../no_stats_shape/query75.out | 28 +-
.../no_stats_shape/query76.out | 22 +-
.../no_stats_shape/query77.out | 42 +-
.../no_stats_shape/query78.out | 14 +-
.../no_stats_shape/query79.out | 14 +-
.../no_stats_shape/query8.out | 18 +-
.../no_stats_shape/query80.out | 34 +-
.../no_stats_shape/query81.out | 24 +-
.../no_stats_shape/query82.out | 12 +-
.../no_stats_shape/query83.out | 42 +-
.../no_stats_shape/query84.out | 14 +-
.../no_stats_shape/query85.out | 20 +-
.../no_stats_shape/query86.out | 10 +-
.../no_stats_shape/query87.out | 26 +-
.../no_stats_shape/query88.out | 78 +-
.../no_stats_shape/query89.out | 12 +-
.../no_stats_shape/query9.out | 62 +-
.../no_stats_shape/query90.out | 18 +-
.../no_stats_shape/query91.out | 20 +-
.../no_stats_shape/query92.out | 8 +-
.../no_stats_shape/query93.out | 6 +-
.../no_stats_shape/query94.out | 14 +-
.../no_stats_shape/query95.out | 68 +-
.../no_stats_shape/query96.out | 8 +-
.../no_stats_shape/query97.out | 10 +-
.../no_stats_shape/query98.out | 10 +-
.../no_stats_shape/query99.out | 12 +-
.../rf_prune/query1.out | 20 +-
.../rf_prune/query10.out | 22 +-
.../rf_prune/query11.out | 22 +-
.../rf_prune/query12.out | 12 +-
.../rf_prune/query13.out | 14 +-
.../rf_prune/query14.out | 82 +-
.../rf_prune/query15.out | 14 +-
.../rf_prune/query16.out | 14 +-
.../rf_prune/query17.out | 20 +-
.../rf_prune/query18.out | 22 +-
.../rf_prune/query19.out | 16 +-
.../rf_prune/query2.out | 22 +-
.../rf_prune/query20.out | 12 +-
.../rf_prune/query21.out | 10 +-
.../rf_prune/query22.out | 8 +-
.../rf_prune/query23.out | 38 +-
.../rf_prune/query24.out | 30 +-
.../rf_prune/query25.out | 20 +-
.../rf_prune/query26.out | 14 +-
.../rf_prune/query27.out | 14 +-
.../rf_prune/query28.out | 22 +-
.../rf_prune/query29.out | 18 +-
.../rf_prune/query3.out | 8 +-
.../rf_prune/query30.out | 22 +-
.../rf_prune/query31.out | 30 +-
.../rf_prune/query32.out | 8 +-
.../rf_prune/query33.out | 44 +-
.../rf_prune/query34.out | 12 +-
.../rf_prune/query35.out | 28 +-
.../rf_prune/query36.out | 12 +-
.../rf_prune/query37.out | 10 +-
.../rf_prune/query38.out | 26 +-
.../rf_prune/query39.out | 16 +-
.../rf_prune/query4.out | 44 +-
.../rf_prune/query40.out | 10 +-
.../rf_prune/query41.out | 8 +-
.../rf_prune/query42.out | 8 +-
.../rf_prune/query43.out | 8 +-
.../rf_prune/query44.out | 28 +-
.../rf_prune/query45.out | 20 +-
.../rf_prune/query46.out | 20 +-
.../rf_prune/query47.out | 18 +-
.../rf_prune/query48.out | 12 +-
.../rf_prune/query49.out | 28 +-
.../rf_prune/query5.out | 54 +-
.../rf_prune/query50.out | 10 +-
.../rf_prune/query51.out | 85 +-
.../rf_prune/query52.out | 8 +-
.../rf_prune/query53.out | 61 +-
.../rf_prune/query54.out | 60 +-
.../rf_prune/query55.out | 8 +-
.../rf_prune/query56.out | 36 +-
.../rf_prune/query57.out | 20 +-
.../rf_prune/query58.out | 56 +-
.../rf_prune/query59.out | 22 +-
.../rf_prune/query6.out | 28 +-
.../rf_prune/query60.out | 40 +-
.../rf_prune/query61.out | 28 +-
.../rf_prune/query62.out | 12 +-
.../rf_prune/query63.out | 12 +-
.../rf_prune/query64.out | 124 +-
.../rf_prune/query65.out | 20 +-
.../rf_prune/query66.out | 24 +-
.../rf_prune/query67.out | 12 +-
.../rf_prune/query68.out | 16 +-
.../rf_prune/query69.out | 26 +-
.../rf_prune/query7.out | 14 +-
.../rf_prune/query70.out | 20 +-
.../rf_prune/query71.out | 30 +-
.../rf_prune/query72.out | 34 +-
.../rf_prune/query73.out | 14 +-
.../rf_prune/query74.out | 28 +-
.../rf_prune/query75.out | 28 +-
.../rf_prune/query76.out | 22 +-
.../rf_prune/query77.out | 38 +-
.../rf_prune/query78.out | 14 +-
.../rf_prune/query79.out | 14 +-
.../rf_prune/query8.out | 18 +-
.../rf_prune/query80.out | 34 +-
.../rf_prune/query81.out | 24 +-
.../rf_prune/query82.out | 10 +-
.../rf_prune/query83.out | 34 +-
.../rf_prune/query84.out | 12 +-
.../rf_prune/query85.out | 16 +-
.../rf_prune/query86.out | 12 +-
.../rf_prune/query87.out | 26 +-
.../rf_prune/query88.out | 78 +-
.../rf_prune/query89.out | 12 +-
.../rf_prune/query9.out | 62 +-
.../rf_prune/query90.out | 18 +-
.../rf_prune/query91.out | 20 +-
.../rf_prune/query92.out | 8 +-
.../rf_prune/query93.out | 6 +-
.../rf_prune/query94.out | 14 +-
.../rf_prune/query95.out | 20 +-
.../rf_prune/query96.out | 8 +-
.../rf_prune/query97.out | 10 +-
.../rf_prune/query98.out | 12 +-
.../rf_prune/query99.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query1.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query10.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query11.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query12.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query13.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query14.out | 82 +-
.../nereids_tpcds_shape_sf100_p0/shape/query15.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query16.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query17.out | 24 +-
.../nereids_tpcds_shape_sf100_p0/shape/query18.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query19.out | 16 +-
.../nereids_tpcds_shape_sf100_p0/shape/query2.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query20.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query21.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query22.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query23.out | 38 +-
.../nereids_tpcds_shape_sf100_p0/shape/query24.out | 34 +-
.../nereids_tpcds_shape_sf100_p0/shape/query25.out | 24 +-
.../nereids_tpcds_shape_sf100_p0/shape/query26.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query27.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query28.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query29.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query3.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query30.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query31.out | 30 +-
.../nereids_tpcds_shape_sf100_p0/shape/query32.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query33.out | 44 +-
.../nereids_tpcds_shape_sf100_p0/shape/query34.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query35.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query36.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query37.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query38.out | 26 +-
.../nereids_tpcds_shape_sf100_p0/shape/query39.out | 16 +-
.../nereids_tpcds_shape_sf100_p0/shape/query4.out | 52 +-
.../nereids_tpcds_shape_sf100_p0/shape/query40.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query41.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query42.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query43.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query44.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query45.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query46.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query47.out | 18 +-
.../nereids_tpcds_shape_sf100_p0/shape/query48.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query49.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query5.out | 60 +-
.../nereids_tpcds_shape_sf100_p0/shape/query50.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query51.out | 85 +-
.../nereids_tpcds_shape_sf100_p0/shape/query52.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query53.out | 61 +-
.../nereids_tpcds_shape_sf100_p0/shape/query54.out | 62 +-
.../nereids_tpcds_shape_sf100_p0/shape/query55.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query56.out | 36 +-
.../nereids_tpcds_shape_sf100_p0/shape/query57.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query58.out | 56 +-
.../nereids_tpcds_shape_sf100_p0/shape/query59.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query6.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query60.out | 40 +-
.../nereids_tpcds_shape_sf100_p0/shape/query61.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query62.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query63.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query64.out | 136 +-
.../nereids_tpcds_shape_sf100_p0/shape/query65.out | 24 +-
.../nereids_tpcds_shape_sf100_p0/shape/query66.out | 24 +-
.../nereids_tpcds_shape_sf100_p0/shape/query67.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query68.out | 16 +-
.../nereids_tpcds_shape_sf100_p0/shape/query69.out | 26 +-
.../nereids_tpcds_shape_sf100_p0/shape/query7.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query70.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query71.out | 30 +-
.../nereids_tpcds_shape_sf100_p0/shape/query72.out | 32 +-
.../nereids_tpcds_shape_sf100_p0/shape/query73.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query74.out | 34 +-
.../nereids_tpcds_shape_sf100_p0/shape/query75.out | 28 +-
.../nereids_tpcds_shape_sf100_p0/shape/query76.out | 22 +-
.../nereids_tpcds_shape_sf100_p0/shape/query77.out | 38 +-
.../nereids_tpcds_shape_sf100_p0/shape/query78.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query79.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query8.out | 18 +-
.../nereids_tpcds_shape_sf100_p0/shape/query80.out | 34 +-
.../nereids_tpcds_shape_sf100_p0/shape/query81.out | 24 +-
.../nereids_tpcds_shape_sf100_p0/shape/query82.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query83.out | 34 +-
.../nereids_tpcds_shape_sf100_p0/shape/query84.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query85.out | 16 +-
.../nereids_tpcds_shape_sf100_p0/shape/query86.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query87.out | 26 +-
.../nereids_tpcds_shape_sf100_p0/shape/query88.out | 78 +-
.../nereids_tpcds_shape_sf100_p0/shape/query89.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query9.out | 62 +-
.../nereids_tpcds_shape_sf100_p0/shape/query90.out | 18 +-
.../nereids_tpcds_shape_sf100_p0/shape/query91.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query92.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query93.out | 6 +-
.../nereids_tpcds_shape_sf100_p0/shape/query94.out | 14 +-
.../nereids_tpcds_shape_sf100_p0/shape/query95.out | 20 +-
.../nereids_tpcds_shape_sf100_p0/shape/query96.out | 8 +-
.../nereids_tpcds_shape_sf100_p0/shape/query97.out | 10 +-
.../nereids_tpcds_shape_sf100_p0/shape/query98.out | 12 +-
.../nereids_tpcds_shape_sf100_p0/shape/query99.out | 12 +-
.../nostats_rf_prune/q1.out | 4 +-
.../nostats_rf_prune/q10.out | 12 +-
.../nostats_rf_prune/q11.out | 20 +-
.../nostats_rf_prune/q12.out | 4 +-
.../nostats_rf_prune/q13.out | 8 +-
.../nostats_rf_prune/q14.out | 6 +-
.../nostats_rf_prune/q15.out | 12 +-
.../nostats_rf_prune/q16.out | 6 +-
.../nostats_rf_prune/q17.out | 6 +-
.../nostats_rf_prune/q18.out | 8 +-
.../nostats_rf_prune/q19.out | 6 +-
.../nostats_rf_prune/q2.out | 12 +-
.../nostats_rf_prune/q20-rewrite.out | 16 +-
.../nostats_rf_prune/q20.out | 16 +-
.../nostats_rf_prune/q21.out | 10 +-
.../nostats_rf_prune/q22.out | 12 +-
.../nostats_rf_prune/q3.out | 8 +-
.../nostats_rf_prune/q4.out | 4 +-
.../nostats_rf_prune/q5.out | 22 +-
.../nostats_rf_prune/q6.out | 2 +-
.../nostats_rf_prune/q7.out | 16 +-
.../nostats_rf_prune/q8.out | 20 +-
.../nostats_rf_prune/q9.out | 14 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q1.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q10.out | 10 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q11.out | 14 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q12.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q13.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q14.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q15.out | 12 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q16.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q17.out | 6 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q18.out | 6 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q19.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q2.out | 12 +-
.../rf_prune/q20-rewrite.out | 16 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q20.out | 16 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q21.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q22.out | 12 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q3.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q4.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q5.out | 14 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q6.out | 2 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q7.out | 16 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q8.out | 18 +-
.../nereids_tpch_shape_sf1000_p0/rf_prune/q9.out | 18 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q1.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/shape/q10.out | 10 +-
.../nereids_tpch_shape_sf1000_p0/shape/q11.out | 14 +-
.../nereids_tpch_shape_sf1000_p0/shape/q12.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/shape/q13.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/shape/q14.out | 4 +-
.../nereids_tpch_shape_sf1000_p0/shape/q15.out | 12 +-
.../nereids_tpch_shape_sf1000_p0/shape/q16.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/shape/q17.out | 6 +-
.../nereids_tpch_shape_sf1000_p0/shape/q18.out | 6 +-
.../nereids_tpch_shape_sf1000_p0/shape/q19.out | 4 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q2.out | 12 +-
.../shape/q20-rewrite.out | 16 +-
.../nereids_tpch_shape_sf1000_p0/shape/q20.out | 16 +-
.../nereids_tpch_shape_sf1000_p0/shape/q21.out | 8 +-
.../nereids_tpch_shape_sf1000_p0/shape/q22.out | 12 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q3.out | 8 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q4.out | 4 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q5.out | 18 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q6.out | 2 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q7.out | 16 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q8.out | 18 +-
.../data/nereids_tpch_shape_sf1000_p0/shape/q9.out | 24 +-
.../shape_no_stats/q1.out | 4 +-
.../shape_no_stats/q10.out | 12 +-
.../shape_no_stats/q11.out | 20 +-
.../shape_no_stats/q12.out | 4 +-
.../shape_no_stats/q13.out | 8 +-
.../shape_no_stats/q14.out | 6 +-
.../shape_no_stats/q15.out | 12 +-
.../shape_no_stats/q16.out | 6 +-
.../shape_no_stats/q17.out | 6 +-
.../shape_no_stats/q18.out | 8 +-
.../shape_no_stats/q19.out | 6 +-
.../shape_no_stats/q2.out | 12 +-
.../shape_no_stats/q20-rewrite.out | 16 +-
.../shape_no_stats/q20.out | 16 +-
.../shape_no_stats/q21.out | 10 +-
.../shape_no_stats/q22.out | 12 +-
.../shape_no_stats/q3.out | 8 +-
.../shape_no_stats/q4.out | 4 +-
.../shape_no_stats/q5.out | 20 +-
.../shape_no_stats/q6.out | 2 +-
.../shape_no_stats/q7.out | 16 +-
.../shape_no_stats/q8.out | 20 +-
.../shape_no_stats/q9.out | 22 +-
.../data/performance_p0/redundant_conjuncts.out | 4 +-
.../test_bucket_hash_local_shuffle.out | 14 +
.../{jira8317.out => rqg/doris8317/doris8317.out} | 0
.../data/query_p0/join/rqg/doris9097/doris9097.out | 1247 ++++++++++
.../data/query_p0/join/rqg/doris9100/doris9100.out | 675 ++++++
.../data/query_p0/join/rqg/doris9161/doris9161.out | 27 +
.../test_array_functions_of_array_countEqual.out | 12 +
.../test_array_functions_of_array_difference.out | 6 +
.../array_functions/test_array_with_scale_type.out | 16 +-
.../sql_functions/case_function/case_null1.csv | 4 +-
.../cast_function/test_cast_struct.out | 2 +-
.../datetime_functions/test_date_function.out | 3 +
.../ip_functions/test_ip_functions.out | 65 +-
.../test_ipv6_cidr_to_range_function.out | 32 +
.../test_ipv6_num_to_string_function.out | 11 +
.../test_is_ip_address_in_range_function.out | 27 +
.../ip_functions/test_is_ip_string_functions.out | 14 +
.../string_functions/test_string_function.out | Bin 3360 -> 3418 bytes
.../test_struct_functions_by_literal.out | 12 +-
.../window_functions/test_window_fn.out | 12 +-
regression-test/data/rollup_p0/a.csv | 1 +
.../rollup_p0/test_materialized_view_load_open.out | 10 +
.../test_agg_keys_schema_change_decimalv2.out | 37 +
.../show_p0/test_show_create_table_and_views.out | 10 +-
.../test_partial_update_strict_mode.out | 16 +
regression-test/data/variant_p0/column_name.out | 2 +-
.../data/variant_p0/compaction/test_compaction.out | 96 +-
regression-test/data/variant_p0/complexjson.out | 10 +-
regression-test/data/variant_p0/delete_update.out | 10 +-
.../data/variant_p0/insert_into_select.out | 10 +-
regression-test/data/variant_p0/load.out | 80 +-
.../test_alter_table_column_with_delete.out | 10 +-
regression-test/data/variant_p0/sql/gh_data.out | 20 +-
.../data/variant_p0/with_index/load.out | 6 +-
.../data/variant_p0/with_index/var_index.out | 10 +-
.../apache/doris/regression/RegressionTest.groovy | 18 +
.../org/apache/doris/regression/suite/Suite.groovy | 36 +-
.../apache/doris/regression/suite/Syncer.groovy | 2 +-
regression-test/pipeline/common/doris-utils.sh | 48 +-
regression-test/pipeline/common/github-utils.sh | 45 +-
regression-test/pipeline/p0/conf/be.conf | 2 +
regression-test/pipeline/p0/conf/fe.conf | 2 +
.../pipeline/p0/conf/regression-conf.groovy | 4 +-
regression-test/pipeline/p1/conf/fe.conf | 2 +
.../performance/clickbench/check-query-result.sh | 32 +
.../performance/clickbench/conf/be_custom.conf | 21 +
.../performance/clickbench/conf/fe_custom.conf | 7 +
.../clickbench/conf/opt_session_variables.sql | 7 +
.../performance/clickbench/queries-sort.sql | 43 +
.../clickbench/query-result-target/doris-q1.result | 2 +
.../query-result-target/doris-q10.result | 11 +
.../query-result-target/doris-q11.result | 11 +
.../query-result-target/doris-q12.result | 11 +
.../query-result-target/doris-q13.result | 11 +
.../query-result-target/doris-q14.result | 11 +
.../query-result-target/doris-q15.result | 11 +
.../query-result-target/doris-q16.result | 11 +
.../query-result-target/doris-q17.result | 11 +
.../query-result-target/doris-q18.result | 11 +
.../query-result-target/doris-q19.result | 11 +
.../clickbench/query-result-target/doris-q2.result | 2 +
.../query-result-target/doris-q20.result | 5 +
.../query-result-target/doris-q21.result | 2 +
.../query-result-target/doris-q22.result | 11 +
.../query-result-target/doris-q23.result | 11 +
.../query-result-target/doris-q24.result | 11 +
.../query-result-target/doris-q25.result | 11 +
.../query-result-target/doris-q26.result | 11 +
.../query-result-target/doris-q27.result | 11 +
.../query-result-target/doris-q28.result | 26 +
.../query-result-target/doris-q29.result | 26 +
.../clickbench/query-result-target/doris-q3.result | 2 +
.../query-result-target/doris-q30.result | 2 +
.../query-result-target/doris-q31.result | 11 +
.../query-result-target/doris-q32.result | 11 +
.../query-result-target/doris-q33.result | 11 +
.../query-result-target/doris-q34.result | 11 +
.../query-result-target/doris-q35.result | 11 +
.../query-result-target/doris-q36.result | 11 +
.../query-result-target/doris-q37.result | 11 +
.../query-result-target/doris-q38.result | 11 +
.../query-result-target/doris-q39.result | 11 +
.../clickbench/query-result-target/doris-q4.result | 2 +
.../query-result-target/doris-q40.result | 11 +
.../query-result-target/doris-q41.result | 11 +
.../query-result-target/doris-q42.result | 11 +
.../query-result-target/doris-q43.result | 11 +
.../clickbench/query-result-target/doris-q5.result | 2 +
.../clickbench/query-result-target/doris-q6.result | 2 +
.../clickbench/query-result-target/doris-q7.result | 2 +
.../clickbench/query-result-target/doris-q8.result | 19 +
.../clickbench/query-result-target/doris-q9.result | 11 +
regression-test/pipeline/performance/compile.sh | 7 +-
.../pipeline/performance/conf/be_custom.conf | 4 +-
.../pipeline/performance/conf/fe_custom.conf | 5 +-
regression-test/pipeline/performance/deploy.sh | 72 +-
regression-test/pipeline/performance/prepare.sh | 40 +-
.../pipeline/performance/run-clickbench.sh | 105 +-
regression-test/pipeline/performance/run-load.sh | 79 +-
regression-test/pipeline/performance/run-tpcds.sh | 29 +-
regression-test/pipeline/performance/run-tpch.sh | 30 +-
.../tpch/tpch-sf100/conf/regression-conf.groovy | 1 +
.../plugins/plugins_get_ids_from_proc.groovy | 62 +
.../suites/account_p0/test_alter_user.groovy | 2 +-
.../account_p0/test_nereids_row_policy.groovy | 2 +-
.../alter_p2/test_alter_table_property.groovy | 2 +-
.../backup_restore/test_backup_restore_with.groovy | 96 +
..._backup_restore_with_two_phase_fetch_opt.groovy | 115 +
.../bloom_filter_p0/test_bloom_filter_hit.groovy | 1 +
.../suites/control_p0/set_replica_status.groovy | 6 +-
.../suites/correctness/test_str_to_date.groovy | 21 +-
.../correctness_p0/test_agg_materialize.groovy | 55 +
.../test_always_nullable_window_function.groovy | 8 +-
.../suites/correctness_p0/test_order_by.groovy | 2 +-
.../test_outer_join_with_null_value.groovy | 211 ++
.../unique/test_unique_table_like.groovy | 2 +-
.../datatype_p0/date/test_date_in_predicate.groovy | 8 +-
.../three_level_nestedtypes_with_s3data.groovy | 2 +-
.../two_level_nestedtypes_with_s3data.groovy | 1 -
.../suites/datatype_p0/nested_types/load.groovy | 2 +-
.../nested_types/query/array_functions/load.groovy | 22 +
.../test_array_element_at_and_slice.groovy | 132 +
...est_array_functions_array_intersect_sort.groovy | 136 ++
.../test_array_functions_array_join.groovy | 75 +
.../test_array_functions_array_with_const.groovy | 62 +
...rray_functions_concat_compact_difference.groovy | 121 +
.../test_array_push_pop_backfront.groovy | 96 +
.../test_array_zip_array_enumerate_uniq.groovy | 100 +
.../map_functions/test_basic_map_function.groovy | 1 -
.../query/test_nested_type_with_count.groovy | 1 -
...st_nested_types_insert_into_with_literal.groovy | 1 -
.../test_nested_types_insert_into_with_s3.groovy | 1 -
...test_nestedtypes_csv_insert_into_with_s3.groovy | 1 -
.../test_nestedtypes_insert_into_select.groovy | 1 -
...est_nestedtypes_json_insert_into_with_s3.groovy | 1 -
.../suites/ddl_p0/test_alter_view.groovy | 4 +-
.../delete_p0/test_array_column_delete.groovy | 2 +-
.../suites/delete_p0/test_delete.groovy | 17 +
.../suites/delete_p0/test_delete_on_mor.groovy | 6 +-
.../suites/delete_p0/test_map_column_delete.groovy | 2 +-
.../delete_p0/test_struct_column_delete.groovy | 2 +-
.../suites/empty_relation/eliminate_empty.groovy | 52 +
.../suites/export/test_array_export.groovy | 2 +-
.../suites/export_p0/test_outfile_exception.groovy | 10 +-
.../broker_load/test_broker_load_func.groovy | 4 +-
.../hive/test_hive_query_cache.groovy | 2 +-
.../hive/test_partial_update_broker_load.groovy | 5 +-
.../hive/test_show_columns.groovy | 62 -
.../iceberg/test_iceberg_statistics.groovy | 57 +
.../info_schema_db/test_info_schema_db.groovy | 134 +
.../jdbc/test_clickhouse_jdbc_catalog.groovy | 4 +-
.../jdbc/test_mysql_jdbc_catalog.groovy | 32 +-
.../jdbc/test_mysql_jdbc_catalog_nereids.groovy | 2 +-
.../jdbc/test_oracle_jdbc_catalog.groovy | 6 +
.../jdbc/test_pg_jdbc_catalog.groovy | 1 +
.../paimon/test_paimon_catalog.groovy | 6 +
.../paimon/test_paimon_statistics.groovy | 47 +
.../external_table_p0/test_catalog_ddl.groovy | 2 +
.../tvf/queries/test_queries_tvf.groovy | 4 +-
...l_tvf_with_complex_type_insertinto_doris.groovy | 2 +-
.../hive/test_hive_hudi_statistics.groovy | 47 +
.../hive/test_hive_statistic_auto.groovy | 12 +-
.../paimon/paimon_base_filesystem.groovy | 66 +
.../test_disable_move_memtable.groovy | 324 +++
.../test_index_compaction_fault_injection.groovy | 307 +++
...index_compound_directory_fault_injection.groovy | 15 +-
.../test_index_fault_injection.groovy | 8 +-
...oad_stream_back_pressure_fault_injection.groovy | 8 +-
.../test_load_stream_fault_injection.groovy | 71 +-
...d_stream_stub_close_wait_fault_injection.groovy | 88 +
.../test_load_stream_stub_failure_injection.groovy | 14 +-
.../test_low_wal_disk_space_fault_injection.groovy | 66 +
.../test_multi_replica_fault_injection.groovy | 100 +
.../test_too_many_segments_fault_injection.groovy | 5 +
...st_wal_mem_back_pressure_fault_injection.groovy | 157 ++
...m_back_pressure_time_out_fault_injection.groovy | 110 +
.../suites/index_p0/test_bitmap_index.groovy | 4 +-
.../test_group_commit_data_bytes_property.groovy | 100 +
.../suites/insert_p0/test_struct_insert.groovy | 32 +-
...ommit_http_stream_lineitem_schema_change.groovy | 2 +-
.../operate_internal_schema.groovy | 126 +
.../test_index_change_with_compaction.groovy | 13 +-
.../test_index_compaction_dup_keys.groovy | 232 ++
.../test_index_compaction_unique_keys.groovy | 236 ++
...dex_compaction_with_multi_index_segments.groovy | 350 ++-
.../inverted_index_p0/test_array_index.groovy | 120 +
.../inverted_index_p0/test_properties.groovy | 233 ++
.../suites/inverted_index_p0/test_show_data.groovy | 344 +++
.../suites/job_p0/test_base_insert_job.groovy | 24 +-
.../load_p0/broker_load/test_array_load.groovy | 10 -
.../mysql_load/test_mysql_load_unified.groovy | 2 -
.../data/multi_table_load_invalid_table.csv | 1 +
.../routine_load/test_routine_load_error.groovy | 94 +
.../stream_load/test_load_to_single_tablet.groovy | 4 +-
.../test_load_with_map_nested_array.groovy | 1 -
.../load_p0/stream_load/test_pipeline_load.groovy | 2 +-
.../stream_load/test_publish_timeout.groovy | 111 +
.../load_p0/stream_load/test_stream_load.groovy | 4 +-
.../test_stream_load_err_log_limit.groovy | 2 +-
.../broker_load/test_tvf_based_broker_load.groovy | 4 +-
.../test_migrate_disk_with_publish_version.groovy | 84 +
.../suites/mtmv_p0/test_build_mtmv.groovy | 63 +-
.../mtmv_p0/test_partition_refresh_mtmv.groovy | 30 +
.../suites/mtmv_p0/test_task_mtmv.groovy | 62 +
.../mv_p0/agg_state/test_agg_state_max_by.groovy | 31 +
.../ssb/multiple_no_where/multiple_no_where.groovy | 2 +-
.../mv_p0/ssb/multiple_ssb/multiple_ssb.groovy | 2 +-
.../multiple_ssb_between.groovy | 2 +-
.../suites/mv_p0/ssb/q_1_1/q_1_1.groovy | 2 +-
.../suites/mv_p0/ssb/q_2_1/q_2_1.groovy | 2 +-
.../suites/mv_p0/ssb/q_3_1/q_3_1.groovy | 2 +-
.../suites/mv_p0/ssb/q_4_1/q_4_1.groovy | 2 +-
.../suites/mv_p0/test_28741/test_28741.groovy | 72 +
.../mv_p0/test_dup_mv_div/test_dup_mv_div.groovy | 9 +-
.../mv_p0/test_dup_mv_json/test_dup_mv_json.groovy | 13 +-
.../suites/mv_p0/test_substr/test_substr.groovy | 56 +
.../suites/mv_p0/test_tcu/test_tcu.groovy | 9 +-
.../testAggQueryOnAggMV1.groovy | 14 +
.../nereids_function_p0/agg_function/agg.groovy | 6 +
.../suites/nereids_function_p0/ip_functions.groovy | 57 +-
.../suites/nereids_function_p0/tvf/tvf.groovy | 2 +-
.../nereids_p0/aggregate/agg_window_project.groovy | 22 +
.../suites/nereids_p0/aggregate/aggregate.groovy | 8 +
.../nereids_p0/create_table/test_ctas.groovy | 4 +-
.../eliminate_outer_join.groovy | 6 +-
.../explain/test_pushdown_explain.groovy | 170 ++
.../nereids_p0/expression/case_when_to_if.groovy | 10 +-
.../nereids_p0/expression/topn_to_max.groovy | 6 +-
.../suites/nereids_p0/hint/fix_leading.groovy | 43 +
.../suites/nereids_p0/hint/test_leading.groovy | 153 ++
.../infer_predicate/infer_predicate.groovy | 12 +-
.../outfile/test_outfile_exception.groovy | 10 +-
.../runtime_filter/runtime_filter.groovy | 48 +
.../select_tablets/select_with_tablets.groovy | 3 +
.../bind_relation/bind_view.groovy | 1 +
.../nereids_rules_p0/eager_aggregate/basic.groovy | 1 +
.../eager_aggregate/basic_one_side.groovy | 1 +
.../push_down_count_through_join.groovy | 1 +
.../push_down_count_through_join_one_side.groovy | 1 +
.../push_down_max_through_join.groovy | 1 +
.../push_down_min_through_join.groovy | 1 +
.../push_down_sum_through_join.groovy | 1 +
.../push_down_sum_through_join_one_side.groovy | 1 +
.../eliminate_join_condition.groovy | 1 +
.../eliminate_not_null/eliminate_not_null.groovy | 1 +
.../eliminate_outer_join.groovy | 1 +
.../filter_push_through_aggregate.groovy | 1 +
.../push_down_alias_through_join.groovy | 1 +
.../push_down_expression_in_hash_join.groovy | 1 +
.../push_down_filter_other_condition.groovy | 1 +
.../push_filter_inside_join.groovy | 1 +
.../filter_push_down/push_filter_through.groovy | 280 +++
.../infer_set_operator_distinct.groovy | 1 +
.../limit_push_down/limit_push_down.groovy | 1 +
.../limit_push_down/order_push_down.groovy | 1 +
.../suites/nereids_rules_p0/load.groovy | 1 +
.../agg_with_roll_up/aggregate_with_roll_up.groovy | 362 ++-
.../aggregate_without_roll_up.groovy | 112 +-
.../mv/join/dphyp_inner/inner_join_dphyp.groovy | 464 ++++
.../mv/join/dphyp_outer/outer_join_dphyp.groovy | 469 ++++
.../mv/join/inner/inner_join.groovy | 77 +-
.../mv/join/left_outer/outer_join.groovy | 130 +-
.../mv/partition_mv_rewrite.groovy | 15 +-
.../test_date_function_prune.groovy | 2 +
.../test_multi_range_partition.groovy | 38 +
.../test_partition_unique_model.groovy | 1 +
.../nereids_rules_p0/pkfk/eliminate_inner.groovy | 115 +
.../predicate_infer/infer_predicate.groovy | 1 +
.../push_down_limit_distinct.groovy | 1 +
.../push_down_top_n_distinct_through_union.groovy | 1 +
.../push_down_top_n_through_union.groovy | 1 +
.../subquery_basic_pullup_and_subquery.groovy | 1 +
.../basic/subquery_basic_pullup_basic.groovy | 1 +
.../subquery/basic/subquery_basic_pullup_or.groovy | 1 +
.../basic/subquery_basic_pullup_or_subquery.groovy | 1 +
.../subquery/basic/subquery_basic_pullup_uk.groovy | 1 +
.../subquery/basic/subquery_basic_ullup_and.groovy | 1 +
.../subquery/misc/subquery_misc_pullup_dml.groovy | 1 +
.../subquery/misc/subquery_misc_pullup_misc.groovy | 1 +
.../subquery_multitable_pullup_and.groovy | 1 +
.../subquery_multitable_pullup_and_subquery.groovy | 1 +
.../subquery_multitable_pullup_basic.groovy | 1 +
.../subquery_multitable_pullup_or.groovy | 1 +
.../subquery_multitable_pullup_or_subquery.groovy | 1 +
.../topop/subquery_topop_pullup_groupby.groovy | 1 +
.../topop/subquery_topop_pullup_having.groovy | 1 +
.../topop/subquery_topop_pullup_orderby.groovy | 1 +
.../topop/subquery_topop_pullup_selectlist.groovy | 1 +
.../topop/subquery_topop_pullup_winfunc.groovy | 1 +
.../transposeJoin/transposeSemiJoinAgg.groovy | 2 +
.../suites/nereids_syntax_p0/cast.groovy | 5 +
.../suites/nereids_syntax_p0/constraint.groovy | 81 +
.../nereids_syntax_p0/group_by_constant.groovy | 2 +
.../suites/nereids_syntax_p0/set_operation.groovy | 1 +
.../nereids_tpcds_shape_sf1000_p0/ddl/shape.tmpl | 1 +
.../shape/query1.groovy | 1 +
.../shape/query10.groovy | 1 +
.../shape/query11.groovy | 1 +
.../shape/query12.groovy | 1 +
.../shape/query13.groovy | 1 +
.../shape/query14.groovy | 1 +
.../shape/query15.groovy | 1 +
.../shape/query16.groovy | 1 +
.../shape/query17.groovy | 1 +
.../shape/query18.groovy | 1 +
.../shape/query19.groovy | 1 +
.../shape/query2.groovy | 1 +
.../shape/query20.groovy | 1 +
.../shape/query21.groovy | 1 +
.../shape/query22.groovy | 1 +
.../shape/query23.groovy | 1 +
.../shape/query24.groovy | 1 +
.../shape/query25.groovy | 1 +
.../shape/query26.groovy | 1 +
.../shape/query27.groovy | 1 +
.../shape/query28.groovy | 1 +
.../shape/query29.groovy | 1 +
.../shape/query3.groovy | 1 +
.../shape/query30.groovy | 1 +
.../shape/query31.groovy | 1 +
.../shape/query32.groovy | 1 +
.../shape/query33.groovy | 1 +
.../shape/query34.groovy | 1 +
.../shape/query35.groovy | 1 +
.../shape/query36.groovy | 1 +
.../shape/query37.groovy | 1 +
.../shape/query38.groovy | 1 +
.../shape/query39.groovy | 1 +
.../shape/query4.groovy | 1 +
.../shape/query40.groovy | 1 +
.../shape/query41.groovy | 1 +
.../shape/query42.groovy | 1 +
.../shape/query43.groovy | 1 +
.../shape/query44.groovy | 1 +
.../shape/query45.groovy | 1 +
.../shape/query46.groovy | 1 +
.../shape/query47.groovy | 1 +
.../shape/query48.groovy | 1 +
.../shape/query49.groovy | 1 +
.../shape/query5.groovy | 1 +
.../shape/query50.groovy | 1 +
.../shape/query51.groovy | 1 +
.../shape/query52.groovy | 1 +
.../shape/query53.groovy | 1 +
.../shape/query54.groovy | 1 +
.../shape/query55.groovy | 1 +
.../shape/query56.groovy | 1 +
.../shape/query57.groovy | 1 +
.../shape/query58.groovy | 1 +
.../shape/query59.groovy | 1 +
.../shape/query6.groovy | 1 +
.../shape/query60.groovy | 1 +
.../shape/query61.groovy | 1 +
.../shape/query62.groovy | 1 +
.../shape/query63.groovy | 1 +
.../shape/query64.groovy | 1 +
.../shape/query65.groovy | 1 +
.../shape/query66.groovy | 1 +
.../shape/query67.groovy | 1 +
.../shape/query68.groovy | 1 +
.../shape/query69.groovy | 1 +
.../shape/query7.groovy | 1 +
.../shape/query70.groovy | 1 +
.../shape/query71.groovy | 1 +
.../shape/query72.groovy | 1 +
.../shape/query73.groovy | 1 +
.../shape/query74.groovy | 1 +
.../shape/query75.groovy | 1 +
.../shape/query76.groovy | 1 +
.../shape/query77.groovy | 1 +
.../shape/query78.groovy | 1 +
.../shape/query79.groovy | 1 +
.../shape/query8.groovy | 1 +
.../shape/query80.groovy | 1 +
.../shape/query81.groovy | 1 +
.../shape/query82.groovy | 1 +
.../shape/query83.groovy | 1 +
.../shape/query84.groovy | 1 +
.../shape/query85.groovy | 1 +
.../shape/query86.groovy | 1 +
.../shape/query87.groovy | 1 +
.../shape/query88.groovy | 1 +
.../shape/query89.groovy | 1 +
.../shape/query9.groovy | 1 +
.../shape/query90.groovy | 1 +
.../shape/query91.groovy | 1 +
.../shape/query92.groovy | 1 +
.../shape/query93.groovy | 1 +
.../shape/query94.groovy | 1 +
.../shape/query95.groovy | 1 +
.../shape/query96.groovy | 1 +
.../shape/query97.groovy | 1 +
.../shape/query98.groovy | 1 +
.../shape/query99.groovy | 1 +
.../constraints/load.groovy | 2549 ++++++++++++++++++++
.../constraints/query23.groovy | 85 +
.../nereids_tpcds_shape_sf100_p0/ddl/rf_prune.tmpl | 1 +
.../nereids_tpcds_shape_sf100_p0/ddl/shape.tmpl | 1 +
.../noStatsRfPrune/query1.groovy | 3 +-
.../noStatsRfPrune/query10.groovy | 3 +-
.../noStatsRfPrune/query11.groovy | 3 +-
.../noStatsRfPrune/query12.groovy | 3 +-
.../noStatsRfPrune/query13.groovy | 3 +-
.../noStatsRfPrune/query14.groovy | 3 +-
.../noStatsRfPrune/query15.groovy | 3 +-
.../noStatsRfPrune/query16.groovy | 3 +-
.../noStatsRfPrune/query17.groovy | 3 +-
.../noStatsRfPrune/query18.groovy | 3 +-
.../noStatsRfPrune/query19.groovy | 3 +-
.../noStatsRfPrune/query2.groovy | 3 +-
.../noStatsRfPrune/query20.groovy | 3 +-
.../noStatsRfPrune/query21.groovy | 3 +-
.../noStatsRfPrune/query22.groovy | 3 +-
.../noStatsRfPrune/query23.groovy | 3 +-
.../noStatsRfPrune/query24.groovy | 3 +-
.../noStatsRfPrune/query25.groovy | 3 +-
.../noStatsRfPrune/query26.groovy | 3 +-
.../noStatsRfPrune/query27.groovy | 3 +-
.../noStatsRfPrune/query28.groovy | 3 +-
.../noStatsRfPrune/query29.groovy | 3 +-
.../noStatsRfPrune/query3.groovy | 3 +-
.../noStatsRfPrune/query30.groovy | 3 +-
.../noStatsRfPrune/query31.groovy | 3 +-
.../noStatsRfPrune/query32.groovy | 3 +-
.../noStatsRfPrune/query33.groovy | 3 +-
.../noStatsRfPrune/query34.groovy | 3 +-
.../noStatsRfPrune/query35.groovy | 3 +-
.../noStatsRfPrune/query36.groovy | 3 +-
.../noStatsRfPrune/query37.groovy | 3 +-
.../noStatsRfPrune/query38.groovy | 3 +-
.../noStatsRfPrune/query39.groovy | 3 +-
.../noStatsRfPrune/query4.groovy | 3 +-
.../noStatsRfPrune/query40.groovy | 3 +-
.../noStatsRfPrune/query41.groovy | 3 +-
.../noStatsRfPrune/query42.groovy | 3 +-
.../noStatsRfPrune/query43.groovy | 3 +-
.../noStatsRfPrune/query44.groovy | 3 +-
.../noStatsRfPrune/query45.groovy | 3 +-
.../noStatsRfPrune/query46.groovy | 3 +-
.../noStatsRfPrune/query47.groovy | 3 +-
.../noStatsRfPrune/query48.groovy | 3 +-
.../noStatsRfPrune/query49.groovy | 3 +-
.../noStatsRfPrune/query5.groovy | 3 +-
.../noStatsRfPrune/query50.groovy | 3 +-
.../noStatsRfPrune/query51.groovy | 3 +-
.../noStatsRfPrune/query52.groovy | 3 +-
.../noStatsRfPrune/query53.groovy | 3 +-
.../noStatsRfPrune/query54.groovy | 3 +-
.../noStatsRfPrune/query55.groovy | 3 +-
.../noStatsRfPrune/query56.groovy | 3 +-
.../noStatsRfPrune/query57.groovy | 3 +-
.../noStatsRfPrune/query58.groovy | 3 +-
.../noStatsRfPrune/query59.groovy | 3 +-
.../noStatsRfPrune/query6.groovy | 3 +-
.../noStatsRfPrune/query60.groovy | 3 +-
.../noStatsRfPrune/query61.groovy | 3 +-
.../noStatsRfPrune/query62.groovy | 3 +-
.../noStatsRfPrune/query63.groovy | 3 +-
.../noStatsRfPrune/query64.groovy | 3 +-
.../noStatsRfPrune/query65.groovy | 3 +-
.../noStatsRfPrune/query66.groovy | 3 +-
.../noStatsRfPrune/query67.groovy | 3 +-
.../noStatsRfPrune/query68.groovy | 3 +-
.../noStatsRfPrune/query69.groovy | 3 +-
.../noStatsRfPrune/query7.groovy | 3 +-
.../noStatsRfPrune/query70.groovy | 3 +-
.../noStatsRfPrune/query71.groovy | 3 +-
.../noStatsRfPrune/query72.groovy | 3 +-
.../noStatsRfPrune/query73.groovy | 3 +-
.../noStatsRfPrune/query74.groovy | 3 +-
.../noStatsRfPrune/query75.groovy | 3 +-
.../noStatsRfPrune/query76.groovy | 3 +-
.../noStatsRfPrune/query77.groovy | 3 +-
.../noStatsRfPrune/query78.groovy | 3 +-
.../noStatsRfPrune/query79.groovy | 3 +-
.../noStatsRfPrune/query8.groovy | 3 +-
.../noStatsRfPrune/query80.groovy | 3 +-
.../noStatsRfPrune/query81.groovy | 3 +-
.../noStatsRfPrune/query82.groovy | 3 +-
.../noStatsRfPrune/query83.groovy | 3 +-
.../noStatsRfPrune/query84.groovy | 3 +-
.../noStatsRfPrune/query85.groovy | 3 +-
.../noStatsRfPrune/query86.groovy | 3 +-
.../noStatsRfPrune/query87.groovy | 3 +-
.../noStatsRfPrune/query88.groovy | 3 +-
.../noStatsRfPrune/query89.groovy | 3 +-
.../noStatsRfPrune/query9.groovy | 3 +-
.../noStatsRfPrune/query90.groovy | 3 +-
.../noStatsRfPrune/query91.groovy | 3 +-
.../noStatsRfPrune/query92.groovy | 3 +-
.../noStatsRfPrune/query93.groovy | 3 +-
.../noStatsRfPrune/query94.groovy | 3 +-
.../noStatsRfPrune/query95.groovy | 3 +-
.../noStatsRfPrune/query96.groovy | 3 +-
.../noStatsRfPrune/query97.groovy | 3 +-
.../noStatsRfPrune/query98.groovy | 3 +-
.../noStatsRfPrune/query99.groovy | 3 +-
.../no_stats_shape/query1.groovy | 3 +-
.../no_stats_shape/query10.groovy | 3 +-
.../no_stats_shape/query11.groovy | 3 +-
.../no_stats_shape/query12.groovy | 3 +-
.../no_stats_shape/query13.groovy | 3 +-
.../no_stats_shape/query14.groovy | 3 +-
.../no_stats_shape/query15.groovy | 3 +-
.../no_stats_shape/query16.groovy | 3 +-
.../no_stats_shape/query17.groovy | 3 +-
.../no_stats_shape/query18.groovy | 3 +-
.../no_stats_shape/query19.groovy | 3 +-
.../no_stats_shape/query2.groovy | 3 +-
.../no_stats_shape/query20.groovy | 3 +-
.../no_stats_shape/query21.groovy | 3 +-
.../no_stats_shape/query22.groovy | 3 +-
.../no_stats_shape/query23.groovy | 3 +-
.../no_stats_shape/query24.groovy | 3 +-
.../no_stats_shape/query25.groovy | 3 +-
.../no_stats_shape/query26.groovy | 3 +-
.../no_stats_shape/query27.groovy | 3 +-
.../no_stats_shape/query28.groovy | 3 +-
.../no_stats_shape/query29.groovy | 3 +-
.../no_stats_shape/query3.groovy | 3 +-
.../no_stats_shape/query30.groovy | 3 +-
.../no_stats_shape/query31.groovy | 3 +-
.../no_stats_shape/query32.groovy | 3 +-
.../no_stats_shape/query33.groovy | 3 +-
.../no_stats_shape/query34.groovy | 3 +-
.../no_stats_shape/query35.groovy | 3 +-
.../no_stats_shape/query36.groovy | 3 +-
.../no_stats_shape/query37.groovy | 3 +-
.../no_stats_shape/query38.groovy | 3 +-
.../no_stats_shape/query39.groovy | 3 +-
.../no_stats_shape/query4.groovy | 3 +-
.../no_stats_shape/query40.groovy | 3 +-
.../no_stats_shape/query41.groovy | 3 +-
.../no_stats_shape/query42.groovy | 3 +-
.../no_stats_shape/query43.groovy | 3 +-
.../no_stats_shape/query44.groovy | 3 +-
.../no_stats_shape/query45.groovy | 3 +-
.../no_stats_shape/query46.groovy | 3 +-
.../no_stats_shape/query47.groovy | 3 +-
.../no_stats_shape/query48.groovy | 3 +-
.../no_stats_shape/query49.groovy | 3 +-
.../no_stats_shape/query5.groovy | 3 +-
.../no_stats_shape/query50.groovy | 3 +-
.../no_stats_shape/query51.groovy | 3 +-
.../no_stats_shape/query52.groovy | 3 +-
.../no_stats_shape/query53.groovy | 3 +-
.../no_stats_shape/query54.groovy | 3 +-
.../no_stats_shape/query55.groovy | 3 +-
.../no_stats_shape/query56.groovy | 3 +-
.../no_stats_shape/query57.groovy | 3 +-
.../no_stats_shape/query58.groovy | 3 +-
.../no_stats_shape/query59.groovy | 3 +-
.../no_stats_shape/query6.groovy | 3 +-
.../no_stats_shape/query60.groovy | 3 +-
.../no_stats_shape/query61.groovy | 3 +-
.../no_stats_shape/query62.groovy | 3 +-
.../no_stats_shape/query63.groovy | 3 +-
.../no_stats_shape/query64.groovy | 3 +-
.../no_stats_shape/query65.groovy | 3 +-
.../no_stats_shape/query66.groovy | 3 +-
.../no_stats_shape/query67.groovy | 3 +-
.../no_stats_shape/query68.groovy | 3 +-
.../no_stats_shape/query69.groovy | 3 +-
.../no_stats_shape/query7.groovy | 3 +-
.../no_stats_shape/query70.groovy | 3 +-
.../no_stats_shape/query71.groovy | 3 +-
.../no_stats_shape/query72.groovy | 3 +-
.../no_stats_shape/query73.groovy | 3 +-
.../no_stats_shape/query74.groovy | 3 +-
.../no_stats_shape/query75.groovy | 3 +-
.../no_stats_shape/query76.groovy | 3 +-
.../no_stats_shape/query77.groovy | 3 +-
.../no_stats_shape/query78.groovy | 3 +-
.../no_stats_shape/query79.groovy | 3 +-
.../no_stats_shape/query8.groovy | 3 +-
.../no_stats_shape/query80.groovy | 3 +-
.../no_stats_shape/query81.groovy | 3 +-
.../no_stats_shape/query82.groovy | 3 +-
.../no_stats_shape/query83.groovy | 3 +-
.../no_stats_shape/query84.groovy | 3 +-
.../no_stats_shape/query85.groovy | 3 +-
.../no_stats_shape/query86.groovy | 3 +-
.../no_stats_shape/query87.groovy | 3 +-
.../no_stats_shape/query88.groovy | 3 +-
.../no_stats_shape/query89.groovy | 3 +-
.../no_stats_shape/query9.groovy | 3 +-
.../no_stats_shape/query90.groovy | 3 +-
.../no_stats_shape/query91.groovy | 3 +-
.../no_stats_shape/query92.groovy | 3 +-
.../no_stats_shape/query93.groovy | 3 +-
.../no_stats_shape/query94.groovy | 3 +-
.../no_stats_shape/query95.groovy | 3 +-
.../no_stats_shape/query96.groovy | 3 +-
.../no_stats_shape/query97.groovy | 3 +-
.../no_stats_shape/query98.groovy | 3 +-
.../no_stats_shape/query99.groovy | 3 +-
.../rf_prune/query1.groovy | 1 +
.../rf_prune/query10.groovy | 1 +
.../rf_prune/query11.groovy | 1 +
.../rf_prune/query12.groovy | 1 +
.../rf_prune/query13.groovy | 1 +
.../rf_prune/query14.groovy | 1 +
.../rf_prune/query15.groovy | 1 +
.../rf_prune/query16.groovy | 1 +
.../rf_prune/query17.groovy | 1 +
.../rf_prune/query18.groovy | 1 +
.../rf_prune/query19.groovy | 1 +
.../rf_prune/query2.groovy | 1 +
.../rf_prune/query20.groovy | 1 +
.../rf_prune/query21.groovy | 1 +
.../rf_prune/query22.groovy | 1 +
.../rf_prune/query23.groovy | 1 +
.../rf_prune/query24.groovy | 1 +
.../rf_prune/query25.groovy | 1 +
.../rf_prune/query26.groovy | 1 +
.../rf_prune/query27.groovy | 1 +
.../rf_prune/query28.groovy | 1 +
.../rf_prune/query29.groovy | 1 +
.../rf_prune/query3.groovy | 1 +
.../rf_prune/query30.groovy | 1 +
.../rf_prune/query31.groovy | 1 +
.../rf_prune/query32.groovy | 1 +
.../rf_prune/query33.groovy | 1 +
.../rf_prune/query34.groovy | 1 +
.../rf_prune/query35.groovy | 1 +
.../rf_prune/query36.groovy | 1 +
.../rf_prune/query37.groovy | 1 +
.../rf_prune/query38.groovy | 1 +
.../rf_prune/query39.groovy | 1 +
.../rf_prune/query4.groovy | 1 +
.../rf_prune/query40.groovy | 1 +
.../rf_prune/query41.groovy | 1 +
.../rf_prune/query42.groovy | 1 +
.../rf_prune/query43.groovy | 1 +
.../rf_prune/query44.groovy | 1 +
.../rf_prune/query45.groovy | 1 +
.../rf_prune/query46.groovy | 1 +
.../rf_prune/query47.groovy | 1 +
.../rf_prune/query48.groovy | 1 +
.../rf_prune/query49.groovy | 1 +
.../rf_prune/query5.groovy | 1 +
.../rf_prune/query50.groovy | 1 +
.../rf_prune/query51.groovy | 1 +
.../rf_prune/query52.groovy | 1 +
.../rf_prune/query53.groovy | 1 +
.../rf_prune/query54.groovy | 1 +
.../rf_prune/query55.groovy | 1 +
.../rf_prune/query56.groovy | 1 +
.../rf_prune/query57.groovy | 1 +
.../rf_prune/query58.groovy | 1 +
.../rf_prune/query59.groovy | 1 +
.../rf_prune/query6.groovy | 1 +
.../rf_prune/query60.groovy | 1 +
.../rf_prune/query61.groovy | 1 +
.../rf_prune/query62.groovy | 1 +
.../rf_prune/query63.groovy | 1 +
.../rf_prune/query64.groovy | 1 +
.../rf_prune/query65.groovy | 1 +
.../rf_prune/query66.groovy | 1 +
.../rf_prune/query67.groovy | 1 +
.../rf_prune/query68.groovy | 1 +
.../rf_prune/query69.groovy | 1 +
.../rf_prune/query7.groovy | 1 +
.../rf_prune/query70.groovy | 1 +
.../rf_prune/query71.groovy | 1 +
.../rf_prune/query72.groovy | 1 +
.../rf_prune/query73.groovy | 1 +
.../rf_prune/query74.groovy | 1 +
.../rf_prune/query75.groovy | 1 +
.../rf_prune/query76.groovy | 1 +
.../rf_prune/query77.groovy | 1 +
.../rf_prune/query78.groovy | 1 +
.../rf_prune/query79.groovy | 1 +
.../rf_prune/query8.groovy | 1 +
.../rf_prune/query80.groovy | 1 +
.../rf_prune/query81.groovy | 1 +
.../rf_prune/query82.groovy | 1 +
.../rf_prune/query83.groovy | 1 +
.../rf_prune/query84.groovy | 1 +
.../rf_prune/query85.groovy | 1 +
.../rf_prune/query86.groovy | 1 +
.../rf_prune/query87.groovy | 1 +
.../rf_prune/query88.groovy | 1 +
.../rf_prune/query89.groovy | 1 +
.../rf_prune/query9.groovy | 1 +
.../rf_prune/query90.groovy | 1 +
.../rf_prune/query91.groovy | 1 +
.../rf_prune/query92.groovy | 1 +
.../rf_prune/query93.groovy | 1 +
.../rf_prune/query94.groovy | 1 +
.../rf_prune/query95.groovy | 1 +
.../rf_prune/query96.groovy | 1 +
.../rf_prune/query97.groovy | 1 +
.../rf_prune/query98.groovy | 1 +
.../rf_prune/query99.groovy | 1 +
.../shape/query1.groovy | 1 +
.../shape/query10.groovy | 1 +
.../shape/query11.groovy | 1 +
.../shape/query12.groovy | 1 +
.../shape/query13.groovy | 1 +
.../shape/query14.groovy | 1 +
.../shape/query15.groovy | 1 +
.../shape/query16.groovy | 1 +
.../shape/query17.groovy | 1 +
.../shape/query18.groovy | 1 +
.../shape/query19.groovy | 1 +
.../shape/query2.groovy | 1 +
.../shape/query20.groovy | 1 +
.../shape/query21.groovy | 1 +
.../shape/query22.groovy | 1 +
.../shape/query23.groovy | 1 +
.../shape/query24.groovy | 1 +
.../shape/query25.groovy | 1 +
.../shape/query26.groovy | 1 +
.../shape/query27.groovy | 1 +
.../shape/query28.groovy | 1 +
.../shape/query29.groovy | 1 +
.../shape/query3.groovy | 1 +
.../shape/query30.groovy | 1 +
.../shape/query31.groovy | 1 +
.../shape/query32.groovy | 1 +
.../shape/query33.groovy | 1 +
.../shape/query34.groovy | 1 +
.../shape/query35.groovy | 1 +
.../shape/query36.groovy | 1 +
.../shape/query37.groovy | 1 +
.../shape/query38.groovy | 1 +
.../shape/query39.groovy | 1 +
.../shape/query4.groovy | 1 +
.../shape/query40.groovy | 1 +
.../shape/query41.groovy | 1 +
.../shape/query42.groovy | 1 +
.../shape/query43.groovy | 1 +
.../shape/query44.groovy | 1 +
.../shape/query45.groovy | 1 +
.../shape/query46.groovy | 1 +
.../shape/query47.groovy | 1 +
.../shape/query48.groovy | 1 +
.../shape/query49.groovy | 1 +
.../shape/query5.groovy | 1 +
.../shape/query50.groovy | 1 +
.../shape/query51.groovy | 1 +
.../shape/query52.groovy | 1 +
.../shape/query53.groovy | 1 +
.../shape/query54.groovy | 1 +
.../shape/query55.groovy | 1 +
.../shape/query56.groovy | 1 +
.../shape/query57.groovy | 1 +
.../shape/query58.groovy | 1 +
.../shape/query59.groovy | 1 +
.../shape/query6.groovy | 1 +
.../shape/query60.groovy | 1 +
.../shape/query61.groovy | 1 +
.../shape/query62.groovy | 1 +
.../shape/query63.groovy | 1 +
.../shape/query64.groovy | 1 +
.../shape/query65.groovy | 1 +
.../shape/query66.groovy | 1 +
.../shape/query67.groovy | 1 +
.../shape/query68.groovy | 1 +
.../shape/query69.groovy | 1 +
.../shape/query7.groovy | 1 +
.../shape/query70.groovy | 1 +
.../shape/query71.groovy | 1 +
.../shape/query72.groovy | 1 +
.../shape/query73.groovy | 1 +
.../shape/query74.groovy | 1 +
.../shape/query75.groovy | 1 +
.../shape/query76.groovy | 1 +
.../shape/query77.groovy | 1 +
.../shape/query78.groovy | 1 +
.../shape/query79.groovy | 1 +
.../shape/query8.groovy | 1 +
.../shape/query80.groovy | 1 +
.../shape/query81.groovy | 1 +
.../shape/query82.groovy | 1 +
.../shape/query83.groovy | 1 +
.../shape/query84.groovy | 1 +
.../shape/query85.groovy | 1 +
.../shape/query86.groovy | 1 +
.../shape/query87.groovy | 1 +
.../shape/query88.groovy | 1 +
.../shape/query89.groovy | 1 +
.../shape/query9.groovy | 1 +
.../shape/query90.groovy | 1 +
.../shape/query91.groovy | 1 +
.../shape/query92.groovy | 1 +
.../shape/query93.groovy | 1 +
.../shape/query94.groovy | 1 +
.../shape/query95.groovy | 1 +
.../shape/query96.groovy | 1 +
.../shape/query97.groovy | 1 +
.../shape/query98.groovy | 1 +
.../shape/query99.groovy | 1 +
.../nostats_rf_prune/q1.groovy | 3 +-
.../nostats_rf_prune/q10.groovy | 3 +-
.../nostats_rf_prune/q11.groovy | 3 +-
.../nostats_rf_prune/q12.groovy | 3 +-
.../nostats_rf_prune/q13.groovy | 3 +-
.../nostats_rf_prune/q14.groovy | 3 +-
.../nostats_rf_prune/q15.groovy | 3 +-
.../nostats_rf_prune/q16.groovy | 3 +-
.../nostats_rf_prune/q17.groovy | 3 +-
.../nostats_rf_prune/q18.groovy | 3 +-
.../nostats_rf_prune/q19.groovy | 3 +-
.../nostats_rf_prune/q2.groovy | 3 +-
.../nostats_rf_prune/q20-rewrite.groovy | 3 +-
.../nostats_rf_prune/q20.groovy | 3 +-
.../nostats_rf_prune/q21.groovy | 3 +-
.../nostats_rf_prune/q22.groovy | 3 +-
.../nostats_rf_prune/q3.groovy | 3 +-
.../nostats_rf_prune/q4.groovy | 3 +-
.../nostats_rf_prune/q5.groovy | 3 +-
.../nostats_rf_prune/q6.groovy | 3 +-
.../nostats_rf_prune/q7.groovy | 3 +-
.../nostats_rf_prune/q8.groovy | 3 +-
.../nostats_rf_prune/q9.groovy | 3 +-
.../rf_prune/q1.groovy | 3 +-
.../rf_prune/q10.groovy | 3 +-
.../rf_prune/q11.groovy | 3 +-
.../rf_prune/q12.groovy | 3 +-
.../rf_prune/q13.groovy | 3 +-
.../rf_prune/q14.groovy | 3 +-
.../rf_prune/q15.groovy | 3 +-
.../rf_prune/q16.groovy | 3 +-
.../rf_prune/q17.groovy | 3 +-
.../rf_prune/q18.groovy | 3 +-
.../rf_prune/q19.groovy | 3 +-
.../rf_prune/q2.groovy | 3 +-
.../rf_prune/q20-rewrite.groovy | 3 +-
.../rf_prune/q20.groovy | 3 +-
.../rf_prune/q21.groovy | 3 +-
.../rf_prune/q22.groovy | 3 +-
.../rf_prune/q3.groovy | 3 +-
.../rf_prune/q4.groovy | 3 +-
.../rf_prune/q5.groovy | 3 +-
.../rf_prune/q6.groovy | 3 +-
.../rf_prune/q7.groovy | 3 +-
.../rf_prune/q8.groovy | 3 +-
.../rf_prune/q9.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q1.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q10.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q11.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q12.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q13.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q14.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q15.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q16.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q17.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q18.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q19.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q2.groovy | 3 +-
.../shape/q20-rewrite.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q20.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q21.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q22.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q3.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q4.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q5.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q6.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q7.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q8.groovy | 3 +-
.../nereids_tpch_shape_sf1000_p0/shape/q9.groovy | 3 +-
.../shape_no_stats/q1.groovy | 3 +-
.../shape_no_stats/q10.groovy | 3 +-
.../shape_no_stats/q11.groovy | 3 +-
.../shape_no_stats/q12.groovy | 3 +-
.../shape_no_stats/q13.groovy | 3 +-
.../shape_no_stats/q14.groovy | 3 +-
.../shape_no_stats/q15.groovy | 3 +-
.../shape_no_stats/q16.groovy | 3 +-
.../shape_no_stats/q17.groovy | 3 +-
.../shape_no_stats/q18.groovy | 3 +-
.../shape_no_stats/q19.groovy | 3 +-
.../shape_no_stats/q2.groovy | 3 +-
.../shape_no_stats/q20-rewrite.groovy | 3 +-
.../shape_no_stats/q20.groovy | 3 +-
.../shape_no_stats/q21.groovy | 3 +-
.../shape_no_stats/q22.groovy | 3 +-
.../shape_no_stats/q3.groovy | 3 +-
.../shape_no_stats/q4.groovy | 3 +-
.../shape_no_stats/q5.groovy | 3 +-
.../shape_no_stats/q6.groovy | 3 +-
.../shape_no_stats/q7.groovy | 3 +-
.../shape_no_stats/q8.groovy | 3 +-
.../shape_no_stats/q9.groovy | 3 +-
.../test_auto_partition_behavior.groovy | 62 +
.../auto_partition/test_auto_partition_load.groovy | 2 +-
.../test_auto_range_partition.groovy | 2 +-
.../auto_partition/sql/multi_thread_load.groovy | 4 +-
.../test_bucket_hash_local_shuffle.groovy | 76 +
.../aggregate/map_agg_nested_insert_doris.groovy | 2 +-
.../suites/query_p0/join/jira8317.groovy | 46 -
.../query_p0/join/rqg/doris8317/doris8317.groovy | 46 +
.../query_p0/join/rqg/doris9097/doris9097.groovy | 69 +
.../query_p0/join/rqg/doris9100/doris9100.groovy | 69 +
.../query_p0/join/rqg/doris9161/doris9161.groovy | 65 +
.../show/test_nested_complex_switch.groovy | 56 -
...test_array_functions_of_array_countEqual.groovy | 1 +
...test_array_functions_of_array_difference.groovy | 4 +
.../test_array_with_scale_type.groovy | 78 +-
.../datetime_functions/test_date_function.groovy | 1 +
.../ip_functions/test_ip_functions.groovy | 50 +-
.../test_ipv6_cidr_to_range_function.groovy | 85 +
.../test_ipv6_num_to_string_function.groovy | 54 +
.../test_is_ip_address_in_range_function.groovy | 67 +
.../test_is_ip_string_functions.groovy | 44 +
.../string_functions/test_string_function.groovy | 2 +
.../window_functions/test_window_fn.groovy | 35 +-
.../test_materialized_view_load_open.groovy | 85 +-
.../test_alter_database_property.groovy | 2 +-
.../test_agg_keys_schema_change_decimalv2.groovy | 294 +++
.../test_show_create_table_and_views.groovy | 2 +-
.../suites/show_p0/test_show_statistic_proc.groovy | 6 +-
.../suites/statistics/analyze_stats.groovy | 245 +-
.../storage_medium_p0/test_disk_health.groovy | 27 +
.../test_storage_medium_has_disk.groovy | 166 ++
.../test_partial_update_strict_mode.groovy | 39 +
.../suites/update/test_update_configs.groovy | 15 +-
.../suites/variant_p0/column_name.groovy | 2 +-
.../variant_p0/compaction/test_compaction.groovy | 2 +-
regression-test/suites/variant_p0/desc.groovy | 6 +-
regression-test/suites/variant_p0/load.groovy | 10 +-
.../suites/variant_p0/with_index/load.groovy | 2 +-
regression-test/suites/variant_p2/load.groovy | 2 +-
thirdparty/CHANGELOG.md | 8 +
thirdparty/build-thirdparty.sh | 11 +-
thirdparty/download-thirdparty.sh | 4 +-
thirdparty/patches/vectorscan-5.4.11.patch | 50 +
thirdparty/patches/vectorscan-5.4.7.patch | 31 -
thirdparty/vars.sh | 18 +-
tools/pick_pr.sh | 108 +
tools/ssb-tools/bin/run-ssb-flat-queries.sh | 15 +-
tools/ssb-tools/bin/run-ssb-queries.sh | 13 +-
tools/tpcds-tools/queries/sf100/query72.sql | 2 +-
2980 files changed, 69927 insertions(+), 29427 deletions(-)
create mode 100644 be/src/http/action/adjust_log_level.cpp
create mode 100644 be/src/http/action/adjust_log_level.h
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index/query/phrase_query.cpp
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index/query/phrase_query.h
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index/query/query.h
create mode 100644 be/src/olap/rowset/segment_v2/inverted_index/query/query_factory.h
create mode 100644 be/src/olap/wal/wal_dirs_info.cpp
create mode 100644 be/src/olap/wal/wal_dirs_info.h
create mode 100644 be/src/olap/wal/wal_info.cpp
create mode 100644 be/src/olap/wal/wal_info.h
create mode 100644 be/src/olap/wal/wal_manager.cpp
create mode 100644 be/src/olap/wal/wal_manager.h
create mode 100644 be/src/olap/wal/wal_reader.cpp
create mode 100644 be/src/olap/wal/wal_reader.h
create mode 100644 be/src/olap/wal/wal_table.cpp
create mode 100644 be/src/olap/wal/wal_table.h
create mode 100644 be/src/olap/wal/wal_writer.cpp
create mode 100644 be/src/olap/wal/wal_writer.h
delete mode 100644 be/src/olap/wal_dirs_info.cpp
delete mode 100644 be/src/olap/wal_dirs_info.h
delete mode 100644 be/src/olap/wal_info.cpp
delete mode 100644 be/src/olap/wal_info.h
delete mode 100644 be/src/olap/wal_manager.cpp
delete mode 100644 be/src/olap/wal_manager.h
delete mode 100644 be/src/olap/wal_reader.cpp
delete mode 100644 be/src/olap/wal_reader.h
delete mode 100644 be/src/olap/wal_table.cpp
delete mode 100644 be/src/olap/wal_table.h
delete mode 100644 be/src/olap/wal_writer.cpp
delete mode 100644 be/src/olap/wal_writer.h
create mode 100644 be/src/runtime/runtime_query_statistics_mgr.cpp
create mode 100644 be/src/runtime/runtime_query_statistics_mgr.h
create mode 100644 be/src/vec/common/ipv6_to_binary.h
create mode 100644 be/src/vec/runtime/ip_address_cidr.h
create mode 100644 be/test/olap/wal/wal_dirs_info_test.cpp
create mode 100644 be/test/olap/wal/wal_manager_test.cpp
create mode 100644 be/test/olap/wal/wal_reader_writer_test.cpp
delete mode 100644 be/test/olap/wal_manager_test.cpp
delete mode 100644 be/test/olap/wal_reader_writer_test.cpp
create mode 100644 docs/en/docs/advanced/auto-increment.md
create mode 100644 docs/en/docs/install/k8s-deploy/helm-chart-deploy.md
rename docs/en/docs/install/{k8s-deploy.md => k8s-deploy/operator-deploy.md} (100%)
create mode 100644 docs/en/docs/lakehouse/sql-dialect.md
create mode 100644 docs/en/docs/query-acceleration/async-materialized-view/async-materialized-view.md
create mode 100644 docs/en/docs/query-acceleration/async-materialized-view/query-async-materialized-view.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/ip-functions/inet6-aton.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/ip-functions/ipv6-string-to-num-or-default.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/ip-functions/ipv6-string-to-num-or-null.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/ip-functions/ipv6-string-to-num.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/table-functions/active_queries.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/table-functions/jobs.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/table-functions/mv_infos.md
delete mode 100644 docs/en/docs/sql-manual/sql-functions/table-functions/queries.md
create mode 100644 docs/en/docs/sql-manual/sql-functions/table-functions/tasks.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Data-Definition-Statements/Alter/ALTER-ASYNC-MATERIALIZED-VIEW.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Data-Definition-Statements/Create/CREATE-ASYNC-MATERIALIZED-VIEW.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Data-Definition-Statements/Drop/DROP-ASYNC-MATERIALIZED-VIEW.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Data-Types/VARIANT.md
delete mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-DIAGNOSE-TABLET.md
delete mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-CONFIG.md
delete mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-REPLICA-DISTRIBUTION.md
delete mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-REPLICA-STATUS.md
delete mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-TABLET-STORAGE-FORMAT.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-CONFIG.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-REPLICA-DISTRIBUTION.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-REPLICA-STATUS.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-TABLET-DIAGNOSIS.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-TABLET-STORAGE-FORMAT.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Utility-Statements/CANCEL-MATERIALIZED-VIEW-TASK.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Utility-Statements/PAUSE-MATERIALIZED-VIEW.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Utility-Statements/REFRESH-MATERIALIZED-VIEW.md
create mode 100644 docs/en/docs/sql-manual/sql-reference/Utility-Statements/RESUME-MATERIALIZED-VIEW.md
create mode 100644 docs/zh-CN/docs/advanced/auto-increment.md
create mode 100644 docs/zh-CN/docs/install/k8s-deploy/helm-chart-deploy.md
rename docs/zh-CN/docs/install/{k8s-deploy.md => k8s-deploy/operator-deploy.md} (100%)
create mode 100644 docs/zh-CN/docs/lakehouse/sql-dialect.md
create mode 100644 docs/zh-CN/docs/query-acceleration/async-materialized-view/async-materialized-view.md
create mode 100644 docs/zh-CN/docs/query-acceleration/async-materialized-view/query-async-materialized-view.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/inet6-aton.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/ipv6-string-to-num-or-default.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/ipv6-string-to-num-or-null.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/ip-functions/ipv6-string-to-num.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/table-functions/active_queries.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/table-functions/jobs.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/table-functions/mv_infos.md
delete mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/table-functions/queries.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-functions/table-functions/tasks.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Data-Definition-Statements/Alter/ALTER-ASYNC-MATERIALIZED-VIEW.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Data-Definition-Statements/Create/CREATE-ASYNC-MATERIALIZED-VIEW.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Data-Definition-Statements/Drop/DROP-ASYNC-MATERIALIZED-VIEW.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Data-Types/VARIANT.md
delete mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-DIAGNOSE-TABLET.md
delete mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-CONFIG.md
delete mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-REPLICA-DISTRIBUTION.md
delete mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-REPLICA-STATUS.md
delete mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/ADMIN-SHOW-TABLET-STORAGE-FORMAT.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-CONFIG.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-REPLICA-DISTRIBUTION.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-REPLICA-STATUS.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-TABLET-DIAGNOSIS.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Database-Administration-Statements/SHOW-TABLET-STORAGE-FORMAT.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Utility-Statements/CANCEL-MATERIALIZED-VIEW-TASK.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Utility-Statements/PAUSE-MATERIALIZED-VIEW.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Utility-Statements/REFRESH-MATERIALIZED-VIEW.md
create mode 100644 docs/zh-CN/docs/sql-manual/sql-reference/Utility-Statements/RESUME-MATERIALIZED-VIEW.md
create mode 100644 fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/JdbcDataSourceConfig.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/AdminDiagnoseTabletStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/AdminShowConfigStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/AdminShowReplicaDistributionStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/AdminShowReplicaStatusStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/AdminShowTabletStorageFormatStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/BrokerLoadStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/DiagnoseTabletStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/MysqlLoadStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/NumericLiteralExpr.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/S3TvfLoadStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/ShowConfigStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaDistributionStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/ShowReplicaStatusStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTabletStorageFormatStmt.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/analysis/SparkLoadStmt.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/catalog/TableAttributes.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/common/util/InternalDatabaseUtil.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/common/util/SQLDialectUtils.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/broker/BrokerInputFile.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/broker/BrokerInputStream.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/broker/IcebergBrokerIO.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/datasource/infoschema/ExternalInfoSchemaDatabase.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/datasource/infoschema/ExternalInfoSchemaTable.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/QueryDetailAction.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteLog.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteManager.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteTask.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/insertoverwrite/InsertOverwriteUtil.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/exceptions/MetaNotFoundException.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/hint/DistributeHint.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/joinorder/hypergraph/ConflictRulesMaker.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/Dialect.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/ParseDialect.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/spark/DateTruncFnCallTransformer.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/spark/SparkSql3FnCallTransformers.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/spark/SparkSql3LogicalPlanBuilder.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/trino/DateDiffFnCallTransformer.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/trino/TrinoFnCallTransformers.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/trino/TrinoLogicalPlanBuilder.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/parser/trino/TrinoParser.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/AddOffsetIntoDistribute.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPrunerForExternalTable.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/HavingToFilter.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalOdbcScanToPhysicalOdbcScan.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/EliminateJoinByUnique.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/MergeTopNs.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/PushConjunctsIntoOdbcScan.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ArrayEnumerateUniq.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/ArrayShuffle.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/G.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/IPv6CIDRToRange.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Ipv6StringToNum.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Ipv6StringToNumOrDefault.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/Ipv6StringToNumOrNull.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/IsIpAddressInRange.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/IsIpv4String.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/scalar/IsIpv6String.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/table/ActiveQueries.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/table/Queries.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/FractionalLiteral.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/NumericLiteral.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/DistributeType.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/JoinHint.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CancelMTMVTaskCommand.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowConstraintsCommand.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CancelMTMVTaskInfo.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalOdbcScan.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalOdbcScan.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/util/ImmutableEqualSet.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/nereids/util/ImmutableEquivalenceSet.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/persist/AlterConstraintLog.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/AuditEvent.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/DialectConverterPlugin.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/LoadAuditEvent.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/StreamLoadAuditEvent.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditEvent.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLoaderPlugin.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditLogBuilder.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/audit/AuditStreamLoader.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/audit/LoadAuditEvent.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/audit/StreamLoadAuditEvent.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/dialect/HttpDialectConverterPlugin.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/plugin/dialect/HttpDialectUtils.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogBuilder.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadRuntimeStatusMgr.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/rewrite/FunctionAlias.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJobInfo.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskInfo.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/statistics/ExternalAnalysisTask.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/statistics/NewPartitionLoadedEvent.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/statistics/UpdateRowsEvent.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/statistics/util/SimpleQueue.java
create mode 100644 fe/fe-core/src/main/java/org/apache/doris/tablefunction/ActiveQueriesTableValuedFunction.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/tablefunction/QueriesTableValuedFunction.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/analysis/AdminShowReplicaTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/analysis/S3TvfLoadStmtTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/analysis/ShowBackupStmtTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/analysis/ShowCreateLoadStmtTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/analysis/ShowReplicaTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/catalog/constraint/ConstraintPersistTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/common/util/SQLDialectUtilsTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/mysql/MysqlServerTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/DistributeHintTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/JoinHintTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/jobs/joinorder/joinhint/DistributeHintTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/jobs/joinorder/joinhint/JoinHintTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/parser/spark/FnTransformTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/parser/trino/FnTransformTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/parser/trino/QueryTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/mv/HyperGraphAggTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/mv/HyperGraphComparatorTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/EliminateJoinByUniqueTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/MergeTopNsTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/PredicatePropagationTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/util/TrinoDialectPlanParseChecker.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/nereids/util/UtilsTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/plugin/DialectPluginTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/plugin/HttpDialectUtilsTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/plugin/PluginTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/plugin/SimpleHttpServer.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/plugin/TestDialectPlugin1.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/plugin/TestDialectPlugin2.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/statistics/ColStatsDataTest.java
create mode 100644 fe/fe-core/src/test/java/org/apache/doris/statistics/JdbcAnalysisTaskTest.java
delete mode 100644 fe/fe-core/src/test/java/org/apache/doris/utframe/SimpleHttpServer.java
create mode 100644 fe_plugins/sparksql-converter/pom.xml
create mode 100755 fe_plugins/sparksql-converter/src/main/assembly/plugin.conf
create mode 100755 fe_plugins/sparksql-converter/src/main/assembly/plugin.properties
copy fe_plugins/{auditloader => sparksql-converter}/src/main/assembly/zip.xml (100%)
create mode 100644 fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect/spark/DateTruncFnCallTransformer.java
create mode 100644 fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect/spark/SparkSql3FnCallTransformers.java
create mode 100644 fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect/spark/SparkSql3LogicalPlanBuilder.java
create mode 100644 fe_plugins/sparksql-converter/src/main/java/org/apache/doris/plugin/dialect/spark/SparkSqlDialectConverterPlugin.java
create mode 100644 fe_plugins/sparksql-converter/src/test/java/org/apache/doris/plugin/dialect/spark/FnTransformTest.java
create mode 100644 fe_plugins/sparksql-converter/src/test/java/org/apache/doris/plugin/dialect/spark/ParserTest.java
create mode 100644 fe_plugins/trino-converter/pom.xml
create mode 100755 fe_plugins/trino-converter/src/main/assembly/plugin.conf
create mode 100755 fe_plugins/trino-converter/src/main/assembly/plugin.properties
copy fe_plugins/{auditloader => trino-converter}/src/main/assembly/zip.xml (100%)
create mode 100644 fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect/trino/DateDiffFnCallTransformer.java
create mode 100644 fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect/trino/TrinoDialectConverterPlugin.java
create mode 100644 fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect/trino/TrinoFnCallTransformers.java
create mode 100644 fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect/trino/TrinoLogicalPlanBuilder.java
create mode 100644 fe_plugins/trino-converter/src/main/java/org/apache/doris/plugin/dialect/trino/TrinoParser.java
create mode 100644 fe_plugins/trino-converter/src/test/java/org/apache/doris/plugin/dialect/trino/FnTransformTest.java
create mode 100644 fe_plugins/trino-converter/src/test/java/org/apache/doris/plugin/dialect/trino/ParserTest.java
create mode 100644 regression-test/data/backup_restore/test_backup_restore_with.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_element_at_and_slice.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_functions_array_intersect_sort.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_functions_array_join.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_functions_array_with_const.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_functions_concat_compact_difference.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_functions_in_ck_case.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_push_pop_backfront.out
create mode 100644 regression-test/data/datatype_p0/nested_types/query/array_functions/test_array_zip_array_enumerate_uniq.out
create mode 100644 regression-test/data/external_table_p0/iceberg/test_iceberg_statistics.out
create mode 100644 regression-test/data/external_table_p0/info_schema_db/test_info_schema_db.out
create mode 100644 regression-test/data/external_table_p0/paimon/test_paimon_statistics.out
create mode 100644 regression-test/data/external_table_p2/hive/test_hive_hudi_statistics.out
create mode 100644 regression-test/data/external_table_p2/paimon/paimon_base_filesystem.out
create mode 100644 regression-test/data/fault_injection_p0/test_index_compaction_fault_injection.out
copy regression-test/data/{load_p0/stream_load/test_group_commit_and_wal_back_pressure.csv.gz => fault_injection_p0/test_low_wal_disk_space_fault_injection.csv.gz} (100%)
create mode 100644 regression-test/data/inverted_index_p0/index_compaction/test_index_compaction_dup_keys.out
create mode 100644 regression-test/data/inverted_index_p0/index_compaction/test_index_compaction_unique_keys.out
create mode 100644 regression-test/data/load_p0/stream_load/test_publish_timeout.out
create mode 100644 regression-test/data/migrate_p0/test_migrate_disk_with_publish_version.out
create mode 100644 regression-test/data/mv_p0/test_28741/test_28741.out
create mode 100644 regression-test/data/mv_p0/test_substr/test_substr.out
create mode 100644 regression-test/data/nereids_p0/hint/fix_leading.out
create mode 100644 regression-test/data/nereids_rules_p0/filter_push_down/push_filter_through.out
create mode 100644 regression-test/data/nereids_rules_p0/mv/join/dphyp_inner/inner_join_dphyp.out
create mode 100644 regression-test/data/nereids_rules_p0/mv/join/dphyp_outer/outer_join_dphyp.out
create mode 100644 regression-test/data/nereids_rules_p0/pkfk/eliminate_inner.out
create mode 100644 regression-test/data/nereids_syntax_p0/constraint.out
create mode 100644 regression-test/data/nereids_tpcds_shape_sf100_p0/constraints/query23.out
create mode 100644 regression-test/data/pipeline_p0/local_shuffle/test_bucket_hash_local_shuffle.out
rename regression-test/data/query_p0/join/{jira8317.out => rqg/doris8317/doris8317.out} (100%)
create mode 100644 regression-test/data/query_p0/join/rqg/doris9097/doris9097.out
create mode 100644 regression-test/data/query_p0/join/rqg/doris9100/doris9100.out
create mode 100644 regression-test/data/query_p0/join/rqg/doris9161/doris9161.out
create mode 100644 regression-test/data/query_p0/sql_functions/ip_functions/test_ipv6_cidr_to_range_function.out
create mode 100644 regression-test/data/query_p0/sql_functions/ip_functions/test_ipv6_num_to_string_function.out
create mode 100644 regression-test/data/query_p0/sql_functions/ip_functions/test_is_ip_address_in_range_function.out
create mode 100644 regression-test/data/query_p0/sql_functions/ip_functions/test_is_ip_string_functions.out
create mode 100644 regression-test/data/rollup_p0/a.csv
create mode 100644 regression-test/data/rollup_p0/test_materialized_view_load_open.out
create mode 100644 regression-test/data/schema_change_p0/decimalv2/test_agg_keys_schema_change_decimalv2.out
create mode 100755 regression-test/pipeline/performance/clickbench/check-query-result.sh
create mode 100644 regression-test/pipeline/performance/clickbench/conf/be_custom.conf
create mode 100644 regression-test/pipeline/performance/clickbench/conf/fe_custom.conf
create mode 100644 regression-test/pipeline/performance/clickbench/conf/opt_session_variables.sql
create mode 100644 regression-test/pipeline/performance/clickbench/queries-sort.sql
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q1.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q10.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q11.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q12.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q13.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q14.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q15.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q16.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q17.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q18.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q19.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q2.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q20.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q21.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q22.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q23.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q24.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q25.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q26.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q27.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q28.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q29.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q3.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q30.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q31.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q32.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q33.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q34.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q35.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q36.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q37.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q38.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q39.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q4.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q40.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q41.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q42.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q43.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q5.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q6.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q7.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q8.result
create mode 100644 regression-test/pipeline/performance/clickbench/query-result-target/doris-q9.result
create mode 100644 regression-test/plugins/plugins_get_ids_from_proc.groovy
create mode 100644 regression-test/suites/backup_restore/test_backup_restore_with.groovy
create mode 100644 regression-test/suites/backup_restore/test_backup_restore_with_two_phase_fetch_opt.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/load.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_element_at_and_slice.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_functions_array_intersect_sort.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_functions_array_join.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_functions_array_with_const.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_functions_concat_compact_difference.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_push_pop_backfront.groovy
create mode 100644 regression-test/suites/datatype_p0/nested_types/query/array_functions/test_array_zip_array_enumerate_uniq.groovy
delete mode 100644 regression-test/suites/external_table_p0/hive/test_show_columns.groovy
create mode 100644 regression-test/suites/external_table_p0/iceberg/test_iceberg_statistics.groovy
create mode 100644 regression-test/suites/external_table_p0/info_schema_db/test_info_schema_db.groovy
create mode 100644 regression-test/suites/external_table_p0/paimon/test_paimon_statistics.groovy
create mode 100644 regression-test/suites/external_table_p2/hive/test_hive_hudi_statistics.groovy
create mode 100644 regression-test/suites/external_table_p2/paimon/paimon_base_filesystem.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_disable_move_memtable.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_index_compaction_fault_injection.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_load_stream_stub_close_wait_fault_injection.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_low_wal_disk_space_fault_injection.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_multi_replica_fault_injection.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_wal_mem_back_pressure_fault_injection.groovy
create mode 100644 regression-test/suites/fault_injection_p0/test_wal_mem_back_pressure_time_out_fault_injection.groovy
create mode 100644 regression-test/suites/insert_p0/test_group_commit_data_bytes_property.groovy
create mode 100644 regression-test/suites/internal_schema_p0/operate_internal_schema.groovy
create mode 100644 regression-test/suites/inverted_index_p0/index_compaction/test_index_compaction_dup_keys.groovy
create mode 100644 regression-test/suites/inverted_index_p0/index_compaction/test_index_compaction_unique_keys.groovy
create mode 100644 regression-test/suites/inverted_index_p0/test_array_index.groovy
create mode 100644 regression-test/suites/inverted_index_p0/test_properties.groovy
create mode 100644 regression-test/suites/inverted_index_p0/test_show_data.groovy
create mode 100644 regression-test/suites/load_p0/routine_load/data/multi_table_load_invalid_table.csv
create mode 100644 regression-test/suites/load_p0/routine_load/test_routine_load_error.groovy
create mode 100644 regression-test/suites/load_p0/stream_load/test_publish_timeout.groovy
create mode 100644 regression-test/suites/migrate_p0/test_migrate_disk_with_publish_version.groovy
create mode 100644 regression-test/suites/mtmv_p0/test_task_mtmv.groovy
create mode 100644 regression-test/suites/mv_p0/test_28741/test_28741.groovy
create mode 100644 regression-test/suites/mv_p0/test_substr/test_substr.groovy
create mode 100644 regression-test/suites/nereids_p0/hint/fix_leading.groovy
create mode 100644 regression-test/suites/nereids_p0/runtime_filter/runtime_filter.groovy
create mode 100644 regression-test/suites/nereids_rules_p0/filter_push_down/push_filter_through.groovy
create mode 100644 regression-test/suites/nereids_rules_p0/mv/join/dphyp_inner/inner_join_dphyp.groovy
create mode 100644 regression-test/suites/nereids_rules_p0/mv/join/dphyp_outer/outer_join_dphyp.groovy
create mode 100644 regression-test/suites/nereids_rules_p0/pkfk/eliminate_inner.groovy
create mode 100644 regression-test/suites/nereids_syntax_p0/constraint.groovy
create mode 100644 regression-test/suites/nereids_tpcds_shape_sf100_p0/constraints/load.groovy
create mode 100644 regression-test/suites/nereids_tpcds_shape_sf100_p0/constraints/query23.groovy
create mode 100644 regression-test/suites/pipeline_p0/local_shuffle/test_bucket_hash_local_shuffle.groovy
delete mode 100644 regression-test/suites/query_p0/join/jira8317.groovy
create mode 100644 regression-test/suites/query_p0/join/rqg/doris8317/doris8317.groovy
create mode 100644 regression-test/suites/query_p0/join/rqg/doris9097/doris9097.groovy
create mode 100644 regression-test/suites/query_p0/join/rqg/doris9100/doris9100.groovy
create mode 100644 regression-test/suites/query_p0/join/rqg/doris9161/doris9161.groovy
create mode 100644 regression-test/suites/query_p0/sql_functions/ip_functions/test_ipv6_cidr_to_range_function.groovy
create mode 100644 regression-test/suites/query_p0/sql_functions/ip_functions/test_ipv6_num_to_string_function.groovy
create mode 100644 regression-test/suites/query_p0/sql_functions/ip_functions/test_is_ip_address_in_range_function.groovy
create mode 100644 regression-test/suites/query_p0/sql_functions/ip_functions/test_is_ip_string_functions.groovy
create mode 100644 regression-test/suites/schema_change_p0/decimalv2/test_agg_keys_schema_change_decimalv2.groovy
create mode 100644 regression-test/suites/storage_medium_p0/test_disk_health.groovy
create mode 100644 regression-test/suites/storage_medium_p0/test_storage_medium_has_disk.groovy
create mode 100644 thirdparty/patches/vectorscan-5.4.11.patch
delete mode 100644 thirdparty/patches/vectorscan-5.4.7.patch
create mode 100755 tools/pick_pr.sh
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org