You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/05/09 07:36:19 UTC
[incubator-inlong] branch master updated (ad5e87332 -> 8b35c0e13)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
from ad5e87332 [INLONG-3473][CI] Add support for chart testing (#3676)
add 8b35c0e13 [INLONG-4128][Manager] Abstracting the logic for creating Hive tables (#4129)
No new revisions were added by this update.
Summary of changes:
.../{OperationType.java => DataNodeType.java} | 27 ++-
.../manager/common/pojo/query/ColumnInfoBean.java | 29 ----
.../manager/common/pojo/query/ColumnQueryBean.java | 49 ------
.../manager/common/pojo/query/ConnectionInfo.java | 40 -----
.../manager/common/pojo/query/DatabaseDetail.java | 41 -----
.../common/pojo/query/DatabaseQueryBean.java | 43 -----
.../manager/common/pojo/query/TableQueryBean.java | 56 ------
.../common/pojo/query/hive/HiveColumnInfoBean.java | 24 ---
.../pojo/query/hive/HiveColumnQueryBean.java | 37 ----
.../common/pojo/sink/hive/HiveColumnInfo.java} | 23 +--
.../manager/common/pojo/sink/hive/HiveSinkDTO.java | 33 ++++
.../hive/HiveTableInfo.java} | 26 +--
.../apache/inlong/manager/dao/HiveServerDao.java | 125 -------------
.../manager/service/core/DataNodeService.java | 8 +
.../manager/service/core/DataSourceService.java | 52 ------
.../service/core/impl/DataNodeServiceImpl.java | 34 ++++
.../service/core/impl/HiveSourceServiceImpl.java | 193 ---------------------
.../CreateSinkResourceForStreamListener.java | 2 +-
.../service/resource/SinkResourceListener.java | 2 +-
.../service/resource/SinkResourceOperator.java | 3 +-
.../service/resource/hive/HiveJdbcUtils.java | 149 ++++++++++++++++
.../resource/hive/HiveResourceOperator.java | 135 ++++++--------
.../manager/service/resource/hive/SqlBuilder.java | 142 +++++++++++++++
.../hive/builder/HiveAddColumnSqlBuilder.java | 60 -------
.../hive/builder/HiveChangeColumnBuilder.java | 51 ------
.../hive/builder/HiveCreateDbSqlBuilder.java | 36 ----
.../hive/builder/HiveDropDbSqlBuilder.java | 38 ----
.../hive/builder/HiveDropTableSqlBuilder.java | 39 -----
.../hive/builder/HiveQueryTableSqlBuilder.java | 38 ----
.../hive/builder/HiveReplaceColumnSqlBuilder.java | 62 -------
.../hive/builder/HiveTableCreateSqlBuilder.java | 76 --------
.../service/resource/hive/builder/SqlBuilder.java | 31 ----
.../resource/kafka/KafkaResourceOperator.java | 25 +--
.../manager/web/controller/DataNodeController.java | 8 +
.../web/controller/StreamSinkController.java | 34 ----
35 files changed, 484 insertions(+), 1287 deletions(-)
copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/{OperationType.java => DataNodeType.java} (79%)
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/ColumnInfoBean.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/ColumnQueryBean.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/ConnectionInfo.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/DatabaseDetail.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/DatabaseQueryBean.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/TableQueryBean.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/hive/HiveColumnInfoBean.java
delete mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/query/hive/HiveColumnQueryBean.java
copy inlong-manager/{manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/dto/JarEntryInfo.java => manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/hive/HiveColumnInfo.java} (74%)
rename inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{query/hive/HiveTableQueryBean.java => sink/hive/HiveTableInfo.java} (74%)
delete mode 100644 inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/HiveServerDao.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/DataSourceService.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/HiveSourceServiceImpl.java
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/HiveJdbcUtils.java
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/SqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveAddColumnSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveChangeColumnBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveCreateDbSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveDropDbSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveDropTableSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveQueryTableSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveReplaceColumnSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/HiveTableCreateSqlBuilder.java
delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/hive/builder/SqlBuilder.java