backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/in/source/InCompressDataSource.java [240:265]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                      finishDeviceModel.setDeviceName(builder.toString());
                      finishRowModel.setDeviceModel(finishDeviceModel);
                      finishRowModel.setIFieldList(new ArrayList<>());
                      sink.next(finishRowModel);
                      sink.complete();
                    } catch (IOException
                        | StatementExecutionException
                        | IoTDBConnectionException
                        | ParamCheckException e) {
                      sink.error(e);
                    } finally {
                      try {
                        if (in != null) {
                          in.close();
                        }
                      } catch (IOException e) {
                        log.error("异常信息:", e);
                      }
                    }
                  });
        });
  }

  public FilenameFilter initFileFilter(ImportModel importModel) {
    return (dir, name) -> {
      switch (importModel.getCompressEnum()) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/in/source/InCsvDataSource.java [242:268]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        finishDeviceModel.setDeviceName(builder.toString());
                        finishRowModel.setDeviceModel(finishDeviceModel);
                        finishRowModel.setIFieldList(new ArrayList<>());
                        sink.next(finishRowModel);
                      }
                      sink.complete();
                    } catch (IOException
                        | StatementExecutionException
                        | IoTDBConnectionException
                        | ParamCheckException e) {
                      sink.error(e);
                    } finally {
                      try {
                        if (in != null) {
                          in.close();
                        }
                      } catch (IOException e) {
                        log.error("异常信息:", e);
                      }
                    }
                  });
        });
  }

  public FilenameFilter initFileFilter(ImportModel importModel) {
    return (dir, name) -> {
      switch (importModel.getCompressEnum()) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -