private ProgressIndex getProgressIndex4RealtimeEvent(final PipeRealtimeEvent event) {
    return event.getEvent() instanceof PipeTsFileInsertionEvent
        ? ((PipeTsFileInsertionEvent) event.getEvent()).forceGetProgressIndex()
        : event.getProgressIndex();
  }
The {@link DisruptorQueue} is used to assign the event to the extractor.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java