public ByteBuffer convertResultSetIntoAvroBytes()

in dbeam-core/src/main/java/com/spotify/dbeam/avro/JdbcAvroRecordConverter.java [90:105]

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

  public ByteBuffer convertResultSetIntoAvroBytes() throws SQLException, IOException {
    final MyByteArrayOutputStream out = new MyByteArrayOutputStream(columnCount * 64);
    binaryEncoder = encoderFactory.directBinaryEncoder(out, binaryEncoder);
    for (int i = 1; i <= columnCount; i++) {
      final Object value = mappings[i].apply(resultSet);
      if (value == null || resultSet.wasNull()) {
        binaryEncoder.writeIndex(0);
        binaryEncoder.writeNull();
      } else {
        binaryEncoder.writeIndex(1);
        writeValue(value, binaryEncoder);
      }
    }
    binaryEncoder.flush();
    return ByteBuffer.wrap(out.getBufffer(), 0, out.size());
  }