This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch branch-catalog-spi
in repository https://gitbox.apache.org/repos/asf/doris.git
omit 52822b098c4 [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
omit 0214560d5f3 [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
omit f38da2ee938 [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
omit 95911521a5a update P5 handoff and fix compile issue
omit 3fb7f392a93 [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
omit 11d36159eee [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
omit 36eb7515225 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
omit 177aa5a66b2 [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
omit 7706bc0313d [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
omit 588189559ea [doc](connector) add project tracking system for catalog
SPI migration
add 7b8f62c1b4d [fix](be) avoid LeakSanitizer false positive on BE startup
failure (#64802)
add 25f291673f1 [fix](fe) Reject Iceberg v3 row lineage columns (#63825)
add 456aa02b7a3 [refactor](be) Use ColumnArrayView in array functions
(#64873)
add 85ea37d4a2d [fix](iceberg)Support LZ4 compression for iceberg/hive
Parquet/ORC writers. (#64723)
add 9ec9d5ffdec [Fix](fold_const) MAKE_SET constant folding should clear
(#64907)
add 69b81114a40 [fix](subquery)show user friendly message when meet
unsupported subquery (#64778)
add 7c409402b7b [fix](be) Skip NaN values in PERCENTILE/PERCENTILE_ARRAY
aggregations (#63472)
add 153335925fd [fix](be) Avoid finalized pipeline task submit crash
(#64899)
add eadf59ee91e [fix](be) Fix SIGSEGV in bvar::take_sample caused by
AgentCombiner/TLS Agent lifetime race under high EPS (#64040)
add 09258e4f275 Revert "[opt](column) avoid redundant COW column clones"
(#64920)
add b054f57c5f2 [fix](be) prevent SIGFPE in int_divide for signed min
value (#64828)
add 5db03a49c54 [fix](external-write) Delete the actual data file on write
failure to avoid orphan files (#64678)
add e2140ebebcf [fix](agg push down) guard Count(*) child access with
arity() check in PushDownAggThroughJoinOnPkFk (#64848)
add 3bd324632a7 [fix](be) Catch std exceptions in pipeline scheduler
(#64934)
add dd94b95b781 [fix](be) Fix sliced FixedSizeBinary Arrow string reads
(#64829)
add 5981cd77fe0 [fix](be) Init thread context on AsyncIO worker threads
(#64846)
add 0e260a1b328 [fix](group commit) fix lost row when prepared stmt reused
plan shares one load_id (#64362)
add e5bbebb4905 [opt](local shuffle) bucket-shuffle dest spreading +
bucket-to-hash parallelism upgrade (#64793)
add 77893fb6a4f [fix](filesystem) replace throttled kerberos relogin with
proactive TGT refresh to fix flaky GSS failure (#64394)
add ac877e5cc4f [fix](iceberg) Write binary columns with proper Arrow
types (#64949)
add 64df172ca85 [fix](cloud) use snapshot read for table version to avoid
txn conflict (#64647)
add 3a05f60a302 [fix](be) catch block serialization exceptions to avoid
coredump (#64852)
add 6b8d128b25e [regression-test](variant) remove unstable
test_variant_arrayInvertedIdx_profile (#64608)
add d574ae7436c [fix](fe) Send recursive CTE blocks to every scan instance
(#64964)
add 153dfb5f586 [fix](data traits) Fix data trait propagation for logical
CTE anchors (#64921)
add 8bcaabb1efe [fix](checker) Avoid false-positive leaked delete bitmaps
for unexpired job tmp rowsets (#64313)
add 85afbb1b2b8 [fix](case) fix insert_group_commit_into_max_filter_ratio
(#64987)
add 7f0ab5608c1 [fix](be) Fix file cache queue evict size metrics (#64897)
add b4aed540e3c [feat](tools) add tpch primary key/foreign key in
tpch-tools (#64863)
add 1c05bf57e18 [fix](security) Add auth and config gate for
_stream_load_forward endpoint (#64935)
add 22d6f58639d [test](microbench) Add some api of get_or_set (#64691)
add c77e215c216 [fix](aggregate) Fix nullable aggregate visitor dispatch
(#64885)
add c02808aae79 [fix](fe) Handle generated columns in delete partial
update (#64884)
add f9105c38823 [fix](be) Validate sequence pattern event numbers (#64930)
add 257417b0295 [feature](be) Support expression zonemap pruning (#63389)
add c23c9914ad4 [fix](fe) set cloud version_cache_ttl to 0 temporarily if
retry a query with -230 (#63721)
add 9d7d3a2c4f4 [fix](be) Avoid local runtime filter merge deadlock
(#64866)
add 03cb15cb8ba [fix](agg) Fix incorrect aggregate merge with duplicate
aliases (#65025)
add 7718451c8e4 [enhancement](limitreach) FE receives many limit reach
error messages and make very confused (#62842)
add 98b4a21b421 [improvement](regression) Align regression framework
arrow/netty with fe-core and target JDK17 (#64677)
add 32a2651f66b [fix](iceberg) Fix NPE in COUNT(*) pushdown when snapshot
summary omits total-* counters (#64648)
add aab2f22f071 [fix](binlog compaction): cumu policy may be null (#65032)
add c48cde7877b [fix](connection) Prevent timeout checker from stopping
after an exception (#65040)
add 4d99c7e4d32 [feature](workload) Support remote scan bytes breaker in
workload policy (#64649)
add b731c4a4681 [chore](github)Remove 'Build Broker' task from .asf.yaml
(#65069)
add ecda456d5fd [fix](set operation) Use regular child output for set
operation rules (#64908)
add 023b766f5ce [fix](be) Validate task executor scan handles (#65054)
add 94a791e6644 [fix](auth) add auth check for manager node and query
qerror REST APIs (#65042)
add 7b2c4b91f11 [fix](group commit) fix can not get a block queue (#63722)
add 7936ec5c712 [fix](case) Stabilize max compute schema metadata case
checks. (#64959)
add 9d93a33fa1a [fix](regression) Stabilize rowsets timestamp filters
(#65050)
add 9502e5757cd [fix](regression) stabilize multi leading scalar predicate
(#65045)
add c8dc6f6c0a9 [fix](regression) update audit log behavior output (#64986)
add fd142ddeec3 [fix](regression) stabilize eliminate_inner aggregate
phase (#64957)
add 9b26234bf1c [fix](column) avoid mutable nullable crc32c hashing
(#64944)
add bec8d9f0ea1 [fix](regression) stabilize colocate column order plan
test (#64940)
add ed823b6d8eb [test](docker) improve the prefix path of cloud mode
docker env (#65001)
add 6ee32534acd [fix](eager-agg) Fix NPE when pushing MAX below both sides
of join (#65005)
add 57672d180d2 [fix](be) Continue sorted merge when sender queue is ready
(#65004)
add b5c0bcd3434 [fix](simplify agg) SimplifyAggGroupBy should verify
injectivity (#64335)
add 2f83e5d3df6 [improvement](query) Align olap scan schema with storage
keys (#64413)
add 3860c27fe76 [test](schema-change) log alter job state in
test_schema_change_mow_with_empty_rowset (#64903)
add 9a0d0cd20f3 [fix](regression) skip temp table status check (#65090)
add 54266107479 [fix](test) stabilize routine load adaptive timeout check
(#65092)
add 4f8c14451a7 [fix](regression) handle cumulative delete-version
compaction wait (#64945)
add 73c481f6584 [feature](cloud) Support file cache write index only
(#64995)
add e23b4030540 [refine](column) Make filter_by_selector const (#65047)
add 43693081393 [fix](fe) Reject invalid char filter replacement in
tokenize (#64794)
add 23c42dbccf9 [fix](regression) wait row count for partition_key_minmax
(#65124)
add 3645dc94306 [feature](be) Add file scanner v2 readers (#65046)
add 53b3bcd4398 [chore](gensrc) Remove unused IDL structures (#65113)
add 38430219e62 [fix](audit) serialize audit loader batch assembly (#65107)
add 6fed3e17814 [fix](test) filter joined FEs in sql cache case (#65098)
add ce88ef41c9d [test](cdc) Add case sensitivity ITCases for MySQL and PG
(#65033)
add 44de6fd7a93 [fix](regression) Use in-network MinIO endpoint for paimon
JDBC seed (#64113)
add a159972fb12 [fix](streaming-job) cdc client PostgreSQL snapshot honors
scan.snapshot.fetch.size to avoid wide-table OOM (#64938)
add 3cfbf220312 [fix](nereids) fix limit + offset overflow when pushing
down TopN/Limit (#64633)
add bc0a1be1796 [doc](connector) add project tracking system for catalog
SPI migration
add a97b26103dd [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
add 8836c9321ae [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
add f5a816479ce [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
add 1603395ce6a [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
add bc776cba12e [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
add c0fb20c7c80 update P5 handoff and fix compile issue
add 9f4815c97e2 [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
add f90c6b5892c [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
add 291d192392c [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
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 (52822b098c4)
\
N -- N -- N refs/heads/branch-catalog-spi (291d192392c)
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 | 1 -
.github/workflows/build-extension.yml | 2 +-
.gitignore | 1 +
be/cmake/thirdparty.cmake | 1 +
be/src/cloud/config.cpp | 1 +
be/src/cloud/config.h | 1 +
be/src/common/config.cpp | 5 +
be/src/common/config.h | 4 +
be/src/common/status.h | 2 +-
be/src/core/block/block.cpp | 36 +-
be/src/core/column/column.cpp | 37 +-
be/src/core/column/column.h | 20 +-
be/src/core/column/column_array.h | 7 +-
be/src/core/column/column_array_view.h | 2 +
be/src/core/column/column_const.h | 6 +-
be/src/core/column/column_decimal.cpp | 10 +
be/src/core/column/column_decimal.h | 6 +-
be/src/core/column/column_dictionary.h | 17 +-
be/src/core/column/column_map.h | 8 +-
be/src/core/column/column_nullable.cpp | 30 +-
be/src/core/column/column_nullable.h | 10 +-
be/src/core/column/column_string.cpp | 3 +-
be/src/core/column/column_string.h | 3 +-
be/src/core/column/column_struct.cpp | 8 +-
be/src/core/column/column_struct.h | 3 +-
be/src/core/column/column_variant.cpp | 17 +-
be/src/core/column/column_variant.h | 3 +-
be/src/core/column/column_vector.cpp | 23 +-
be/src/core/column/column_vector.h | 7 +-
be/src/core/data_type/data_type_timestamptz.h | 4 +
.../data_type_serde/data_type_datetimev2_serde.cpp | 143 +
.../data_type_serde/data_type_datetimev2_serde.h | 2 +
.../data_type_serde/data_type_datev2_serde.cpp | 24 +
.../core/data_type_serde/data_type_datev2_serde.h | 2 +
.../data_type_serde/data_type_decimal_serde.cpp | 152 +
.../core/data_type_serde/data_type_decimal_serde.h | 2 +
.../core/data_type_serde/data_type_jsonb_serde.cpp | 5 +-
.../data_type_serde/data_type_nullable_serde.cpp | 37 +-
.../data_type_serde/data_type_nullable_serde.h | 2 +
.../data_type_serde/data_type_number_serde.cpp | 170 +
.../core/data_type_serde/data_type_number_serde.h | 3 +
be/src/core/data_type_serde/data_type_serde.cpp | 48 +
be/src/core/data_type_serde/data_type_serde.h | 9 +
.../data_type_serde/data_type_string_serde.cpp | 165 +-
.../core/data_type_serde/data_type_string_serde.h | 3 +
.../core/data_type_serde/data_type_time_serde.cpp | 48 +
be/src/core/data_type_serde/data_type_time_serde.h | 2 +
.../data_type_timestamptz_serde.cpp | 85 +
.../data_type_serde/data_type_timestamptz_serde.h | 4 +
.../data_type_serde/data_type_varbinary_serde.cpp | 35 +
be/src/core/data_type_serde/decoded_column_view.h | 105 +
be/src/exec/exchange/vdata_stream_recvr.cpp | 12 +-
be/src/exec/exchange/vdata_stream_recvr.h | 17 +-
be/src/exec/operator/exchange_source_operator.cpp | 13 +-
be/src/exec/operator/exchange_source_operator.h | 36 +
be/src/exec/operator/file_scan_operator.cpp | 29 +-
be/src/exec/operator/file_scan_operator.h | 2 +
.../operator/group_commit_block_sink_operator.cpp | 61 +-
.../operator/group_commit_block_sink_operator.h | 4 +
.../operator/multi_cast_data_stream_source.cpp | 2 +-
be/src/exec/operator/olap_scan_operator.cpp | 20 +-
be/src/exec/operator/olap_scan_operator.h | 14 +-
be/src/exec/operator/result_sink_operator.h | 2 +-
be/src/exec/pipeline/pipeline_fragment_context.cpp | 40 +-
be/src/exec/pipeline/pipeline_fragment_context.h | 7 +-
be/src/exec/pipeline/pipeline_task.cpp | 9 +
be/src/exec/pipeline/pipeline_task.h | 9 +
be/src/exec/pipeline/task_scheduler.cpp | 17 +-
.../runtime_filter/runtime_filter_consumer.cpp | 2 +-
be/src/exec/runtime_filter/runtime_filter_merger.h | 27 +-
be/src/exec/runtime_filter/runtime_filter_mgr.cpp | 142 +-
be/src/exec/runtime_filter/runtime_filter_mgr.h | 35 +-
.../runtime_filter/runtime_filter_producer.cpp | 42 +-
be/src/exec/scan/access_path_parser.cpp | 479 +++
.../scan/access_path_parser.h} | 30 +-
be/src/exec/scan/file_scanner.cpp | 28 +-
be/src/exec/scan/file_scanner.h | 4 +-
be/src/exec/scan/file_scanner_v2.cpp | 835 ++++
be/src/exec/scan/file_scanner_v2.h | 162 +
be/src/exec/scan/olap_scanner.cpp | 46 +-
be/src/exec/scan/olap_scanner.h | 10 +-
be/src/exec/scan/scanner_scheduler.cpp | 11 +-
be/src/exec/scan/scanner_scheduler.h | 22 +-
be/src/exec/scan/split_source_connector.h | 29 +
.../time_sharing/time_sharing_task_executor.cpp | 28 +-
.../writer/iceberg/viceberg_delete_file_writer.cpp | 4 +
.../writer/iceberg/viceberg_partition_writer.cpp | 13 +-
.../sink/writer/iceberg/viceberg_table_writer.cpp | 21 +-
.../sink/writer/maxcompute/vmc_table_writer.cpp | 2 +-
be/src/exec/sink/writer/vhive_partition_writer.cpp | 85 +-
be/src/exec/sink/writer/vhive_partition_writer.h | 2 +
be/src/exec/sink/writer/vhive_table_writer.cpp | 22 +-
be/src/exec/sort/sort_cursor.h | 22 +-
be/src/exec/sort/vsorted_run_merger.cpp | 34 +-
be/src/exec/sort/vsorted_run_merger.h | 8 +-
.../aggregate/aggregate_function_percentile.h | 53 +-
.../aggregate/aggregate_function_sequence_match.h | 10 +-
be/src/exprs/expr_zonemap_filter.cpp | 268 ++
be/src/exprs/expr_zonemap_filter.h | 125 +
be/src/exprs/function/array/function_array_index.h | 183 +-
.../exprs/function/array/function_array_remove.h | 310 +-
.../exprs/function/array/function_arrays_overlap.h | 141 +-
be/src/exprs/function/function.cpp | 6 +
be/src/exprs/function/function.h | 19 +
be/src/exprs/function/function_string.cpp | 91 +-
be/src/exprs/function/functions_comparison.h | 145 +-
be/src/exprs/function/int_div.cpp | 30 +-
be/src/exprs/function/is_not_null.h | 13 +-
be/src/exprs/function/is_null.h | 11 +
.../exprs/lambda_function/varray_map_function.cpp | 18 +-
be/src/exprs/runtime_filter_expr.cpp | 51 +-
be/src/exprs/runtime_filter_expr.h | 11 +
be/src/exprs/short_circuit_evaluation_expr.h | 35 +-
be/src/exprs/vbloom_predicate.h | 7 +
be/src/exprs/vcase_expr.h | 11 +
be/src/exprs/vcast_expr.h | 12 +
be/src/exprs/vcolumn_ref.h | 13 +
be/src/exprs/vcompound_pred.h | 53 +
be/src/exprs/vcondition_expr.cpp | 3 +-
be/src/exprs/vcondition_expr.h | 15 +
be/src/exprs/vdirect_in_predicate.h | 76 +-
be/src/exprs/vectorized_fn_call.cpp | 14 +-
be/src/exprs/vectorized_fn_call.h | 8 +
be/src/exprs/vexpr.cpp | 65 +-
be/src/exprs/vexpr.h | 24 +-
be/src/exprs/vexpr_context.cpp | 33 +-
be/src/exprs/vexpr_context.h | 8 +-
be/src/exprs/vin_predicate.cpp | 53 +-
be/src/exprs/vin_predicate.h | 22 +-
be/src/exprs/vliteral.cpp | 6 -
be/src/exprs/vliteral.h | 23 +-
be/src/exprs/vslot_ref.cpp | 41 +-
be/src/exprs/vslot_ref.h | 15 +-
be/src/exprs/vtopn_pred.h | 5 +
be/src/format/CMakeLists.txt | 3 +
be/src/format/arrow/arrow_block_convertor.cpp | 131 +-
be/src/format/csv/csv_reader.cpp | 4 +-
be/src/format/generic_reader.h | 12 +-
be/src/format/json/new_json_reader.cpp | 4 +-
be/src/format/native/native_reader.cpp | 4 +-
be/src/format/orc/vorc_reader.cpp | 6 +-
be/src/format/parquet/vparquet_group_reader.cpp | 2 +-
be/src/format/parquet/vparquet_reader.cpp | 225 +-
be/src/format/parquet/vparquet_reader.h | 17 +
be/src/format/table/deletion_vector_reader.cpp | 19 +-
be/src/format/table/deletion_vector_reader.h | 35 +-
be/src/format/table/iceberg/arrow_schema_util.cpp | 19 +-
be/src/format/table/iceberg/arrow_schema_util.h | 1 +
be/src/format/table/iceberg/types.h | 2 +
be/src/format/table/iceberg_reader_mixin.h | 11 +-
be/src/format/transformer/vorc_transformer.cpp | 7 +
be/src/format/transformer/vparquet_transformer.cpp | 11 +
be/src/format_v2/column_data.h | 410 ++
be/src/format_v2/column_mapper.cpp | 2029 ++++++++++
be/src/format_v2/column_mapper.h | 294 ++
be/src/format_v2/column_mapper_nested.cpp | 1050 +++++
be/src/format_v2/column_mapper_nested.h | 105 +
be/src/format_v2/delimited_text/csv_reader.cpp | 295 ++
be/src/format_v2/delimited_text/csv_reader.h | 73 +
.../delimited_text/delimited_text_reader.cpp | 644 +++
.../delimited_text/delimited_text_reader.h | 176 +
be/src/format_v2/delimited_text/text_reader.cpp | 164 +
be/src/format_v2/delimited_text/text_reader.h | 62 +
be/src/format_v2/expr/cast.cpp | 131 +
.../vin_predicate.h => format_v2/expr/cast.h} | 49 +-
be/src/format_v2/expr/delete_predicate.cpp | 122 +
.../expr/delete_predicate.h} | 39 +-
.../format_v2/expr/equality_delete_predicate.cpp | 159 +
.../expr/equality_delete_predicate.h} | 56 +-
be/src/format_v2/file_reader.cpp | 209 +
be/src/format_v2/file_reader.h | 400 ++
be/src/format_v2/jni/hudi_jni_reader.cpp | 167 +
.../jni/hudi_jni_reader.h} | 34 +-
be/src/format_v2/jni/iceberg_sys_table_reader.cpp | 76 +
.../jni/iceberg_sys_table_reader.h} | 29 +-
be/src/format_v2/jni/jdbc_reader.cpp | 187 +
be/src/format_v2/jni/jdbc_reader.h | 56 +
be/src/format_v2/jni/jni_table_reader.cpp | 386 ++
be/src/format_v2/jni/jni_table_reader.h | 117 +
be/src/format_v2/jni/max_compute_jni_reader.cpp | 149 +
be/src/format_v2/jni/max_compute_jni_reader.h | 51 +
be/src/format_v2/jni/paimon_jni_reader.cpp | 93 +
.../src/format_v2/jni/paimon_jni_reader.h | 35 +-
.../format_v2/jni/trino_connector_jni_reader.cpp | 141 +
.../jni/trino_connector_jni_reader.h} | 31 +-
be/src/format_v2/json/json_reader.cpp | 1123 ++++++
be/src/format_v2/json/json_reader.h | 179 +
be/src/format_v2/materialized_reader_util.cpp | 89 +
be/src/format_v2/materialized_reader_util.h | 63 +
be/src/format_v2/native/native_reader.cpp | 311 ++
be/src/format_v2/native/native_reader.h | 70 +
be/src/format_v2/parquet/parquet_column_schema.cpp | 492 +++
be/src/format_v2/parquet/parquet_column_schema.h | 80 +
be/src/format_v2/parquet/parquet_file_context.cpp | 442 +++
be/src/format_v2/parquet/parquet_file_context.h | 99 +
be/src/format_v2/parquet/parquet_profile.cpp | 191 +
be/src/format_v2/parquet/parquet_profile.h | 140 +
be/src/format_v2/parquet/parquet_reader.cpp | 674 ++++
be/src/format_v2/parquet/parquet_reader.h | 92 +
be/src/format_v2/parquet/parquet_scan.cpp | 648 +++
be/src/format_v2/parquet/parquet_scan.h | 182 +
be/src/format_v2/parquet/parquet_statistics.cpp | 1303 ++++++
be/src/format_v2/parquet/parquet_statistics.h | 109 +
be/src/format_v2/parquet/parquet_type.cpp | 358 ++
be/src/format_v2/parquet/parquet_type.h | 82 +
be/src/format_v2/parquet/reader/column_reader.cpp | 625 +++
be/src/format_v2/parquet/reader/column_reader.h | 200 +
.../parquet/reader/global_rowid_column_reader.cpp | 84 +
.../parquet/reader/global_rowid_column_reader.h | 47 +
.../parquet/reader/list_column_reader.cpp | 203 +
.../format_v2/parquet/reader/list_column_reader.h | 52 +
.../format_v2/parquet/reader/map_column_reader.cpp | 238 ++
.../format_v2/parquet/reader/map_column_reader.h | 56 +
.../parquet/reader/nested_column_materializer.cpp | 70 +
.../parquet/reader/nested_column_materializer.h | 45 +
.../parquet/reader/parquet_leaf_reader.cpp | 728 ++++
.../format_v2/parquet/reader/parquet_leaf_reader.h | 168 +
.../parquet/reader/row_position_column_reader.cpp | 76 +
.../parquet/reader/row_position_column_reader.h} | 34 +-
.../parquet/reader/scalar_column_reader.cpp | 315 ++
.../parquet/reader/scalar_column_reader.h | 92 +
.../parquet/reader/struct_column_reader.cpp | 258 ++
.../parquet/reader/struct_column_reader.h | 61 +
be/src/format_v2/parquet/selection_vector.h | 163 +
be/src/format_v2/schema_projection.cpp | 147 +
be/src/format_v2/schema_projection.h | 57 +
be/src/format_v2/table/hive_reader.cpp | 150 +
be/src/format_v2/table/hive_reader.h | 41 +
be/src/format_v2/table/hudi_reader.cpp | 163 +
be/src/format_v2/table/hudi_reader.h | 78 +
be/src/format_v2/table/iceberg_reader.cpp | 797 ++++
be/src/format_v2/table/iceberg_reader.h | 175 +
be/src/format_v2/table/paimon_reader.cpp | 194 +
be/src/format_v2/table/paimon_reader.h | 84 +
be/src/format_v2/table/remote_doris_reader.cpp | 365 ++
be/src/format_v2/table/remote_doris_reader.h | 104 +
be/src/format_v2/table/schema_history_util.cpp | 150 +
be/src/format_v2/table/schema_history_util.h | 43 +
be/src/format_v2/table_reader.cpp | 847 ++++
be/src/format_v2/table_reader.h | 1565 ++++++++
be/src/io/cache/block_file_cache.cpp | 14 +-
be/src/io/cache/block_file_cache_profile.cpp | 48 +
be/src/io/cache/block_file_cache_profile.h | 10 +
be/src/io/cache/cached_remote_file_reader.cpp | 66 +-
be/src/io/cache/cached_remote_file_reader.h | 8 +-
be/src/io/file_factory.cpp | 13 +-
be/src/io/file_factory.h | 5 +-
be/src/io/fs/file_reader.h | 1 +
be/src/io/fs/file_writer.h | 5 +-
be/src/io/fs/packed_file_system.cpp | 22 +-
be/src/io/fs/s3_file_system.cpp | 2 +
be/src/io/io_common.h | 14 +
be/src/io/tools/file_cache_microbench.cpp | 349 +-
be/src/load/group_commit/group_commit_mgr.cpp | 342 +-
be/src/load/group_commit/group_commit_mgr.h | 45 +-
be/src/load/group_commit/wal/wal_table.cpp | 11 +-
be/src/runtime/runtime_state.cpp | 5 +-
.../workload_management/workload_condition.cpp | 15 +-
.../workload_management/workload_condition.h | 33 +-
.../workload_management/workload_sched_policy.cpp | 6 +
be/src/service/doris_main.cpp | 19 +-
.../http/action/stream_load_forward_handler.cpp | 12 +
.../http/action/stream_load_forward_handler.h | 8 +-
be/src/service/http_service.cpp | 2 +-
be/src/storage/compaction/compaction.cpp | 5 +
.../index/zone_map/zonemap_eval_context.cpp | 49 +
.../storage/index/zone_map/zonemap_eval_context.h | 70 +
.../storage/index/zone_map/zonemap_filter_result.h | 16 +-
be/src/storage/iterator/vcollect_iterator.cpp | 24 +-
be/src/storage/iterators.h | 8 +-
be/src/storage/olap_common.h | 5 +
be/src/storage/rowset/beta_rowset_reader.cpp | 3 +-
be/src/storage/rowset/beta_rowset_writer.cpp | 24 +-
be/src/storage/rowset/beta_rowset_writer.h | 2 +-
be/src/storage/rowset/rowset_reader_context.h | 7 +-
be/src/storage/rowset/rowset_writer_context.h | 27 +-
be/src/storage/rowset/segment_creator.cpp | 28 +-
be/src/storage/rowset/segment_creator.h | 9 +
.../storage/rowset/vertical_beta_rowset_writer.cpp | 34 +-
.../storage/rowset/vertical_beta_rowset_writer.h | 7 +
be/src/storage/schema.cpp | 6 +
be/src/storage/schema.h | 4 +
be/src/storage/segment/column_reader.cpp | 29 +
be/src/storage/segment/column_reader.h | 7 +
be/src/storage/segment/condition_cache.h | 18 +-
be/src/storage/segment/segment.cpp | 79 +
.../segment/segment_index_file_cache_loader.cpp | 179 +
.../segment/segment_index_file_cache_loader.h | 102 +
be/src/storage/segment/segment_iterator.cpp | 514 ++-
be/src/storage/segment/segment_iterator.h | 30 +-
be/src/storage/segment/segment_writer.cpp | 25 +-
be/src/storage/segment/segment_writer.h | 8 +-
be/src/storage/segment/vertical_segment_writer.cpp | 21 +-
be/src/storage/segment/vertical_segment_writer.h | 8 +-
be/src/storage/tablet/tablet.cpp | 3 +-
be/src/storage/tablet/tablet_manager.cpp | 7 +-
be/src/storage/tablet/tablet_reader.cpp | 7 +-
be/src/storage/tablet/tablet_reader.h | 8 +-
be/src/util/async_io.h | 7 +
be/src/util/jni-util.h | 8 +
be/test/CMakeLists.txt | 1 +
be/test/cloud/cloud_compaction_test.cpp | 17 +
be/test/core/column/column_dictionary_test.cpp | 12 +-
be/test/core/column/column_nullable_test.cpp | 225 +-
be/test/core/column/column_string_test.cpp | 4 +-
.../data_type_serde/data_type_jsonb_serde_test.cpp | 48 +-
.../data_type_serde/data_type_serde_arrow_test.cpp | 108 +
.../data_type_serde_decoded_values_test.cpp | 1852 +++++++++
.../data_type_serde/data_type_serde_pb_test.cpp | 14 +-
.../data_type_serde_string_test.cpp | 38 +
.../data_type_serde_varbinary_test.cpp | 18 +
be/test/core/value/sort_merger_test.cpp | 201 +-
.../time_sharing_task_executor_test.cpp | 57 +
be/test/exec/pipeline/pipeline_task_test.cpp | 194 +
be/test/exec/pipeline/thrift_builder.h | 2 -
.../runtime_filter_expr_sampling_test.cpp | 46 +
.../runtime_filter/runtime_filter_merger_test.cpp | 26 +-
.../runtime_filter/runtime_filter_mgr_test.cpp | 33 +-
.../runtime_filter_partition_pruner_test.cpp | 2 +-
be/test/exec/scan/access_path_parser_test.cpp | 371 ++
be/test/exec/scan/file_scanner_v2_test.cpp | 347 ++
be/test/exec/scan/vfile_scanner_exception_test.cpp | 115 +-
.../exprs/aggregate/vec_sequence_match_test.cpp | 63 +
be/test/exprs/expr_zonemap_filter_test.cpp | 819 ++++
.../exprs/function/function_arithmetic_test.cpp | 87 +
.../exprs/function/function_array_index_test.cpp | 25 +
.../exprs/function/function_array_remove_test.cpp | 115 +
.../function/function_arrays_overlap_test.cpp | 22 +
be/test/format/parquet/parquet_expr_test.cpp | 412 +-
.../table/iceberg/arrow_schema_util_test.cpp | 28 +
be/test/format_v2/column_mapper_test.cpp | 4140 ++++++++++++++++++++
.../format_v2/delimited_text/csv_reader_test.cpp | 1070 +++++
.../format_v2/delimited_text/text_reader_test.cpp | 965 +++++
be/test/format_v2/expr/cast_test.cpp | 172 +
be/test/format_v2/expr/delete_predicate_test.cpp | 168 +
.../expr/equality_delete_predicate_test.cpp | 181 +
be/test/format_v2/json/json_reader_test.cpp | 608 +++
be/test/format_v2/native/native_reader_test.cpp | 419 ++
.../parquet/parquet_column_reader_test.cpp | 3620 +++++++++++++++++
.../format_v2/parquet/parquet_leaf_reader_test.cpp | 506 +++
.../parquet/parquet_page_cache_range_test.cpp | 117 +
.../parquet/parquet_reader_control_test.cpp | 1034 +++++
be/test/format_v2/parquet/parquet_reader_test.cpp | 2274 +++++++++++
be/test/format_v2/parquet/parquet_scan_test.cpp | 804 ++++
be/test/format_v2/parquet/parquet_schema_test.cpp | 527 +++
.../parquet/parquet_serde_reader_test.cpp | 459 +++
.../format_v2/parquet/parquet_statistics_test.cpp | 460 +++
be/test/format_v2/parquet/parquet_type_test.cpp | 494 +++
be/test/format_v2/table/hive_reader_test.cpp | 151 +
be/test/format_v2/table/hudi_reader_test.cpp | 182 +
be/test/format_v2/table/iceberg_reader_test.cpp | 1852 +++++++++
be/test/format_v2/table/paimon_reader_test.cpp | 539 +++
.../format_v2/table/remote_doris_reader_test.cpp | 470 +++
be/test/format_v2/table_reader_request_test.cpp | 96 +
be/test/format_v2/table_reader_test.cpp | 3826 ++++++++++++++++++
be/test/runtime/workload_sched_policy_test.cpp | 34 +-
.../cloud_file_cache_write_index_only_test.cpp | 799 ++++
.../compaction/compaction_file_cache_test.cpp | 58 +-
.../segment/segment_iterator_expr_zonemap_test.cpp | 244 ++
cloud/src/meta-service/meta_service_partition.cpp | 18 +-
cloud/src/meta-service/meta_service_txn.cpp | 18 +-
cloud/src/recycler/checker.cpp | 127 +-
cloud/src/recycler/checker.h | 2 +
cloud/src/recycler/recycler.h | 5 +
cloud/test/recycler_test.cpp | 125 +
docker/runtime/doris-compose/cluster.py | 3 +
docs/doris-iceberg-parquet-api-design.md | 511 +++
docs/new-parquet-reader-column-index-refactor.md | 404 ++
docs/new-parquet-reader-ut-improvement-plan.md | 325 ++
docs/parquet-list-map-compat-design.md | 664 ++++
.../org/apache/doris/paimon/PaimonJniScanner.java | 3 +
fe/fe-common/pom.xml | 5 +
.../apache/doris/analysis/InvertedIndexUtil.java | 53 +-
.../doris/datasource/hive/HMSExternalTable.java | 3 +
.../doris/datasource/hive/HMSTransaction.java | 30 +-
.../org/apache/doris/datasource/hive/HiveUtil.java | 6 +-
.../datasource/iceberg/IcebergMetadataOps.java | 8 +-
.../doris/datasource/iceberg/IcebergUtils.java | 62 +-
.../datasource/iceberg/source/IcebergScanNode.java | 19 +-
.../doris/httpv2/rest/manager/NodeAction.java | 6 +
.../httpv2/rest/manager/QueryProfileAction.java | 10 +-
.../CharReplaceCharFilterValidator.java | 30 +-
.../glue/translator/PhysicalPlanTranslator.java | 41 +-
.../glue/translator/PlanTranslatorContext.java | 31 +
.../nereids/processor/post/PushTopnToAgg.java | 6 +
.../properties/ChildrenPropertiesRegulator.java | 10 +-
.../doris/nereids/rules/analysis/BindSink.java | 30 +-
.../nereids/rules/analysis/SubExprAnalyzer.java | 68 +-
.../implementation/LogicalTopNToPhysicalTopN.java | 15 +-
.../rules/rewrite/CollectLimitAboveConsumer.java | 13 +-
.../nereids/rules/rewrite/LimitAggToTopNAgg.java | 5 +
.../nereids/rules/rewrite/MergeAggregate.java | 12 +-
.../doris/nereids/rules/rewrite/MergeLimits.java | 11 +
.../rewrite/MergeOneRowRelationIntoUnion.java | 21 +-
.../doris/nereids/rules/rewrite/MergeTopNs.java | 6 +
.../rewrite/PushDownAggThroughJoinOnPkFk.java | 1 +
.../rewrite/PushDownLimitDistinctThroughJoin.java | 8 +
.../rewrite/PushDownLimitDistinctThroughUnion.java | 14 +-
.../rewrite/PushDownScoreTopNIntoOlapScan.java | 7 +
.../rewrite/PushDownTopNDistinctThroughJoin.java | 18 +-
.../rewrite/PushDownTopNDistinctThroughUnion.java | 17 +-
.../rules/rewrite/PushDownTopNThroughJoin.java | 16 +-
.../rules/rewrite/PushDownTopNThroughUnion.java | 12 +-
.../rules/rewrite/PushDownTopNThroughWindow.java | 11 +
.../rewrite/PushDownVectorTopNIntoOlapScan.java | 7 +
.../nereids/rules/rewrite/SimplifyAggGroupBy.java | 57 +-
.../doris/nereids/rules/rewrite/SplitLimit.java | 9 +-
.../rewrite/eageraggregation/EagerAggRewriter.java | 3 +-
.../functions/agg/SequenceFunction.java | 19 +
.../functions/executable/StringArithmetic.java | 2 +-
.../expressions/functions/scalar/Tokenize.java | 5 +-
.../visitor/AggregateFunctionVisitor.java | 6 +-
.../trees/plans/commands/info/CreateTableInfo.java | 36 +
.../trees/plans/distribute/DistributePlanner.java | 57 +-
.../trees/plans/logical/LogicalCTEAnchor.java | 34 +-
.../nereids/trees/plans/logical/LogicalLimit.java | 6 +
.../nereids/trees/plans/logical/LogicalTopN.java | 5 +
.../trees/plans/physical/PhysicalCTEAnchor.java | 34 +-
.../trees/plans/physical/PhysicalLimit.java | 10 +
.../trees/plans/physical/PhysicalOlapScan.java | 5 +-
.../nereids/trees/plans/physical/PhysicalTopN.java | 5 +
.../apache/doris/nereids/util/ExpressionUtils.java | 36 -
.../java/org/apache/doris/nereids/util/Utils.java | 16 +
.../org/apache/doris/planner/AddLocalExchange.java | 105 +
.../org/apache/doris/planner/ExchangeNode.java | 7 +
.../org/apache/doris/planner/HashJoinNode.java | 96 +-
.../org/apache/doris/planner/OlapScanNode.java | 25 +
.../org/apache/doris/planner/RuntimeFilter.java | 37 +
.../org/apache/doris/plugin/audit/AuditLoader.java | 3 +-
.../java/org/apache/doris/qe/ConnectPoolMgr.java | 7 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 10 +-
.../java/org/apache/doris/qe/SessionVariable.java | 78 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 36 +-
.../doris/qe/runtime/ThriftPlansBuilder.java | 58 +-
.../workloadschedpolicy/WorkloadCondition.java | 3 +
...kloadConditionBeScanBytesFromRemoteStorage.java | 60 +
.../workloadschedpolicy/WorkloadMetricType.java | 3 +-
.../WorkloadSchedPolicyMgr.java | 7 +-
.../analysis/InvertedIndexPropertiesTest.java | 120 +
.../datasource/hive/HMSTransactionPathTest.java | 145 +-
.../iceberg/IcebergDDLAndDMLPlanTest.java | 71 +
.../datasource/iceberg/IcebergMetadataOpTest.java | 50 +-
.../iceberg/source/IcebergCountPushDownTest.java | 86 +
.../ParquetFileFormatPropertiesTest.java | 2 +
.../doris/indexpolicy/PolicyValidatorTests.java | 14 +
.../translator/PhysicalPlanTranslatorTest.java | 52 +-
.../doris/nereids/properties/DataTraitTest.java | 37 +-
.../rules/analysis/AnalyzeSubQueryTest.java | 66 +
.../nereids/rules/rewrite/MergeAggregateTest.java | 28 +-
.../rewrite/PushDownAggThroughJoinOnPkFkTest.java | 14 +
.../rewrite/SetOperationOutputMappingTest.java | 157 +
.../rules/rewrite/SimplifyAggGroupByTest.java | 240 ++
.../expressions/functions/scalar/TokenizeTest.java | 85 +
.../visitor/AggregateFunctionVisitorTest.java | 114 +
.../trees/plans/DeleteFromUsingCommandTest.java | 89 +
.../org/apache/doris/nereids/util/UtilsTest.java | 17 +
.../planner/LocalShuffleNodeCoverageTest.java | 160 +-
.../apache/doris/plugin/audit/AuditLoaderTest.java | 82 +
.../org/apache/doris/qe/ConnectSchedulerTest.java | 36 +
.../java/org/apache/doris/qe/StmtExecutorTest.java | 48 +
.../doris/qe/runtime/ThriftPlansBuilderTest.java | 91 +
.../WorkloadSchedPolicyMgrTest.java | 46 +
fe/fe-filesystem/fe-filesystem-spi/pom.xml | 8 +
.../foundation/security/KerberosTicketUtils.java | 75 +
.../security/KerberosTicketUtilsTest.java | 72 +
fs_brokers/cdc_client/build.sh | 2 +-
.../cdcclient/service/PipelineCoordinator.java | 8 +-
.../reader/postgres/PostgresSourceReader.java | 26 +-
.../source/fetch/PostgresScanFetchTask.java | 10 +-
.../cdcclient/itcase/MySqlCaseSensitiveITCase.java | 158 +
.../itcase/PostgresCaseFoldingITCase.java | 192 +
.../reader/postgres/PostgresSourceReaderTest.java | 57 +
.../doris/cdcclient/utils/ConfigUtilTest.java | 40 +
gensrc/proto/column_data_file.proto | 68 -
gensrc/proto/internal_service.proto | 40 -
gensrc/proto/olap_common.proto | 32 -
gensrc/thrift/BackendService.thrift | 4 +-
gensrc/thrift/DataSinks.thrift | 5 +
gensrc/thrift/Exprs.thrift | 4 +
gensrc/thrift/Opcodes.thrift | 2 +
gensrc/thrift/PaloInternalService.thrift | 16 +-
gensrc/thrift/PlanNodes.thrift | 16 +
.../data/audit/test_audit_log_behavior.out | 2 +-
.../test_delete_generated_column.out | 12 +
.../data/export_p0/export/test_show_export.out | 298 +-
.../parquet/test_outfile_parquet_complex_type.out | 12 +
.../data/export_p0/test_export_parquet.out | 198 +-
.../hive_read/parquet/test_hive_read_parquet.out | 24 +-
...out => test_hive_read_parquet_complex_type.out} | 0
.../external_table_p0/hive/ddl/test_hive_ctas.out | 200 -
.../external_table_p0/hive/ddl/test_hive_ddl.out | 9 +
.../external_table_p0/hive/test_complex_types.out | 48 -
.../hive/test_external_catalog_hive.out | 124 -
.../hive/test_external_catalog_hive_partition.out | 120 -
.../hive/test_hive_compress_type.out | 595 ++-
.../hive/test_hive_get_schema_from_table.out | 651 ---
.../hive/test_hive_openx_json.out | 1 +
.../hive/test_hive_schema_evolution.out | 36 -
.../hive/write/test_hive_write_insert.out | 232 --
.../iceberg/test_iceberg_export_timestamp_tz.out | 48 +-
.../test_iceberg_write_parquet_compression.out | 44 +
.../paimon/test_paimon_catalog_timestamp_tz.out | 8 +-
.../tvf/test_hdfs_parquet_group0.out | 33 +
.../tvf/test_hdfs_parquet_group2.out | 203 +-
.../tvf/test_hdfs_parquet_group3.out | 40 +-
.../tvf/test_hdfs_parquet_group4.out | 139 +-
.../tvf/test_hdfs_parquet_group5.out | 20 +-
.../tvf/test_hdfs_parquet_group6.out | 30 +-
.../maxcompute/test_max_compute_schema.out | 51 +-
.../merge_aggregate/merge_aggregate.out | 5 +
.../support_type/percentile/percentile.out | 42 +
.../percentile_ap/percentile_approx.out | 21 +
.../percentile_ap_w/percentile_approx_weighted.out | 21 +
.../percentile_ar/percentile_array.out | 21 +
.../query_p0/eager_agg/bilateral_eager_agg.out | 4 +
.../data/query_p0/hint/multi_leading.out | 2 +-
.../subquery/correlated_scalar_subquery.out | 63 +
.../sql}/q01.out | 0
.../sql}/q02.out | 0
.../sql}/q03.out | 0
.../sql}/q04.out | 0
.../sql}/q05.out | 0
.../sql}/q06.out | 0
.../sql}/q07.out | 0
.../sql}/q08.out | 0
.../sql}/q09.out | 0
.../sql}/q10.out | 0
.../sql}/q11.out | 0
.../sql}/q12.out | 0
.../sql}/q13.out | 0
.../sql/q14.out | 0
.../sql}/q15.out | 0
.../sql}/q16.out | 0
.../sql/q17.out | 0
.../sql}/q18.out | 0
.../sql}/q19.out | 0
.../sql}/q20.out | 0
.../sql}/q21.out | 0
.../sql}/q22.out | 0
.../test_array_inverted_index_profile.out | 45 -
regression-test/framework/pom.xml | 11 +-
.../regression/util/RoutineLoadTestUtils.groovy | 101 +-
regression-test/pipeline/cloud_p0/run.sh | 5 +-
regression-test/pipeline/common/doris-utils.sh | 8 +-
regression-test/pipeline/vault_p0/run.sh | 5 +-
regression-test/plugins/plugin_compaction.groovy | 29 +-
.../auth_p0/test_http_node_action_auth.groovy | 113 +
.../test_file_cache_write_index_file_only.groovy | 344 ++
..._index_file_only_compaction_segment_data.groovy | 239 ++
..._cache_write_index_file_only_packed_file.groovy | 293 ++
.../cloud_p0/query_retry/test_retry_e-230.groovy | 55 +
.../test_colocate_join_of_column_order.groovy | 2 +-
.../test_delete_generated_column.groovy | 96 +
.../test_outfile_parquet_complex_type.groovy | 11 +
.../parquet/test_hive_read_parquet.groovy | 3 +-
... => test_hive_read_parquet_complex_type.groovy} | 3 +-
.../hive/ddl/test_hive_ddl.groovy | 22 +-
.../hive/test_hive_compress_type.groovy | 26 +-
.../hive/test_hive_date_timezone.groovy | 1 -
.../hive/test_parquet_lazy_mat_profile.groovy | 2 +
.../test_workload_policy_remote_scan_bytes.groovy | 143 +
.../iceberg/test_iceberg_optimize_count.groovy | 6 +-
.../test_iceberg_write_parquet_compression.groovy | 155 +
.../paimon/test_paimon_jdbc_catalog.groovy | 50 +-
.../test_remote_doris_agg_table_select.groovy | 4 +-
.../test_remote_doris_unique_table_select.groovy | 4 +-
.../test_remote_doris_variant_select.groovy | 2 +-
.../tvf/test_hdfs_parquet_group0.groovy | 8 +-
.../tvf/test_hdfs_parquet_group2.groovy | 5 +-
.../tvf/test_hdfs_parquet_group4.groovy | 4 +-
.../tvf/test_hdfs_parquet_group5.groovy | 4 +-
.../tvf/test_hdfs_parquet_group6.groovy | 14 +-
.../maxcompute/test_max_compute_schema.groovy | 35 +-
.../group_commit/test_group_commit_error.groovy | 46 +-
.../test_group_commit_prepare_lost_row.groovy | 157 +
...nsert_group_commit_into_max_filter_ratio.groovy | 1 +
.../analyzer/test_custom_analyzer1.groovy | 15 +-
.../inverted_index_p0/test_properties.groovy | 43 +
.../suites/inverted_index_p0/test_tokenize.groovy | 12 +
.../test_routine_load_adaptive_param.groovy | 12 +-
.../stream_load/test_group_commit_redirect.groovy | 1 +
...ommit_stream_load_high_concurrency_async.groovy | 138 +
.../test_local_shuffle_bucket_upgrade.groovy | 193 +
.../test_local_shuffle_rqg_bugs.groovy | 75 +-
.../merge_aggregate/merge_aggregate.groovy | 30 +
.../merge_one_row_relation_into_union.groovy | 15 +-
.../nereids_rules_p0/pkfk/eliminate_inner.groovy | 4 +-
.../push_down_limit_distinct_through_union.groovy | 58 +
.../push_down_top_n_distinct_through_union.groovy | 21 +-
.../push_down_top_n_through_union.groovy | 27 +
.../nereids_syntax_p0/test_nereids_function.groovy | 27 +
.../support_type/percentile/percentile.groovy | 48 +
.../percentile_ap/percentile_approx.groovy | 9 +
.../percentile_approx_weighted.groovy | 8 +
.../percentile_ar/percentile_array.groovy | 7 +
.../query_p0/cache/parse_sql_from_sql_cache.groovy | 15 +-
.../query_p0/eager_agg/bilateral_eager_agg.groovy | 59 +-
.../expr_zonemap/test_expr_zonemap_pruning.groovy | 227 ++
.../suites/query_p0/hint/multi_leading.groovy | 2 +-
.../string_functions/test_string_function.groovy | 5 +
.../query_p0/stats/partition_key_minmax.groovy | 16 +-
.../subquery/correlated_scalar_subquery.groovy | 219 ++
.../query_p0/system/test_query_sys_rowsets.groovy | 12 +-
.../system/test_query_sys_scan_rowsets.groovy | 7 +-
.../test_expr_zonemap_pruning_p1.groovy | 157 +
.../recursive_cte/rec_cte_parallel_targets.groovy | 79 +
...test_schema_change_mow_with_empty_rowset.groovy | 1 +
.../suites/temp_table_p0/test_temp_table.groovy | 16 +-
.../ddl/create_table.sql | 0
.../ddl/customer.sql | 10 +-
.../ddl/customer_delete.sql | 0
.../ddl/lineitem.sql | 20 +-
.../ddl/lineitem_delete.sql | 0
.../ddl/nation.sql | 8 +-
.../ddl/nation_delete.sql | 0
.../tpch_sf0.1_constraints_p1/ddl/orders.sql | 17 +
.../ddl/orders_delete.sql | 0
.../suites/tpch_sf0.1_constraints_p1/ddl/part.sql | 17 +
.../ddl/part_delete.sql | 0
.../tpch_sf0.1_constraints_p1/ddl/partsupp.sql | 13 +
.../ddl/partsupp_delete.sql | 0
.../ddl/region.sql | 6 +-
.../ddl/region_delete.sql | 0
.../ddl/revenue1.sql | 0
.../ddl/revenue1_delete.sql | 0
.../ddl/supplier.sql | 10 +-
.../ddl/supplier_delete.sql | 0
.../suites/tpch_sf0.1_constraints_p1/load.groovy | 142 +
.../sql/q01.sql | 0
.../sql/q02.sql | 0
.../sql/q03.sql | 0
.../sql/q04.sql | 0
.../sql/q05.sql | 0
.../sql/q06.sql | 0
.../sql/q07.sql | 0
.../sql/q08.sql | 0
.../sql/q09.sql | 0
.../sql/q10.sql | 0
.../sql/q11.sql | 0
.../sql/q12.sql | 0
.../sql/q13.sql | 0
.../sql/q14.sql | 0
.../sql/q15.sql | 0
.../sql/q16.sql | 0
.../sql/q17.sql | 0
.../sql/q18.sql | 0
.../sql/q19.sql | 0
.../sql/q20.sql | 0
.../sql/q21.sql | 0
.../sql/q22.sql | 0
.../suites/tpch_sf0.1_p1/ddl/customer.sql | 10 +-
.../suites/tpch_sf0.1_p1/ddl/lineitem.sql | 20 +-
.../suites/tpch_sf0.1_p1/ddl/nation.sql | 8 +-
.../suites/tpch_sf0.1_p1/ddl/orders.sql | 16 +-
regression-test/suites/tpch_sf0.1_p1/ddl/part.sql | 14 +-
.../suites/tpch_sf0.1_p1/ddl/partsupp.sql | 10 +-
.../suites/tpch_sf0.1_p1/ddl/region.sql | 6 +-
.../suites/tpch_sf0.1_p1/ddl/supplier.sql | 10 +-
.../test_array_inverted_index_profile.groovy | 165 -
.../test_nereids_show_create_storage_vault.groovy | 4 +-
run-regression-test.sh | 30 +-
thirdparty/build-thirdparty.sh | 5 +-
thirdparty/download-thirdparty.sh | 3 +
thirdparty/patches/apache-arrow-17.0.0-lzo.patch | 84 +
...pc-1.4.0-fix-agent-combiner-thread-safety.patch | 439 +++
thirdparty/vars.sh | 8 +-
.../tpch-tools/constraints/drop-fk-constraints.sql | 11 +
.../constraints/drop-pk-uk-constraints.sql | 11 +
tools/tpch-tools/constraints/tpch-fd.sql | 25 +
669 files changed, 73135 insertions(+), 4874 deletions(-)
create mode 100644 be/src/core/data_type_serde/decoded_column_view.h
create mode 100644 be/src/exec/scan/access_path_parser.cpp
copy be/src/{format/table/iceberg/arrow_schema_util.h =>
exec/scan/access_path_parser.h} (54%)
create mode 100644 be/src/exec/scan/file_scanner_v2.cpp
create mode 100644 be/src/exec/scan/file_scanner_v2.h
create mode 100644 be/src/exprs/expr_zonemap_filter.cpp
create mode 100644 be/src/exprs/expr_zonemap_filter.h
create mode 100644 be/src/format_v2/column_data.h
create mode 100644 be/src/format_v2/column_mapper.cpp
create mode 100644 be/src/format_v2/column_mapper.h
create mode 100644 be/src/format_v2/column_mapper_nested.cpp
create mode 100644 be/src/format_v2/column_mapper_nested.h
create mode 100644 be/src/format_v2/delimited_text/csv_reader.cpp
create mode 100644 be/src/format_v2/delimited_text/csv_reader.h
create mode 100644 be/src/format_v2/delimited_text/delimited_text_reader.cpp
create mode 100644 be/src/format_v2/delimited_text/delimited_text_reader.h
create mode 100644 be/src/format_v2/delimited_text/text_reader.cpp
create mode 100644 be/src/format_v2/delimited_text/text_reader.h
create mode 100644 be/src/format_v2/expr/cast.cpp
copy be/src/{exprs/vin_predicate.h => format_v2/expr/cast.h} (68%)
create mode 100644 be/src/format_v2/expr/delete_predicate.cpp
copy be/src/{exprs/vin_predicate.h => format_v2/expr/delete_predicate.h} (66%)
create mode 100644 be/src/format_v2/expr/equality_delete_predicate.cpp
copy be/src/{exprs/vin_predicate.h =>
format_v2/expr/equality_delete_predicate.h} (62%)
create mode 100644 be/src/format_v2/file_reader.cpp
create mode 100644 be/src/format_v2/file_reader.h
create mode 100644 be/src/format_v2/jni/hudi_jni_reader.cpp
copy be/src/{format/table/iceberg/arrow_schema_util.h =>
format_v2/jni/hudi_jni_reader.h} (52%)
create mode 100644 be/src/format_v2/jni/iceberg_sys_table_reader.cpp
copy be/src/{format/table/iceberg/arrow_schema_util.h =>
format_v2/jni/iceberg_sys_table_reader.h} (57%)
create mode 100644 be/src/format_v2/jni/jdbc_reader.cpp
create mode 100644 be/src/format_v2/jni/jdbc_reader.h
create mode 100644 be/src/format_v2/jni/jni_table_reader.cpp
create mode 100644 be/src/format_v2/jni/jni_table_reader.h
create mode 100644 be/src/format_v2/jni/max_compute_jni_reader.cpp
create mode 100644 be/src/format_v2/jni/max_compute_jni_reader.h
create mode 100644 be/src/format_v2/jni/paimon_jni_reader.cpp
copy fe/fe-core/src/test/java/org/apache/doris/nereids/util/UtilsTest.java =>
be/src/format_v2/jni/paimon_jni_reader.h (57%)
create mode 100644 be/src/format_v2/jni/trino_connector_jni_reader.cpp
copy be/src/{format/table/iceberg/arrow_schema_util.h =>
format_v2/jni/trino_connector_jni_reader.h} (54%)
create mode 100644 be/src/format_v2/json/json_reader.cpp
create mode 100644 be/src/format_v2/json/json_reader.h
create mode 100644 be/src/format_v2/materialized_reader_util.cpp
create mode 100644 be/src/format_v2/materialized_reader_util.h
create mode 100644 be/src/format_v2/native/native_reader.cpp
create mode 100644 be/src/format_v2/native/native_reader.h
create mode 100644 be/src/format_v2/parquet/parquet_column_schema.cpp
create mode 100644 be/src/format_v2/parquet/parquet_column_schema.h
create mode 100644 be/src/format_v2/parquet/parquet_file_context.cpp
create mode 100644 be/src/format_v2/parquet/parquet_file_context.h
create mode 100644 be/src/format_v2/parquet/parquet_profile.cpp
create mode 100644 be/src/format_v2/parquet/parquet_profile.h
create mode 100644 be/src/format_v2/parquet/parquet_reader.cpp
create mode 100644 be/src/format_v2/parquet/parquet_reader.h
create mode 100644 be/src/format_v2/parquet/parquet_scan.cpp
create mode 100644 be/src/format_v2/parquet/parquet_scan.h
create mode 100644 be/src/format_v2/parquet/parquet_statistics.cpp
create mode 100644 be/src/format_v2/parquet/parquet_statistics.h
create mode 100644 be/src/format_v2/parquet/parquet_type.cpp
create mode 100644 be/src/format_v2/parquet/parquet_type.h
create mode 100644 be/src/format_v2/parquet/reader/column_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/column_reader.h
create mode 100644
be/src/format_v2/parquet/reader/global_rowid_column_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/global_rowid_column_reader.h
create mode 100644 be/src/format_v2/parquet/reader/list_column_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/list_column_reader.h
create mode 100644 be/src/format_v2/parquet/reader/map_column_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/map_column_reader.h
create mode 100644
be/src/format_v2/parquet/reader/nested_column_materializer.cpp
create mode 100644 be/src/format_v2/parquet/reader/nested_column_materializer.h
create mode 100644 be/src/format_v2/parquet/reader/parquet_leaf_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/parquet_leaf_reader.h
create mode 100644
be/src/format_v2/parquet/reader/row_position_column_reader.cpp
copy be/src/{format/table/iceberg/arrow_schema_util.h =>
format_v2/parquet/reader/row_position_column_reader.h} (50%)
create mode 100644 be/src/format_v2/parquet/reader/scalar_column_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/scalar_column_reader.h
create mode 100644 be/src/format_v2/parquet/reader/struct_column_reader.cpp
create mode 100644 be/src/format_v2/parquet/reader/struct_column_reader.h
create mode 100644 be/src/format_v2/parquet/selection_vector.h
create mode 100644 be/src/format_v2/schema_projection.cpp
create mode 100644 be/src/format_v2/schema_projection.h
create mode 100644 be/src/format_v2/table/hive_reader.cpp
create mode 100644 be/src/format_v2/table/hive_reader.h
create mode 100644 be/src/format_v2/table/hudi_reader.cpp
create mode 100644 be/src/format_v2/table/hudi_reader.h
create mode 100644 be/src/format_v2/table/iceberg_reader.cpp
create mode 100644 be/src/format_v2/table/iceberg_reader.h
create mode 100644 be/src/format_v2/table/paimon_reader.cpp
create mode 100644 be/src/format_v2/table/paimon_reader.h
create mode 100644 be/src/format_v2/table/remote_doris_reader.cpp
create mode 100644 be/src/format_v2/table/remote_doris_reader.h
create mode 100644 be/src/format_v2/table/schema_history_util.cpp
create mode 100644 be/src/format_v2/table/schema_history_util.h
create mode 100644 be/src/format_v2/table_reader.cpp
create mode 100644 be/src/format_v2/table_reader.h
create mode 100644 be/src/storage/index/zone_map/zonemap_eval_context.cpp
create mode 100644 be/src/storage/index/zone_map/zonemap_eval_context.h
copy
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadMetricType.java
=> be/src/storage/index/zone_map/zonemap_filter_result.h (82%)
create mode 100644 be/src/storage/segment/segment_index_file_cache_loader.cpp
create mode 100644 be/src/storage/segment/segment_index_file_cache_loader.h
create mode 100644
be/test/core/data_type_serde/data_type_serde_decoded_values_test.cpp
create mode 100644 be/test/exec/scan/access_path_parser_test.cpp
create mode 100644 be/test/exec/scan/file_scanner_v2_test.cpp
create mode 100644 be/test/exprs/expr_zonemap_filter_test.cpp
create mode 100644 be/test/exprs/function/function_array_remove_test.cpp
create mode 100644 be/test/format_v2/column_mapper_test.cpp
create mode 100644 be/test/format_v2/delimited_text/csv_reader_test.cpp
create mode 100644 be/test/format_v2/delimited_text/text_reader_test.cpp
create mode 100644 be/test/format_v2/expr/cast_test.cpp
create mode 100644 be/test/format_v2/expr/delete_predicate_test.cpp
create mode 100644 be/test/format_v2/expr/equality_delete_predicate_test.cpp
create mode 100644 be/test/format_v2/json/json_reader_test.cpp
create mode 100644 be/test/format_v2/native/native_reader_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_column_reader_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_leaf_reader_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_page_cache_range_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_reader_control_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_reader_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_scan_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_schema_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_serde_reader_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_statistics_test.cpp
create mode 100644 be/test/format_v2/parquet/parquet_type_test.cpp
create mode 100644 be/test/format_v2/table/hive_reader_test.cpp
create mode 100644 be/test/format_v2/table/hudi_reader_test.cpp
create mode 100644 be/test/format_v2/table/iceberg_reader_test.cpp
create mode 100644 be/test/format_v2/table/paimon_reader_test.cpp
create mode 100644 be/test/format_v2/table/remote_doris_reader_test.cpp
create mode 100644 be/test/format_v2/table_reader_request_test.cpp
create mode 100644 be/test/format_v2/table_reader_test.cpp
create mode 100644 be/test/storage/cloud_file_cache_write_index_only_test.cpp
create mode 100644
be/test/storage/segment/segment_iterator_expr_zonemap_test.cpp
create mode 100644 docs/doris-iceberg-parquet-api-design.md
create mode 100644 docs/new-parquet-reader-column-index-refactor.md
create mode 100644 docs/new-parquet-reader-ut-improvement-plan.md
create mode 100644 docs/parquet-list-map-compat-design.md
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadConditionBeScanBytesFromRemoteStorage.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/datasource/iceberg/source/IcebergCountPushDownTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/SetOperationOutputMappingTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/scalar/TokenizeTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/visitor/AggregateFunctionVisitorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/plugin/audit/AuditLoaderTest.java
create mode 100644
fe/fe-foundation/src/main/java/org/apache/doris/foundation/security/KerberosTicketUtils.java
create mode 100644
fe/fe-foundation/src/test/java/org/apache/doris/foundation/security/KerberosTicketUtilsTest.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/MySqlCaseSensitiveITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/itcase/PostgresCaseFoldingITCase.java
create mode 100644
fs_brokers/cdc_client/src/test/java/org/apache/doris/cdcclient/source/reader/postgres/PostgresSourceReaderTest.java
delete mode 100644 gensrc/proto/column_data_file.proto
rename
regression-test/data/external_table_p0/export/hive_read/parquet/{test_hive_read_parquet_comlex_type.out
=> test_hive_read_parquet_complex_type.out} (100%)
create mode 100644
regression-test/data/external_table_p0/iceberg/write/test_iceberg_write_parquet_compression.out
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q01.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q02.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q03.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q04.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q05.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q06.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q07.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q08.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q09.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q10.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q11.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q12.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q13.out (100%)
copy regression-test/data/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q14.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q15.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q16.out (100%)
copy regression-test/data/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q17.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q18.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q19.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q20.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q21.out (100%)
copy regression-test/data/{tpch_sf0.1_p1/spill =>
tpch_sf0.1_constraints_p1/sql}/q22.out (100%)
delete mode 100644
regression-test/data/variant_p0/with_index/test_array_inverted_index_profile.out
create mode 100644
regression-test/suites/auth_p0/test_http_node_action_auth.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/write_index_only/test_file_cache_write_index_file_only.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/write_index_only/test_file_cache_write_index_file_only_compaction_segment_data.groovy
create mode 100644
regression-test/suites/cloud_p0/cache/write_index_only/test_file_cache_write_index_file_only_packed_file.groovy
rename
regression-test/suites/external_table_p0/export/hive_read/parquet/{test_hive_read_parquet_comlex_type.groovy
=> test_hive_read_parquet_complex_type.groovy} (99%)
create mode 100644
regression-test/suites/external_table_p0/hive/test_workload_policy_remote_scan_bytes.groovy
create mode 100644
regression-test/suites/external_table_p0/iceberg/write/test_iceberg_write_parquet_compression.groovy
create mode 100644
regression-test/suites/insert_p0/group_commit/test_group_commit_prepare_lost_row.groovy
create mode 100644
regression-test/suites/load_p0/stream_load/test_group_commit_stream_load_high_concurrency_async.groovy
create mode 100644
regression-test/suites/nereids_p0/local_shuffle/test_local_shuffle_bucket_upgrade.groovy
copy
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadMetricType.java
=>
regression-test/suites/nereids_rules_p0/merge_one_row_relation/merge_one_row_relation_into_union.groovy
(65%)
create mode 100644
regression-test/suites/nereids_rules_p0/push_down_limit_distinct/push_down_limit_distinct_through_union.groovy
create mode 100644
regression-test/suites/query_p0/expr_zonemap/test_expr_zonemap_pruning.groovy
create mode 100644
regression-test/suites/query_p1/expr_zonemap/test_expr_zonemap_pruning_p1.groovy
create mode 100644
regression-test/suites/recursive_cte/rec_cte_parallel_targets.groovy
copy regression-test/suites/{nereids_rules_p0/mv/tpch =>
tpch_sf0.1_constraints_p1}/ddl/create_table.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/ddl/customer.sql (62%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/customer_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/ddl/lineitem.sql (55%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/lineitem_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/ddl/nation.sql (52%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/nation_delete.sql (100%)
create mode 100644
regression-test/suites/tpch_sf0.1_constraints_p1/ddl/orders.sql
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/orders_delete.sql (100%)
create mode 100644
regression-test/suites/tpch_sf0.1_constraints_p1/ddl/part.sql
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/part_delete.sql (100%)
create mode 100644
regression-test/suites/tpch_sf0.1_constraints_p1/ddl/partsupp.sql
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/partsupp_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/ddl/region.sql (59%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/region_delete.sql (100%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/revenue1.sql (100%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/revenue1_delete.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/ddl/supplier.sql (58%)
copy regression-test/suites/{cloud_p0/multi_cluster/async_copy_into =>
tpch_sf0.1_constraints_p1}/ddl/supplier_delete.sql (100%)
create mode 100644 regression-test/suites/tpch_sf0.1_constraints_p1/load.groovy
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q01.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q02.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q03.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q04.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q05.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q06.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q07.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q08.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q09.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q10.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q11.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q12.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q13.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q14.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q15.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q16.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q17.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q18.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q19.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q20.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q21.sql (100%)
copy regression-test/suites/{tpch_sf0.1_p1 =>
tpch_sf0.1_constraints_p1}/sql/q22.sql (100%)
delete mode 100644
regression-test/suites/variant_p0/with_index/test_array_inverted_index_profile.groovy
create mode 100644 thirdparty/patches/apache-arrow-17.0.0-lzo.patch
create mode 100644
thirdparty/patches/brpc-1.4.0-fix-agent-combiner-thread-safety.patch
create mode 100644 tools/tpch-tools/constraints/drop-fk-constraints.sql
create mode 100644 tools/tpch-tools/constraints/drop-pk-uk-constraints.sql
create mode 100644 tools/tpch-tools/constraints/tpch-fd.sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
