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

fix(forest): 修复解析类错误导致无法获取数据

Browse Source
This commit is contained in:
兰缘小妖
2023-07-06 16:51:53 +08:00
parent 894faae2ed
commit f0c4031365
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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<HudiInstant> timelinePendingCompactionList(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
}