private def toCqlValue()

in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraScanBuilder.scala [278:294]

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

  private def toCqlValue(tableDef: TableDef, columnName: String, value: Any): Any = {
    value match {
      case decimal: Decimal =>
        val isVarIntColumn = tableDef.columnByName(columnName).columnType == VarIntType
        if (isVarIntColumn) decimal.toJavaBigDecimal.toBigInteger else decimal
      case utf8String: UTF8String =>
        val columnType = tableDef.columnByName(columnName).columnType
        if (columnType == InetType) {
          InetAddress.getByName(utf8String.toString)
        } else if (columnType == UUIDType) {
          UUID.fromString(utf8String.toString)
        } else {
          utf8String
        }
      case other => other
    }
  }