public CsvRecordConverter()

in src/main/java/com/aliyun/odps/kafka/connect/converter/CsvRecordConverter.java [61:74]

• 12 lines of code
• 5 McCabe index (conditional complexity)

  public CsvRecordConverter(TableSchema schema, RecordConverterBuilder.Mode mode) {
    this.schema = schema;
    this.mode = mode;

    // Init userColIndex
    for (int i = 0; i < schema.getColumns().size(); i++) {
      Column c = schema.getColumn(i);
      if (!TOPIC.equalsIgnoreCase(c.getName())
          && !PARTITION.equalsIgnoreCase(c.getName())
          && !OFFSET.equalsIgnoreCase(c.getName())) {
        userColIndex.add(i);
      }
    }
  }