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,