This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from d20b5f90d8 [feature](executor) Automatically set the instance_num
using the info from be. (#19345)
add 894801f5ce [feature](load-refactor) Step1: InsertStmt as facade layer
and run S3/Broker Load (#19142)
No new revisions were added by this update.
Summary of changes:
fe/fe-core/src/main/cup/sql_parser.cup | 6 +-
.../java/org/apache/doris/analysis/BrokerDesc.java | 3 +-
.../org/apache/doris/analysis/BrokerLoadStmt.java | 130 +++
.../doris/analysis/CreateTableAsSelectStmt.java | 2 +-
.../org/apache/doris/analysis/DataDescription.java | 16 +-
.../java/org/apache/doris/analysis/DeleteStmt.java | 2 +-
.../java/org/apache/doris/analysis/InsertStmt.java | 869 +++++----------------
.../java/org/apache/doris/analysis/LabelName.java | 1 +
.../java/org/apache/doris/analysis/LoadStmt.java | 6 +-
.../analysis/{FunctionArgs.java => LoadType.java} | 43 +-
.../org/apache/doris/analysis/MysqlLoadStmt.java | 94 +++
.../{InsertStmt.java => NativeInsertStmt.java} | 157 ++--
.../org/apache/doris/analysis/ResourceDesc.java | 7 +-
.../org/apache/doris/analysis/SparkLoadStmt.java | 101 +++
.../org/apache/doris/analysis/StorageDesc.java | 8 +-
.../org/apache/doris/analysis/UnifiedLoadStmt.java | 61 ++
.../java/org/apache/doris/analysis/UpdateStmt.java | 2 +-
.../main/java/org/apache/doris/catalog/Env.java | 17 +-
.../org/apache/doris/load/loadv2/BulkLoadJob.java | 34 +
.../org/apache/doris/load/loadv2/LoadManager.java | 43 +-
.../doris/load/loadv2/LoadManagerAdapter.java | 55 ++
.../org/apache/doris/planner/OriginalPlanner.java | 2 +-
.../java/org/apache/doris/qe/SessionVariable.java | 17 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 79 +-
.../org/apache/doris/analysis/InsertStmtTest.java | 19 +-
.../load_p0/broker_load/test_array_load.groovy | 85 ++
.../load_p2/broker_load/test_broker_load.groovy | 63 ++
27 files changed, 1098 insertions(+), 824 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/BrokerLoadStmt.java
copy fe/fe-core/src/main/java/org/apache/doris/analysis/{FunctionArgs.java =>
LoadType.java} (51%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/MysqlLoadStmt.java
copy fe/fe-core/src/main/java/org/apache/doris/analysis/{InsertStmt.java =>
NativeInsertStmt.java} (92%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/SparkLoadStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/LoadManagerAdapter.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
