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

feat(database): 增加汇聚平台表信息表sql

Browse Source
This commit is contained in:
v-zhangjc9
2024-05-16 14:50:59 +08:00
parent 20e3fdae87
commit 486b9ec6b5
15 changed files with 76 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
database/table_tb_app_hudi_sync_state.sql Normal file
View File

@@ -0,0 +1,31 @@
CREATE TABLE `tb_app_hudi_sync_state`
(
`id` varchar(100) NOT NULL COMMENT '唯一标识',
`message_id` varchar(50) DEFAULT NULL COMMENT 'pulsar 消息位移',
`source_database` varchar(50) DEFAULT NULL COMMENT '源数据库',
`source_schema` varchar(50) DEFAULT NULL COMMENT '源库',
`source_table` varchar(50) DEFAULT NULL COMMENT '源表',
`source_start_time` datetime DEFAULT NULL COMMENT '同步启动时间',
`source_checkpoint_time` datetime DEFAULT NULL COMMENT '同步检查时间',
`source_publish_time` datetime DEFAULT NULL COMMENT '消息发布时间',
`source_op_time` datetime DEFAULT NULL COMMENT '消息业务时间',
`source_application_id` varchar(50) DEFAULT NULL COMMENT '同步程序 application id',
`source_cluster` varchar(50) DEFAULT NULL COMMENT '运行主机',
`compaction_start_time` datetime DEFAULT NULL COMMENT '压缩启动时间',
`compaction_finish_time` datetime DEFAULT NULL COMMENT '压缩完成时间',
`compaction_message` text COMMENT '压缩异常信息',
`compaction_application_id` varchar(50) DEFAULT NULL COMMENT '压缩任务 yarn id',
`compaction_status` varchar(20) DEFAULT NULL COMMENT '压缩状态',
`compaction_status_time` datetime DEFAULT NULL COMMENT '压缩事件时间',
`compaction_cluster` varchar(50) DEFAULT NULL COMMENT '运行主机',
`compaction_latest_op_ts` datetime DEFAULT NULL COMMENT '压缩提供的 latest_op_ts',
`update_batch_marker` varchar(100) DEFAULT NULL COMMENT '更新批次号',
`pulsar_back_log` bigint(20) DEFAULT NULL COMMENT 'pulsar 积压',
`update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
`check_source_total` bigint(20) DEFAULT NULL COMMENT '检查源数据总数',
`check_source_total_time` datetime DEFAULT NULL COMMENT '检查源数据总数耗时',
`check_target_total` bigint(20) DEFAULT NULL COMMENT '检查目标数据总数',
`check_target_latest_op_ts` varchar(100) DEFAULT NULL COMMENT '检查目标数据最新业务时间',
`check_target_total_time` datetime DEFAULT NULL COMMENT '检查目标数据总数耗时',
PRIMARY KEY (`id`)
) DEFAULT CHARSET = utf8mb4 COMMENT ='表实时状态';