private def getValueTransformer()

in connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoResponseDeserializer.scala [31:56]

• 25 lines of code
• 20 McCabe index (conditional complexity)

  private def getValueTransformer(valueType: String): Any => Any = {

    valueType.toLowerCase() match {
      case "string" => value: Any => value
      case "int64" => value: Any => value
      case "datetime" => value: Any => Timestamp.from(Instant.parse(value.toString))
      case "timespan" => value: Any => value
      case "sbyte" => value: Any => value
      case "long" => {
        case i: Int => i.toLong
        case value => value.asInstanceOf[Long]
      }
      case "double" => value: Any => value
      case "decimal" => value: Any => BigDecimal(value.asInstanceOf[String])
      case "int" => value: Any => value
      case "int32" => value: Any => value
      case "bool" => value: Any => value
      case "real" => {
        case v: Int => v.toDouble
        case v: Long => v.toDouble
        case v: java.math.BigDecimal => v.doubleValue()
        case v => v.asInstanceOf[Double]
      }
      case _ => value: Any => value.toString
    }
  }