This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 79a8620a130 [enhancement](nereids)simplify OneRowRelation scalar
subquery (#32276)
add 0deac158375 [feature](insert)implement hive table sink plan (#31765)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/common/Config.java | 17 +-
.../org/apache/doris/datasource/CatalogIf.java | 3 +
.../apache/doris/datasource/ExternalCatalog.java | 11 +
.../apache/doris/datasource/InternalCatalog.java | 2 +-
.../doris/datasource/hive/HMSCachedClient.java | 2 +
.../doris/datasource/hive/HiveMetadataOps.java | 8 +-
.../doris/datasource/hive/HiveTableMetadata.java | 30 +-
.../hive/PostgreSQLJdbcHMSCachedClient.java | 33 +-
.../datasource/hive/ThriftHMSCachedClient.java | 48 +-
...undTableSink.java => UnboundHiveTableSink.java} | 97 +---
.../doris/nereids/analyzer/UnboundTableSink.java | 49 +-
.../nereids/analyzer/UnboundTableSinkCreator.java | 74 +++
.../glue/translator/PhysicalPlanTranslator.java | 30 ++
.../doris/nereids/parser/LogicalPlanBuilder.java | 10 +-
... DistributionSpecTableSinkHashPartitioned.java} | 25 +-
...istributionSpecTableSinkRandomPartitioned.java} | 11 +-
.../nereids/properties/PhysicalProperties.java | 3 +
.../nereids/properties/RequestPropertyDeriver.java | 11 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +-
.../doris/nereids/rules/analysis/BindSink.java | 569 ++++++++++++---------
...ogicalHiveTableSinkToPhysicalHiveTableSink.java | 4 +-
.../apache/doris/nereids/trees/plans/PlanType.java | 2 +
.../trees/plans/commands/CreateTableCommand.java | 6 +-
.../plans/commands/DeleteFromUsingCommand.java | 4 +-
.../nereids/trees/plans/commands/LoadCommand.java | 4 +-
.../trees/plans/commands/UpdateCommand.java | 6 +-
.../plans/commands/UpdateMvByPartitionCommand.java | 11 +-
...dContext.java => HiveInsertCommandContext.java} | 13 +-
.../plans/commands/insert/HiveInsertExecutor.java | 45 +-
.../commands/insert/InsertIntoTableCommand.java | 6 +-
.../insert/InsertOverwriteTableCommand.java | 56 +-
.../trees/plans/commands/insert/InsertUtils.java | 76 +--
.../trees/plans/logical/LogicalHiveTableSink.java | 41 +-
...gicalTableSink.java => UnboundLogicalSink.java} | 41 +-
.../plans/physical/PhysicalHiveTableSink.java | 78 ++-
.../nereids/trees/plans/physical/PhysicalSink.java | 10 +-
.../trees/plans/physical/PhysicalTableSink.java | 2 +
.../nereids/trees/plans/visitor/SinkVisitor.java | 5 +
.../apache/doris/nereids/util/RelationUtil.java | 2 +-
.../org/apache/doris/planner/DataPartition.java | 2 +
.../org/apache/doris/planner/HiveTableSink.java | 172 ++++++-
.../doris/datasource/hive/HmsCommitTest.java | 8 +-
42 files changed, 1028 insertions(+), 601 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/{UnboundTableSink.java
=> UnboundHiveTableSink.java} (50%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/UnboundTableSinkCreator.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/{DistributionSpecTabletIdShuffle.java
=> DistributionSpecTableSinkHashPartitioned.java} (56%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/properties/{DistributionSpecMustShuffle.java
=> DistributionSpecTableSinkRandomPartitioned.java} (70%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/{InsertCommandContext.java
=> HiveInsertCommandContext.java} (75%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/{LogicalTableSink.java
=> UnboundLogicalSink.java} (50%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
