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 951d4384673 [refactor](catalog) Catalog spi 11 hive (#65473)
omit c0865b021b0 [doc](catalog) HANDOFF: $position_deletes port done; e2e
is the only remaining flip gate
omit 2e49827ecdd [feat](catalog) P6.6: support the iceberg
$position_deletes system table on the connector SPI
omit 95125c573b0 [doc](catalog) HANDOFF: point next step at the
$position_deletes port design (T0 evidence in)
omit af0f0582bdf [doc](catalog) P6.6 $position_deletes connector port:
research notes + design (T0 evidence in, ready to implement)
omit fb67a1a7f51 [doc](catalog) HANDOFF: rebase to upstream 30a44d61a8a +
register $position_deletes connector gap as flip blocker
omit c215c4c77c5 [fix](build) fix parallel -T shade race in
fe-connector-paimon-hive-shade
omit b8c8accadfd [fix](catalog) reconcile upstream #65365 with connector
SPI after rebase to 4f48ccfaa7d
omit a319b978a81 [doc](catalog) P6.6-C6 #63068 HANDOFF: record
cache-leakage data-flow test + Task 0 retained-base verify
omit e7e73b34094 [feat](catalog) P6.6-C6 #63068 FE: re-migrate
ExternalDatabaseSessionContextTest (cross-user cache-leakage data-flow)
omit 7d1d03aabbb [doc](catalog) P6.6-C6 #63068 OIDC session migration:
design + research notes + HANDOFF (Tasks 0-7 DONE)
omit d6adf3b7f17 [feat](catalog) P6.6-C6 #63068 iceberg: per-user REST
session routing (metadata + scan/write/procedure)
omit cab9aab728c [feat](catalog) P6.6-C6 #63068 FE: capability-gated
credential injection + per-user cache bypass
omit 6f085e4b4ff [feat](catalog) P6.6-C6 #63068 SPI: neutral
delegated-credential DTO + user-session capability
omit 441917635ea [fix](catalog) tier3 #65094: preserve external-table
top-level column-name case on the read path
omit 2ac353fc67f [fix](catalog) port upstream #65332/#65094 datasource
fixes into SPI connectors
omit 01d23afd17c [fix](catalog) P4 maxcompute: drop dangling legacy
MaxComputeExternalTableTest after rebase
omit 743e5f101a6 [fix](catalog) jdbc: keep driver classloaders alive per
URL to stop Metaspace leak
omit 442a1081e6d [refactor](catalog) P6 iceberg: migrate to catalog SPI +
cutover + remove legacy fe-core subsystem (#64688)
omit 60f99269991 [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
omit f52c9672018 [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
omit c276e955683 [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
omit 8b4394a30da update P5 handoff and fix compile issue
omit 85a71916eea [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
omit 6acfc131e42 [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
omit 20fbd1916d2 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
omit 323cf213b6b [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
omit 637c0cf6cd2 [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
omit 82dc967dc2c [doc](connector) add project tracking system for catalog
SPI migration
add ec716229c84 [fix](be) Fix ORC V2 pushdown correctness and fallback
(#65562)
add f59397efd94 [fix](regression) Extend rebalance warm-up wait timeout
(#65604)
add 82e90efae65 [feat](job) show first error message for routine load
(#65553)
add 296d2a29964 [fix](be) Fix lazy reads for default value columns (#65603)
add 3b0aed45edf [fix](regression) Fix agg_sync_mv data path (#65538)
add 9673a500366 [fix](ci) Generate local review context and randomize
Codex auth (#65626)
add ae61e64702e [refactor](fe) Extract forward handling and bound the
group commit BE cache (#65607)
add f421e9df50d [chore](s3) Adjust S3 SlowDown retry configurable (#65508)
add 2e1d44a6b8f [fix](storage) fix DOUBLE/FLOAT zone-map (#65302)
add 77cf85a7aab [fix](regression) Avoid midnight race in auto recycle case
(#65435)
add df6a3242797 [fix](binlog) Support hidden key columns in row binlog
(#65076)
add e38455feb61 [fix](regression) Handle loopback export hosts locally
(#65444)
add 348de6e920c [test](fe) Isolate cloud frontend service test (#65577)
add 52729f1969e [fix](fe) Fix row binlog schema change test metadata
(#65663)
add 35f98129184 [fix](regression) Support forced replica golden in show
create case (#65543)
add e7803ce2147 [fix](regression) wait for version headroom before schema
change (#65373)
add 897fd0f9a35 [fix](test) Isolate cloud mode in colocation proc test
(#65515)
add 68938c5ca31 [fix](s3) Add S3 rate limit observability (#64038)
add c8b81647776 [improvement](be) Track Python UDF Arrow memory
allocations (#65361)
add b2ed598e8a7 [fix](Nereids) Add shapeInfo() override in
AggregateFunction to preserve table qualifier in EXPLAIN output (#65264)
add dae78849123 [chore](ci) Update code review model configuration (#65643)
add 307bf9e333f [Refactor](bitmap) Refactor BitmapValue small_set and
roaring_bitmap (#65421)
add c3e2004ebc9 [fix](iceberg) Guard synthesized slots in
_create_column_ids (#65610)
add b440a3f6f94 [fix](be) Harden FileScannerV2 filtering and profiling
(#65624)
add e230e078bc6 [feature](fe) Let an FE declare and broadcast its local
resource group (#65611)
add a6745ebc5cb [improvement] (table stream) refactor misleading name
StreamTableInfo(#65636)
add 27357c32063 [fix](be) Track block bloom filter memory (#65578)
add 163a10a3c44 [improvement](fe) add fe_meta_auth_token for FE
meta-service internal HTTP auth (#65551)
add f1a168db108 [fix](be) Fix nested array_map lambda captures (#64563)
add c70cf12a841 [opt](regression) remove duplicated tpcds 64 plan shape
check (#65652)
add e7b0e4e22d5 [fix](regression) Run restore auth case non-concurrently
(#65668)
add b4aa99ecbd4 [fix](regression) Make incomplete commit info injection
deterministic (#65633)
add e40d599a2ac [fix](be) Fix row binlog writer test metadata (#65686)
add 52cdeb6c4cf [fix](regression) Wait for show config output before
parsing (#65486)
add 532042c4dad [fix](regression) Drop view before its base tables in
test_join5 (#65455)
add d983219f5bb [fix](regression) Restore time zone after test_tz_load
(#65412)
add 10de7ac0614 [fix](test) stabilize file cache statistics case (#65666)
add fd16ebdc331 [fix](regression) Select compaction profile BE by tablet
replica (#65552)
add 87d57a84729 [feat](fs) Migrate HDFS properties into fe-filesystem; fix
OSS listing/URI issues (#64695)
add 5abd40cc536 [fix](regression) Disable auto compaction for physical row
inspections (#65536)
add db0b39a4f1a [fix](be) Make replica fault injection deterministic
(#65627)
add 728d362448a [fix](test) Stabilize BDB unmatched transaction test
(#65587)
add fe3175e35c4 [doc](connector) add project tracking system for catalog
SPI migration
add 4235de9bb8d [feat](connector) P0 SPI baseline + DDL/Partition + import
gate (T03-T27) (#63582)
add ea61b536723 [P1-T03-T05] route plugin-driven scans first in nereids
translator (#63641)
add dfc58d6e794 [feat](connector) P2 migrate trino-connector to catalog
SPI (T01-T13) (#64096)
add 6021582d496 [feat](connector) P3 hudi connector hardening + test
baseline + dispatch design (hybrid, T02-T08) (#64143)
add e0703a557ac [refactor](connector) P4 maxcompute: remove legacy
subsystem from fe-core + make fe-core odps-free (T07-T09) (#64300)
add 3ab9005a4ba update P5 handoff and fix compile issue
add 65ddc62a550 [refactor](catalog) P5 paimon: migrate to catalog SPI +
cutover (#64446) (#64446)
add 3effe0b416d [refactor](catalog) P5 paimon: remove legacy subsystem
from fe-core + make fe-core paimon-SDK-free (T29) (#64653)
add 5e005323ceb [refactor](catalog) P3b: consolidate kerberos
authentication into fe-kerberos (#64655)
add 8450d7c4bd0 [refactor](catalog) P6 iceberg: migrate to catalog SPI +
cutover + remove legacy fe-core subsystem (#64688)
add 3b8d5dde804 [fix](catalog) jdbc: keep driver classloaders alive per
URL to stop Metaspace leak
add 3d8e8e17a27 [fix](catalog) P4 maxcompute: drop dangling legacy
MaxComputeExternalTableTest after rebase
add 843844aa6a9 [fix](catalog) port upstream #65332/#65094 datasource
fixes into SPI connectors
add dbd1b996ad8 [fix](catalog) tier3 #65094: preserve external-table
top-level column-name case on the read path
add 1afb9c18cc4 [feat](catalog) P6.6-C6 #63068 SPI: neutral
delegated-credential DTO + user-session capability
add a9701b55f4b [feat](catalog) P6.6-C6 #63068 FE: capability-gated
credential injection + per-user cache bypass
add 4f80cfb6f2e [feat](catalog) P6.6-C6 #63068 iceberg: per-user REST
session routing (metadata + scan/write/procedure)
add 65f0628ffbc [doc](catalog) P6.6-C6 #63068 OIDC session migration:
design + research notes + HANDOFF (Tasks 0-7 DONE)
add dda855c608f [feat](catalog) P6.6-C6 #63068 FE: re-migrate
ExternalDatabaseSessionContextTest (cross-user cache-leakage data-flow)
add 7ecb54860aa [doc](catalog) P6.6-C6 #63068 HANDOFF: record
cache-leakage data-flow test + Task 0 retained-base verify
add a3b61ca903d [fix](catalog) reconcile upstream #65365 with connector
SPI after rebase to 4f48ccfaa7d
add 64a3228ffc6 [fix](build) fix parallel -T shade race in
fe-connector-paimon-hive-shade
add e931e9bc750 [doc](catalog) HANDOFF: rebase to upstream 30a44d61a8a +
register $position_deletes connector gap as flip blocker
add 046ccc229b6 [doc](catalog) P6.6 $position_deletes connector port:
research notes + design (T0 evidence in, ready to implement)
add 09d62d1a77c [doc](catalog) HANDOFF: point next step at the
$position_deletes port design (T0 evidence in)
add 9520659bf4f [feat](catalog) P6.6: support the iceberg
$position_deletes system table on the connector SPI
add 8f22dd86ad9 [doc](catalog) HANDOFF: $position_deletes port done; e2e
is the only remaining flip gate
add afb59b58a0a [refactor](catalog) Catalog spi 11 hive (#65473)
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 (951d4384673)
\
N -- N -- N refs/heads/branch-catalog-spi (afb59b58a0a)
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:
.github/scripts/emit_litefuse_otel_io.py | 2 +-
.github/workflows/code-review-runner.yml | 92 +-
be/src/common/config.cpp | 3 +
be/src/common/config.h | 1 +
.../data_type_serde/data_type_number_serde.cpp | 16 +-
be/src/core/value/bitmap_value.h | 1287 ++++++++++++------
be/src/exec/scan/file_scanner_v2.cpp | 10 +-
be/src/exec/sink/writer/vtablet_writer.cpp | 10 +-
.../aggregate/aggregate_function_python_udaf.cpp | 11 +-
be/src/exprs/block_bloom_filter_impl.cc | 23 +-
be/src/exprs/function/function_bitmap.cpp | 34 +-
be/src/exprs/function/function_bitmap_min_or_max.h | 12 +-
be/src/exprs/function/function_python_udf.cpp | 4 +-
.../lambda_function/lambda_execution_context.h | 116 ++
be/src/exprs/lambda_function/lambda_function.h | 2 +-
.../exprs/lambda_function/varray_map_function.cpp | 245 ++--
.../exprs/lambda_function/varray_sort_function.cpp | 179 ++-
.../exprs/table_function/python_udtf_function.cpp | 5 +-
be/src/exprs/vcolumn_ref.h | 60 +-
be/src/exprs/vexpr_context.cpp | 12 +
be/src/exprs/vexpr_context.h | 39 +-
be/src/exprs/vlambda_function_call_expr.h | 2 +-
be/src/exprs/vlambda_function_expr.h | 14 +-
be/src/exprs/vslot_ref.h | 1 +
be/src/format/table/iceberg_reader.cpp | 36 +-
be/src/format_v2/column_mapper.cpp | 32 +
be/src/format_v2/orc/orc_reader.cpp | 78 +-
be/src/format_v2/orc/orc_search_argument.cpp | 589 ++++----
be/src/format_v2/orc/orc_search_argument.h | 7 +-
be/src/format_v2/parquet/parquet_statistics.cpp | 10 +-
.../parquet/reader/scalar_column_reader.cpp | 25 +-
be/src/format_v2/table/iceberg_reader.cpp | 17 +-
.../schema_routine_load_job_scanner.cpp | 4 +
be/src/io/fs/azure_obj_storage_client.cpp | 5 +-
be/src/io/fs/s3_obj_storage_client.cpp | 20 +-
be/src/io/fs/stream_sink_file_writer.cpp | 68 +-
be/src/io/fs/stream_sink_file_writer.h | 2 +
be/src/load/stream_load/stream_load_executor.cpp | 7 +-
be/src/storage/segment/column_reader.cpp | 12 +
.../storage/segment/row_binlog_segment_writer.cpp | 144 +-
be/src/storage/segment/row_binlog_segment_writer.h | 12 +-
be/src/udf/python/python_udaf_client.cpp | 13 +-
be/src/util/coding.h | 15 +
be/src/util/s3_util.cpp | 19 +-
be/src/util/s3_util.h | 1 +
be/test/core/block/column_complex_test.cpp | 4 +-
.../data_type_serde_number_test.cpp | 51 +
be/test/core/value/bitmap_value_test.cpp | 449 ++++++-
be/test/exec/scan/file_scanner_v2_test.cpp | 11 +-
be/test/exprs/bloom_filter_func_test.cpp | 27 +
.../lambda_function/array_map_function_test.cpp | 1409 ++++++++++++++++++++
be/test/exprs/vcolumn_ref_test.cpp | 148 ++
.../iceberg_reader_create_column_ids_test.cpp | 95 +-
be/test/format_v2/column_mapper_test.cpp | 39 +-
be/test/format_v2/orc/orc_reader_test.cpp | 646 ++++++++-
.../parquet/parquet_reader_control_test.cpp | 54 +
be/test/format_v2/parquet/parquet_reader_test.cpp | 2 +-
be/test/format_v2/parquet/parquet_scan_test.cpp | 2 +-
be/test/format_v2/table_reader_test.cpp | 9 +-
be/test/io/fs/stream_sink_file_writer_test.cpp | 56 +-
be/test/olap/rowset/group_rowset_writer_test.cpp | 126 +-
be/test/storage/olap_type_test.cpp | 518 ++-----
be/test/storage/segment/column_reader_test.cpp | 120 ++
.../segment/row_binlog_segment_writer_test.cpp | 157 +++
be/test/storage/segment/zone_map_index_test.cpp | 80 +-
bin/start_fe.sh | 16 +-
build.sh | 4 +-
cloud/src/common/config.h | 5 +-
cloud/src/recycler/azure_obj_client.cpp | 9 +-
cloud/src/recycler/s3_accessor.cpp | 29 +-
cloud/src/recycler/s3_obj_client.cpp | 29 +-
cloud/test/s3_rate_limiter_test.cpp | 81 +-
common/cpp/obj_retry_strategy.cpp | 17 +
common/cpp/obj_retry_strategy.h | 2 +
common/cpp/token_bucket_rate_limiter.cpp | 91 +-
common/cpp/token_bucket_rate_limiter.h | 38 +-
.../main/java/org/apache/doris/common/Config.java | 21 +-
.../java/org/apache/doris/common/ConfigBase.java | 20 +-
.../java/org/apache/doris/common/ConfigTest.java | 58 +
.../iceberg/FakeS3CompatibleStorageProperties.java | 7 +
.../src/main/java/org/apache/doris/DorisFE.java | 49 +-
.../apache/doris/alter/SchemaChangeHandler.java | 6 +-
.../apache/doris/analysis/ExprToThriftVisitor.java | 1 +
.../java/org/apache/doris/backup/Repository.java | 5 +-
.../main/java/org/apache/doris/catalog/Env.java | 20 +
.../java/org/apache/doris/catalog/OlapTable.java | 5 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 1 +
.../doris/catalog/stream/BaseTableStream.java | 12 +-
...ableInfo.java => TableStreamBaseTableInfo.java} | 10 +-
.../transaction/CloudGlobalTransactionMgr.java | 6 +-
.../apache/doris/cloud/transaction/TxnUtil.java | 3 +
.../doris/common/proc/FrontendsProcNode.java | 1 +
.../org/apache/doris/common/util/HttpURLUtil.java | 10 +
.../apache/doris/fs/SpiSwitchingFileSystem.java | 288 +++-
.../doris/fs/StoragePropertiesConverter.java | 9 +-
.../org/apache/doris/httpv2/meta/MetaService.java | 77 +-
.../doris/httpv2/rest/manager/NodeAction.java | 13 +-
.../apache/doris/httpv2/restv2/ImportAction.java | 5 +-
.../main/java/org/apache/doris/load/ExportMgr.java | 6 +-
.../org/apache/doris/load/GroupCommitManager.java | 58 +-
.../org/apache/doris/load/loadv2/BulkLoadJob.java | 14 +
.../routineload/RLTaskTxnCommitAttachment.java | 15 +
.../doris/load/routineload/RoutineLoadJob.java | 35 +-
.../java/org/apache/doris/master/MetaHelper.java | 2 +-
.../apache/doris/nereids/properties/OrderKey.java | 4 +
.../trees/expressions/AggregateExpression.java | 9 +
.../doris/nereids/trees/expressions/Alias.java | 5 +
.../trees/expressions/ArrayItemReference.java | 5 +
.../doris/nereids/trees/expressions/Between.java | 5 +
.../doris/nereids/trees/expressions/CaseWhen.java | 12 +
.../doris/nereids/trees/expressions/Cast.java | 5 +
.../nereids/trees/expressions/InPredicate.java | 7 +
.../doris/nereids/trees/expressions/IsFalse.java | 5 +
.../doris/nereids/trees/expressions/IsNull.java | 5 +
.../doris/nereids/trees/expressions/IsTrue.java | 5 +
.../doris/nereids/trees/expressions/Like.java | 9 +
.../doris/nereids/trees/expressions/Match.java | 6 +
.../doris/nereids/trees/expressions/Not.java | 5 +
.../nereids/trees/expressions/OrderExpression.java | 5 +
.../trees/expressions/SessionVarGuardExpr.java | 8 +-
.../trees/expressions/StringRegexPredicate.java | 5 +
.../doris/nereids/trees/expressions/TryCast.java | 5 +
.../nereids/trees/expressions/UnaryOperator.java | 5 +
.../nereids/trees/expressions/WhenClause.java | 5 +
.../trees/expressions/WindowExpression.java | 18 +
.../trees/expressions/functions/BoundFunction.java | 14 +
.../functions/agg/AggregateFunction.java | 16 +
.../plans/commands/ShowRoutineLoadCommand.java | 1 +
.../commands/insert/InsertIntoTVFCommand.java | 11 +-
.../java/org/apache/doris/qe/MasterOpExecutor.java | 4 +-
.../java/org/apache/doris/qe/SessionVariable.java | 6 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 5 +-
.../apache/doris/service/FrontendServiceImpl.java | 155 ++-
.../java/org/apache/doris/system/Frontend.java | 13 +
.../apache/doris/system/FrontendHbResponse.java | 12 +-
.../java/org/apache/doris/system/HeartbeatMgr.java | 5 +-
.../FrontendsTableValuedFunction.java | 3 +-
.../doris/alter/SchemaChangeHandlerTest.java | 41 +
.../doris/analysis/ExprToThriftBehaviorTest.java | 16 +
.../catalog/OlapTableRowBinlogSchemaTest.java | 56 +-
.../stream/TableStreamBaseTableInfoTest.java | 67 +
.../transaction/CloudGlobalTransactionMgrTest.java | 50 +
.../common/proc/ColocationGroupProcDirTest.java | 30 +-
.../apache/doris/common/util/HttpURLUtilTest.java | 59 +
.../doris/fs/SpiSwitchingFileSystemTest.java | 198 +++
.../fs/StoragePropertiesConverterHdfsDirTest.java | 60 +
.../apache/doris/httpv2/meta/MetaServiceTest.java | 295 ++++
.../doris/journal/bdbje/BDBEnvironmentTest.java | 51 +-
.../doris/load/routineload/RoutineLoadJobTest.java | 39 +
.../trees/expressions/ExpressionShapeInfoTest.java | 57 +
.../plans/commands/ShowRoutineLoadCommandTest.java | 2 +
.../service/FrontendServiceImplCloudTest.java | 78 ++
.../doris/service/FrontendServiceImplTest.java | 48 -
.../S3CompatibleFileSystemProperties.java | 12 +
.../S3CompatibleFileSystemPropertiesTest.java | 6 +
.../apache/doris/filesystem/cos/CosFileSystem.java | 2 +-
.../filesystem/cos/CosFileSystemProperties.java | 6 +
.../apache/doris/filesystem/cos/CosObjStorage.java | 39 +-
.../pom.xml | 65 +-
.../doris/filesystem/hdfs/DFSFileSystem.java | 0
.../doris/filesystem/hdfs/HdfsConfigBuilder.java | 16 +-
.../doris/filesystem/hdfs/HdfsFileIterator.java | 0
.../doris/filesystem/hdfs/HdfsInputFile.java | 0
.../doris/filesystem/hdfs/HdfsOutputFile.java | 0
.../filesystem/hdfs/HdfsSeekableInputStream.java | 0
.../hdfs/properties/HdfsCompatibleProperties.java | 109 ++
.../hdfs/properties/HdfsConfigFileLoader.java | 62 +
.../hdfs/properties/HdfsPropertiesUtils.java | 268 ++++
.../filesystem/hdfs/properties/UserException.java} | 19 +-
.../filesystem/hdfs/DFSFileSystemEnvTest.java | 0
.../filesystem/hdfs/HdfsFileIteratorTest.java | 0
.../hdfs/HdfsSeekableInputStreamTest.java | 0
.../hdfs/KerberosHadoopAuthenticatorEnvTest.java | 0
fe/fe-filesystem/fe-filesystem-hdfs/pom.xml | 49 +-
.../filesystem/hdfs/HdfsFileSystemProvider.java | 39 +-
.../filesystem/hdfs/properties/HdfsProperties.java | 148 ++
.../filesystem/hdfs/HdfsConfigBuilderTest.java | 13 +-
.../hdfs/HdfsFileSystemProviderTest.java | 78 ++
.../hdfs/properties/HdfsPropertiesTest.java | 130 ++
.../pom.xml | 52 +-
.../src/main/assembly/plugin-zip.xml | 59 +
.../filesystem/jfs/JfsFileSystemProvider.java | 67 +
.../filesystem/jfs/properties/JfsProperties.java | 93 ++
....apache.doris.filesystem.spi.FileSystemProvider | 18 +
.../filesystem/jfs/JfsFileSystemProviderTest.java | 61 +
.../jfs/properties/JfsPropertiesTest.java | 54 +
.../apache/doris/filesystem/obs/ObsFileSystem.java | 2 +-
.../filesystem/obs/ObsFileSystemProperties.java | 6 +
.../apache/doris/filesystem/obs/ObsObjStorage.java | 30 +-
.../pom.xml | 52 +-
.../src/main/assembly/plugin-zip.xml | 59 +
.../filesystem/hdfs/OssHdfsFileSystemProvider.java | 103 ++
.../hdfs/properties/OssHdfsProperties.java | 184 +++
....apache.doris.filesystem.spi.FileSystemProvider | 18 +
.../hdfs/OssHdfsFileSystemProviderTest.java | 96 ++
.../hdfs/properties/OssHdfsPropertiesTest.java | 162 +++
.../apache/doris/filesystem/oss/OssFileSystem.java | 2 +-
.../filesystem/oss/OssFileSystemProperties.java | 6 +
.../filesystem/oss/OssFileSystemProvider.java | 28 +-
.../apache/doris/filesystem/oss/OssObjStorage.java | 96 +-
.../filesystem/oss/OssFileSystemProviderTest.java | 93 ++
.../doris/filesystem/oss/OssObjStorageTest.java | 75 ++
.../apache/doris/filesystem/s3/S3FileSystem.java | 4 +-
.../filesystem/s3/S3FileSystemProperties.java | 6 +
.../apache/doris/filesystem/s3/S3ObjStorage.java | 33 +-
.../java/org/apache/doris/filesystem/s3/S3Uri.java | 103 --
.../org/apache/doris/filesystem/s3/S3UriTest.java | 133 --
.../doris/filesystem/spi/ObjectStorageUri.java | 70 +-
.../filesystem/spi/S3CompatibleFileSystem.java | 18 +-
.../doris/filesystem/spi/ObjectStorageUriTest.java | 203 +++
.../filesystem/spi/S3CompatibleFileSystemTest.java | 179 +++
fe/fe-filesystem/pom.xml | 3 +
gensrc/proto/cloud.proto | 2 +
gensrc/thrift/Exprs.thrift | 4 +
gensrc/thrift/FrontendService.thrift | 3 +
...test_light_schema_change_lazy_pruned_struct.out | 13 +
.../data/empty_relation/eliminate_empty.out | 4 +-
.../adjust_nullable/test_agg_nullable.out | 2 +-
.../adjust_nullable/test_subquery_nullable.out | 20 +-
.../case_when_rules/test_case_when_rules.out | 8 +-
.../constant_propagation/constant_propagation.out | 64 +-
.../eliminate_not_null/eliminate_not_null.out | 14 +-
.../eliminate_outer_join/eliminate_outer_join.out | 20 +-
.../test_disable_nereids_expression_rule.out | 2 +-
...simplify_comparison_predicate_int_vs_double.out | 36 +-
.../expression/test_simplify_range.out | 2 +-
.../push_down_filter_other_condition.out | 2 +-
.../filter_push_down/push_filter_inside_join.out | 36 -
.../filter_push_down/push_filter_through.out | 16 +-
.../extend_infer_equal_predicate.out | 196 +--
.../infer_predicate/infer_intersect_except.out | 14 +-
.../infer_predicate/infer_unequal_predicates.out | 4 +-
.../infer_predicate/pull_up_predicate_literal.out | 90 +-
.../infer_predicate/pull_up_predicate_set_op.out | 34 +-
.../join_extract_or_from_case_when.out | 146 +-
.../limit_push_down/limit_push_down.out | 2 +-
.../limit_push_down/merge_topn_prefix_key.out | 1 +
.../max_min_filter_push_down.out | 2 +-
.../predicate_infer/infer_predicate.out | 12 +-
.../pull_up_join_from_union.out | 2 +-
.../extract_from_disjunction_in_join.out | 32 +-
.../push_down_filter_through_window.out | 2 +-
.../data/nereids_rules_p0/sumRewrite.out | 124 +-
.../add_project_for_unique_function.out | 45 +-
.../unique_function/agg_with_unique_function.out | 46 +-
.../between_with_unique_function.out | 2 +-
...filter_through_project_with_unique_function.out | 20 +-
...nfer_predicates_set_op_with_unique_function.out | 8 +-
.../merge_project_with_unique_function.out | 40 +-
...join_condition_for_nlj_with_unique_function.out | 14 +-
...own_filter_through_agg_with_unique_function.out | 4 +-
...ilter_through_generate_with_unique_function.out | 4 +-
...wn_filter_through_join_with_unique_function.out | 24 +-
...through_partition_topn_with_unique_function.out | 2 +-
..._filter_through_window_with_unique_function.out | 2 +-
...n_join_other_condition_with_unique_function.out | 7 +-
...ush_project_into_union_with_unique_function.out | 6 +-
.../data/nereids_syntax_p0/analyze_agg.out | 4 +-
.../data/query_p0/eager_agg/eager_agg.out | 2 +-
.../eliminate_outer_join/eliminate_outer_join.out | 28 +-
regression-test/data/query_p0/hint/fix_leading.out | 2 +-
.../test_physical_translator.out | 6 +-
.../array_functions/test_nested_array_map.out | 13 +
.../bitmap_functions/test_bitmap_function.out | 21 +
.../adjust_virtual_slot_nullable.out | 2 +-
.../data/shape_check/clickbench/query11.out | 2 +-
.../data/shape_check/clickbench/query12.out | 2 +-
.../data/shape_check/clickbench/query13.out | 2 +-
.../data/shape_check/clickbench/query14.out | 2 +-
.../data/shape_check/clickbench/query15.out | 2 +-
.../data/shape_check/clickbench/query2.out | 2 +-
.../data/shape_check/clickbench/query21.out | 2 +-
.../data/shape_check/clickbench/query22.out | 2 +-
.../data/shape_check/clickbench/query23.out | 2 +-
.../data/shape_check/clickbench/query24.out | 2 +-
.../data/shape_check/clickbench/query25.out | 2 +-
.../data/shape_check/clickbench/query26.out | 2 +-
.../data/shape_check/clickbench/query27.out | 2 +-
.../data/shape_check/clickbench/query28.out | 2 +-
.../data/shape_check/clickbench/query29.out | 2 +-
.../data/shape_check/clickbench/query31.out | 2 +-
.../data/shape_check/clickbench/query32.out | 2 +-
.../data/shape_check/clickbench/query37.out | 2 +-
.../data/shape_check/clickbench/query38.out | 2 +-
.../data/shape_check/clickbench/query39.out | 2 +-
.../data/shape_check/clickbench/query41.out | 2 +-
.../data/shape_check/clickbench/query8.out | 2 +-
.../data/shape_check/ssb_sf100/shape/q3.3.out | 4 +-
.../data/shape_check/ssb_sf100/shape/q3.4.out | 4 +-
.../data/shape_check/ssb_sf100/shape/q4.1.out | 2 +-
.../data/shape_check/ssb_sf100/shape/q4.2.out | 4 +-
.../data/shape_check/ssb_sf100/shape/q4.3.out | 2 +-
.../tpcds_sf100/constraints/query23.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query1.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query10.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query11.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query12.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query13.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query15.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query16.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query17.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query18.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query19.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query20.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query21.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query23.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query24.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query27.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query29.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query30.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query31.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query32.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query34.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query36.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query37.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query39.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query4.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query41.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query44.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query45.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query46.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query47.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query48.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query53.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query56.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query57.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query58.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query6.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query63.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query64.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query65.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query66.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query68.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query69.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query71.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query72.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query73.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query74.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query75.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query76.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query78.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query79.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query8.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query81.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query82.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query83.out | 6 +-
.../tpcds_sf100/noStatsRfPrune/query85.out | 8 +-
.../tpcds_sf100/noStatsRfPrune/query88.out | 16 +-
.../tpcds_sf100/noStatsRfPrune/query89.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query91.out | 4 +-
.../tpcds_sf100/noStatsRfPrune/query92.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query94.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query95.out | 2 +-
.../tpcds_sf100/noStatsRfPrune/query98.out | 2 +-
.../tpcds_sf100/no_stats_shape/query1.out | 2 +-
.../tpcds_sf100/no_stats_shape/query10.out | 2 +-
.../tpcds_sf100/no_stats_shape/query11.out | 2 +-
.../tpcds_sf100/no_stats_shape/query12.out | 2 +-
.../tpcds_sf100/no_stats_shape/query13.out | 8 +-
.../tpcds_sf100/no_stats_shape/query15.out | 2 +-
.../tpcds_sf100/no_stats_shape/query16.out | 4 +-
.../tpcds_sf100/no_stats_shape/query17.out | 4 +-
.../tpcds_sf100/no_stats_shape/query18.out | 4 +-
.../tpcds_sf100/no_stats_shape/query19.out | 2 +-
.../tpcds_sf100/no_stats_shape/query20.out | 2 +-
.../tpcds_sf100/no_stats_shape/query21.out | 2 +-
.../tpcds_sf100/no_stats_shape/query23.out | 8 +-
.../tpcds_sf100/no_stats_shape/query24.out | 2 +-
.../tpcds_sf100/no_stats_shape/query27.out | 2 +-
.../tpcds_sf100/no_stats_shape/query29.out | 2 +-
.../tpcds_sf100/no_stats_shape/query30.out | 2 +-
.../tpcds_sf100/no_stats_shape/query31.out | 8 +-
.../tpcds_sf100/no_stats_shape/query32.out | 2 +-
.../tpcds_sf100/no_stats_shape/query34.out | 6 +-
.../tpcds_sf100/no_stats_shape/query36.out | 2 +-
.../tpcds_sf100/no_stats_shape/query37.out | 2 +-
.../tpcds_sf100/no_stats_shape/query39.out | 4 +-
.../tpcds_sf100/no_stats_shape/query4.out | 4 +-
.../tpcds_sf100/no_stats_shape/query41.out | 2 +-
.../tpcds_sf100/no_stats_shape/query44.out | 4 +-
.../tpcds_sf100/no_stats_shape/query45.out | 4 +-
.../tpcds_sf100/no_stats_shape/query46.out | 6 +-
.../tpcds_sf100/no_stats_shape/query47.out | 4 +-
.../tpcds_sf100/no_stats_shape/query48.out | 6 +-
.../tpcds_sf100/no_stats_shape/query53.out | 6 +-
.../tpcds_sf100/no_stats_shape/query56.out | 6 +-
.../tpcds_sf100/no_stats_shape/query57.out | 4 +-
.../tpcds_sf100/no_stats_shape/query58.out | 4 +-
.../tpcds_sf100/no_stats_shape/query6.out | 2 +-
.../tpcds_sf100/no_stats_shape/query63.out | 6 +-
.../tpcds_sf100/no_stats_shape/query64.out | 6 +-
.../tpcds_sf100/no_stats_shape/query65.out | 2 +-
.../tpcds_sf100/no_stats_shape/query66.out | 4 +-
.../tpcds_sf100/no_stats_shape/query68.out | 6 +-
.../tpcds_sf100/no_stats_shape/query69.out | 2 +-
.../tpcds_sf100/no_stats_shape/query71.out | 2 +-
.../tpcds_sf100/no_stats_shape/query72.out | 2 +-
.../tpcds_sf100/no_stats_shape/query73.out | 6 +-
.../tpcds_sf100/no_stats_shape/query74.out | 2 +-
.../tpcds_sf100/no_stats_shape/query75.out | 8 +-
.../tpcds_sf100/no_stats_shape/query76.out | 6 +-
.../tpcds_sf100/no_stats_shape/query78.out | 2 +-
.../tpcds_sf100/no_stats_shape/query79.out | 2 +-
.../tpcds_sf100/no_stats_shape/query8.out | 4 +-
.../tpcds_sf100/no_stats_shape/query81.out | 2 +-
.../tpcds_sf100/no_stats_shape/query82.out | 2 +-
.../tpcds_sf100/no_stats_shape/query83.out | 6 +-
.../tpcds_sf100/no_stats_shape/query85.out | 8 +-
.../tpcds_sf100/no_stats_shape/query88.out | 16 +-
.../tpcds_sf100/no_stats_shape/query89.out | 4 +-
.../tpcds_sf100/no_stats_shape/query91.out | 4 +-
.../tpcds_sf100/no_stats_shape/query92.out | 2 +-
.../tpcds_sf100/no_stats_shape/query94.out | 2 +-
.../tpcds_sf100/no_stats_shape/query95.out | 2 +-
.../tpcds_sf100/no_stats_shape/query98.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query1.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query10.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query11.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query12.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query13.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query15.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query16.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query17.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query18.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query19.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query20.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query21.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query23.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query24.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query27.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query29.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query30.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query31.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query32.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query34.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query36.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query37.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query39.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query4.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query41.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query44.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query45.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query46.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query47.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query48.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query53.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query56.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query57.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query58.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query6.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query63.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query64.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query65.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query66.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query68.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query69.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query71.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query72.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query73.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query74.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query75.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query76.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query78.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query79.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query8.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query81.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query82.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query83.out | 6 +-
.../shape_check/tpcds_sf100/rf_prune/query85.out | 8 +-
.../shape_check/tpcds_sf100/rf_prune/query88.out | 16 +-
.../shape_check/tpcds_sf100/rf_prune/query89.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query91.out | 4 +-
.../shape_check/tpcds_sf100/rf_prune/query92.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query94.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query95.out | 2 +-
.../shape_check/tpcds_sf100/rf_prune/query98.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query1.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query10.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query11.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query12.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query13.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query15.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query16.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query17.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query18.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query19.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query20.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query21.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query23.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query24.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query27.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query29.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query30.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query31.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query32.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query34.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query36.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query37.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query39.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query4.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query41.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query44.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query45.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query46.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query47.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query48.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query53.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query56.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query57.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query58.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query6.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query63.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query64.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query65.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query66.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query68.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query69.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query71.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query72.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query73.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query74.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query75.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query76.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query78.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query79.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query8.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query81.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query82.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query83.out | 6 +-
.../data/shape_check/tpcds_sf100/shape/query85.out | 8 +-
.../data/shape_check/tpcds_sf100/shape/query88.out | 16 +-
.../data/shape_check/tpcds_sf100/shape/query89.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query91.out | 4 +-
.../data/shape_check/tpcds_sf100/shape/query92.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query94.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query95.out | 2 +-
.../data/shape_check/tpcds_sf100/shape/query98.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query13.out | 8 +-
.../tpcds_sf1000/bs_downgrade_shape/query19.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query44.out | 4 +-
.../tpcds_sf1000/bs_downgrade_shape/query45.out | 4 +-
.../tpcds_sf1000/bs_downgrade_shape/query56.out | 6 +-
.../tpcds_sf1000/bs_downgrade_shape/query6.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query68.out | 6 +-
.../tpcds_sf1000/bs_downgrade_shape/query8.out | 2 +-
.../tpcds_sf1000/bs_downgrade_shape/query91.out | 4 +-
.../tpcds_sf1000/bs_downgrade_shape/query95.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query1.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query10.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query12.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query13.out | 8 +-
.../shape_check/tpcds_sf1000/dphyper/query15.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query16.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query17.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query18.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query19.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query20.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query21.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query23.out | 8 +-
.../shape_check/tpcds_sf1000/dphyper/query24.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query29.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query30.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query31.out | 8 +-
.../shape_check/tpcds_sf1000/dphyper/query32.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query34.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query37.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query39.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query4.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query41.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query44.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query45.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query46.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query47.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query48.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query53.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query54.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query56.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query57.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query58.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query6.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query63.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query64.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query65.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query66.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query68.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query69.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query71.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query72.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query73.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query75.out | 8 +-
.../shape_check/tpcds_sf1000/dphyper/query76.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query78.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query79.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query8.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query81.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query82.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query83.out | 6 +-
.../shape_check/tpcds_sf1000/dphyper/query85.out | 8 +-
.../shape_check/tpcds_sf1000/dphyper/query88.out | 16 +-
.../shape_check/tpcds_sf1000/dphyper/query89.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query91.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query92.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query94.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query95.out | 2 +-
.../shape_check/tpcds_sf1000/dphyper/query97.out | 4 +-
.../shape_check/tpcds_sf1000/dphyper/query98.out | 2 +-
.../tpcds_sf1000/eliminate_empty/query10_empty.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query1.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query10.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query11.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query12.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query13.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query15.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query16.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query17.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query18.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query19.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query20.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query21.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query23.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query24.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query29.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query30.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query31.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query32.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query34.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query37.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query39.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query4.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query41.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query44.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query45.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query46.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query47.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query48.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query53.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query56.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query57.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query58.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query6.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query63.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query64.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query65.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query66.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query68.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query69.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query71.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query73.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query74.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query75.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query76.out | 6 +-
.../data/shape_check/tpcds_sf1000/hint/query78.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query79.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query8.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query81.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query82.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query85.out | 8 +-
.../data/shape_check/tpcds_sf1000/hint/query88.out | 16 +-
.../data/shape_check/tpcds_sf1000/hint/query89.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query91.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query92.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query94.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query95.out | 2 +-
.../data/shape_check/tpcds_sf1000/hint/query97.out | 4 +-
.../data/shape_check/tpcds_sf1000/hint/query98.out | 2 +-
.../data/shape_check/tpcds_sf1000/shape/query1.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query10.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query11.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query12.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query13.out | 8 +-
.../shape_check/tpcds_sf1000/shape/query15.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query16.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query17.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query18.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query19.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query20.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query21.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query23.out | 8 +-
.../shape_check/tpcds_sf1000/shape/query24.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query29.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query30.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query31.out | 8 +-
.../shape_check/tpcds_sf1000/shape/query32.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query34.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query37.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query39.out | 4 +-
.../data/shape_check/tpcds_sf1000/shape/query4.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query41.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query44.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query45.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query46.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query47.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query48.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query53.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query56.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query57.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query58.out | 4 +-
.../data/shape_check/tpcds_sf1000/shape/query6.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query63.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query64.out | 102 --
.../shape_check/tpcds_sf1000/shape/query65.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query66.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query68.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query69.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query71.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query72.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query73.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query74.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query75.out | 8 +-
.../shape_check/tpcds_sf1000/shape/query76.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query78.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query79.out | 2 +-
.../data/shape_check/tpcds_sf1000/shape/query8.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query81.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query82.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query83.out | 6 +-
.../shape_check/tpcds_sf1000/shape/query85.out | 8 +-
.../shape_check/tpcds_sf1000/shape/query88.out | 16 +-
.../shape_check/tpcds_sf1000/shape/query89.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query91.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query92.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query94.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query95.out | 2 +-
.../shape_check/tpcds_sf1000/shape/query97.out | 4 +-
.../shape_check/tpcds_sf1000/shape/query98.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query1.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query10.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query11.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query12.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query13.out | 8 +-
.../tpcds_sf1000_nopkfk/shape/query15.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query16.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query17.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query18.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query19.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query20.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query21.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query23.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query24.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query29.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query30.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query31.out | 8 +-
.../tpcds_sf1000_nopkfk/shape/query32.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query34.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query37.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query39.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query4.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query41.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query44.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query45.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query46.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query47.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query48.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query53.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query56.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query57.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query58.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query6.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query63.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query64.out | 102 --
.../tpcds_sf1000_nopkfk/shape/query65.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query66.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query68.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query69.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query71.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query72.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query73.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query74.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query75.out | 8 +-
.../tpcds_sf1000_nopkfk/shape/query76.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query78.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query79.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query8.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query81.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query82.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query83.out | 6 +-
.../tpcds_sf1000_nopkfk/shape/query85.out | 8 +-
.../tpcds_sf1000_nopkfk/shape/query88.out | 16 +-
.../tpcds_sf1000_nopkfk/shape/query89.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query91.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query92.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query94.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query95.out | 2 +-
.../tpcds_sf1000_nopkfk/shape/query97.out | 4 +-
.../tpcds_sf1000_nopkfk/shape/query98.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query1.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query10.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query11.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query12.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query13.out | 8 +-
.../shape_check/tpcds_sf10t_orc/shape/query15.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query16.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query17.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query18.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query19.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query20.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query21.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query23.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query24.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query27.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query29.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query30.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query31.out | 8 +-
.../shape_check/tpcds_sf10t_orc/shape/query32.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query34.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query36.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query37.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query39.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query4.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query41.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query44.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query45.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query46.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query47.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query48.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query53.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query56.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query57.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query58.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query6.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query63.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query64.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query65.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query66.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query68.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query69.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query71.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query72.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query73.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query74.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query75.out | 8 +-
.../shape_check/tpcds_sf10t_orc/shape/query76.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query78.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query79.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query8.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query81.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query82.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query83.out | 6 +-
.../shape_check/tpcds_sf10t_orc/shape/query85.out | 8 +-
.../shape_check/tpcds_sf10t_orc/shape/query88.out | 16 +-
.../shape_check/tpcds_sf10t_orc/shape/query89.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query91.out | 4 +-
.../shape_check/tpcds_sf10t_orc/shape/query92.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query94.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query95.out | 2 +-
.../shape_check/tpcds_sf10t_orc/shape/query98.out | 2 +-
.../check_point/probeShortcutFactor.out | 2 +-
.../data/shape_check/tpch_sf1000/dphyper/q12.out | 2 +-
.../data/shape_check/tpch_sf1000/dphyper/q13.out | 2 +-
.../data/shape_check/tpch_sf1000/dphyper/q16.out | 4 +-
.../data/shape_check/tpch_sf1000/dphyper/q17.out | 2 +-
.../data/shape_check/tpch_sf1000/dphyper/q19.out | 6 +-
.../data/shape_check/tpch_sf1000/dphyper/q2.out | 2 +-
.../tpch_sf1000/dphyper/q20-rewrite.out | 4 +-
.../data/shape_check/tpch_sf1000/dphyper/q20.out | 4 +-
.../data/shape_check/tpch_sf1000/dphyper/q21.out | 4 +-
.../data/shape_check/tpch_sf1000/dphyper/q22.out | 6 +-
.../data/shape_check/tpch_sf1000/dphyper/q7.out | 4 +-
.../data/shape_check/tpch_sf1000/dphyper/q9.out | 2 +-
.../data/shape_check/tpch_sf1000/hint/q12.out | 2 +-
.../data/shape_check/tpch_sf1000/hint/q13.out | 2 +-
.../data/shape_check/tpch_sf1000/hint/q17.out | 2 +-
.../data/shape_check/tpch_sf1000/hint/q19.out | 6 +-
.../data/shape_check/tpch_sf1000/hint/q7.out | 4 +-
.../data/shape_check/tpch_sf1000/hint/q9.out | 2 +-
.../tpch_sf1000/nostats_rf_prune/q12.out | 2 +-
.../tpch_sf1000/nostats_rf_prune/q13.out | 2 +-
.../tpch_sf1000/nostats_rf_prune/q16.out | 4 +-
.../tpch_sf1000/nostats_rf_prune/q17.out | 2 +-
.../tpch_sf1000/nostats_rf_prune/q19.out | 6 +-
.../tpch_sf1000/nostats_rf_prune/q2.out | 2 +-
.../tpch_sf1000/nostats_rf_prune/q20-rewrite.out | 4 +-
.../tpch_sf1000/nostats_rf_prune/q20.out | 4 +-
.../tpch_sf1000/nostats_rf_prune/q21.out | 4 +-
.../tpch_sf1000/nostats_rf_prune/q22.out | 4 +-
.../tpch_sf1000/nostats_rf_prune/q7.out | 4 +-
.../tpch_sf1000/nostats_rf_prune/q9.out | 2 +-
.../data/shape_check/tpch_sf1000/rf_prune/q12.out | 2 +-
.../data/shape_check/tpch_sf1000/rf_prune/q13.out | 2 +-
.../data/shape_check/tpch_sf1000/rf_prune/q16.out | 4 +-
.../data/shape_check/tpch_sf1000/rf_prune/q17.out | 2 +-
.../data/shape_check/tpch_sf1000/rf_prune/q19.out | 6 +-
.../data/shape_check/tpch_sf1000/rf_prune/q2.out | 2 +-
.../tpch_sf1000/rf_prune/q20-rewrite.out | 4 +-
.../data/shape_check/tpch_sf1000/rf_prune/q20.out | 4 +-
.../data/shape_check/tpch_sf1000/rf_prune/q21.out | 4 +-
.../data/shape_check/tpch_sf1000/rf_prune/q22.out | 4 +-
.../data/shape_check/tpch_sf1000/rf_prune/q7.out | 4 +-
.../data/shape_check/tpch_sf1000/rf_prune/q9.out | 2 +-
.../data/shape_check/tpch_sf1000/shape/q12.out | 2 +-
.../data/shape_check/tpch_sf1000/shape/q13.out | 2 +-
.../data/shape_check/tpch_sf1000/shape/q16.out | 4 +-
.../data/shape_check/tpch_sf1000/shape/q17.out | 2 +-
.../data/shape_check/tpch_sf1000/shape/q19.out | 6 +-
.../data/shape_check/tpch_sf1000/shape/q2.out | 2 +-
.../shape_check/tpch_sf1000/shape/q20-rewrite.out | 4 +-
.../data/shape_check/tpch_sf1000/shape/q20.out | 4 +-
.../data/shape_check/tpch_sf1000/shape/q21.out | 4 +-
.../data/shape_check/tpch_sf1000/shape/q22.out | 4 +-
.../data/shape_check/tpch_sf1000/shape/q7.out | 4 +-
.../data/shape_check/tpch_sf1000/shape/q9.out | 2 +-
.../shape_check/tpch_sf1000/shape_no_stats/q12.out | 2 +-
.../shape_check/tpch_sf1000/shape_no_stats/q13.out | 2 +-
.../shape_check/tpch_sf1000/shape_no_stats/q16.out | 4 +-
.../shape_check/tpch_sf1000/shape_no_stats/q17.out | 2 +-
.../shape_check/tpch_sf1000/shape_no_stats/q19.out | 6 +-
.../shape_check/tpch_sf1000/shape_no_stats/q2.out | 2 +-
.../tpch_sf1000/shape_no_stats/q20-rewrite.out | 4 +-
.../shape_check/tpch_sf1000/shape_no_stats/q20.out | 4 +-
.../shape_check/tpch_sf1000/shape_no_stats/q21.out | 4 +-
.../shape_check/tpch_sf1000/shape_no_stats/q22.out | 4 +-
.../shape_check/tpch_sf1000/shape_no_stats/q7.out | 4 +-
.../shape_check/tpch_sf1000/shape_no_stats/q9.out | 2 +-
.../test_show_create_table_and_views_nereids.out | 20 +-
.../regression/util/RemoteFileOperator.groovy | 32 +-
.../suites/auth_call/test_ddl_restore_auth.groovy | 2 +-
.../cloud_p0/multi_cluster/test_rebalance.groovy | 2 +-
.../test_compaction_profile_action.groovy | 9 +-
...t_light_schema_change_lazy_pruned_struct.groovy | 95 ++
.../datatype_p0/datetimev2/test_tz_load.groovy | 9 +-
.../cache/test_file_cache_statistics.groovy | 10 +-
.../tvf/test_frontends_tvf.groovy | 11 +-
...test_partial_update_publish_conflict_seq.groovy | 1 +
.../test_incomplete_commit_info.groovy | 22 +-
.../test_mow_table_with_format_v2.groovy | 4 +-
.../test_routine_load_first_error_msg.groovy | 127 ++
.../suites/meta_action_p0/test_dump_image.groovy | 1 +
.../test_simplify_comparison_predicate.groovy | 78 +-
.../infer_predicate/infer_intersect_except.groovy | 10 +-
.../mv/aggregate/agg_sync_mv.groovy | 4 +-
.../auto_partition/test_auto_new_recycle.groovy | 5 +-
.../suites/query_p0/join/test_join5.groovy | 2 +
.../array_functions/test_nested_array_map.groovy | 90 ++
.../bitmap_functions/test_bitmap_function.groovy | 13 +
.../row_binlog_p0/test_row_binlog_basic.groovy | 10 +-
.../test_schema_change_with_empty_rowset.groovy | 44 +-
.../tpcds_sf100/noStatsRfPrune/query64.groovy | 166 ---
.../tpcds_sf100/no_stats_shape/query64.groovy | 166 ---
.../tpcds_sf100/rf_prune/query64.groovy | 161 ---
.../shape_check/tpcds_sf100/shape/query64.groovy | 161 ---
.../shape_check/tpcds_sf1000/hint/query64.groovy | 286 ----
.../shape_check/tpcds_sf1000/shape/query64.groovy | 279 ----
.../tpcds_sf1000_nopkfk/shape/query64.groovy | 279 ----
.../tpcds_sf10t_orc/shape/query64.groovy | 166 ---
...test_show_create_table_and_views_nereids.groovy | 26 +-
.../test_auto_inc_replica_consistency.groovy | 1 +
.../test_f_seq_publish_read_from_old.groovy | 1 +
...xble_partial_update_publish_conflict_seq.groovy | 1 +
.../flexible/test_f_seq_read_from_old.groovy | 3 +-
...test_flexible_partial_update_delete_sign.groovy | 9 +-
.../test_flexible_partial_update_seq_col.groovy | 4 +-
.../test_p_seq_publish_read_from_old.groovy | 1 +
.../test_partial_update_seq_read_from_old.groovy | 3 +-
953 files changed, 13206 insertions(+), 6069 deletions(-)
create mode 100644 be/src/exprs/lambda_function/lambda_execution_context.h
create mode 100644 be/test/exprs/lambda_function/array_map_function_test.cpp
create mode 100644 be/test/exprs/vcolumn_ref_test.cpp
create mode 100644 be/test/storage/segment/row_binlog_segment_writer_test.cpp
rename
fe/fe-core/src/main/java/org/apache/doris/catalog/stream/{StreamTableInfo.java
=> TableStreamBaseTableInfo.java} (94%)
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/catalog/stream/TableStreamBaseTableInfoTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/fs/StoragePropertiesConverterHdfsDirTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/httpv2/meta/MetaServiceTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/ExpressionShapeInfoTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/service/FrontendServiceImplCloudTest.java
copy fe/fe-filesystem/{fe-filesystem-hdfs => fe-filesystem-hdfs-base}/pom.xml
(66%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/main/java/org/apache/doris/filesystem/hdfs/DFSFileSystem.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/main/java/org/apache/doris/filesystem/hdfs/HdfsConfigBuilder.java
(80%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/main/java/org/apache/doris/filesystem/hdfs/HdfsFileIterator.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/main/java/org/apache/doris/filesystem/hdfs/HdfsInputFile.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/main/java/org/apache/doris/filesystem/hdfs/HdfsOutputFile.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/main/java/org/apache/doris/filesystem/hdfs/HdfsSeekableInputStream.java
(100%)
create mode 100644
fe/fe-filesystem/fe-filesystem-hdfs-base/src/main/java/org/apache/doris/filesystem/hdfs/properties/HdfsCompatibleProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-hdfs-base/src/main/java/org/apache/doris/filesystem/hdfs/properties/HdfsConfigFileLoader.java
create mode 100644
fe/fe-filesystem/fe-filesystem-hdfs-base/src/main/java/org/apache/doris/filesystem/hdfs/properties/HdfsPropertiesUtils.java
copy
fe/fe-filesystem/{fe-filesystem-cos/src/main/java/org/apache/doris/filesystem/cos/CosFileSystem.java
=>
fe-filesystem-hdfs-base/src/main/java/org/apache/doris/filesystem/hdfs/properties/UserException.java}
(58%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/test/java/org/apache/doris/filesystem/hdfs/DFSFileSystemEnvTest.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/test/java/org/apache/doris/filesystem/hdfs/HdfsFileIteratorTest.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/test/java/org/apache/doris/filesystem/hdfs/HdfsSeekableInputStreamTest.java
(100%)
rename fe/fe-filesystem/{fe-filesystem-hdfs =>
fe-filesystem-hdfs-base}/src/test/java/org/apache/doris/filesystem/hdfs/KerberosHadoopAuthenticatorEnvTest.java
(100%)
create mode 100644
fe/fe-filesystem/fe-filesystem-hdfs/src/main/java/org/apache/doris/filesystem/hdfs/properties/HdfsProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-hdfs/src/test/java/org/apache/doris/filesystem/hdfs/HdfsFileSystemProviderTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-hdfs/src/test/java/org/apache/doris/filesystem/hdfs/properties/HdfsPropertiesTest.java
copy fe/fe-filesystem/{fe-filesystem-hdfs => fe-filesystem-jfs}/pom.xml (63%)
create mode 100644
fe/fe-filesystem/fe-filesystem-jfs/src/main/assembly/plugin-zip.xml
create mode 100644
fe/fe-filesystem/fe-filesystem-jfs/src/main/java/org/apache/doris/filesystem/jfs/JfsFileSystemProvider.java
create mode 100644
fe/fe-filesystem/fe-filesystem-jfs/src/main/java/org/apache/doris/filesystem/jfs/properties/JfsProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-jfs/src/main/resources/META-INF/services/org.apache.doris.filesystem.spi.FileSystemProvider
create mode 100644
fe/fe-filesystem/fe-filesystem-jfs/src/test/java/org/apache/doris/filesystem/jfs/JfsFileSystemProviderTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-jfs/src/test/java/org/apache/doris/filesystem/jfs/properties/JfsPropertiesTest.java
copy fe/fe-filesystem/{fe-filesystem-hdfs => fe-filesystem-oss-hdfs}/pom.xml
(63%)
create mode 100644
fe/fe-filesystem/fe-filesystem-oss-hdfs/src/main/assembly/plugin-zip.xml
create mode 100644
fe/fe-filesystem/fe-filesystem-oss-hdfs/src/main/java/org/apache/doris/filesystem/hdfs/OssHdfsFileSystemProvider.java
create mode 100644
fe/fe-filesystem/fe-filesystem-oss-hdfs/src/main/java/org/apache/doris/filesystem/hdfs/properties/OssHdfsProperties.java
create mode 100644
fe/fe-filesystem/fe-filesystem-oss-hdfs/src/main/resources/META-INF/services/org.apache.doris.filesystem.spi.FileSystemProvider
create mode 100644
fe/fe-filesystem/fe-filesystem-oss-hdfs/src/test/java/org/apache/doris/filesystem/hdfs/OssHdfsFileSystemProviderTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-oss-hdfs/src/test/java/org/apache/doris/filesystem/hdfs/properties/OssHdfsPropertiesTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-oss/src/test/java/org/apache/doris/filesystem/oss/OssFileSystemProviderTest.java
delete mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/main/java/org/apache/doris/filesystem/s3/S3Uri.java
delete mode 100644
fe/fe-filesystem/fe-filesystem-s3/src/test/java/org/apache/doris/filesystem/s3/S3UriTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-spi/src/test/java/org/apache/doris/filesystem/spi/ObjectStorageUriTest.java
create mode 100644
fe/fe-filesystem/fe-filesystem-spi/src/test/java/org/apache/doris/filesystem/spi/S3CompatibleFileSystemTest.java
create mode 100644
regression-test/data/datatype_p0/complex_types/test_light_schema_change_lazy_pruned_struct.out
create mode 100644
regression-test/data/query_p0/sql_functions/array_functions/test_nested_array_map.out
delete mode 100644
regression-test/data/shape_check/tpcds_sf1000/shape/query64.out
delete mode 100644
regression-test/data/shape_check/tpcds_sf1000_nopkfk/shape/query64.out
create mode 100644
regression-test/suites/datatype_p0/complex_types/test_light_schema_change_lazy_pruned_struct.groovy
create mode 100644
regression-test/suites/load_p0/routine_load/test_routine_load_first_error_msg.groovy
create mode 100644
regression-test/suites/query_p0/sql_functions/array_functions/test_nested_array_map.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf100/noStatsRfPrune/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf100/no_stats_shape/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf100/rf_prune/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf100/shape/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf1000/hint/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf1000/shape/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf1000_nopkfk/shape/query64.groovy
delete mode 100644
regression-test/suites/shape_check/tpcds_sf10t_orc/shape/query64.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
