feat(command): 增加手动调度全表压缩和重点表压缩

2024-05-21 19:03:01 +08:00
parent 617456b7d9
commit 9db8746496
1 changed files with 10 additions and 0 deletions
--- 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,