This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from a15eef99919 [improvement](plsql) Select statement supports insert into
variables #31574
add e79462cdd80 [feature](sink) support paritition tablet sink shuffle
(#30914)
No new revisions were added by this update.
Summary of changes:
be/src/vec/sink/vdata_stream_sender.cpp | 102 ++++++++++++++++++++-
be/src/vec/sink/vdata_stream_sender.h | 41 ++++++++-
be/src/vec/sink/vrow_distribution.h | 3 +
.../glue/translator/PhysicalPlanTranslator.java | 3 +
...y.java => DistributionSpecTabletIdShuffle.java} | 10 +-
.../nereids/properties/PhysicalProperties.java | 3 +
.../trees/plans/commands/InsertExecutor.java | 26 +++++-
.../plans/commands/InsertIntoTableCommand.java | 15 ++-
.../plans/physical/PhysicalOlapTableSink.java | 21 +----
.../org/apache/doris/planner/DataPartition.java | 34 +++----
.../org/apache/doris/planner/DataStreamSink.java | 46 ++++++++++
.../org/apache/doris/planner/OlapTableSink.java | 22 ++++-
.../java/org/apache/doris/qe/SessionVariable.java | 9 ++
gensrc/thrift/DataSinks.thrift | 7 +-
14 files changed, 280 insertions(+), 62 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/{DistributionSpecAny.java
=> DistributionSpecTabletIdShuffle.java} (73%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
