diff --git a/database/table_tb_app_hudi_compaction_job.sql b/database/table_tb_app_hudi_compaction_job.sql deleted file mode 100644 index e5720ef..0000000 --- a/database/table_tb_app_hudi_compaction_job.sql +++ /dev/null @@ -1,9 +0,0 @@ -CREATE TABLE `tb_app_hudi_compaction_job` -( - `flink_job_id` bigint(20) NOT NULL, - `alias` varchar(100) NOT NULL COMMENT '别名', - `comment` varchar(100) DEFAULT NULL COMMENT '备注', - `application_id` varchar(100) NOT NULL COMMENT 'yarn 应用 id', - `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', - `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间' -) DEFAULT CHARSET = utf8mb4 COMMENT ='压缩调度任务队列'; diff --git a/service-common/src/main/java/com/lanyuanxiaoyao/service/common/SQLConstants.java b/service-common/src/main/java/com/lanyuanxiaoyao/service/common/SQLConstants.java index dc5de66..37f6f92 100644 --- a/service-common/src/main/java/com/lanyuanxiaoyao/service/common/SQLConstants.java +++ b/service-common/src/main/java/com/lanyuanxiaoyao/service/common/SQLConstants.java @@ -504,68 +504,6 @@ public interface SQLConstants { String ZK_URL_A = _alias_.getAlias() + "." + ZK_URL_O; } - /** - * tb_app_hudi_compaction_job 压缩调度任务队列 - */ - interface TbAppHudiCompactionJob { - /** - * 表原名 - */ - String _origin_ = _name_ + ".tb_app_hudi_compaction_job"; - /** - * SqlBuilder 别名对象 {@link Alias} - */ - Alias _alias_ = Alias.of(_name_ + ".tb_app_hudi_compaction_job", "tahcj"); - /** - * 字段 flink_job_id 原始值 flink_job_id - */ - String FLINK_JOB_ID_O = "flink_job_id"; - /** - * 字段 flink_job_id 别名值 tahcj.flink_job_id - */ - String FLINK_JOB_ID_A = _alias_.getAlias() + "." + FLINK_JOB_ID_O; - /** - * 字段 alias 原始值 alias 别名 - */ - String ALIAS_O = "alias"; - /** - * 字段 alias 别名值 tahcj.alias 别名 - */ - String ALIAS_A = _alias_.getAlias() + "." + ALIAS_O; - /** - * 字段 comment 原始值 comment 备注 - */ - String COMMENT_O = "comment"; - /** - * 字段 comment 别名值 tahcj.comment 备注 - */ - String COMMENT_A = _alias_.getAlias() + "." + COMMENT_O; - /** - * 字段 application_id 原始值 application_id - */ - String APPLICATION_ID_O = "application_id"; - /** - * 字段 application_id 别名值 tahcj.application_id - */ - String APPLICATION_ID_A = _alias_.getAlias() + "." + APPLICATION_ID_O; - /** - * 字段 create_time 原始值 create_time 创建时间 - */ - String CREATE_TIME_O = "create_time"; - /** - * 字段 create_time 别名值 tahcj.create_time 创建时间 - */ - String CREATE_TIME_A = _alias_.getAlias() + "." + CREATE_TIME_O; - /** - * 字段 update_time 原始值 update_time 更新时间 - */ - String UPDATE_TIME_O = "update_time"; - /** - * 字段 update_time 别名值 tahcj.update_time 更新时间 - */ - String UPDATE_TIME_A = _alias_.getAlias() + "." + UPDATE_TIME_O; - } - /** * tb_app_hudi_compaction_metrics 压缩计划执行具体指标 */