public PipeSource generateSource()

in backup-core/src/main/java/org/apache/iotdb/backup/core/ImportStarter.java [132:150]

• 19 lines of code
• 6 McCabe index (conditional complexity)

  public PipeSource generateSource(ImportModel importModel) {
    PipeSource pipeSource;
    switch (importModel.getCompressEnum()) {
      case SQL:
        pipeSource = new InSqlDataSource("sql source", importModel.getParallelism());
        break;
      case CSV:
        pipeSource = new InCsvDataSource("csv source", importModel.getParallelism());
        break;
      case SNAPPY:
      case GZIP:
      case LZ4:
        pipeSource = new InCompressDataSource("compress source", importModel.getParallelism());
        break;
      default:
        throw new IllegalStateException("Unexpected value: " + importModel.getCompressEnum());
    }
    return pipeSource;
  }