lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(common): 移除没有使用的表

Browse Source
This commit is contained in:
v-zhangjc9
2024-05-23 11:50:59 +08:00
parent 5c80589ff6
commit 496b09d2de
2 changed files with 0 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
database/table_tb_app_hudi_compaction_job.sql
View File

@@ -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 ='压缩调度任务队列';

62
service-common/src/main/java/com/lanyuanxiaoyao/service/common/SQLConstants.java
View File

@@ -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 压缩计划执行具体指标
*/