public void convert()

in src/main/java/com/aliyun/odps/kafka/connect/converter/BinaryRecordConverter.java [49:66]

• 17 lines of code
• 4 McCabe index (conditional complexity)

  public void convert(SinkRecord in, Record out) {
    out.setString(TOPIC, in.topic());
    out.setBigint(PARTITION, in.kafkaPartition().longValue());
    out.setBigint(OFFSET, in.kafkaOffset());

    switch (mode) {
      case KEY:
        out.set(KEY, convertToBinary(in.key()));
        break;
      case VALUE:
        out.set(VALUE, convertToBinary(in.value()));
        break;
      case DEFAULT:
      default:
        out.set(KEY, convertToBinary(in.key()));
        out.set(VALUE, convertToBinary(in.value()));
    }
  }