Add getCurrentLeafSplitsSize metric

trinodb · Sep 6, 2023 · 72d8f24 · 72d8f24
1 parent 675defb
commit 72d8f24
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...o-main/src/main/java/io/trino/execution/executor/timesharing/TimeSharingTaskExecutor.java b/...o-main/src/main/java/io/trino/execution/executor/timesharing/TimeSharingTaskExecutor.java
@@ -669,6 +669,12 @@ public DistributionStat getLeafSplitsSize()
         return leafSplitsSize;
     }
 
+    @Managed
+    public synchronized int getCurrentLeafSplitsSize()
+    {
+        return allSplits.size() - intermediateSplits.size();
+    }
+
     @Managed
     public int getRunningSplits()
     {