From 8fda8f76692e0e7a5afddefd28d51d9fe73f8de8 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Sat, 12 Oct 2024 15:52:05 +0800 Subject: [PATCH] =?UTF-8?q?fix(hudi-query):=20=E4=BF=AE=E5=A4=8D=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E8=B0=83=E7=94=A8=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/hudi/controller/HdfsController.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/HdfsController.java b/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/HdfsController.java index 78fe75c..460ebab 100644 --- a/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/HdfsController.java +++ b/service-hudi-query/src/main/java/com/lanyuanxiaoyao/service/hudi/controller/HdfsController.java @@ -85,16 +85,16 @@ public class HdfsController { @GetMapping("count") public Long count(@RequestParam("root") String root) throws IOException { - return hdfsService.size(root); + return hdfsService.count(root); } @GetMapping("file_count") public Long fileCount(@RequestParam("root") String root) throws IOException { - return hdfsService.size(root); + return hdfsService.countFiles(root); } @GetMapping("directory_count") public Long DirectoryCount(@RequestParam("root") String root) throws IOException { - return hdfsService.size(root); + return hdfsService.countDirectories(root); } }