This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch tpc_preview4-external
in repository https://gitbox.apache.org/repos/asf/doris.git
omit c7572648fb9 Optimize location for tpch1000 (#59218)
omit 8147ffe4740 [Enhancement](parquet)update runtime filter when read next
parquet row group.(#59053) (#59181)
omit bdaf8202784 [opt](multi-catalog) Optimize file split size. (#59175)
omit bbca9eacc3b Manifest cache for tpch1000 (#59178)
omit df02946fe26 support stream agg topn
omit 9a980895355 fix query error
omit 1432172e29b contine page
omit 9a33e3ec66d Revert "use bitshuffle to decoding"
omit ae0e410294b use bitshuffle to decoding
omit 69297e76312 plain lz4 null page encode
omit 3cc5165d3d3 change the null map encode
add e5bd39a5328 [fix](pkfk)add agg shuffle key var and pick drop pk
(#59384)
add 49d4af3d088 change the null map encode
add 2a7881ea9a8 plain lz4 null page encode
add d3dfae5ac0a use bitshuffle to decoding
add ebea32d255a Revert "use bitshuffle to decoding"
add 59d8b3d5ecf contine page
add 2771e6aeafa fix query error
add afc9ac198a0 support stream agg topn
add 6e937adc3ec adjust some local shuffle rules
add 20dcce00b03 scanner merge after projection
add 58c267e4d32 Manifest cache for tpch1000 (#59178)
add ccaef260512 [opt](multi-catalog) Optimize file split size. (#59175)
add 9b897fc2a62 [Enhancement](parquet)update runtime filter when read next
parquet row group.(#59053) (#59181)
add e3aa5501fec Optimize location for tpch1000 (#59218)
add 85e7e26be5e [Exec](shuffle) random shuffle firstly use local channel
to improve performance
add 3ebdd61569b [enhance](agg)choose one agg gby key shuffle (#59449)
add 65eccb6e512 [opt](profile) use same metric name as OLAP SCAN NODE for
FILE SCAN NODE (#59159)
add fec5a1959d7 [opt](profile) change the node name format of
MultiCastDataStreamer (#59422)
add 22a6a695dc2 change runtime filter wait time to level 1
add 1496e52efd2 sort out parquet metrics
new 3122b6f572d add timed lock and PerScannerWaitSchedLockTime
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 (c7572648fb9)
\
N -- N -- N refs/heads/tpc_preview4-external (3122b6f572d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/io/fs/tracing_file_reader.h | 1 +
.../exec/distinct_streaming_aggregation_operator.h | 2 +-
be/src/pipeline/exec/exchange_sink_operator.cpp | 9 +
be/src/pipeline/exec/file_scan_operator.cpp | 7 +-
be/src/pipeline/exec/hashjoin_probe_operator.h | 16 +-
be/src/pipeline/exec/jdbc_scan_operator.cpp | 2 +-
.../pipeline/exec/multi_cast_data_stream_sink.cpp | 11 +-
be/src/pipeline/pipeline_fragment_context.cpp | 5 +-
be/src/runtime_filter/runtime_filter_consumer.cpp | 4 +-
be/src/util/timed_lock.h | 297 +++++++++++++++++++++
.../format/parquet/vparquet_column_chunk_reader.h | 2 +
.../exec/format/parquet/vparquet_column_reader.cpp | 6 +-
.../exec/format/parquet/vparquet_column_reader.h | 8 +-
.../exec/format/parquet/vparquet_page_reader.cpp | 5 +-
.../vec/exec/format/parquet/vparquet_page_reader.h | 1 +
be/src/vec/exec/format/parquet/vparquet_reader.cpp | 4 +
be/src/vec/exec/format/parquet/vparquet_reader.h | 1 +
be/src/vec/exec/scan/file_scanner.cpp | 18 +-
be/src/vec/exec/scan/file_scanner.h | 2 +
be/src/vec/exec/scan/scanner.cpp | 34 ++-
be/src/vec/exec/scan/scanner.h | 18 ++
be/src/vec/exec/scan/scanner_context.cpp | 14 +
be/src/vec/exec/scan/scanner_scheduler.h | 2 +-
be/src/vec/exec/scan/simplified_scan_scheduler.cpp | 24 +-
be/src/vec/functions/complex_dict_hash_map.h | 3 +-
.../java/org/apache/doris/catalog/TableIf.java | 58 +++-
.../catalog/constraint/ForeignKeyConstraint.java | 11 +
.../catalog/constraint/PrimaryKeyConstraint.java | 4 +
.../doris/catalog/constraint/TableIdentifier.java | 2 +-
.../apache/doris/datasource/InternalCatalog.java | 1 +
.../java/org/apache/doris/nereids/PlanContext.java | 4 +
.../org/apache/doris/nereids/cost/CostModel.java | 4 +-
.../nereids/properties/RequestPropertyDeriver.java | 90 ++++++-
.../rules/implementation/SplitAggBaseRule.java | 9 +-
.../rules/implementation/SplitAggMultiPhase.java | 10 +-
.../SplitAggMultiPhaseWithoutGbyKey.java | 4 +-
.../implementation/SplitAggWithoutDistinct.java | 6 +-
.../rules/rewrite/PullUpJoinFromUnionAll.java | 2 +-
.../doris/nereids/rules/rewrite/SaltJoin.java | 5 +-
.../plans/commands/DropConstraintCommand.java | 22 +-
.../trees/plans/physical/PhysicalDistribute.java | 5 +
.../plans/physical/PhysicalHashAggregate.java | 35 ++-
.../java/org/apache/doris/qe/ConnectContext.java | 12 +
.../java/org/apache/doris/qe/SessionVariable.java | 9 +
.../properties/ChildOutputPropertyDeriverTest.java | 3 +
.../properties/RequestPropertyDeriverTest.java | 3 +
.../doris/nereids/trees/plans/PlanEqualsTest.java | 6 +-
.../nereids_p0/pkfk/test_pk_fk_drop_table.groovy | 59 ++++
48 files changed, 772 insertions(+), 88 deletions(-)
create mode 100644 be/src/util/timed_lock.h
create mode 100644
regression-test/suites/nereids_p0/pkfk/test_pk_fk_drop_table.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
