Skip to content

J
jz-dmp-service
Commit e340e546 authored by mcb's avatar mcb
Browse files
Options

no message

parent b7cfadf6
Hide whitespace changes
Inline Side-by-side
Showing with 1073 additions and 0 deletions
src/main/java/com/jz/dmp/agent/DmpAgentResult.java 0 → 100644
View file @ e340e546
package com.jz.dmp.agent;
import java.io.Serializable;
public class DmpAgentResult implements Serializable {
private static final long serialVersionUID = -7601078775407397787L;
private Long id;
private ResultCode code;
private String message;
private Object result;
public DmpAgentResult() {
this.setCode(ResultCode.SUCCESS);
this.setMessage("成功！");
}
public DmpAgentResult(ResultCode code) {
this.setCode(code);
this.setMessage(code.msg());
}
public DmpAgentResult(ResultCode code, String message) {
this.setCode(code);
this.setMessage(message);
}
public DmpAgentResult(ResultCode code, Object data) {
this.setCode(code);
this.setMessage(code.msg());
this.setResult(result);
}
public DmpAgentResult(ResultCode code, String message, Object data) {
this.setCode(code);
this.setMessage(message);
this.setResult(result);
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public ResultCode getCode() {
return code;
}
public void setCode(ResultCode code) {
this.code = code;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public Object getResult() {
return result;
}
public void setResult(Object result) {
this.result = result;
}
}
src/main/java/com/jz/dmp/agent/ResultCode.java 0 → 100644
View file @ e340e546
package com.jz.dmp.agent;
public enum ResultCode {
/** 成功 */
SUCCESS("200", "成功"),
/** 没有登录 */
NOT_LOGIN("400", "没有登录"),
/** 发生异常 */
EXCEPTION("401", "发生异常"),
/** 系统错误 */
SYS_ERROR("402", "系统错误"),
/** 参数错误 */
PARAMS_ERROR("403", "参数错误 "),
/** 不支持当前请求方法 */
METHOD_NOT_ALLOWED("405", "不支持当前请求方法 "),
/** 不支持或已经废弃 */
NOT_SUPPORTED("410", "不支持或已经废弃"),
/** 不支持当前媒体类型 */
UNSUPPORTED_MEDIA_TYPE("415", "不支持当前媒体类型"),
/** AuthCode错误 */
INVALID_AUTHCODE("444", "无效的AuthCode"),
/** 太频繁的调用 */
TOO_FREQUENT("445", "太频繁的调用"),
/** 未知的错误 */
UNKNOWN_ERROR("499", "未知错误"),
/** 内部服务出错 */
INTERNAL_SERVER_ERROR("500", "内部服务出错-逻辑异常");
private String val;
private String msg;
private ResultCode(String value, String msg) {
this.val = value;
this.msg = msg;
}
public String val() {
return val;
}
public String msg() {
return msg;
}
}
src/main/java/com/jz/dmp/modules/model/DmpProject.java 0 → 100644
View file @ e340e546
package com.jz.dmp.modules.model;
import java.io.Serializable;
import java.util.Date;
/**
* 项目信息(DmpProject)实体类
*
* @author makejava
* @since 2020-12-21 18:56:33
*/
public class DmpProject implements Serializable {
private static final long serialVersionUID = -21825960415558182L;
/**
* ID
*/
private Integer id;
/**
* 管理员帐号
*/
private String ownerId;
/**
* 生产帐号
*/
private String productionId;
/**
* 数据仓库帐号
*/
private String dataWarehouseId;
/**
* 项目名称
*/
private String name;
/**
* 项目显示名称
*/
private String displayName;
/**
* 项目描述
*/
private String projectDesc;
/**
* 发布目标
*/
private Integer publishTargetId;
/**
* 启动调度周期
*/
private String isEnableScheduler;
/**
* 允许在本项目中直接编辑任务和代码
*/
private String isEditTaskCode;
/**
* 能否下载select结果
*/
private String isEnableSelect;
/**
* 数据仓库项目名称
*/
private String dwName;
/**
* 数据仓库访问身份类型
*/
private String dwAccessType;
/**
* 使用ACL授权
*/
private String dwIsEnableAcl;
/**
* 允许对象创建者访问对象
*/
private String dwIsEnableAccessObj;
/**
* 允许对象创建者授权对象
*/
private String dwIsEnableAuthObj;
/**
* 项目空间数据保护
*/
private String dwIsProtectData;
/**
* 数据状态
*/
private String dataStatus;
/**
* 创建用户ID
*/
private String createUserId;
/**
* 数据创建时间
*/
private Date createTime;
/**
* 创建用户ID
*/
private String updateUserId;
private String impalaJdbcUrl;
private String impalaMasterFqdn;
/**
* 数据更新时间
*/
private Date updateTime;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getOwnerId() {
return ownerId;
}
public void setOwnerId(String ownerId) {
this.ownerId = ownerId;
}
public String getProductionId() {
return productionId;
}
public void setProductionId(String productionId) {
this.productionId = productionId;
}
public String getDataWarehouseId() {
return dataWarehouseId;
}
public void setDataWarehouseId(String dataWarehouseId) {
this.dataWarehouseId = dataWarehouseId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getDisplayName() {
return displayName;
}
public void setDisplayName(String displayName) {
this.displayName = displayName;
}
public String getProjectDesc() {
return projectDesc;
}
public void setProjectDesc(String projectDesc) {
this.projectDesc = projectDesc;
}
public Integer getPublishTargetId() {
return publishTargetId;
}
public void setPublishTargetId(Integer publishTargetId) {
this.publishTargetId = publishTargetId;
}
public String getIsEnableScheduler() {
return isEnableScheduler;
}
public void setIsEnableScheduler(String isEnableScheduler) {
this.isEnableScheduler = isEnableScheduler;
}
public String getIsEditTaskCode() {
return isEditTaskCode;
}
public void setIsEditTaskCode(String isEditTaskCode) {
this.isEditTaskCode = isEditTaskCode;
}
public String getIsEnableSelect() {
return isEnableSelect;
}
public void setIsEnableSelect(String isEnableSelect) {
this.isEnableSelect = isEnableSelect;
}
public String getDwName() {
return dwName;
}
public void setDwName(String dwName) {
this.dwName = dwName;
}
public String getDwAccessType() {
return dwAccessType;
}
public void setDwAccessType(String dwAccessType) {
this.dwAccessType = dwAccessType;
}
public String getDwIsEnableAcl() {
return dwIsEnableAcl;
}
public void setDwIsEnableAcl(String dwIsEnableAcl) {
this.dwIsEnableAcl = dwIsEnableAcl;
}
public String getDwIsEnableAccessObj() {
return dwIsEnableAccessObj;
}
public void setDwIsEnableAccessObj(String dwIsEnableAccessObj) {
this.dwIsEnableAccessObj = dwIsEnableAccessObj;
}
public String getDwIsEnableAuthObj() {
return dwIsEnableAuthObj;
}
public void setDwIsEnableAuthObj(String dwIsEnableAuthObj) {
this.dwIsEnableAuthObj = dwIsEnableAuthObj;
}
public String getDwIsProtectData() {
return dwIsProtectData;
}
public void setDwIsProtectData(String dwIsProtectData) {
this.dwIsProtectData = dwIsProtectData;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public String getCreateUserId() {
return createUserId;
}
public void setCreateUserId(String createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(String updateUserId) {
this.updateUserId = updateUserId;
}
public String getImpalaJdbcUrl() {
return impalaJdbcUrl;
}
public void setImpalaJdbcUrl(String impalaJdbcUrl) {
this.impalaJdbcUrl = impalaJdbcUrl;
}
public String getImpalaMasterFqdn() {
return impalaMasterFqdn;
}
public void setImpalaMasterFqdn(String impalaMasterFqdn) {
this.impalaMasterFqdn = impalaMasterFqdn;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
\ No newline at end of file
src/main/java/com/jz/dmp/modules/model/DmpProjectSystemInfo.java 0 → 100644
View file @ e340e546
package com.jz.dmp.modules.model;
import java.io.Serializable;
import java.util.Date;
/**
* DW系统配置信息(DmpProjectSystemInfo)实体类
*
* @author makejava
* @since 2020-12-21 18:49:50
*/
public class DmpProjectSystemInfo implements Serializable {
private static final long serialVersionUID = -40082608195904585L;
/**
* ID
*/
private Integer id;
/**
* 项目ID
*/
private Integer projectId;
/**
* 是否启用KERBEROS
*/
private String kerberosIsenable;
/**
* krb5地址
*/
private String kerberosKrb5Conf;
/**
* jaas地址
*/
private String kerberosJaasConf;
/**
* keytab地址
*/
private String kerberosKeytabConf;
/**
* keytab用户
*/
private String kerberosKeytabUser;
/**
* FQDN
*/
private String kerberosFqdn;
/**
* spark专用jaas
*/
private String kerberosSparkJaasConf;
/**
* jaas默认Clinet名称
*/
private String kerberosJaasClientName;
/**
* 远程连接默认SERVER地址
*/
private String shellCmdServer;
/**
* 远程连接默认用户
*/
private String shellCmdUser;
/**
* 远程连接默认用户
*/
private String shellCmdPassword;
/**
* 远程连接默认密码
*/
private String shellCmdSubmitSycning;
/**
* 提交同步任务CMD
*/
private String shellCmdQueryStatus;
/**
* 查询同步任务状态CMD
*/
private String shellCmdStopSycning;
/**
* 停止同步任务CMD
*/
private String shellCmdCatLog;
/**
* Shell服务器FTP下载目录
*/
private String shellFtpDownloadDir;
/**
* 提交XML默认defaultFS
*/
private String hdfsHttpPath;
/**
* 调用HADOOP的用户名称
*/
private String hdfsUserName;
/**
* 提交XML到HDFS路径
*/
private String hdfsSyncingPath;
/**
* IMPALA JDBC URL
*/
private String impalaJdbcUrl;
/**
* IMPALA_SHELL_URL
*/
private String impalaShellUrl;
/**
* AZKABAN WEB服务地址
*/
private String azkabanMonitorUrl;
/**
* 执行shell任务命令
*/
private String azkabanExectorShellExec;
/**
* 执行impala_sql任务命令
*/
private String azkabanExectorSqlExec;
/**
* 执行数据同步任务命令
*/
private String azkabanExectorXmlExec;
/**
* AZKABAN_EXECTOR_SQL_PATH
*/
private String azkabanExectorSqlPath;
/**
* AZKABAN_EXECTOR_SHELL_PATH
*/
private String azkabanExectorShellPath;
/**
* AZKABAN_LOCAL_TASK_FILE_PATH
*/
private String azkabanLocalTaskFilePath;
/**
* KAFKA_CONNECTOR_URL
*/
private String kafkaConnectorUrl;
/**
* KAFKA_BOOTSTRAP_SERVERS
*/
private String kafkaBootstrapServers;
/**
* KAFKA_MONITOR_URL
*/
private String kafkaMonitorUrl;
/**
* KAFKA_OFFSET_UPDATE_SHELL
*/
private String kafkaOffsetUpdateShell;
/**
* 数据状态
*/
private String dataStatus;
/**
* 创建用户ID
*/
private String createUserId;
/**
* 数据创建时间
*/
private Date createTime;
/**
* 创建用户ID
*/
private String updateUserId;
/**
* 数据更新时间
*/
private Date updateTime;
/**
* connector schema 注册地址
*/
private String kafkaSchemaRegisterUrl;
private String kafkaInfluxUrl;
private String kafkaInfluxUserName;
private String kafkaInfluxPassword;
/**
* 上传配置的SFTP端口
*/
private Integer shellSftpPort;
/**
* hive元数据地址
*/
private String sparkHiveMetastoreUris;
/**
* SPART提交YARN队列名称
*/
private String sparkYarnQueue;
/**
* spark_executor_memory
*/
private String sparkDefaultExecutorMemory;
/**
* spark_executor_cores
*/
private Integer sparkDefaultExecutorCores;
/**
* spark_total_executor_cores
*/
private Integer sparkDefaultTotalExecutorCores;
/**
* 统计每天离线同步数据量（表级）
*/
private String sparkStatisticsSourceDataSwitch;
/**
* ATLAS WEB服务地址
*/
private String atlasMonitorUrl;
private String openapiInterfaceUrl;
private String azkabanExectorShellExportData;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public Integer getProjectId() {
return projectId;
}
public void setProjectId(Integer projectId) {
this.projectId = projectId;
}
public String getKerberosIsenable() {
return kerberosIsenable;
}
public void setKerberosIsenable(String kerberosIsenable) {
this.kerberosIsenable = kerberosIsenable;
}
public String getKerberosKrb5Conf() {
return kerberosKrb5Conf;
}
public void setKerberosKrb5Conf(String kerberosKrb5Conf) {
this.kerberosKrb5Conf = kerberosKrb5Conf;
}
public String getKerberosJaasConf() {
return kerberosJaasConf;
}
public void setKerberosJaasConf(String kerberosJaasConf) {
this.kerberosJaasConf = kerberosJaasConf;
}
public String getKerberosKeytabConf() {
return kerberosKeytabConf;
}
public void setKerberosKeytabConf(String kerberosKeytabConf) {
this.kerberosKeytabConf = kerberosKeytabConf;
}
public String getKerberosKeytabUser() {
return kerberosKeytabUser;
}
public void setKerberosKeytabUser(String kerberosKeytabUser) {
this.kerberosKeytabUser = kerberosKeytabUser;
}
public String getKerberosFqdn() {
return kerberosFqdn;
}
public void setKerberosFqdn(String kerberosFqdn) {
this.kerberosFqdn = kerberosFqdn;
}
public String getKerberosSparkJaasConf() {
return kerberosSparkJaasConf;
}
public void setKerberosSparkJaasConf(String kerberosSparkJaasConf) {
this.kerberosSparkJaasConf = kerberosSparkJaasConf;
}
public String getKerberosJaasClientName() {
return kerberosJaasClientName;
}
public void setKerberosJaasClientName(String kerberosJaasClientName) {
this.kerberosJaasClientName = kerberosJaasClientName;
}
public String getShellCmdServer() {
return shellCmdServer;
}
public void setShellCmdServer(String shellCmdServer) {
this.shellCmdServer = shellCmdServer;
}
public String getShellCmdUser() {
return shellCmdUser;
}
public void setShellCmdUser(String shellCmdUser) {
this.shellCmdUser = shellCmdUser;
}
public String getShellCmdPassword() {
return shellCmdPassword;
}
public void setShellCmdPassword(String shellCmdPassword) {
this.shellCmdPassword = shellCmdPassword;
}
public String getShellCmdSubmitSycning() {
return shellCmdSubmitSycning;
}
public void setShellCmdSubmitSycning(String shellCmdSubmitSycning) {
this.shellCmdSubmitSycning = shellCmdSubmitSycning;
}
public String getShellCmdQueryStatus() {
return shellCmdQueryStatus;
}
public void setShellCmdQueryStatus(String shellCmdQueryStatus) {
this.shellCmdQueryStatus = shellCmdQueryStatus;
}
public String getShellCmdStopSycning() {
return shellCmdStopSycning;
}
public void setShellCmdStopSycning(String shellCmdStopSycning) {
this.shellCmdStopSycning = shellCmdStopSycning;
}
public String getShellCmdCatLog() {
return shellCmdCatLog;
}
public void setShellCmdCatLog(String shellCmdCatLog) {
this.shellCmdCatLog = shellCmdCatLog;
}
public String getShellFtpDownloadDir() {
return shellFtpDownloadDir;
}
public void setShellFtpDownloadDir(String shellFtpDownloadDir) {
this.shellFtpDownloadDir = shellFtpDownloadDir;
}
public String getHdfsHttpPath() {
return hdfsHttpPath;
}
public void setHdfsHttpPath(String hdfsHttpPath) {
this.hdfsHttpPath = hdfsHttpPath;
}
public String getHdfsUserName() {
return hdfsUserName;
}
public void setHdfsUserName(String hdfsUserName) {
this.hdfsUserName = hdfsUserName;
}
public String getHdfsSyncingPath() {
return hdfsSyncingPath;
}
public void setHdfsSyncingPath(String hdfsSyncingPath) {
this.hdfsSyncingPath = hdfsSyncingPath;
}
public String getImpalaJdbcUrl() {
return impalaJdbcUrl;
}
public void setImpalaJdbcUrl(String impalaJdbcUrl) {
this.impalaJdbcUrl = impalaJdbcUrl;
}
public String getImpalaShellUrl() {
return impalaShellUrl;
}
public void setImpalaShellUrl(String impalaShellUrl) {
this.impalaShellUrl = impalaShellUrl;
}
public String getAzkabanMonitorUrl() {
return azkabanMonitorUrl;
}
public void setAzkabanMonitorUrl(String azkabanMonitorUrl) {
this.azkabanMonitorUrl = azkabanMonitorUrl;
}
public String getAzkabanExectorShellExec() {
return azkabanExectorShellExec;
}
public void setAzkabanExectorShellExec(String azkabanExectorShellExec) {
this.azkabanExectorShellExec = azkabanExectorShellExec;
}
public String getAzkabanExectorSqlExec() {
return azkabanExectorSqlExec;
}
public void setAzkabanExectorSqlExec(String azkabanExectorSqlExec) {
this.azkabanExectorSqlExec = azkabanExectorSqlExec;
}
public String getAzkabanExectorXmlExec() {
return azkabanExectorXmlExec;
}
public void setAzkabanExectorXmlExec(String azkabanExectorXmlExec) {
this.azkabanExectorXmlExec = azkabanExectorXmlExec;
}
public String getAzkabanExectorSqlPath() {
return azkabanExectorSqlPath;
}
public void setAzkabanExectorSqlPath(String azkabanExectorSqlPath) {
this.azkabanExectorSqlPath = azkabanExectorSqlPath;
}
public String getAzkabanExectorShellPath() {
return azkabanExectorShellPath;
}
public void setAzkabanExectorShellPath(String azkabanExectorShellPath) {
this.azkabanExectorShellPath = azkabanExectorShellPath;
}
public String getAzkabanLocalTaskFilePath() {
return azkabanLocalTaskFilePath;
}
public void setAzkabanLocalTaskFilePath(String azkabanLocalTaskFilePath) {
this.azkabanLocalTaskFilePath = azkabanLocalTaskFilePath;
}
public String getKafkaConnectorUrl() {
return kafkaConnectorUrl;
}
public void setKafkaConnectorUrl(String kafkaConnectorUrl) {
this.kafkaConnectorUrl = kafkaConnectorUrl;
}
public String getKafkaBootstrapServers() {
return kafkaBootstrapServers;
}
public void setKafkaBootstrapServers(String kafkaBootstrapServers) {
this.kafkaBootstrapServers = kafkaBootstrapServers;
}
public String getKafkaMonitorUrl() {
return kafkaMonitorUrl;
}
public void setKafkaMonitorUrl(String kafkaMonitorUrl) {
this.kafkaMonitorUrl = kafkaMonitorUrl;
}
public String getKafkaOffsetUpdateShell() {
return kafkaOffsetUpdateShell;
}
public void setKafkaOffsetUpdateShell(String kafkaOffsetUpdateShell) {
this.kafkaOffsetUpdateShell = kafkaOffsetUpdateShell;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public String getCreateUserId() {
return createUserId;
}
public void setCreateUserId(String createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(String updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
public String getKafkaSchemaRegisterUrl() {
return kafkaSchemaRegisterUrl;
}
public void setKafkaSchemaRegisterUrl(String kafkaSchemaRegisterUrl) {
this.kafkaSchemaRegisterUrl = kafkaSchemaRegisterUrl;
}
public String getKafkaInfluxUrl() {
return kafkaInfluxUrl;
}
public void setKafkaInfluxUrl(String kafkaInfluxUrl) {
this.kafkaInfluxUrl = kafkaInfluxUrl;
}
public String getKafkaInfluxUserName() {
return kafkaInfluxUserName;
}
public void setKafkaInfluxUserName(String kafkaInfluxUserName) {
this.kafkaInfluxUserName = kafkaInfluxUserName;
}
public String getKafkaInfluxPassword() {
return kafkaInfluxPassword;
}
public void setKafkaInfluxPassword(String kafkaInfluxPassword) {
this.kafkaInfluxPassword = kafkaInfluxPassword;
}
public Integer getShellSftpPort() {
return shellSftpPort;
}
public void setShellSftpPort(Integer shellSftpPort) {
this.shellSftpPort = shellSftpPort;
}
public String getSparkHiveMetastoreUris() {
return sparkHiveMetastoreUris;
}
public void setSparkHiveMetastoreUris(String sparkHiveMetastoreUris) {
this.sparkHiveMetastoreUris = sparkHiveMetastoreUris;
}
public String getSparkYarnQueue() {
return sparkYarnQueue;
}
public void setSparkYarnQueue(String sparkYarnQueue) {
this.sparkYarnQueue = sparkYarnQueue;
}
public String getSparkDefaultExecutorMemory() {
return sparkDefaultExecutorMemory;
}
public void setSparkDefaultExecutorMemory(String sparkDefaultExecutorMemory) {
this.sparkDefaultExecutorMemory = sparkDefaultExecutorMemory;
}
public Integer getSparkDefaultExecutorCores() {
return sparkDefaultExecutorCores;
}
public void setSparkDefaultExecutorCores(Integer sparkDefaultExecutorCores) {
this.sparkDefaultExecutorCores = sparkDefaultExecutorCores;
}
public Integer getSparkDefaultTotalExecutorCores() {
return sparkDefaultTotalExecutorCores;
}
public void setSparkDefaultTotalExecutorCores(Integer sparkDefaultTotalExecutorCores) {
this.sparkDefaultTotalExecutorCores = sparkDefaultTotalExecutorCores;
}
public String getSparkStatisticsSourceDataSwitch() {
return sparkStatisticsSourceDataSwitch;
}
public void setSparkStatisticsSourceDataSwitch(String sparkStatisticsSourceDataSwitch) {
this.sparkStatisticsSourceDataSwitch = sparkStatisticsSourceDataSwitch;
}
public String getAtlasMonitorUrl() {
return atlasMonitorUrl;
}
public void setAtlasMonitorUrl(String atlasMonitorUrl) {
this.atlasMonitorUrl = atlasMonitorUrl;
}
public String getOpenapiInterfaceUrl() {
return openapiInterfaceUrl;
}
public void setOpenapiInterfaceUrl(String openapiInterfaceUrl) {
this.openapiInterfaceUrl = openapiInterfaceUrl;
}
public String getAzkabanExectorShellExportData() {
return azkabanExectorShellExportData;
}
public void setAzkabanExectorShellExportData(String azkabanExectorShellExportData) {
this.azkabanExectorShellExportData = azkabanExectorShellExportData;
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment