public FlattenRecordConverter()

in src/main/java/com/aliyun/odps/kafka/connect/converter/FlattenRecordConverter.java [24:35]

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

  public FlattenRecordConverter(RecordConverterBuilder.Mode mode, TableSchema schema) {
    this.mode = mode;
    for (int i = 0; i < schema.getColumns().size(); i++) {
      String cur = schema.getColumn(i).getName().toLowerCase();
      colNames.add(cur);
      lookID.put(cur, i);
    }
    String[] fixedColumns = {TOPIC, PARTITION, OFFSET};
    for (String column : fixedColumns) {
      checkColumnExist(column);
    }
  }