public RecordConverter build()

in src/main/java/com/aliyun/odps/kafka/connect/converter/RecordConverterBuilder.java [88:106]

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

  public RecordConverter build() {
    if (Format.TEXT.equals(format)) {
      return new DefaultRecordConverter(mode);
    } else if (Format.BINARY.equals(format)) {
      return new BinaryRecordConverter(mode);
    } else if (Format.CSV.equals(format) && !Mode.DEFAULT.equals(mode)) {
      if (schema == null) {
        throw new IllegalArgumentException("Required argument: schema");
      }
      return new CsvRecordConverter(schema, mode);
    } else if (Format.JSON.equals(format)) {
      return new JsonRecordConverter(mode);
    } else if (Format.FLATTEN.equals(format)) {
      return new FlattenRecordConverter(mode, schema);
    } else {
      throw new IllegalArgumentException(
          "Unsupported combination, Converter type: " + mode + ", format: " + format);
    }
  }