private TsFileWriter getTsfileWriter()

in backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutTsfileDataSink.java [264:291]

24 lines of code
3 McCabe index (conditional complexity)


  private TsFileWriter getTsfileWriter(
      ConcurrentMap<String, TsFileWriter> tsfileWriterMap,
      ConcurrentMap<String, Schema> schemaMap,
      String deviceId,
      String tsfileNameKey,
      String fileFolder) {
    TsFileWriter tsFileWriter = null;
    synchronized (tsfileWriterMap) {
      if (!tsfileWriterMap.containsKey(tsfileNameKey)) {
        try {
          File file = new File(fileFolder + File.separator + tsfileNameKey);
          Schema schema = new Schema();
          //          TSFileConfig config = TSFileDescriptor.getInstance().getConfig();
          //          config.setGroupSizeInByte(16 * 1024 * 1024);
          //          tsfileWriterMap.putIfAbsent(tsfileNameKey, new TsFileWriter(file, schema,
          // config));
          tsfileWriterMap.putIfAbsent(tsfileNameKey, new TsFileWriter(file, schema));
          schemaMap.putIfAbsent(tsfileNameKey, schema);
          tsFileWriter = tsfileWriterMap.get(tsfileNameKey);
        } catch (IOException e) {
          e.printStackTrace();
        }
      } else {
        tsFileWriter = tsfileWriterMap.get(tsfileNameKey);
      }
      return tsFileWriter;
    }
  }