From f4f713130aaa006b11c3405107a40c86d280dfef Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Wed, 24 Jan 2024 17:19:15 +0800 Subject: [PATCH] =?UTF-8?q?feat(hudi-query):=20=E5=A2=9E=E5=8A=A0=E5=88=A4?= =?UTF-8?q?=E6=96=AD=E5=8E=8B=E7=BC=A9=E8=AE=A1=E5=88=92=E6=98=AF=E5=90=A6?= =?UTF-8?q?=E5=AD=98=E5=9C=A8=E7=9A=84=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/forest/service/HudiService.java | 3 +++ .../service/hudi/controller/TimelineController.java | 8 ++++++++ 2 files changed, 11 insertions(+) diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java index a631f7c..1a0d8ec 100644 --- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java +++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java @@ -47,6 +47,9 @@ public interface HudiService { @Get("/timeline/list_pending_compaction") ImmutableList timelinePendingCompactionList(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); + @Get("/timeline/exists_compaction_plan") + Boolean existsCompactionPlan(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); + @Get("/table/schema") ImmutableMap schema(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); diff --git a/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java b/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java index ab82891..a8f2c8a 100644 --- a/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java +++ b/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java @@ -140,4 +140,12 @@ public class TimelineController { ) throws IOException { return timelineService.pendingCompactionTimeline(flinkJobId, alias); } + + @GetMapping("exists_compaction_plan") + public Boolean existsCompactionPlan( + @RequestParam("flink_job_id") Long flinkJobId, + @RequestParam("alias") String alias + ) throws IOException { + return !timelineService.pendingCompactionTimeline(flinkJobId, alias).isEmpty(); + } }