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

feat(hudi-query): 增加判断压缩计划是否存在的方法

Browse Source
This commit is contained in:
兰缘小妖
2024-01-24 17:19:15 +08:00
parent 284571485c
commit f4f713130a
2 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/HudiService.java
View File

@@ -47,6 +47,9 @@ public interface HudiService {
@Get("/timeline/list_pending_compaction") @Get("/timeline/list_pending_compaction")
ImmutableList<HudiInstant> timelinePendingCompactionList(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); ImmutableList<HudiInstant> 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") @Get("/table/schema")
ImmutableMap<String, Object> schema(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); ImmutableMap<String, Object> schema(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);

8
service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/TimelineController.java
View File

@@ -140,4 +140,12 @@ public class TimelineController {
) throws IOException { ) throws IOException {
return timelineService.pendingCompactionTimeline(flinkJobId, alias); 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();
}
} }