diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java index 350fbad..56dc073 100644 --- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java +++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java @@ -43,4 +43,10 @@ public interface InfoService { @Get("/sync_state/detail") SyncState syncStateDetail(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); + + @Get("/non_updated_version_tables") + ImmutableList nonUpdatedVersionTables(); + + @Get("/updated_version_tables") + ImmutableList updatedVersionTables(); } diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/InfoController.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/InfoController.java index 24f76a0..281afc4 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/InfoController.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/InfoController.java @@ -89,4 +89,14 @@ public class InfoController { public SyncState syncState(@RequestParam("flink_job_id") Long flinkJobId, @RequestParam("alias") String alias) { return infoService.syncState(flinkJobId, alias); } + + @GetMapping("/non_updated_version_tables") + public ImmutableList nonUpdatedVersionTables() { + return infoService.nonUpdatedVersionTables(); + } + + @GetMapping("/updated_version_tables") + public ImmutableList updatedVersionTables() { + return infoService.nonUpdatedVersionTables(); + } } diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java index 224c583..9e8207e 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java @@ -186,4 +186,16 @@ public class InfoService { public TableMeta tableMeta(Long flinkJobId, String alias) { return databaseService.getTableMeta(flinkJobId, alias); } + + @Cacheable("un-updated-version-table") + @Retryable(Throwable.class) + public ImmutableList nonUpdatedVersionTables() { + return databaseService.findAllUnScheduledTable(); + } + + @Cacheable("updated-version-table") + @Retryable(Throwable.class) + public ImmutableList updatedVersionTables() { + return databaseService.findAllScheduledTable(); + } }