Change method name isFlushing to isStageFlushing and move the method

core/trino-main/src/main/java/io/trino/execution/scheduler/PipelinedStageExecution.java

@@ -237,13 +237,6 @@ public synchronized void schedulingComplete()
         }
     }
 
-    private synchronized boolean isFlushing()
-    {
-        // to transition to flushing, there must be at least one flushing task, and all others must be flushing or finished.
-        return !flushingTasks.isEmpty()
-                && allTasks.stream().allMatch(taskId -> finishedTasks.contains(taskId) || flushingTasks.contains(taskId));
-    }
-
     @Override
     public synchronized void schedulingComplete(PlanNodeId partitionedSource)
     {
@@ -389,6 +382,13 @@ private synchronized void updateTaskStatus(TaskStatus taskStatus)
         }
     }
 
+    private synchronized boolean isStageFlushing()
+    {
+        // to transition to flushing, there must be at least one flushing task, and all others must be flushing or finished.
+        return !flushingTasks.isEmpty()
+                && allTasks.stream().allMatch(taskId -> finishedTasks.contains(taskId) || flushingTasks.contains(taskId));
+    }
+
     private ExecutionFailureInfo rewriteTransportFailure(ExecutionFailureInfo executionFailureInfo)
     {
         if (executionFailureInfo.getRemoteHost() == null || failureDetector.getState(executionFailureInfo.getRemoteHost()) != GONE) {