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 cae8161dd8 [test](lazy open) add lazy open test (#19896)
add ebe3f6ec42 [refactor](routineload)Refactored routineload to improve
scalability (#19834)
No new revisions were added by this update.
Summary of changes:
fe/fe-core/src/main/cup/sql_parser.cup | 9 +-
.../doris/analysis/AlterRoutineLoadStmt.java | 36 +-
.../doris/analysis/CreateRoutineLoadStmt.java | 45 +--
.../analysis/RoutineLoadDataSourceProperties.java | 419 ---------------------
.../routineload/AbstractDataSourceProperties.java | 106 ++++++
.../load/routineload/KafkaRoutineLoadJob.java | 168 +++++----
.../RoutineLoadDataSourcePropertyFactory.java | 42 +++
.../doris/load/routineload/RoutineLoadJob.java | 27 +-
.../doris/load/routineload/RoutineLoadManager.java | 7 +-
.../load/routineload/kafka/KafkaConfiguration.java | 70 ++++
.../kafka/KafkaDataSourceProperties.java | 282 ++++++++++++++
.../persist/AlterRoutineLoadJobOperationLog.java | 10 +-
.../org/apache/doris/persist/gson/GsonUtils.java | 10 +-
.../doris/analysis/AlterRoutineLoadStmtTest.java | 104 +++--
.../doris/analysis/CreateRoutineLoadStmtTest.java | 19 +-
.../RoutineLoadDataSourcePropertiesTest.java | 348 -----------------
.../load/routineload/KafkaRoutineLoadJobTest.java | 15 +-
.../load/routineload/RoutineLoadManagerTest.java | 9 +-
.../persist/AlterRoutineLoadOperationLogTest.java | 26 +-
.../doris/persist/DataSourcePropertiesTest.java | 108 ++++++
20 files changed, 855 insertions(+), 1005 deletions(-)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/RoutineLoadDataSourceProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/routineload/AbstractDataSourceProperties.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadDataSourcePropertyFactory.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/routineload/kafka/KafkaConfiguration.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/routineload/kafka/KafkaDataSourceProperties.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/RoutineLoadDataSourcePropertiesTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/persist/DataSourcePropertiesTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
