public PipeChannel generateChannel()

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

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

  public PipeChannel generateChannel(ImportModel importModel) {
    PipeChannel pipeChannel;
    switch (importModel.getCompressEnum()) {
      case SQL:
        pipeChannel = new SpecialForSQLChannel("sql channel");
        break;
      case CSV:
      case SNAPPY:
      case GZIP:
      case LZ4:
        pipeChannel = new FieldColumnFormatChannel("csv channel");
        break;
      default:
        throw new IllegalStateException("Unexpected value: " + importModel.getCompressEnum());
    }
    return pipeChannel;
  }