def get()

in GlueCustomConnectors/development/Spark/SparkConnectorMySQL.scala [150:159]

• 10 lines of code
• 6 McCabe index (conditional complexity)

  def get(): InternalRow = {
    val values = columns.map {
      case "id" => rs.getInt("id")
      case "emp_name" => UTF8String.fromString(rs.getString("emp_name"))
      case "dep_name" => UTF8String.fromString(rs.getString("dep_name"))
      case "salary" => Decimal(rs.getBigDecimal("salary"))
      case "age" => Decimal(rs.getBigDecimal("age"))
    }
    InternalRow.fromSeq(values)
  }