From 9db874649636775b9855794e8ea944a57f86ce33 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 21 May 2024 19:03:01 +0800 Subject: [PATCH] =?UTF-8?q?feat(command):=20=E5=A2=9E=E5=8A=A0=E6=89=8B?= =?UTF-8?q?=E5=8A=A8=E8=B0=83=E5=BA=A6=E5=85=A8=E8=A1=A8=E5=8E=8B=E7=BC=A9?= =?UTF-8?q?=E5=92=8C=E9=87=8D=E7=82=B9=E8=A1=A8=E5=8E=8B=E7=BC=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/command/commands/CompactionCommand.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java index bdea9a1..6f6276f 100644 --- a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java +++ b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java @@ -40,6 +40,16 @@ public class CompactionCommand extends AbstractUtilShellComponent { this.launchersService = launchersService; } + @ShellMethod("启动全部表压缩") + public void compactionAll() { + scheduleService.scheduleAllTable(); + } + + @ShellMethod("启动全部重点表压缩") + public void compactionAllForce() { + scheduleService.scheduleAllFocus(); + } + @ShellMethod("启动表压缩任务") public String compactionRun( @ShellOption(help = "Flink job id") Long flinkJobId,