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 206b5a4235 [doc](flink-connector) add flink cdc sync mysql database
(#20486)
add 9a83d78dfe [Enhancement](hudi) support hudi mor table, step2 follow
#19909 (#20570)
No new revisions were added by this update.
Summary of changes:
.../scan/{jni_reader.cpp => hudi_jni_reader.cpp} | 62 ++++---
.../exec/scan/{jni_reader.h => hudi_jni_reader.h} | 19 ++-
be/src/vec/exec/scan/vfile_scanner.cpp | 13 +-
fe/fe-core/pom.xml | 6 +
.../doris/catalog/HiveMetaStoreClientHelper.java | 59 +++++--
.../java/org/apache/doris/catalog/HudiUtils.java | 166 ++++++++++++++++++
.../doris/catalog/external/HMSExternalTable.java | 28 ++--
.../catalog/external/HudiExternalDatabase.java | 72 --------
.../doris/catalog/external/HudiExternalTable.java | 125 --------------
.../apache/doris/datasource/CatalogFactory.java | 3 -
.../doris/datasource/hive/HiveMetaStoreCache.java | 16 +-
.../datasource/hudi/HudiHMSExternalCatalog.java | 68 --------
.../glue/translator/PhysicalPlanTranslator.java | 2 +-
.../apache/doris/planner/SingleNodePlanner.java | 2 +-
.../doris/planner/external/FileQueryScanNode.java | 12 +-
.../doris/planner/external/HiveScanNode.java | 91 +++++-----
.../doris/planner/external/HudiScanNode.java | 48 ------
.../doris/planner/external/hudi/HudiHMSSource.java | 81 ---------
.../doris/planner/external/hudi/HudiScanNode.java | 185 +++++++++++----------
.../doris/planner/external/hudi/HudiSource.java | 39 -----
.../doris/planner/external/hudi/HudiSplit.java | 5 +-
fe/java-udf/pom.xml | 21 +--
.../org/apache/doris/hudi/HudiColumnValue.java | 42 ++++-
.../java/org/apache/doris/hudi/HudiJniScanner.java | 59 ++++++-
.../java/org/apache/doris/hudi/HudiScanParam.java | 43 ++---
.../java/org/apache/doris/jni/utils/Utils.java | 113 +++++++++++++
.../java/org/apache/doris/jni/vec/ColumnType.java | 171 ++++++++++---------
gensrc/thrift/PlanNodes.thrift | 15 +-
28 files changed, 793 insertions(+), 773 deletions(-)
copy be/src/vec/exec/scan/{jni_reader.cpp => hudi_jni_reader.cpp} (55%)
copy be/src/vec/exec/scan/{jni_reader.h => hudi_jni_reader.h} (81%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/HudiUtils.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/external/HudiExternalDatabase.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/catalog/external/HudiExternalTable.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/HudiHMSExternalCatalog.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/external/HudiScanNode.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/external/hudi/HudiHMSSource.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/planner/external/hudi/HudiSource.java
create mode 100644
fe/java-udf/src/main/java/org/apache/doris/jni/utils/Utils.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
