public PipeSink generateSink()

in backup-core/src/main/java/org/apache/iotdb/backup/core/ExportStarter.java [201:222]

• 22 lines of code
• 7 McCabe index (conditional complexity)

  public PipeSink<TimeSeriesRowModel, TimeSeriesRowModel> generateSink(ExportModel exportModel) {
    PipeSink<TimeSeriesRowModel, TimeSeriesRowModel> pipeSink;
    switch (exportModel.getCompressEnum()) {
      case SQL:
        pipeSink = new OutSqlFileSink("sql sink");
        break;
      case CSV:
        pipeSink = new OutCsvFileSink("csv sink");
        break;
      case SNAPPY:
      case GZIP:
      case LZ4:
        pipeSink = new OutCompressFileSink("compress sink");
        break;
      case TSFILE:
        pipeSink = new OutTsfileDataSink("tsfile sink");
        break;
      default:
        throw new IllegalStateException("Unexpected value: " + exportModel.getCompressEnum());
    }
    return pipeSink;
  }