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 c0865cc7c0b [Bug](Variant) fix incorrect use of column index in
TabletSchema (#35019)
add 09cb8b93845 [feature](iceberg)support iceberg insert grammar (#34257)
No new revisions were added by this update.
Summary of changes:
.../datasource/iceberg/IcebergExternalCatalog.java | 5 +-
.../datasource/iceberg/IcebergExternalTable.java | 16 +++
.../datasource/iceberg/IcebergTransaction.java | 4 +
.../doris/datasource/iceberg/IcebergUtils.java | 58 +++++++-
.../iceberg/source/IcebergApiSource.java | 11 +-
.../iceberg/source/IcebergHMSSource.java | 12 +-
.../datasource/iceberg/source/IcebergSource.java | 3 -
...Sink.java => UnboundBaseExternalTableSink.java} | 68 +++-------
.../nereids/analyzer/UnboundHiveTableSink.java | 91 ++-----------
.../nereids/analyzer/UnboundIcebergTableSink.java | 84 ++++++++++++
.../nereids/analyzer/UnboundTableSinkCreator.java | 9 ++
.../glue/translator/PhysicalPlanTranslator.java | 25 +++-
.../pre/TurnOffPageCacheForInsertIntoSelect.java | 8 ++
.../nereids/properties/RequestPropertyDeriver.java | 12 ++
.../org/apache/doris/nereids/rules/RuleSet.java | 2 +
.../org/apache/doris/nereids/rules/RuleType.java | 2 +
.../doris/nereids/rules/analysis/BindSink.java | 68 +++++++++-
...IcebergTableSinkToPhysicalIcebergTableSink.java | 48 +++++++
.../apache/doris/nereids/trees/plans/PlanType.java | 2 +
... => BaseExternalTableInsertCommandContext.java} | 24 +---
...r.java => BaseExternalTableInsertExecutor.java} | 95 ++++++-------
.../commands/insert/HiveInsertCommandContext.java | 11 +-
.../plans/commands/insert/HiveInsertExecutor.java | 110 ++-------------
.../commands/insert/IcebergInsertExecutor.java | 71 ++++++++++
.../commands/insert/InsertIntoTableCommand.java | 9 +-
.../trees/plans/commands/insert/InsertUtils.java | 6 +-
.../plans/logical/LogicalIcebergTableSink.java | 150 +++++++++++++++++++++
.../physical/PhysicalBaseExternalTableSink.java | 79 +++++++++++
.../plans/physical/PhysicalHiveTableSink.java | 50 ++-----
...ableSink.java => PhysicalIcebergTableSink.java} | 93 +++++--------
.../nereids/trees/plans/visitor/SinkVisitor.java | 15 +++
.../doris/planner/BaseExternalTableDataSink.java | 97 +++++++++++++
.../java/org/apache/doris/planner/DataSink.java | 3 +
.../org/apache/doris/planner/HiveTableSink.java | 72 +++-------
.../org/apache/doris/planner/IcebergTableSink.java | 146 ++++++++++++++++++++
.../main/java/org/apache/doris/qe/Coordinator.java | 17 +++
.../transaction/IcebergTransactionManager.java | 69 ++++++++++
.../transaction/TransactionManagerFactory.java | 5 +
.../datasource/hive/HiveDDLAndDMLPlanTest.java | 27 +++-
.../doris/datasource/hive/HmsCommitTest.java | 1 -
gensrc/thrift/DataSinks.thrift | 24 ++++
41 files changed, 1198 insertions(+), 504 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/{UnboundHiveTableSink.java
=> UnboundBaseExternalTableSink.java} (56%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/analyzer/UnboundIcebergTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/implementation/LogicalIcebergTableSinkToPhysicalIcebergTableSink.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/{HiveInsertCommandContext.java
=> BaseExternalTableInsertCommandContext.java} (67%)
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/{HiveInsertExecutor.java
=> BaseExternalTableInsertExecutor.java} (66%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/IcebergInsertExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalIcebergTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalBaseExternalTableSink.java
copy
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/{PhysicalHiveTableSink.java
=> PhysicalIcebergTableSink.java} (56%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/BaseExternalTableDataSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/IcebergTableSink.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/transaction/IcebergTransactionManager.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
