public PipeSink generateSink()

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

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

  public PipeSink generateSink(ImportModel importModel) {
    PipeSink pipeSink;
    switch (importModel.getCompressEnum()) {
      case SQL:
        pipeSink = new InSqlFileSink("sql sink");
        break;
      case CSV:
      case SNAPPY:
      case GZIP:
      case LZ4:
        pipeSink = new InRowModelFileSink("compress sink");
        break;
      default:
        throw new IllegalStateException("Unexpected value: " + importModel.getCompressEnum());
    }
    return pipeSink;
  }