This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a change to branch dev_rec4
in repository https://gitbox.apache.org/repos/asf/doris.git
discard 6ff0e83295f fix bug
discard 5649e5030f2 fix create mtmv task fail
discard eff7c8daf6a fix
discard 61f731e70a4 Revert "fix"
discard 41bba83e370 fix
discard 07567f27c51 fix
discard 1199851dec7 fix
discard 7e6d2071dc1 rebase code
discard 6d2cbae34f3 remove useless case
discard cafe7033ebf recursive cte be part
discard c36d1ce7a5b recursive cte fe part
discard 4b5937492f7 support rec cte (be part / proto part)
add 2b05dcffe9b [feature](type)support timestamptz type (#56646)
add f6a2892f4ba [fix](case)fix create sync mv failed in test case (#58834)
add 13b7314238a [fix](variable persist) fix regression test test_mtmv
(#58869)
add dff8a23c0f6 [test](mtmv) Inject stats for complex mv to make test case
stable (#58876)
add a09eaa61414 [chore](planner) remove useless code from analyzer and
planner package (#58939)
add a35424def6b [bugfix](memory_profile) should split memtable memory from
task's memory profile (#58908)
add c4bdf6f8cc2 [chore](load) Not log unnecessary stack information
(#58420)
add 8acca2dce07 [refine](pipeline) remove static_cast<void> in pipeline
(#58910)
add dbf237199ac [opt](jvm) add more --add-opens (#58936)
add 6b04964e2a5 [chore](readme) readme in multi languages (#58983)
add df86f2784cb [opt](olap) Optimize the performance of
StructFileColumnIterator::read_by_rowids in scenarios where the rowids are
continuous (#58851)
add 85d45024114 [chore](plan translator) remove useless partition and
order eq expr in analytic node (#58940)
add 49763e94b77 [opt](agg) Adjust the parameters of
StreamingHtMinReductionEntry (#58938)
add d2c429b5b55 [chore](ci) exclude test_insert_error_url to avoid stop
grace fail (#58985)
add c1c78bff836 [refactor](predicate) Disable predicates push down for
cast expr (#58960)
add c66cd281212 [fix](inverted index) fix incorrect variable usage in
phrase query building (#58952)
add 580ed5a09c9 [fix](mtmv) Fix query rewrite by mv fail when both use cte
and group sets (#57741)
add f54124c15bb [fix](build) fix macOS build (#58790)
add e92f641f9c8 [fix](ann search)
l2_distance_approximate/inner_product_approximate should not be deterministic
(#58988)
add fda035d1d06 [chore](Expr) set nullable for expr when translation
(#57862)
add 7b1edb26d62 [fix](skew_join)should make skewExpr and skewValues have
same datatype (#58941)
add 96dabda28f9 [feature](posexplode) support multi args (#58990)
add 16c92b6b431 [chore](test) Use `DORIS_MS_INSTANCE_ID` instead of
`get_instance` (#58980)
add c11cb9fabc3 [fix](filecache) fix benchmark varification problem
(#58845)
add 9bdd09ffaa9 [fix](filecache) dedup need_update_lru_block queue to
reduce memory consumption (#58903)
add eab260e3368 [Enhancement](Snapshot) Add migrate and compact parallel
config (#58935)
add f9867ed0742 [fix](parser) Fix FROM DUAL incorrectly matching table
names starting with dual (#59003)
add d63f8db8648 [fix](json) Replace invalid JSONB with default JSONB null
value (#59007)
add e4786790134 [fix](nereids) deduplicate scope slots (#58683)
add 37ec44d4936 [opt](iceberg) able to ignore iceberg dangling delete to
do count push down (#58889)
add 3baca2295aa [Opt](tbl_priv) Optimize PrivTable search and insert with
ordered lookup (#58828)
add 555e430d86e [fix](packed-file) improve packed file trailer tooling and
recycler robustness (#58883)
add 49c43dd76b3 [chore](code)Remove the unused member variable
_getting_const_col and get_const_col no longer constructs a block. (#58841)
add 678d78ff1cf [opt](cloud) optimize load performance for mow table when
pack small files (#58839)
add 4502d122ea2 [fix](packed-file) fix some case for packed small files
(#58977)
add 17677cd4a89 [feature](QueryPlanAction)add sql received from table
query plan action into audit log (#58739)
add 104aa2dbd51 [improve](varbinary) support varbinary type with topn
runtime filter (#58721)
add c0c420436a8 [fix](enforcer) shuffle if has continuous project or
filter on cte consumer (#58964)
add 1e5b338007b [chore](cloud) ms http util supports versioned keys --
encode decode (#58953)
add 43f2d406e8c [opt](inverted index) release dir memory after index file
writer close (#59031)
add 58e3f6d1557 [feat](catalog)Support for Loading Catalog Credentials via
AwsCredentialsProviderChain (#58740)
add aa0e8d4ea0c [Fix](fe) Fix NPE in `OlapTableSink.createPaloNodesInfo`
due to concurrent drop backend (#58999)
add 1d312cae6f0 [chore](thrift)thrift warn when socket is nullptr (#58599)
add 5a0ec52fcc0 [fix](filecache) fix warm up cancel failure when BE is
down (#58035)
add 8631b18199a [fix](mtmv) Fix mv rewrite failed when mv is rewritten by
LimitAggToTopNAgg but query is not (#58974)
add 0031179b1e6 [fix](parquet)fix parquet topn lazy mat complex data error
result (#58785)
add 4616c7f55c7 [chore](catalog)Remove the HMS-related parts from
be-extension. (#58280)
add 992a5d13e8d [Fix](Iam-role)Ensure StorageProperties list remains
ordered when auto-loading default HDFS (#58968)
add b23d5b475a7 [refactor](predicate) Refactor predicates on external
tables (#58905)
add 836b9f9075c [test](be) test revert local shuffle union (#58813)
add f2619bdba49 [fix](test) fix case test_array_agg_view use same table in
a database (#59027)
add 63ed2382ce2 [fix](docker) fix_parse_config_file (#59039)
add 232a5a2b81a [refactor](topn) Refactor topn filter push down (#59005)
add ca2aadf5f59 [case](profile) rm useless profile_test case (#58569)
add 75449722ffa [fix](profile) Fix the issue about load channel profile
(#58787)
add b9a05c843db [enhance](iceberg) Doris Iceberg Scan Metrics Integration
(#59010)
add 99d14a8d815 [fix](delete) Fix missing `prepare_rowset` for delete job
(#59089)
add d80976a6efe [chore](parser) remove useless class TimestampArithmetic
(#59049)
add 11f0a7aa072 [chore](planner) remove useless NullableTuples in PlanNode
(#58967)
add 9c6353f2ee5 [refact](inverted index) use inverted index context for
query (#58981)
add 1ec62bd69ad [fix](predicate) Fix use-after-free caused by string
predicate (#59098)
add e77de3af9fa Revert "[Fix](mow) seg compaction should wait for calc
delete bitmap tasks on input segments before converting delete bitmaps on them
(#53198)" (#59066)
add 345f473a35c [fix](catalog) Fix lastUpdateTime not updated on refresh
and add scheduled refresh logs (#58997)
add 83482aae11c [chore](profile) add more counter in SetOperator (#59025)
add a6828abe341 [check](column)Columns must be created only via their
corresponding create methods. (#59087)
add 5242f9302c2 [fix](cloud) correct the min_read_version of the
CloneChainReader (#59086)
add 32b831ca3cf [chore](asf) Rename TangSiyang2001 to his new name
Hastyshell (#59012)
add 346e2c4dce8 [enhance](agg) Support max_by/min_by agg functions for
some complex type (#58736)
add 2cacaf52cdb [feature](audit) add dynamic configuration for sql_digest
generation (#59102)
add 8e30d70a3e7 [chore](dep)Remove hadoop-gcs dependencies (#59063)
add 161982415ce [fix](profile) sort out parquet reader profile (#58895)
add c43fc487d5b [fix](auth)fix some ldap bug (#58541)
add f418eedefb4 [fix](cases) fix unstable case
test_full_compaciton_run_status.groovy (#58123)
add 262b16ed6f1 [refactor](predicate) Initialize topN predicate with
correct cid (#59088)
add 0ce926253b3 [chore](checker) Add `resource_mgr` for checker (#58954)
add 4475ce444ee [refactor](predicate) Refine predicate and unit tests
(#59126)
add cdc187330f9 [chore](compilation)fix compilation error in BE benchmark.
(#59122)
add bb6b39bcc97 [fix](rbo) use wrong child's output of set operation
(#59105)
add 80d73c8ffe0 [opt](olap) Optimize reading by rowids of Map Column
(#59043)
add 89d23081a86 [fix](olap) Should erase the segment footer cache after
compaction (#59101)
add 37114b8099e [Opt](encoding) Let `storage_format` control default
encoding for interger and binary (#59075)
add 843381ed284 [Enhancement](variable) Adding a whitelist allows you to
ignore certain unsupported variables (#58998)
add 5a1fce56adc [fix](nullable) set SlotRef's nullable to right value
(#59092)
add 7919b4b51fe [fix](test) modify conf for regression tests (#59073)
add 0d85bd1183f [chore](expr) remove isAnalysis flag on Expr (#59119)
add 752d86c4fde [chore](dep)Remove unused dependencies (#59079)
add 15d2a429601 [fix](core) fix core if hll_from_base64 input invalid
(#59106)
add edbfb8f6fc8 [fix](test) fix test test_view_var_persist unstable
(#58931)
add 3f65bfd6580 [refine](util) add cast_to_column to cast ColumnPtr
(#58092)
add 8ef5babb5c6 [Feature](Export) support native format (#58711)
add 9e8106678fd [fix](inverted index) also release dir when search cache
after writer enable and fix get_index_file_names for v1 (#59139)
add 86f0b3a0896 [feat](catalog) Support passing credentials_provider_type
to BE for S3 access (#59082)
add 0918952c70c [refactor](filecache) ttl management refactoring (#57922)
add fe0df602c22 [fix](packed-file) fix issues in packed file recycler
checker (#59153)
add 6d98eab9f05 [fix](load) Fix the sensitivity issue of load column
mapping with expressions (#59149)
add 38199f1ec4c [feat](snapshot) fix recycle deleted instance (#59134)
add c8ba19dca56 [fix](job) set cluster when routine load job replay from
image (#59135)
add d5465e83e0b [fix](metrics) resolve deadlock by moving deregister_hook
to destructor (#59110)
add 654bcb74475 [fix](catalog) Only sync storage vault when it exists
(#59113)
add 281e13de906 [fix](inverted index) check policy type when dropping
index policy (#59132)
add aef789fb2a5 [Enhancement](iceberg) add iceberg expire cache params in
catalog property (#57187)
add 0a5c352b79a [fix](p0) fix unstable p0 test (#59160)
add 28be8c77dac [fix](pkfk) Fix drop table not drop constraint related
info (#58958)
add 83aafd64082 [chore](test) Export `JAVA_HOME` before start fe (#59084)
add b4e78bafa82 [feature](inverted index) Implement es-like boolean query
(#58545)
add 77f6cd44bad [improve](cloud) Allow to control txn lazy commit
advancing during reads (#59196)
add edb39265065 [improve](cloud) TxnLazyCommitter do not block bthreads
(#59216)
add d4c38d1deda [improve](cloud) Get visible version explicitly wait for
pending txns (#59213)
add b2a218d61e8 [improve](cloud) Shuffle the partitions to reduce
committing conflicts (#59212)
add 8b26ec102fd support rec cte (be part / proto part)
add 680a52e8774 recursive cte fe part
add 2402caa8efc recursive cte be part
add 43c67ab3ca1 remove useless case
add 847bb6c5d71 rebase code
add 76d7ef8ef13 update some fix, todo and comment
add fe5aa757f10 fix create mtmv task fail
add e40279bc930 fix bug
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 (6ff0e83295f)
\
N -- N -- N refs/heads/dev_rec4 (e40279bc930)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
README.md | 10 +
be/src/cloud/cloud_delete_task.cpp | 8 +-
be/src/cloud/cloud_internal_service.cpp | 8 +-
be/src/cloud/cloud_rowset_writer.cpp | 8 +-
be/src/cloud/cloud_rowset_writer.h | 4 +-
be/src/cloud/cloud_storage_engine.cpp | 29 +-
be/src/cloud/cloud_storage_engine.h | 19 +-
be/src/cloud/cloud_tablet.cpp | 24 +-
be/src/cloud/cloud_tablet_mgr.cpp | 47 +-
be/src/cloud/cloud_tablet_mgr.h | 15 +-
be/src/cloud/cloud_warm_up_manager.cpp | 8 +-
be/src/cloud/config.cpp | 3 +-
be/src/cloud/config.h | 1 -
be/src/cloud/pb_convert.cpp | 28 +
be/src/common/config.cpp | 19 +-
be/src/common/config.h | 10 +-
be/src/exec/olap_common.h | 71 +-
be/src/exec/schema_scanner.cpp | 7 +
.../exec/schema_scanner/schema_columns_scanner.cpp | 15 +-
be/src/exec/table_connector.cpp | 170 -
be/src/exec/table_connector.h | 5 -
be/src/exec/tablet_info.cpp | 27 +-
be/src/exprs/bloom_filter_func_impl.h | 2 +
be/src/exprs/create_predicate_function.h | 1 +
be/src/exprs/hybrid_set.h | 2 +-
be/src/io/cache/block_file_cache.cpp | 464 +-
be/src/io/cache/block_file_cache.h | 64 +-
be/src/io/cache/block_file_cache_ttl_mgr.cpp | 261 +
be/src/io/cache/block_file_cache_ttl_mgr.h | 78 +
be/src/io/cache/cache_block_meta_store.cpp | 5 +
be/src/io/cache/cache_block_meta_store.h | 1 +
be/src/io/cache/file_block.cpp | 13 -
be/src/io/cache/file_block.h | 2 -
be/src/io/cache/file_cache_common.cpp | 1 +
be/src/io/cache/file_cache_storage.h | 2 -
be/src/io/cache/fs_file_cache_storage.cpp | 29 +-
be/src/io/cache/fs_file_cache_storage.h | 2 -
be/src/io/cache/mem_file_cache_storage.cpp | 7 -
be/src/io/cache/mem_file_cache_storage.h | 2 -
be/src/io/fs/buffered_reader.cpp | 3 -
be/src/io/fs/buffered_reader.h | 18 -
be/src/io/fs/file_writer.h | 4 +-
be/src/io/fs/packed_file_manager.cpp | 64 +-
be/src/io/fs/packed_file_trailer.cpp | 152 +
.../src/io/fs/packed_file_trailer.h | 22 +-
be/src/io/fs/tracing_file_reader.h | 1 +
be/src/io/tools/file_cache_microbench.cpp | 16 +-
be/src/olap/base_tablet.cpp | 24 +-
be/src/olap/base_tablet.h | 15 +-
be/src/olap/calc_delete_bitmap_executor.cpp | 16 +-
be/src/olap/calc_delete_bitmap_executor.h | 24 +-
be/src/olap/collection_statistics.cpp | 7 +-
be/src/olap/column_predicate.h | 39 +-
be/src/olap/comparison_predicate.h | 2 +-
be/src/olap/delete_handler.cpp | 471 +-
be/src/olap/delete_handler.h | 17 +-
be/src/olap/field.h | 4 +
be/src/olap/in_list_predicate.h | 77 -
be/src/olap/inverted_index_parser.h | 28 +-
be/src/olap/key_coder.cpp | 1 +
be/src/olap/key_coder.h | 35 +
be/src/olap/olap_common.h | 38 +-
be/src/olap/page_cache.h | 6 +
be/src/olap/partial_update_info.cpp | 9 +-
be/src/olap/predicate_creator.cpp | 6 +
be/src/olap/predicate_creator.h | 365 +-
be/src/olap/primary_key_index.cpp | 2 +-
be/src/olap/push_handler.cpp | 3 +-
be/src/olap/rowset/beta_rowset_reader.cpp | 8 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 159 +-
be/src/olap/rowset/beta_rowset_writer.h | 9 +-
be/src/olap/rowset/rowset_factory.cpp | 4 +-
be/src/olap/rowset/rowset_writer_context.h | 11 +-
be/src/olap/rowset/segcompaction.cpp | 40 +-
be/src/olap/rowset/segcompaction.h | 11 +-
be/src/olap/rowset/segment_v2/binary_dict_page.cpp | 21 +-
.../segment_v2/bloom_filter_index_writer.cpp | 1 +
be/src/olap/rowset/segment_v2/column_reader.cpp | 185 +-
be/src/olap/rowset/segment_v2/column_reader.h | 4 +
be/src/olap/rowset/segment_v2/column_writer.cpp | 11 +-
be/src/olap/rowset/segment_v2/column_writer.h | 7 +-
be/src/olap/rowset/segment_v2/encoding_info.cpp | 58 +-
be/src/olap/rowset/segment_v2/encoding_info.h | 14 +-
.../olap/rowset/segment_v2/index_file_writer.cpp | 25 +-
be/src/olap/rowset/segment_v2/index_writer.cpp | 1 +
.../rowset/segment_v2/indexed_column_reader.cpp | 2 +-
.../rowset/segment_v2/indexed_column_writer.cpp | 2 +-
.../inverted_index/analyzer/analyzer.cpp | 57 +-
.../segment_v2/inverted_index/analyzer/analyzer.h | 4 +-
.../inverted_index/query_v2/all_query/all_query.h | 112 +
.../query_v2/boolean_query/boolean_query_builder.h | 84 +
.../inverted_index/query_v2/boolean_query/occur.h | 9 +-
.../query_v2/boolean_query/occur_boolean_query.h | 75 +
.../boolean_query/occur_boolean_weight.cpp | 287 +
.../query_v2/boolean_query/occur_boolean_weight.h | 88 +
.../query_v2/{ => boolean_query}/operator.h | 0
.../{boolean_query.h => operator_boolean_query.h} | 41 +-
...{boolean_weight.h => operator_boolean_weight.h} | 12 +-
.../inverted_index/query_v2/disjunction_scorer.cpp | 129 +
.../inverted_index/query_v2/disjunction_scorer.h | 66 +
.../segment_v2/inverted_index/query_v2/doc_set.h | 4 +
.../inverted_index/query_v2/exclude_scorer.cpp | 86 +
.../{union/simple_union.h => exclude_scorer.h} | 42 +-
.../inverted_index/query_v2/intersection.cpp | 206 +-
.../inverted_index/query_v2/intersection.h | 20 +-
.../query_v2/phrase_query/multi_phrase_weight.h | 3 +-
.../query_v2/phrase_query/phrase_scorer.cpp | 16 +-
.../query_v2/phrase_query/phrase_scorer.h | 7 +-
.../query_v2/phrase_query/phrase_weight.h | 6 +-
.../query_v2/postings/loaded_postings.cpp | 3 +-
.../query_v2/regexp_query/regexp_weight.cpp | 2 +-
.../inverted_index/query_v2/reqopt_scorer.h | 80 +
.../inverted_index/query_v2/segment_postings.h | 195 +-
.../segment_v2/inverted_index/query_v2/size_hint.h | 48 +
.../query_v2/term_query/term_scorer.h | 5 +-
.../query_v2/term_query/term_weight.h | 23 +-
.../query_v2/union/buffered_union.cpp | 259 +
.../inverted_index/query_v2/union/buffered_union.h | 65 +
.../inverted_index/query_v2/union/simple_union.cpp | 2 +-
.../inverted_index/query_v2/union/simple_union.h | 5 +
.../segment_v2/inverted_index/query_v2/weight.h | 20 +-
.../segment_v2/inverted_index/util/tiny_set.h | 34 +-
.../rowset/segment_v2/inverted_index_iterator.cpp | 3 +-
.../rowset/segment_v2/inverted_index_iterator.h | 6 +
.../rowset/segment_v2/inverted_index_reader.cpp | 21 +-
.../olap/rowset/segment_v2/inverted_index_reader.h | 12 +-
.../rowset/segment_v2/inverted_index_writer.cpp | 33 +-
.../olap/rowset/segment_v2/inverted_index_writer.h | 4 +-
be/src/olap/rowset/segment_v2/options.h | 10 +
be/src/olap/rowset/segment_v2/page_io.cpp | 2 +-
be/src/olap/rowset/segment_v2/row_ranges.h | 10 +-
be/src/olap/rowset/segment_v2/segment.cpp | 42 +-
be/src/olap/rowset/segment_v2/segment.h | 5 +
be/src/olap/rowset/segment_v2/segment_iterator.cpp | 45 -
be/src/olap/rowset/segment_v2/segment_writer.cpp | 4 +
.../variant/variant_column_writer_impl.cpp | 27 +-
.../variant/variant_column_writer_impl.h | 4 +-
.../rowset/segment_v2/vertical_segment_writer.cpp | 4 +
be/src/olap/rowset/segment_v2/zone_map_index.cpp | 3 +-
be/src/olap/schema.cpp | 3 +
be/src/olap/schema_change.cpp | 2 +-
be/src/olap/shared_predicate.h | 3 +-
be/src/olap/storage_engine.cpp | 17 +-
be/src/olap/storage_engine.h | 24 +-
be/src/olap/tablet_meta.cpp | 7 +
be/src/olap/tablet_reader.cpp | 31 +-
be/src/olap/tablet_reader.h | 3 -
be/src/olap/tablet_schema.cpp | 22 +
be/src/olap/tablet_schema.h | 20 +
be/src/olap/types.cpp | 55 +-
be/src/olap/types.h | 40 +
be/src/olap/utils.cpp | 4 +-
be/src/olap/utils.h | 1 +
be/src/pipeline/dependency.cpp | 10 +-
be/src/pipeline/dependency.h | 43 +-
be/src/pipeline/exec/aggregation_sink_operator.cpp | 2 +-
be/src/pipeline/exec/analytic_sink_operator.cpp | 2 +-
.../distinct_streaming_aggregation_operator.cpp | 2 +-
be/src/pipeline/exec/exchange_sink_buffer.cpp | 2 +-
be/src/pipeline/exec/exchange_sink_buffer.h | 2 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 31 +-
be/src/pipeline/exec/exchange_sink_operator.h | 3 +-
be/src/pipeline/exec/exchange_source_operator.cpp | 3 +-
be/src/pipeline/exec/file_scan_operator.h | 2 -
.../pipeline/exec/join/process_hash_table_probe.h | 1 +
be/src/pipeline/exec/join_probe_operator.cpp | 6 +-
.../exec/nested_loop_join_build_operator.cpp | 2 +-
be/src/pipeline/exec/olap_scan_operator.cpp | 15 +
be/src/pipeline/exec/olap_scan_operator.h | 15 +
be/src/pipeline/exec/operator.h | 10 +-
.../pipeline/exec/partition_sort_sink_operator.cpp | 2 +-
.../pipeline/exec/rec_cte_anchor_sink_operator.h | 26 +-
be/src/pipeline/exec/rec_cte_sink_operator.h | 3 +-
be/src/pipeline/exec/rec_cte_source_operator.cpp | 17 +-
be/src/pipeline/exec/rec_cte_source_operator.h | 19 +-
be/src/pipeline/exec/result_file_sink_operator.cpp | 2 +-
be/src/pipeline/exec/scan_operator.cpp | 162 +-
be/src/pipeline/exec/scan_operator.h | 30 +-
be/src/pipeline/exec/set_probe_sink_operator.cpp | 8 +
be/src/pipeline/exec/set_probe_sink_operator.h | 2 +
be/src/pipeline/exec/set_sink_operator.cpp | 7 +
be/src/pipeline/exec/set_sink_operator.h | 2 +
be/src/pipeline/exec/set_source_operator.cpp | 4 +
be/src/pipeline/exec/set_source_operator.h | 1 +
be/src/pipeline/exec/sort_sink_operator.cpp | 2 +-
.../exec/streaming_aggregation_operator.cpp | 2 +-
be/src/pipeline/exec/union_sink_operator.cpp | 2 +-
be/src/pipeline/exec/union_source_operator.h | 2 +-
be/src/pipeline/pipeline_fragment_context.cpp | 35 +-
be/src/pipeline/pipeline_fragment_context.h | 1 -
be/src/pipeline/pipeline_task.cpp | 5 +
be/src/pipeline/rec_cte_shared_state.h | 3 +
be/src/pipeline/shuffle/writer.cpp | 4 +-
be/src/pipeline/shuffle/writer.h | 2 +-
be/src/runtime/define_primitive_type.h | 3 +-
be/src/runtime/descriptors.cpp | 26 +-
be/src/runtime/descriptors.h | 9 +-
be/src/runtime/exec_env.cpp | 14 +-
be/src/runtime/exec_env.h | 13 +-
be/src/runtime/fold_constant_executor.cpp | 26 +-
be/src/runtime/fold_constant_executor.h | 4 +-
be/src/runtime/fragment_mgr.cpp | 14 +-
be/src/runtime/memory/memory_profile.cpp | 24 +-
be/src/runtime/memory/memory_profile.h | 5 +-
be/src/runtime/primitive_type.cpp | 7 +
be/src/runtime/primitive_type.h | 28 +-
be/src/runtime/raw_value.h | 4 +
be/src/runtime/runtime_predicate.cpp | 28 +-
be/src/runtime/runtime_predicate.h | 10 +-
be/src/runtime/runtime_state.h | 1 +
.../runtime/stream_load/stream_load_recorder.cpp | 2 +-
be/src/runtime/task_execution_context.cpp | 60 +
be/src/runtime/task_execution_context.h | 26 +-
be/src/runtime/type_limit.h | 13 +
be/src/runtime_filter/runtime_filter_mgr.cpp | 18 +-
be/src/runtime_filter/runtime_filter_mgr.h | 4 +-
be/src/runtime_filter/runtime_filter_wrapper.cpp | 5 +
be/src/runtime_filter/utils.h | 5 +
be/src/service/internal_service.cpp | 6 +
be/src/service/point_query_executor.cpp | 2 +-
be/src/tools/CMakeLists.txt | 29 +
be/src/tools/packed_file_tool.cpp | 56 +
be/src/util/binary_cast.hpp | 6 +-
be/src/util/date_func.cpp | 12 +
be/src/util/date_func.h | 3 +
be/src/util/jsonb_document.cpp | 38 +
be/src/util/jsonb_document.h | 25 -
be/src/util/jvm_metrics.cpp | 13 +-
be/src/util/jvm_metrics.h | 2 +-
be/src/util/mysql_row_buffer.cpp | 7 +
be/src/util/mysql_row_buffer.h | 6 +
be/src/util/s3_util.cpp | 43 +-
be/src/util/s3_util.h | 2 +
be/src/util/thrift_client.h | 24 +-
.../aggregate_function_approx_count_distinct.cpp | 7 +-
.../aggregate_function_approx_count_distinct.h | 4 +-
.../aggregate_function_collect.h | 2 +-
.../aggregate_function_min_by.cpp | 32 -
.../aggregate_function_min_max.cpp | 23 +-
.../aggregate_function_min_max_by.cpp | 16 +-
.../aggregate_function_min_max_by.h | 103 +-
.../aggregate_function_reader_first_last.h | 5 +
.../aggregate_function_simple_factory.cpp | 6 +-
.../aggregate_function_topn.cpp | 2 +-
.../aggregate_function_uniq.cpp | 6 +-
be/src/vec/columns/column.h | 14 +-
be/src/vec/columns/column_array.cpp | 5 +
be/src/vec/columns/column_array.h | 3 +-
be/src/vec/columns/column_varbinary.cpp | 10 +-
be/src/vec/columns/column_varbinary.h | 9 +-
be/src/vec/columns/column_variant.cpp | 33 +-
be/src/vec/columns/column_variant.h | 14 +-
be/src/vec/columns/column_vector.cpp | 2 +
be/src/vec/columns/column_vector.h | 17 +-
be/src/vec/common/cow.h | 6 +
be/src/vec/common/field_visitors.h | 4 +
be/src/vec/common/schema_util.cpp | 2 +-
be/src/vec/common/string_view.h | 7 +-
be/src/vec/core/block.cpp | 41 +-
be/src/vec/core/call_on_type_index.h | 5 +
be/src/vec/core/column_with_type_and_name.cpp | 14 +-
be/src/vec/core/column_with_type_and_name.h | 5 +
be/src/vec/core/field.cpp | 39 +
be/src/vec/core/field.h | 99 +-
be/src/vec/core/sort_block.h | 6 +
be/src/vec/data_types/convert_field_to_type.cpp | 5 +
be/src/vec/data_types/data_type.cpp | 17 +-
be/src/vec/data_types/data_type.h | 13 +-
be/src/vec/data_types/data_type_array.cpp | 3 +-
be/src/vec/data_types/data_type_date_time.h | 5 +
be/src/vec/data_types/data_type_factory.cpp | 10 +
be/src/vec/data_types/data_type_number_base.cpp | 1 +
be/src/vec/data_types/data_type_number_base.h | 5 +-
be/src/vec/data_types/data_type_timestamptz.cpp | 41 +
be/src/vec/data_types/data_type_timestamptz.h | 74 +
be/src/vec/data_types/data_type_varbinary.h | 2 +-
.../vec/data_types/serde/data_type_array_serde.cpp | 29 +-
.../vec/data_types/serde/data_type_array_serde.h | 21 +-
.../data_types/serde/data_type_bitmap_serde.cpp | 17 +-
.../vec/data_types/serde/data_type_bitmap_serde.h | 16 +-
.../serde/data_type_date_or_datetime_serde.cpp | 6 +-
.../serde/data_type_date_or_datetime_serde.h | 6 +-
.../serde/data_type_datetimev2_serde.cpp | 7 +-
.../data_types/serde/data_type_datetimev2_serde.h | 6 +-
.../data_types/serde/data_type_datev2_serde.cpp | 6 +-
.../vec/data_types/serde/data_type_datev2_serde.h | 6 +-
.../data_types/serde/data_type_decimal_serde.cpp | 18 +-
.../vec/data_types/serde/data_type_decimal_serde.h | 15 +-
.../vec/data_types/serde/data_type_hll_serde.cpp | 16 +-
be/src/vec/data_types/serde/data_type_hll_serde.h | 16 +-
.../vec/data_types/serde/data_type_ipv4_serde.cpp | 3 +-
be/src/vec/data_types/serde/data_type_ipv4_serde.h | 3 +-
.../vec/data_types/serde/data_type_ipv6_serde.cpp | 9 +-
be/src/vec/data_types/serde/data_type_ipv6_serde.h | 9 +-
.../vec/data_types/serde/data_type_jsonb_serde.cpp | 13 +-
.../vec/data_types/serde/data_type_jsonb_serde.h | 13 +-
.../vec/data_types/serde/data_type_map_serde.cpp | 35 +-
be/src/vec/data_types/serde/data_type_map_serde.h | 20 +-
.../vec/data_types/serde/data_type_nothing_serde.h | 10 +-
.../data_types/serde/data_type_nullable_serde.cpp | 39 +-
.../data_types/serde/data_type_nullable_serde.h | 24 +-
.../data_types/serde/data_type_number_serde.cpp | 69 +-
.../vec/data_types/serde/data_type_number_serde.h | 30 +-
.../serde/data_type_quantilestate_serde.cpp | 7 +-
.../serde/data_type_quantilestate_serde.h | 17 +-
be/src/vec/data_types/serde/data_type_serde.cpp | 24 +-
be/src/vec/data_types/serde/data_type_serde.h | 37 +-
.../data_types/serde/data_type_string_serde.cpp | 20 +-
.../vec/data_types/serde/data_type_string_serde.h | 16 +-
.../data_types/serde/data_type_struct_serde.cpp | 30 +-
.../vec/data_types/serde/data_type_struct_serde.h | 20 +-
.../vec/data_types/serde/data_type_time_serde.cpp | 3 +-
be/src/vec/data_types/serde/data_type_time_serde.h | 3 +-
.../serde/data_type_timestamptz_serde.cpp | 177 +
..._ipv4_serde.h => data_type_timestamptz_serde.h} | 65 +-
.../data_types/serde/data_type_varbinary_serde.cpp | 27 +-
.../data_types/serde/data_type_varbinary_serde.h | 12 +-
.../data_types/serde/data_type_variant_serde.cpp | 28 +-
.../vec/data_types/serde/data_type_variant_serde.h | 12 +-
be/src/vec/exec/format/generic_reader.cpp | 125 +-
be/src/vec/exec/format/generic_reader.h | 3 +-
be/src/vec/exec/format/native/native_format.h | 57 +
be/src/vec/exec/format/native/native_reader.cpp | 369 +
be/src/vec/exec/format/native/native_reader.h | 107 +
be/src/vec/exec/format/parquet/level_decoder.cpp | 1 +
be/src/vec/exec/format/parquet/parquet_common.cpp | 101 +
be/src/vec/exec/format/parquet/parquet_common.h | 100 +-
.../parquet/vparquet_column_chunk_reader.cpp | 347 +-
.../format/parquet/vparquet_column_chunk_reader.h | 150 +-
.../exec/format/parquet/vparquet_column_reader.cpp | 507 +-
.../exec/format/parquet/vparquet_column_reader.h | 197 +-
.../exec/format/parquet/vparquet_group_reader.cpp | 14 +-
.../exec/format/parquet/vparquet_group_reader.h | 2 +-
.../exec/format/parquet/vparquet_page_reader.cpp | 74 +-
.../vec/exec/format/parquet/vparquet_page_reader.h | 214 +-
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 206 +-
be/src/vec/exec/format/parquet/vparquet_reader.h | 17 +-
be/src/vec/exec/jni_connector.cpp | 2 +
be/src/vec/exec/scan/file_scanner.cpp | 48 +-
be/src/vec/exec/scan/file_scanner.h | 4 +-
be/src/vec/exec/scan/scanner_context.cpp | 2 +-
be/src/vec/exprs/vbitmap_predicate.cpp | 2 +-
be/src/vec/exprs/vbloom_predicate.cpp | 2 +-
be/src/vec/exprs/vcase_expr.cpp | 2 +-
be/src/vec/exprs/vcase_expr.h | 2 +
be/src/vec/exprs/vcast_expr.cpp | 6 +-
be/src/vec/exprs/vcolumn_ref.h | 4 +-
be/src/vec/exprs/vcondition_expr.cpp | 4 +-
be/src/vec/exprs/vdirect_in_predicate.h | 2 +-
be/src/vec/exprs/vectorized_fn_call.cpp | 2 +-
be/src/vec/exprs/vexpr.cpp | 46 +-
be/src/vec/exprs/vexpr.h | 23 +-
be/src/vec/exprs/vexpr_context.h | 20 +
be/src/vec/exprs/vin_predicate.cpp | 2 +-
be/src/vec/exprs/vlambda_function_call_expr.h | 2 +-
be/src/vec/exprs/vlambda_function_expr.h | 2 +-
be/src/vec/exprs/vliteral.cpp | 19 +-
be/src/vec/exprs/vliteral.h | 4 +-
be/src/vec/exprs/vmatch_predicate.cpp | 38 +-
be/src/vec/exprs/vmatch_predicate.h | 6 +-
be/src/vec/exprs/vruntimefilter_wrapper.cpp | 10 +-
be/src/vec/exprs/vtopn_pred.h | 3 +
.../functions/array/function_array_aggregation.cpp | 4 +-
.../vec/functions/array/function_array_apply.cpp | 3 +
be/src/vec/functions/array/function_array_index.h | 4 +-
be/src/vec/functions/array/function_array_remove.h | 5 +
.../vec/functions/array/function_arrays_overlap.h | 5 +-
be/src/vec/functions/cast/cast_base.cpp | 4 +
be/src/vec/functions/cast/cast_to_date.h | 148 +-
.../vec/functions/cast/cast_to_datetimev2_impl.hpp | 179 +-
be/src/vec/functions/cast/cast_to_jsonb.h | 2 +-
be/src/vec/functions/cast/cast_to_string.h | 29 +-
be/src/vec/functions/cast/cast_to_timestamptz.h | 268 +
be/src/vec/functions/cast/cast_to_variant.h | 180 +-
be/src/vec/functions/cast/function_cast.cpp | 3 +
be/src/vec/functions/dictionary.cpp | 4 +-
be/src/vec/functions/dictionary.h | 9 +-
be/src/vec/functions/function.cpp | 5 +-
be/src/vec/functions/function.h | 8 +-
.../function_date_or_datetime_computation.h | 16 +-
be/src/vec/functions/function_hll.cpp | 3 +-
be/src/vec/functions/function_ip.h | 1 +
be/src/vec/functions/function_multi_match.cpp | 4 +-
be/src/vec/functions/function_multi_match.h | 1 +
be/src/vec/functions/function_search.cpp | 39 +-
be/src/vec/functions/function_search.h | 3 +-
be/src/vec/functions/function_tokenize.cpp | 48 +-
be/src/vec/functions/function_tokenize.h | 4 +-
be/src/vec/functions/functions_comparison.h | 7 +-
be/src/vec/functions/in.h | 4 +-
be/src/vec/functions/is_not_null.h | 1 +
be/src/vec/functions/is_null.h | 1 +
be/src/vec/functions/least_greast.cpp | 8 +
be/src/vec/functions/match.cpp | 136 +-
be/src/vec/functions/match.h | 25 +-
be/src/vec/jsonb/serialize.cpp | 5 +-
be/src/vec/olap/olap_data_convertor.cpp | 3 +
be/src/vec/runtime/timestamptz_value.cpp | 132 +
be/src/vec/runtime/timestamptz_value.h | 123 +
be/src/vec/runtime/vcsv_transformer.cpp | 1 +
be/src/vec/runtime/vdata_stream_recvr.cpp | 2 +-
be/src/vec/runtime/vnative_transformer.cpp | 133 +
be/src/vec/runtime/vnative_transformer.h | 65 +
be/src/vec/runtime/vorc_transformer.cpp | 7 +-
be/src/vec/sink/tablet_sink_hash_partitioner.cpp | 3 +-
be/src/vec/sink/vdata_stream_sender.cpp | 1 -
be/src/vec/sink/vdata_stream_sender.h | 14 +-
be/src/vec/sink/vmysql_result_writer.cpp | 22 +-
be/src/vec/sink/vrow_distribution.cpp | 7 +-
be/src/vec/sink/writer/vfile_result_writer.cpp | 9 +
be/src/vec/sink/writer/vmysql_table_writer.cpp | 274 -
be/src/vec/sink/writer/vmysql_table_writer.h | 67 -
be/src/vec/sink/writer/vtablet_writer.cpp | 4 +-
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 2 +-
be/src/vec/utils/histogram_helpers.hpp | 9 +-
be/test/data/vec/columns/TIMESTAMPTZ(0).csv | 6 +
be/test/data/vec/columns/TIMESTAMPTZ(6).csv | 16 +
.../data/vec/native/all_types_single_row.native | Bin 0 -> 1120 bytes
be/test/io/cache/block_file_cache_test.cpp | 624 +-
be/test/io/cache/block_file_cache_test_common.h | 2 +
.../io/cache/block_file_cache_test_lru_dump.cpp | 25 +-
.../io/cache/block_file_cache_test_meta_store.cpp | 94 +-
be/test/io/cache/block_file_cache_ttl_mgr_test.cpp | 348 +
be/test/io/cache/need_update_lru_blocks_test.cpp | 112 +
be/test/io/fs/packed_file_manager_test.cpp | 18 +-
be/test/io/packed_file_trailer_test.cpp | 116 +
be/test/io/s3_client_factory_test.cpp | 8 +-
be/test/olap/block_column_predicate_test.cpp | 174 +
be/test/olap/delete_handler_test.cpp | 221 +-
be/test/olap/inverted_index_parser_test.cpp | 34 +-
.../rowset/segment_v2/binary_dict_page_test.cpp | 106 +-
.../rowset/segment_v2/block_bloom_filter_test.cpp | 64 +
.../bloom_filter_index_reader_writer_test.cpp | 72 +-
.../olap/rowset/segment_v2/encoding_info_test.cpp | 117 +-
.../rowset/segment_v2/index_reader_helper_test.cpp | 3 +-
.../inverted_index/ananlyzer/analyzer_test.cpp | 126 +-
.../boolean_query/boolean_query_builder_test.cpp | 387 +
.../inverted_index/query_v2/boolean_query_test.cpp | 31 +-
.../query_v2/buffered_union_test.cpp | 684 ++
.../query_v2/disjunction_scorer_test.cpp | 389 +
.../query_v2/exclude_scorer_test.cpp | 569 ++
.../inverted_index/query_v2/intersection_test.cpp | 94 +-
.../query_v2/occur_boolean_query_test.cpp | 707 ++
.../inverted_index/query_v2/reqopt_scorer_test.cpp | 540 +
.../query_v2/segment_postings_test.cpp | 226 +-
.../segment_v2/inverted_index/util/reader_test.cpp | 20 +-
.../segment_v2/inverted_index_file_writer_test.cpp | 6 +
.../segment_v2/inverted_index_reader_test.cpp | 74 +-
.../variant_column_writer_reader_test.cpp | 19 +-
.../olap/rowset/segment_v2/zone_map_index_test.cpp | 181 +
be/test/olap/segcompaction_mow_test.cpp | 20 -
.../olap/vector_search/ann_range_search_test.cpp | 12 +-
.../ann_topn_runtime_negative_test.cpp | 2 +-
be/test/olap/vector_search/vector_search_utils.h | 2 +-
be/test/olap/wal/wal_manager_test.cpp | 1 -
.../pipeline/operator/hash_join_test_helper.cpp | 8 +-
.../partitioned_aggregation_test_helper.cpp | 5 +-
.../partitioned_hash_join_probe_operator_test.cpp | 12 +-
.../partitioned_hash_join_sink_operator_test.cpp | 7 +-
.../operator/partitioned_hash_join_test_helper.cpp | 8 +-
.../operator/scan_normalize_predicate_test.cpp | 553 +-
.../pipeline/operator/spill_sort_test_helper.cpp | 5 +-
be/test/pipeline/thrift_builder.h | 1 -
be/test/runtime/timestamptz_value_test.cpp | 198 +
be/test/scan/scanner_context_test.cpp | 2 -
.../testutil/datetime_ut_util.h} | 13 +-
be/test/testutil/test_util.cpp | 10 +-
be/test/testutil/test_util.h | 6 +-
be/test/util/profile_spec_test.cpp | 8 +-
.../aggregate_functions/agg_min_max_by_test.cpp | 6 +-
.../vec/columns/check_and_get_column_ptr_test.cpp | 30 +
be/test/vec/columns/column_varbinary_test.cpp | 4 +-
be/test/vec/columns/column_variant_test.cpp | 11 +-
be/test/vec/common/string_view_test.cpp | 9 +-
be/test/vec/core/field_test.cpp | 8 +
.../vec/data_types/common_data_type_serder_test.h | 6 +-
be/test/vec/data_types/data_type_struct_test.cpp | 11 +-
.../vec/data_types/data_type_timestamptz_test.cpp | 184 +
.../vec/data_types/data_type_varbinary_test.cpp | 18 +-
.../serde/data_type_jsonb_serde_test.cpp | 15 +-
.../serde/data_type_serde_agg_state_test.cpp | 10 +-
.../serde/data_type_serde_bitmap_test.cpp | 5 +-
.../serde/data_type_serde_datetime_v1_test.cpp | 5 +-
.../serde/data_type_serde_datetime_v2_test.cpp | 5 +-
.../serde/data_type_serde_decimal_test.cpp | 5 +-
.../data_type_serde_fixed_length_object_test.cpp | 6 +-
.../data_types/serde/data_type_serde_hll_test.cpp | 5 +-
.../serde/data_type_serde_mysql_test.cpp | 2 +-
.../serde/data_type_serde_number_test.cpp | 5 +-
.../serde/data_type_serde_quantile_state_test.cpp | 6 +-
.../serde/data_type_serde_string_test.cpp | 5 +-
.../vec/data_types/serde/data_type_serde_test.cpp | 7 +-
...st.cpp => data_type_serde_timestamptz_test.cpp} | 54 +-
.../serde/data_type_serde_varbinary_test.cpp | 29 +-
.../format/native/native_reader_writer_test.cpp | 1359 +++
.../vec/exec/format/parquet/parquet_expr_test.cpp | 3 +-
.../exec/format/parquet/parquet_reader_test.cpp | 24 +-
.../exec/format/parquet/parquet_thrift_test.cpp | 25 +-
be/test/vec/exec/orc/orc_read_lines.cpp | 2 +-
be/test/vec/exec/orc_reader_test.cpp | 2 +-
be/test/vec/exec/scan_operator_test.cpp | 2 -
be/test/vec/exec/vfile_scanner_exception_test.cpp | 1 -
be/test/vec/exprs/vexpr_test.cpp | 57 +-
be/test/vec/function/cast/cast_to_string.cpp | 3 +-
.../vec/function/cast/cast_to_timestamptz_test.cpp | 362 +
be/test/vec/function/function_is_null_test.cpp | 16 +-
be/test/vec/function/function_match_test.cpp | 19 +-
be/test/vec/function/function_multi_match_test.cpp | 2 +-
be/test/vec/function/function_search_test.cpp | 4 +-
.../vec/function/function_variant_element_test.cpp | 5 +-
be/test/vec/jsonb/jsonb_document_test.cpp | 15 +
bin/start_be.sh | 126 +-
bin/start_fe.sh | 124 +
cloud/src/common/bvars.cpp | 4 +
cloud/src/common/bvars.h | 4 +
cloud/src/common/config.h | 23 +
cloud/src/meta-service/http_encode_key.cpp | 288 +-
cloud/src/meta-service/meta_service.cpp | 216 +-
cloud/src/meta-service/meta_service.h | 4 +
cloud/src/meta-service/meta_service_job.cpp | 5 +-
cloud/src/meta-service/meta_service_txn.cpp | 28 +
cloud/src/meta-service/txn_lazy_committer.cpp | 398 +-
cloud/src/meta-service/txn_lazy_committer.h | 10 +-
cloud/src/meta-store/clone_chain_reader.cpp | 27 +-
cloud/src/meta-store/keys.cpp | 37 +
cloud/src/meta-store/keys.h | 12 +
cloud/src/recycler/checker.cpp | 87 +-
cloud/src/recycler/checker.h | 4 +
cloud/src/recycler/recycler.cpp | 666 +-
cloud/src/recycler/recycler.h | 4 +
cloud/src/recycler/recycler_operation_log.cpp | 67 +-
cloud/test/http_encode_key_test.cpp | 438 +
cloud/test/recycle_versioned_keys_test.cpp | 60 +-
cloud/test/recycler_test.cpp | 87 +
cloud/test/txn_lazy_commit_test.cpp | 10 +-
common/cpp/aws_common.cpp | 29 +
common/cpp/aws_common.h | 13 +-
.../cpp/custom_aws_credentials_provider_chain.cpp | 3 +
conf/be.conf | 2 +-
conf/fe.conf | 2 +-
contrib/clucene | 2 +-
.../be/resource/be_disaggregated_entrypoint.sh | 14 +-
.../be/resource/be_disaggregated_prestop.sh | 23 +-
.../runtime/be/resource/be_disaggregated_probe.sh | 22 +-
docker/runtime/be/resource/be_entrypoint.sh | 14 +-
docker/runtime/be/resource/be_prestop.sh | 19 +-
.../fe/resource/fe_disaggregated_entrypoint.sh | 30 +-
.../fe/resource/fe_disaggregated_prestop.sh | 20 +-
.../runtime/fe/resource/fe_disaggregated_probe.sh | 21 +-
docker/runtime/fe/resource/fe_entrypoint.sh | 13 +-
docker/runtime/fe/resource/fe_prestop.sh | 20 +-
.../ms/resource/ms_disaggregated_prestop.sh | 2 +-
.../runtime/ms/resource/ms_disaggregated_probe.sh | 16 +-
.../scripts/create_preinstalled_scripts/run80.hql | 21 +
.../data_part_1.parquet | Bin 0 -> 4547 bytes
.../data_part_2.parquet | Bin 0 -> 4542 bytes
.../data_part_3.parquet | Bin 0 -> 4342 bytes
.../data_part_4.parquet | Bin 0 -> 4354 bytes
.../data_part_1.parquet | Bin 0 -> 5732 bytes
.../data_part_2.parquet | Bin 0 -> 5715 bytes
.../data_part_3.parquet | Bin 0 -> 7565 bytes
.../data_part_4.parquet | Bin 0 -> 5531 bytes
docs/ar-SA/README.md | 310 +
docs/bn-BD/README.md | 310 +
docs/de-DE/README.md | 310 +
docs/es-ES/README.md | 310 +
docs/fa-IR/README.md | 310 +
docs/fr-FR/README.md | 314 +
docs/hi-IN/README.md | 310 +
docs/id-ID/README.md | 310 +
docs/it-IT/README.md | 310 +
docs/ja-JP/README.md | 314 +
docs/ko-KR/README.md | 313 +
docs/pl-PL/README.md | 310 +
docs/pt-BR/README.md | 310 +
docs/ro-RO/README.md | 310 +
docs/ru-RU/README.md | 310 +
docs/sl-SI/README.md | 310 +
docs/th-TH/README.md | 310 +
docs/tr-TR/README.md | 310 +
docs/uk-UA/README.md | 310 +
docs/vi-VN/README.md | 310 +
docs/zh-CN/README.md | 309 +
docs/zh-TW/README.md | 309 +
fe/be-java-extensions/avro-scanner/pom.xml | 21 +-
fe/be-java-extensions/hadoop-deps/pom.xml | 4 +
fe/be-java-extensions/hadoop-hudi-scanner/pom.xml | 35 +-
.../iceberg-metadata-scanner/pom.xml | 1 +
.../doris/iceberg/IcebergSysTableColumnValue.java | 7 +
fe/be-java-extensions/java-common/pom.xml | 84 +
.../apache/doris/common/jni/utils/UdfUtils.java | 19 +-
fe/be-java-extensions/java-udf/pom.xml | 13 +-
fe/be-java-extensions/jdbc-scanner/pom.xml | 3 +-
fe/be-java-extensions/max-compute-scanner/pom.xml | 17 +-
fe/be-java-extensions/paimon-scanner/pom.xml | 25 +-
fe/be-java-extensions/preload-extensions/pom.xml | 96 +-
.../main/java/org/apache/doris/preload/README.md | 217 -
.../hadoop/hive/metastore/HiveMetaStoreClient.java | 3630 -------
.../hadoop/hive/metastore/HiveVersionUtil.java | 84 -
.../src/main/resources/package-proj.xml | 37 -
.../trino-connector-scanner/pom.xml | 8 +-
fe/fe-common/pom.xml | 21 -
.../org/apache/doris/catalog/PrimitiveType.java | 21 +-
.../java/org/apache/doris/catalog/ScalarType.java | 54 +-
.../main/java/org/apache/doris/catalog/Type.java | 29 +-
.../main/java/org/apache/doris/common/Config.java | 31 +
.../DataLakeAWSCredentialsProvider.java | 59 -
fe/fe-core/pom.xml | 19 +-
.../antlr4/org/apache/doris/nereids/DorisLexer.g4 | 4 +-
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 7 +-
.../ConfigurationAWSCredentialsProvider.java | 13 +-
.../amazonaws/glue/catalog/util/AWSGlueConfig.java | 1 +
.../org/apache/doris/alter/SchemaChangeJobV2.java | 8 +-
.../org/apache/doris/analysis/AggregateInfo.java | 76 +-
.../apache/doris/analysis/AggregateInfoBase.java | 117 -
.../org/apache/doris/analysis/ArithmeticExpr.java | 17 +-
.../org/apache/doris/analysis/ArrayLiteral.java | 2 +-
.../apache/doris/analysis/BetweenPredicate.java | 8 -
.../org/apache/doris/analysis/BinaryPredicate.java | 21 +-
.../org/apache/doris/analysis/BoolLiteral.java | 3 +
.../java/org/apache/doris/analysis/CaseExpr.java | 34 +-
.../java/org/apache/doris/analysis/CastExpr.java | 14 +-
.../org/apache/doris/analysis/ClusterName.java | 64 -
.../java/org/apache/doris/analysis/ColumnDef.java | 2 +
.../org/apache/doris/analysis/ColumnRefExpr.java | 14 +-
.../apache/doris/analysis/CompoundPredicate.java | 19 +-
.../org/apache/doris/analysis/DateLiteral.java | 146 +-
.../org/apache/doris/analysis/DecimalLiteral.java | 27 +-
.../org/apache/doris/analysis/EncryptKeyRef.java | 1 +
.../main/java/org/apache/doris/analysis/Expr.java | 94 +-
.../apache/doris/analysis/ExprSubstitutionMap.java | 2 -
.../org/apache/doris/analysis/FloatLiteral.java | 4 +-
.../apache/doris/analysis/FunctionCallExpr.java | 58 +-
.../org/apache/doris/analysis/GroupByClause.java | 224 -
.../org/apache/doris/analysis/IPv4Literal.java | 4 +-
.../org/apache/doris/analysis/IPv6Literal.java | 2 +-
.../apache/doris/analysis/ImportColumnsStmt.java | 2 +-
.../apache/doris/analysis/ImportDeleteOnStmt.java | 2 +-
.../apache/doris/analysis/ImportSequenceStmt.java | 2 +-
.../org/apache/doris/analysis/ImportWhereStmt.java | 2 +-
.../org/apache/doris/analysis/InPredicate.java | 24 +-
.../java/org/apache/doris/analysis/IntLiteral.java | 7 +-
.../org/apache/doris/analysis/IsNullPredicate.java | 19 +-
.../org/apache/doris/analysis/JsonLiteral.java | 3 +-
.../doris/analysis/LambdaFunctionCallExpr.java | 4 +-
.../apache/doris/analysis/LambdaFunctionExpr.java | 13 +-
.../org/apache/doris/analysis/LargeIntLiteral.java | 32 +-
.../org/apache/doris/analysis/LikePredicate.java | 1 +
.../org/apache/doris/analysis/LiteralExpr.java | 8 +-
.../doris/analysis/MVColumnBitmapUnionPattern.java | 69 -
.../doris/analysis/MVColumnHLLUnionPattern.java | 67 -
.../doris/analysis/MVColumnOneChildPattern.java | 51 -
.../java/org/apache/doris/analysis/MapLiteral.java | 2 +
.../org/apache/doris/analysis/MatchPredicate.java | 3 +-
.../java/org/apache/doris/analysis/MaxLiteral.java | 1 +
.../apache/doris/analysis/NotFallbackInParser.java | 24 -
.../org/apache/doris/analysis/NullLiteral.java | 2 +-
.../apache/doris/analysis/NumericLiteralExpr.java | 1 +
.../org/apache/doris/analysis/OutFileClause.java | 2 +
.../apache/doris/analysis/PartitionExprUtil.java | 3 +-
.../org/apache/doris/analysis/PlaceHolderExpr.java | 17 +-
.../org/apache/doris/analysis/ResourceDesc.java | 2 -
.../org/apache/doris/analysis/SearchPredicate.java | 5 +-
.../java/org/apache/doris/analysis/SlotRef.java | 12 +-
.../org/apache/doris/analysis/StringLiteral.java | 8 +-
.../org/apache/doris/analysis/StructLiteral.java | 15 +-
.../org/apache/doris/analysis/TimeV2Literal.java | 2 +-
.../doris/analysis/TimestampArithmeticExpr.java | 16 +-
.../java/org/apache/doris/analysis/ToSqlUtils.java | 56 -
.../org/apache/doris/analysis/TryCastExpr.java | 38 +-
.../apache/doris/analysis/VarBinaryLiteral.java | 2 +-
.../org/apache/doris/analysis/VariableExpr.java | 1 +
.../org/apache/doris/analysis/VirtualSlotRef.java | 10 +-
.../apache/doris/catalog/AggregateFunction.java | 28 -
.../org/apache/doris/catalog/AggregateType.java | 2 +
.../org/apache/doris/catalog/AliasFunction.java | 13 -
.../catalog/BuiltinTableGeneratingFunctions.java | 3 +-
.../main/java/org/apache/doris/catalog/Column.java | 3 +-
.../java/org/apache/doris/catalog/Function.java | 155 +-
.../apache/doris/catalog/ListPartitionInfo.java | 2 +-
.../org/apache/doris/catalog/PartitionKey.java | 35 +-
.../apache/doris/catalog/RangePartitionInfo.java | 2 +-
.../org/apache/doris/catalog/RefreshManager.java | 13 +-
.../org/apache/doris/catalog/ScalarFunction.java | 13 -
.../java/org/apache/doris/catalog/TableIf.java | 58 +-
.../catalog/constraint/ForeignKeyConstraint.java | 11 +
.../catalog/constraint/PrimaryKeyConstraint.java | 4 +
.../doris/catalog/constraint/TableIdentifier.java | 2 +-
.../org/apache/doris/cloud/CloudWarmUpJob.java | 75 +-
.../cloud/catalog/CloudInstanceStatusChecker.java | 4 +
.../apache/doris/cloud/catalog/CloudPartition.java | 21 +-
.../cloud/datasource/CloudInternalCatalog.java | 3 +
.../transaction/CloudGlobalTransactionMgr.java | 32 +-
.../doris/common/proc/BuildIndexProcDir.java | 1 +
.../doris/common/proc/PartitionsProcDir.java | 1 +
.../apache/doris/common/proc/RollupProcDir.java | 1 +
.../doris/common/proc/SchemaChangeProcDir.java | 1 +
.../doris/common/profile/SummaryProfile.java | 3 +
.../doris/common/util/DynamicPartitionUtil.java | 3 +-
.../doris/common/util/FileFormatConstants.java | 1 +
.../java/org/apache/doris/common/util/Util.java | 4 +
.../org/apache/doris/datasource/CatalogMgr.java | 19 +-
.../apache/doris/datasource/CatalogProperty.java | 30 +-
.../apache/doris/datasource/ExternalCatalog.java | 1 +
.../doris/datasource/ExternalMetaCacheMgr.java | 69 +-
.../apache/doris/datasource/InternalCatalog.java | 1 +
.../doris/datasource/hive/HMSExternalTable.java | 5 +-
.../datasource/iceberg/DorisTypeToIcebergType.java | 2 +
.../datasource/iceberg/IcebergExternalCatalog.java | 37 +-
.../datasource/iceberg/IcebergMetadataCache.java | 43 +-
.../iceberg/IcebergMetadataCacheMgr.java | 51 -
.../doris/datasource/iceberg/IcebergUtils.java | 12 +-
.../iceberg/profile/IcebergMetricsReporter.java | 167 +
.../iceberg/source/IcebergApiSource.java | 7 +-
.../iceberg/source/IcebergHMSSource.java | 5 +-
.../datasource/iceberg/source/IcebergScanNode.java | 25 +-
.../datasource/paimon/PaimonExternalCatalog.java | 2 +-
.../common/AwsCredentialsProviderFactory.java | 158 +
.../common/AwsCredentialsProviderMode.java | 74 +
.../property/fileformat/FileFormatProperties.java | 3 +
.../fileformat/NativeFileFormatProperties.java | 65 +
.../metastore/AWSGlueMetaStoreBaseProperties.java | 18 +-
.../metastore/HiveGlueMetaStoreProperties.java | 11 +
.../metastore/IcebergGlueMetaStoreProperties.java | 1 +
.../storage/AbstractS3CompatibleProperties.java | 2 +
.../datasource/property/storage/S3Properties.java | 81 +-
.../property/storage/StorageProperties.java | 23 +-
.../doris/httpv2/rest/TableQueryPlanAction.java | 119 +-
.../apache/doris/indexpolicy/IndexPolicyMgr.java | 4 +
.../doris/load/routineload/RoutineLoadManager.java | 3 +
.../doris/mtmv/MTMVPartitionExprDateTrunc.java | 3 +-
.../org/apache/doris/mysql/MysqlSerializer.java | 4 +-
.../doris/mysql/authenticate/ldap/LdapClient.java | 16 +-
.../mysql/authenticate/ldap/LdapUserInfo.java | 3 +-
.../org/apache/doris/mysql/privilege/Auth.java | 16 +-
.../apache/doris/mysql/privilege/PrivTable.java | 35 +-
.../org/apache/doris/nereids/NereidsPlanner.java | 8 +-
.../glue/translator/ExpressionTranslator.java | 269 +-
.../glue/translator/PhysicalPlanTranslator.java | 332 +-
.../glue/translator/PlanTranslatorContext.java | 24 +-
.../glue/translator/RunTimeFilterTranslatorV2.java | 5 +-
.../glue/translator/RuntimeFilterTranslator.java | 5 +-
.../nereids/load/NereidsLoadPlanInfoCollector.java | 11 -
.../nereids/load/NereidsLoadScanProvider.java | 9 +-
.../doris/nereids/parser/LogicalPlanBuilder.java | 33 +-
.../properties/ChildrenPropertiesRegulator.java | 39 +
.../nereids/rules/analysis/CheckAfterRewrite.java | 8 +-
.../nereids/rules/analysis/ExpressionAnalyzer.java | 32 +-
.../nereids/rules/analysis/NormalizeRepeat.java | 48 +-
.../mv/AbstractMaterializedViewAggregateRule.java | 6 +-
.../mv/InitMaterializationContextHook.java | 6 +-
.../mv/MaterializedViewFilterAggregateRule.java | 7 +-
...MaterializedViewFilterProjectAggregateRule.java | 5 +-
...MaterializedViewProjectFilterAggregateRule.java | 14 +-
.../nereids/rules/expression/check/CheckCast.java | 24 +-
.../expression/rules/FoldConstantRuleOnFE.java | 12 -
.../rules/rewrite/EliminateEmptyRelation.java | 94 +-
.../doris/nereids/rules/rewrite/SkewJoin.java | 9 +-
.../doris/nereids/stats/ExpressionEstimation.java | 15 -
.../doris/nereids/trees/expressions/Cast.java | 24 +-
.../trees/expressions/ExpressionEvaluator.java | 3 -
.../trees/expressions/TimestampArithmetic.java | 174 -
.../doris/nereids/trees/expressions/TryCast.java | 2 +-
.../functions/agg/AggregateFunction.java | 2 +-
.../trees/expressions/functions/agg/MaxBy.java | 7 +-
.../trees/expressions/functions/agg/MinBy.java | 7 +-
.../functions/generator/PosExplode.java | 56 +-
.../functions/generator/PosExplodeOuter.java | 55 +-
.../functions/scalar/InnerProductApproximate.java | 5 +
.../functions/scalar/L2DistanceApproximate.java | 5 +
.../trees/expressions/literal/DateTimeLiteral.java | 68 +-
.../expressions/literal/DateTimeV2Literal.java | 53 +-
.../nereids/trees/expressions/literal/Literal.java | 10 +
.../trees/expressions/literal/NumericLiteral.java | 4 +
.../expressions/literal/StringLikeLiteral.java | 11 +-
...eTimeV2Literal.java => TimestampTzLiteral.java} | 242 +-
.../literal/format/DateTimeChecker.java | 1 +
.../visitor/ExpressionColumnFilterConverter.java | 3 +-
.../expressions/visitor/ExpressionVisitor.java | 10 +-
.../plans/commands/CreateFunctionCommand.java | 8 +-
.../plans/commands/DropConstraintCommand.java | 22 +-
.../trees/plans/commands/info/CopyIntoInfo.java | 2 +-
.../commands/info/MTMVPartitionDefinition.java | 4 +-
.../plans/commands/info/PartitionTableInfo.java | 3 +-
.../plans/commands/refresh/RefreshLdapCommand.java | 10 +-
.../worker/job/UnassignedJobBuilder.java | 6 +-
.../worker/job/UnassignedLocalShuffleUnionJob.java | 99 -
.../org/apache/doris/nereids/types/DataType.java | 29 +-
.../doris/nereids/types/TimeStampTzType.java | 110 +
.../apache/doris/nereids/types/VarBinaryType.java | 4 +
.../doris/nereids/util/TypeCoercionUtils.java | 74 +-
.../org/apache/doris/planner/AnalyticEvalNode.java | 24 +-
.../apache/doris/planner/AssertNumRowsNode.java | 8 +-
.../org/apache/doris/planner/DataPartition.java | 3 +-
.../org/apache/doris/planner/ExchangeNode.java | 15 +-
.../org/apache/doris/planner/HashJoinNode.java | 13 -
.../apache/doris/planner/NestedLoopJoinNode.java | 12 -
.../org/apache/doris/planner/OlapTableSink.java | 3 +
.../apache/doris/planner/PartitionSortNode.java | 1 -
.../java/org/apache/doris/planner/PlanNode.java | 32 +-
.../java/org/apache/doris/planner/SelectNode.java | 1 -
.../java/org/apache/doris/planner/SortNode.java | 1 -
.../java/org/apache/doris/planner/UnionNode.java | 10 -
.../java/org/apache/doris/qe/AuditLogHelper.java | 6 +-
.../java/org/apache/doris/qe/ConnectContext.java | 5 +-
.../java/org/apache/doris/qe/QueryDetailQueue.java | 69 -
.../java/org/apache/doris/qe/SessionVariable.java | 34 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 4 +-
.../main/java/org/apache/doris/qe/VariableMgr.java | 31 +
.../org/apache/doris/qe/cache/PartitionRange.java | 1 +
.../service/arrowflight/FlightSqlSchemaHelper.java | 8 +
.../doris/statistics/util/StatisticsUtil.java | 5 +
.../ExternalFileTableValuedFunction.java | 14 +-
.../doris/tablefunction/MetadataGenerator.java | 2 +-
.../org/apache/doris/analysis/DateLiteralTest.java | 98 +
.../apache/doris/analysis/SearchPredicateTest.java | 25 +-
.../java/org/apache/doris/catalog/ColumnTest.java | 3 +-
.../doris/catalog/RangePartitionInfoTest.java | 2 +-
.../doris/common/proc/IndexSchemaProcNodeTest.java | 2 +-
.../doris/datasource/RefreshCatalogTest.java | 13 +-
.../property/storage/AzurePropertiesTest.java | 4 +-
.../property/storage/COSPropertiesTest.java | 7 +-
.../property/storage/OBSPropertyTest.java | 8 +-
.../property/storage/OSSPropertiesTest.java | 7 +-
.../property/storage/S3PropertiesTest.java | 38 +-
.../TrinoConnectorPredicateTest.java | 4 +-
.../external/elasticsearch/QueryBuildersTest.java | 12 +-
.../MTMVRelatedPartitionDescGeneratorTest.java | 2 +-
...TMVRelatedPartitionDescRollUpGeneratorTest.java | 4 +-
.../mysql/authenticate/ldap/LdapUserInfoTest.java} | 19 +-
.../org/apache/doris/mysql/privilege/AuthTest.java | 25 +-
.../nereids/distribute/LocalShuffleUnionTest.java | 141 -
.../glue/translator/ExpressionTranslatorTest.java | 7 +-
.../ChildrenPropertiesRegulatorTest.java | 167 +
.../nereids/rules/expression/FoldConstantTest.java | 82 -
.../nereids/trees/expressions/TryCastTest.java | 80 +-
.../functions/generator/PosExplodeOuterTest.java | 73 +
.../functions/generator/PosExplodeTest.java | 73 +
.../expressions/literal/LargeIntLiteralTest.java | 5 +-
.../org/apache/doris/nereids/util/PlanChecker.java | 13 +-
.../org/apache/doris/qe/OlapQueryCacheTest.java | 23 -
.../org/apache/doris/qe/QueryDetailQueueTest.java | 67 -
fe/pom.xml | 14 +-
gensrc/proto/cloud.proto | 9 +
gensrc/proto/olap_file.proto | 11 +
gensrc/proto/types.proto | 1 +
gensrc/thrift/Normalization.thrift | 3 +-
gensrc/thrift/Partitions.thrift | 3 -
gensrc/thrift/PlanNodes.thrift | 15 +-
gensrc/thrift/Types.thrift | 3 +-
regression-test/conf/regression-conf.groovy | 7 +
.../data/cloud_p0/cache/ttl/test_show_ttl.out | 4 +-
.../complex_types/test_pruned_columns.out | 55 +-
.../timestamptz/array/test_tz_array_functions.out | 37 +
.../index/test_timestamptz_bloom_filter.csv | 10003 +++++++++++++++++++
.../index/test_timestamptz_bloom_filter.out | 7 +
.../index/test_timestamptz_inverted_index.out | 64 +
.../stream_load/test_timestamptz_stream_load.csv | 10 +
.../stream_load/test_timestamptz_stream_load.out | 47 +
.../timestamptz/test_cast_timestamptz.out | 59 +
.../timestamptz/test_timestamptz_binary_output.out | 65 +
.../timestamptz/test_timestamptz_cast.out | 23 +
.../timestamptz/test_timestamptz_cmp.out | 12 +
.../timestamptz/test_timestamptz_complext_type.out | 19 +
.../test_timestamptz_count_distinct.out} | 14 +-
.../timestamptz/test_timestamptz_delete.out | 12 +
.../test_timestamptz_delete_agg_key.out | 543 +
.../test_timestamptz_delete_dup_key.out | 510 +
.../test_timestamptz_delete_uniq_key.out | 543 +
.../timestamptz/test_timestamptz_group_by.out} | 13 +-
.../timestamptz/test_timestamptz_join.out | 5 +
.../timestamptz/test_timestamptz_mv.out | 23 +
.../timestamptz/test_timestamptz_rf.out | 17 +
.../timestamptz/test_timestamptz_sort.out | 18 +
.../test_timestamptz_storage_agg_key.out | 501 +
.../test_timestamptz_storage_dup_key.out | 703 ++
.../test_timestamptz_storage_uniq_key.out | 475 +
.../data/empty_relation/eliminate_empty.out | 17 +-
.../outfile/native/test_outfile_native.out | 25 +
.../export/test_hive_export_varbinary.out | 29 +
.../data/external_table_p0/hive/test_hive_orc.out | 96 +
.../hive/test_hive_topn_lazy_mat.out | 1427 +++
.../iceberg/test_iceberg_optimize_count.out | 6 +
.../iceberg/test_iceberg_sys_table.out | 35 +
.../test_mow_seq_seg_compaction.out | 23 -
.../test_index_lowercase_fault_injection.out | 2 +-
.../data/inverted_index_p0/test_pinyin_phrase.out | 18 +
.../sql_functions/table_function/posexplode.out | 159 +-
.../infer_predicate/pull_up_predicate_set_op.out | 4 +-
.../mv/grouping_sets/grouping_sets.out | 60 +
regression-test/data/query_p0/dual/dual.out | 15 +
.../test_aggregate_all_functions2.out | 67 +-
.../test_load_channel_profile.out} | 13 +-
.../shape_check/tpcds_sf100/rf_prune/query72.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query72.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query72.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query72.out | 2 +-
.../pipeline/cloud_p0/conf/be_custom.conf | 2 -
.../pipeline/cloud_p1/conf/be_custom.conf | 2 -
regression-test/pipeline/external/conf/be.conf | 4 +-
regression-test/pipeline/external/conf/fe.conf | 5 +-
.../pipeline/nonConcurrent/conf/be.conf | 2 +-
.../nonConcurrent/conf/regression-conf.groovy | 1 +
regression-test/pipeline/p0/conf/be.conf | 4 +-
regression-test/pipeline/p0/conf/fe.conf | 2 +-
regression-test/pipeline/p1/conf/be.conf | 4 +-
regression-test/pipeline/p1/conf/fe.conf | 2 +-
.../suites/audit/test_audit_log_behavior.groovy | 2 +-
.../suites/audit/test_sql_digest_generation.groovy | 83 +
.../suites/auth_p0/test_refresh_ldap_auth.groovy | 56 +
.../test_catalog_instance_profile.groovy | 125 +
.../aws_iam_role_p0/test_tvf_anonymous.groovy | 69 +
.../suites/cloud_p0/cache/ttl/alter_ttl_1.groovy | 92 +-
.../suites/cloud_p0/cache/ttl/alter_ttl_2.groovy | 92 +-
.../suites/cloud_p0/cache/ttl/alter_ttl_3.groovy | 92 +-
.../cloud_p0/cache/ttl/alter_ttl_seconds.groovy | 105 +-
.../cache/ttl/create_table_as_select.groovy | 5 +-
.../cloud_p0/cache/ttl/create_table_like.groovy | 5 +-
.../suites/cloud_p0/cache/ttl/test_ttl.groovy | 100 +-
.../cloud_p0/cache/ttl/test_ttl_lru_evict.groovy | 12 +
.../test_packed_file_concurrent_load.groovy | 50 +-
.../packed_file/test_packed_file_mixed_load.groovy | 28 +-
.../test_packed_file_query_with_table_drop.groovy | 10 +-
.../test_packed_file_with_group_commit.groovy | 42 +-
.../suites/cloud_p0/recycler/test_recycler.groovy | 2 +
.../recycler/test_recycler_clone_instance.groovy | 22 +-
.../test_clean_tablet_when_drop_force_table.groovy | 24 +
.../complex_types/test_pruned_columns.groovy | 25 +-
.../array/test_tz_array_functions.groovy | 116 +
.../index/test_timestamptz_bloom_filter.groovy | 69 +
.../index/test_timestamptz_inverted_index.groovy | 107 +
.../test_timestamptz_stream_load.groovy | 241 +
.../timestamptz/test_cast_timestamptz.groovy | 220 +
.../test_timestamptz_binary_output.groovy | 113 +
.../timestamptz/test_timestamptz_cast.groovy | 77 +
.../timestamptz/test_timestamptz_cmp.groovy | 61 +
.../test_timestamptz_complext_type.groovy | 68 +
.../test_timestamptz_count_distinct.groovy | 50 +
.../test_timestamptz_delete_agg_key.groovy | 652 ++
.../test_timestamptz_delete_dup_key.groovy | 647 ++
.../test_timestamptz_delete_uniq_key.groovy | 633 ++
.../timestamptz/test_timestamptz_group_by.groovy | 45 +-
.../timestamptz/test_timestamptz_join.groovy | 61 +
.../timestamptz/test_timestamptz_mv.groovy | 94 +
.../timestamptz/test_timestamptz_rf.groovy | 149 +
.../timestamptz/test_timestamptz_sort.groovy | 53 +
.../test_timestamptz_storage_agg_key.groovy | 1077 ++
.../test_timestamptz_storage_dup_key.groovy | 1470 +++
.../test_timestamptz_storage_negative_case.groovy | 79 +
.../test_timestamptz_storage_uniq_key.groovy | 809 ++
.../outfile/native/test_outfile_native.groovy | 100 +
...test_export_table_with_materialized_view.groovy | 2 +-
.../test_export_variant_10k_columns.groovy | 215 +
.../export/test_hive_export_varbinary.groovy | 120 +
.../external_table_p0/hive/test_hive_orc.groovy | 55 +
.../hive/test_hive_topn_lazy_mat.groovy | 23 +-
.../iceberg/test_iceberg_optimize_count.groovy | 9 +
.../iceberg/test_iceberg_sys_table.groovy | 19 +
.../iceberg/test_iceberg_table_meta_cache.groovy | 168 +
.../test_jdbc_catalog_refresh_update_time.groovy | 104 +
.../hudi/hudi_mtmv/test_hudi_rewrite_mtmv.groovy | 82 +-
.../test_full_compaciton_run_status.groovy | 6 +-
.../test_mow_seq_seg_compaction.groovy | 103 -
.../test_index_policy_drop.groovy | 43 +-
.../inverted_index_p0/test_pinyin_phrase.groovy | 73 +
.../broker_load/test_s3_load_with_set.groovy | 2 +-
.../suites/nereids_function_p0/load.groovy | 6 +
.../translate_tuple_id/join_input_tuple_id.groovy | 6 +-
.../nereids_p0/pkfk/test_pk_fk_drop_table.groovy | 59 +
.../nereids_p0/slot_bind/test_bind_slot.groovy | 39 +-
.../sql_functions/table_function/posexplode.groovy | 49 +
.../variables_persist/test_array_agg_view.groovy | 8 +-
.../nereids_p0/variables_persist/test_mtmv.groovy | 5 +-
.../variables_persist/test_view_var_persist.groovy | 6 +-
.../agg_optimize_when_uniform.groovy | 4 +
.../mv/grouping_sets/grouping_sets.groovy | 168 +-
.../mv/nested/nested_materialized_view.groovy | 1252 ++-
.../nereids_rules_p0/skew_join/skew_join.groovy | 137 +
.../suites/nereids_syntax_p0/cte.groovy | 5 +
.../test_timestamp_arithmetic.groovy | 4 +-
.../test_dynamic_partition_failed.groovy | 3 +-
.../test_partition_table_err_msg.groovy | 6 +-
regression-test/suites/query_p0/dual/dual.groovy | 30 +
.../set/test_mysql_compat_var_whitelist.groovy | 114 +
.../test_aggregate_all_functions2.groovy | 34 +-
.../hll_functions/test_hll_functions.groovy | 5 +
.../query_profile/test_load_channel_profile.groovy | 139 +
.../suites/query_profile/test_profile.groovy | 83 -
.../suites/show_p0/test_show_data_warehouse.groovy | 14 +-
.../test_storage_format_controls_encoding.groovy | 71 +
991 files changed, 56554 insertions(+), 14767 deletions(-)
create mode 100644 be/src/io/cache/block_file_cache_ttl_mgr.cpp
create mode 100644 be/src/io/cache/block_file_cache_ttl_mgr.h
create mode 100644 be/src/io/fs/packed_file_trailer.cpp
copy common/cpp/aws_common.h => be/src/io/fs/packed_file_trailer.h (58%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/all_query/all_query.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/boolean_query_builder.h
rename fe/fe-core/src/main/java/org/apache/doris/analysis/MVColumnPattern.java
=> be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/occur.h
(81%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/occur_boolean_query.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/occur_boolean_weight.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/occur_boolean_weight.h
copy be/src/olap/rowset/segment_v2/inverted_index/query_v2/{ =>
boolean_query}/operator.h (100%)
rename
be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/{boolean_query.h
=> operator_boolean_query.h} (62%)
rename
be/src/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/{boolean_weight.h
=> operator_boolean_weight.h} (95%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/disjunction_scorer.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/disjunction_scorer.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/exclude_scorer.cpp
copy
be/src/olap/rowset/segment_v2/inverted_index/query_v2/{union/simple_union.h =>
exclude_scorer.h} (53%)
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/reqopt_scorer.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/size_hint.h
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/union/buffered_union.cpp
create mode 100644
be/src/olap/rowset/segment_v2/inverted_index/query_v2/union/buffered_union.h
create mode 100644 be/src/runtime/task_execution_context.cpp
create mode 100644 be/src/tools/packed_file_tool.cpp
delete mode 100644 be/src/vec/aggregate_functions/aggregate_function_min_by.cpp
create mode 100644 be/src/vec/data_types/data_type_timestamptz.cpp
create mode 100644 be/src/vec/data_types/data_type_timestamptz.h
create mode 100644 be/src/vec/data_types/serde/data_type_timestamptz_serde.cpp
copy be/src/vec/data_types/serde/{data_type_ipv4_serde.h =>
data_type_timestamptz_serde.h} (61%)
create mode 100644 be/src/vec/exec/format/native/native_format.h
create mode 100644 be/src/vec/exec/format/native/native_reader.cpp
create mode 100644 be/src/vec/exec/format/native/native_reader.h
create mode 100644 be/src/vec/functions/cast/cast_to_timestamptz.h
create mode 100644 be/src/vec/runtime/timestamptz_value.cpp
create mode 100644 be/src/vec/runtime/timestamptz_value.h
create mode 100644 be/src/vec/runtime/vnative_transformer.cpp
create mode 100644 be/src/vec/runtime/vnative_transformer.h
delete mode 100644 be/src/vec/sink/writer/vmysql_table_writer.cpp
delete mode 100644 be/src/vec/sink/writer/vmysql_table_writer.h
create mode 100644 be/test/data/vec/columns/TIMESTAMPTZ(0).csv
create mode 100644 be/test/data/vec/columns/TIMESTAMPTZ(6).csv
create mode 100644 be/test/data/vec/native/all_types_single_row.native
create mode 100644 be/test/io/cache/block_file_cache_ttl_mgr_test.cpp
create mode 100644 be/test/io/cache/need_update_lru_blocks_test.cpp
create mode 100644 be/test/io/packed_file_trailer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/boolean_query/boolean_query_builder_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/buffered_union_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/disjunction_scorer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/exclude_scorer_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/occur_boolean_query_test.cpp
create mode 100644
be/test/olap/rowset/segment_v2/inverted_index/query_v2/reqopt_scorer_test.cpp
create mode 100644 be/test/runtime/timestamptz_value_test.cpp
rename be/{src/olap/rowset/segment_v2/inverted_index/query_v2/operator.h =>
test/testutil/datetime_ut_util.h} (68%)
create mode 100644 be/test/vec/data_types/data_type_timestamptz_test.cpp
copy be/test/vec/data_types/serde/{data_type_serde_datetime_v1_test.cpp =>
data_type_serde_timestamptz_test.cpp} (82%)
create mode 100644 be/test/vec/exec/format/native/native_reader_writer_test.cpp
create mode 100644 be/test/vec/function/cast/cast_to_timestamptz_test.cpp
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table/data_part_1.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table/data_part_2.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table/data_part_3.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table/data_part_4.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table_multi_pages/data_part_1.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table_multi_pages/data_part_2.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table_multi_pages/data_part_3.parquet
create mode 100644
docker/thirdparties/docker-compose/hive/scripts/preinstalled_data/parquet_table/parquet_topn_lazy_complex_table_multi_pages/data_part_4.parquet
create mode 100644 docs/ar-SA/README.md
create mode 100644 docs/bn-BD/README.md
create mode 100644 docs/de-DE/README.md
create mode 100644 docs/es-ES/README.md
create mode 100644 docs/fa-IR/README.md
create mode 100644 docs/fr-FR/README.md
create mode 100644 docs/hi-IN/README.md
create mode 100644 docs/id-ID/README.md
create mode 100644 docs/it-IT/README.md
create mode 100644 docs/ja-JP/README.md
create mode 100644 docs/ko-KR/README.md
create mode 100644 docs/pl-PL/README.md
create mode 100644 docs/pt-BR/README.md
create mode 100644 docs/ro-RO/README.md
create mode 100644 docs/ru-RU/README.md
create mode 100644 docs/sl-SI/README.md
create mode 100644 docs/th-TH/README.md
create mode 100644 docs/tr-TR/README.md
create mode 100644 docs/uk-UA/README.md
create mode 100644 docs/vi-VN/README.md
create mode 100644 docs/zh-CN/README.md
create mode 100644 docs/zh-TW/README.md
delete mode 100644
fe/be-java-extensions/preload-extensions/src/main/java/org/apache/doris/preload/README.md
delete mode 100644
fe/be-java-extensions/preload-extensions/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
delete mode 100644
fe/be-java-extensions/preload-extensions/src/main/java/org/apache/hadoop/hive/metastore/HiveVersionUtil.java
delete mode 100644
fe/be-java-extensions/preload-extensions/src/main/resources/package-proj.xml
delete mode 100644
fe/fe-common/src/main/java/org/apache/doris/common/credentials/DataLakeAWSCredentialsProvider.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AggregateInfoBase.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ClusterName.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/GroupByClause.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/MVColumnBitmapUnionPattern.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/MVColumnHLLUnionPattern.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/MVColumnOneChildPattern.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/NotFallbackInParser.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ToSqlUtils.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergMetadataCacheMgr.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/profile/IcebergMetricsReporter.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/common/AwsCredentialsProviderFactory.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/common/AwsCredentialsProviderMode.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/property/fileformat/NativeFileFormatProperties.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/TimestampArithmetic.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/literal/{DateTimeV2Literal.java
=> TimestampTzLiteral.java} (56%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/UnassignedLocalShuffleUnionJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/types/TimeStampTzType.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/qe/QueryDetailQueue.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/DateLiteralTest.java
rename fe/fe-core/src/{main/java/org/apache/doris/analysis/LoadType.java =>
test/java/org/apache/doris/mysql/authenticate/ldap/LdapUserInfoTest.java} (73%)
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/distribute/LocalShuffleUnionTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/properties/ChildrenPropertiesRegulatorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/generator/PosExplodeOuterTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/generator/PosExplodeTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/qe/QueryDetailQueueTest.java
create mode 100644
regression-test/data/datatype_p0/timestamptz/array/test_tz_array_functions.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/index/test_timestamptz_bloom_filter.csv
create mode 100644
regression-test/data/datatype_p0/timestamptz/index/test_timestamptz_bloom_filter.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/index/test_timestamptz_inverted_index.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/load/stream_load/test_timestamptz_stream_load.csv
create mode 100644
regression-test/data/datatype_p0/timestamptz/load/stream_load/test_timestamptz_stream_load.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_cast_timestamptz.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_binary_output.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_cast.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_cmp.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_complext_type.out
copy
regression-test/data/{inverted_index_p0/test_index_lowercase_fault_injection.out
=> datatype_p0/timestamptz/test_timestamptz_count_distinct.out} (65%)
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_delete.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_delete_agg_key.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_delete_dup_key.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_delete_uniq_key.out
copy
regression-test/data/{inverted_index_p0/test_index_lowercase_fault_injection.out
=> datatype_p0/timestamptz/test_timestamptz_group_by.out} (56%)
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_join.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_mv.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_rf.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_sort.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_storage_agg_key.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_storage_dup_key.out
create mode 100644
regression-test/data/datatype_p0/timestamptz/test_timestamptz_storage_uniq_key.out
create mode 100644
regression-test/data/export_p0/outfile/native/test_outfile_native.out
create mode 100644
regression-test/data/external_table_p0/export/test_hive_export_varbinary.out
delete mode 100644
regression-test/data/fault_injection_p0/test_mow_seq_seg_compaction.out
create mode 100644
regression-test/data/inverted_index_p0/test_pinyin_phrase.out
copy
regression-test/data/{inverted_index_p0/test_index_lowercase_fault_injection.out
=> query_profile/test_load_channel_profile.out} (63%)
create mode 100644
regression-test/suites/audit/test_sql_digest_generation.groovy
create mode 100644 regression-test/suites/auth_p0/test_refresh_ldap_auth.groovy
create mode 100644
regression-test/suites/aws_iam_role_p0/test_catalog_instance_profile.groovy
create mode 100644
regression-test/suites/aws_iam_role_p0/test_tvf_anonymous.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/array/test_tz_array_functions.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/index/test_timestamptz_bloom_filter.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/index/test_timestamptz_inverted_index.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/load/stream_load/test_timestamptz_stream_load.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_cast_timestamptz.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_binary_output.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_cast.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_cmp.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_complext_type.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_count_distinct.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_delete_agg_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_delete_dup_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_delete_uniq_key.groovy
rename
fe/fe-core/src/main/java/org/apache/doris/analysis/ColocateGroupName.java =>
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_group_by.groovy
(51%)
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_join.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_mv.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_rf.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_sort.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_storage_agg_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_storage_dup_key.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_storage_negative_case.groovy
create mode 100644
regression-test/suites/datatype_p0/timestamptz/test_timestamptz_storage_uniq_key.groovy
create mode 100644
regression-test/suites/export_p0/outfile/native/test_outfile_native.groovy
create mode 100644
regression-test/suites/export_p0/test_export_variant_10k_columns.groovy
create mode 100644
regression-test/suites/external_table_p0/export/test_hive_export_varbinary.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/test_iceberg_table_meta_cache.groovy
create mode 100644
regression-test/suites/external_table_p0/jdbc/test_jdbc_catalog_refresh_update_time.groovy
delete mode 100644
regression-test/suites/fault_injection_p0/test_mow_seq_seg_compaction.groovy
rename
fe/fe-core/src/main/java/org/apache/doris/analysis/DefaultValueExpr.java =>
regression-test/suites/inverted_index_p0/test_index_policy_drop.groovy (55%)
create mode 100644
regression-test/suites/inverted_index_p0/test_pinyin_phrase.groovy
create mode 100644
regression-test/suites/nereids_p0/pkfk/test_pk_fk_drop_table.groovy
rename be/src/vec/aggregate_functions/aggregate_function_max_by.cpp =>
regression-test/suites/nereids_p0/slot_bind/test_bind_slot.groovy (50%)
create mode 100644
regression-test/suites/query_p0/set/test_mysql_compat_var_whitelist.groovy
create mode 100644
regression-test/suites/query_profile/test_load_channel_profile.groovy
delete mode 100644 regression-test/suites/query_profile/test_profile.groovy
create mode 100644
regression-test/suites/table_p0/test_storage_format_controls_encoding.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
