Update PipeHistoricalDataRegionTsFileAndDeletionExtractor.java

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionExtractor.java

@@ -617,6 +617,26 @@ private void extractDeletions(
         originalDeletionCount);
   }
 
+  @Override
+  public synchronized Event supply() {
+    if (!hasBeenStarted && StorageEngine.getInstance().isReadyForNonReadWriteFunctions()) {
+      start();
+    }
+
+    if (Objects.isNull(pendingQueue)) {
+      return null;
+    }
+
+    final PersistentResource resource = pendingQueue.poll();
+    if (resource == null) {
+      return supplyTerminateEvent();
+    } else if (resource instanceof TsFileResource) {
+      return supplyTsFileEvent((TsFileResource) resource);
+    } else {
+      return supplyDeletionEvent((DeletionResource) resource);
+    }
+  }
+
   private Event supplyTsFileEvent(TsFileResource resource) {
     final PipeTsFileInsertionEvent event =
         new PipeTsFileInsertionEvent(
@@ -708,26 +728,6 @@ private Event supplyTerminateEvent() {
     return terminateEvent;
   }
 
-  @Override
-  public synchronized Event supply() {
-    if (!hasBeenStarted && StorageEngine.getInstance().isReadyForNonReadWriteFunctions()) {
-      start();
-    }
-
-    if (Objects.isNull(pendingQueue)) {
-      return null;
-    }
-
-    final PersistentResource resource = pendingQueue.poll();
-    if (resource == null) {
-      return supplyTerminateEvent();
-    } else if (resource instanceof TsFileResource) {
-      return supplyTsFileEvent((TsFileResource) resource);
-    } else {
-      return supplyDeletionEvent((DeletionResource) resource);
-    }
-  }
-
   @Override
   public synchronized boolean hasConsumedAll() {
     // If the pendingQueues are null when the function is called, it implies that the extractor only