default void process(TsFileInsertionEvent tsFileInsertionEvent, EventCollector eventCollector)
      throws Exception {
    try {
      for (final TabletInsertionEvent tabletInsertionEvent :
          tsFileInsertionEvent.toTabletInsertionEvents()) {
        process(tabletInsertionEvent, eventCollector);
      }
    } finally {
      tsFileInsertionEvent.close();
    }
  }
This method is called to process the {@link TsFileInsertionEvent}.

@param tsFileInsertionEvent {@link TsFileInsertionEvent} to be processed
@param eventCollector used to collect result events after processing
@throws Exception the user can throw errors if necessary
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java