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

feature(web): 增加 hive 表维度统计

Browse Source
This commit is contained in:
兰缘小妖
2023-06-13 18:47:03 +08:00
parent 266584cece
commit 3ded854480
2 changed files with 20 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java
View File

@@ -11,6 +11,11 @@ import com.lanyuanxiaoyao.service.forest.service.InfoService;
import com.lanyuanxiaoyao.service.forest.service.QueueService;
import com.lanyuanxiaoyao.service.forest.service.YarnService;
import com.lanyuanxiaoyao.service.web.entity.JobIdAndAliasVO;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import org.eclipse.collections.api.factory.Lists;
import org.eclipse.collections.api.factory.Maps;
import org.eclipse.collections.api.list.ImmutableList;
@@ -22,12 +27,6 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
/**
* 概览
*
@@ -56,17 +55,23 @@ public class OverviewController extends BaseController {
CompletableFuture<Long> tableFocusCountFuture = CompletableFuture.supplyAsync(infoService::tableFocusCount, ExecutorProvider.EXECUTORS);
CompletableFuture<Long> hudiCountFuture = CompletableFuture.supplyAsync(infoService::hudiCount, ExecutorProvider.EXECUTORS);
CompletableFuture<Long> hudiFocusCountFuture = CompletableFuture.supplyAsync(infoService::hudiFocusCount, ExecutorProvider.EXECUTORS);
CompletableFuture<Long> hiveCountFuture = CompletableFuture.supplyAsync(infoService::hiveCount, ExecutorProvider.EXECUTORS);
CompletableFuture<Long> hiveFocusCountFuture = CompletableFuture.supplyAsync(infoService::hiveFocusCount, ExecutorProvider.EXECUTORS);
CompletableFuture.allOf(
tableCountFuture,
tableFocusCountFuture,
hudiCountFuture,
hudiFocusCountFuture
hudiFocusCountFuture,
hiveCountFuture,
hiveFocusCountFuture
).get();
return responseData()
.withData("table_count", tableCountFuture.get())
.withData("table_focus_count", tableFocusCountFuture.get())
.withData("hudi_count", hudiCountFuture.get())
.withData("hudi_focus_count", hudiFocusCountFuture.get());
.withData("hudi_focus_count", hudiFocusCountFuture.get())
.withData("hive_count", hiveCountFuture.get())
.withData("hive_focus_count", hiveFocusCountFuture.get());
}
@GetMapping("yarn-job")