def toSqlData()

in connectors/spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/Converter.scala [35:48]

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

  def toSqlData(field: StructField, value: String): Any = {
    if (value == null || value.equals(SQLConstant.NULL_STR)) return null

    val r = field.dataType match {
      case BooleanType => java.lang.Boolean.valueOf(value)
      case IntegerType => value.toInt
      case LongType => value.toLong
      case FloatType => value.toFloat
      case DoubleType => value.toDouble
      case StringType => value
      case other => throw new UnsupportedOperationException(s"Unsupported type $other")
    }
    r
  }