From f0c4031365534cedd50b73ad84a3fd2b89b2158e Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Thu, 6 Jul 2023 16:51:53 +0800 Subject: [PATCH] =?UTF-8?q?fix(forest):=20=E4=BF=AE=E5=A4=8D=E8=A7=A3?= =?UTF-8?q?=E6=9E=90=E7=B1=BB=E9=94=99=E8=AF=AF=E5=AF=BC=E8=87=B4=E6=97=A0?= =?UTF-8?q?=E6=B3=95=E8=8E=B7=E5=8F=96=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/forest/service/HudiService.java | 14 ++++++++++++++ 1 file changed, 14 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 9091cb3..9d61f32 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 @@ -4,8 +4,10 @@ import com.dtflys.forest.annotation.BaseRequest; import com.dtflys.forest.annotation.Get; import com.dtflys.forest.annotation.Query; import com.lanyuanxiaoyao.service.configuration.entity.PageResponse; +import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiCleanerPlan; import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiCompactionPlan; import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiInstant; +import com.lanyuanxiaoyao.service.configuration.entity.hudi.HudiRollbackPlan; import java.util.Map; import org.eclipse.collections.api.list.ImmutableList; @@ -29,6 +31,18 @@ public interface HudiService { @Get("/timeline/read_compaction_plan_hdfs") HudiCompactionPlan readCompactionPlanHdfs(@Query("hdfs") String hdfs, @Query("instant") String instant); + @Get("/timeline/read_rollback_plan") + HudiRollbackPlan readRollbackPlan(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("instant") String instant); + + @Get("/timeline/read_rollback_plan_hdfs") + HudiRollbackPlan readRollbackPlanHdfs(@Query("hdfs") String hdfs, @Query("instant") String instant); + + @Get("/timeline/read_cleaner_plan") + HudiCleanerPlan readCleanerPlan(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("instant") String instant); + + @Get("/timeline/read_cleaner_plan_hdfs") + HudiCleanerPlan readCleanerPlanHdfs(@Query("hdfs") String hdfs, @Query("instant") String instant); + @Get("/timeline/list_pending_compaction") ImmutableList timelinePendingCompactionList(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias); }