def getSparkValue()

in connectors/spark-iotdb-table-connector/spark-iotdb-table-common/src/main/scala/org/apache/iotdb/spark/table/db/IoTDBUtils.scala [91:103]

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

  def getSparkValue(sparkDataType: DataType, dataSetIterator: SessionDataSet#DataIterator, columnIdx: Int): Any = {
    sparkDataType match {
      case BooleanType => dataSetIterator.getBoolean(columnIdx)
      case IntegerType => dataSetIterator.getInt(columnIdx)
      case DateType => DateTimeUtils.fromJavaDate(DateUtils.parseIntToDate(dataSetIterator.getInt(columnIdx)))
      case LongType => dataSetIterator.getLong(columnIdx)
      case FloatType => dataSetIterator.getFloat(columnIdx)
      case DoubleType => dataSetIterator.getDouble(columnIdx)
      case StringType => UTF8String.fromString(dataSetIterator.getString(columnIdx))
      case BinaryType => getByteArrayFromHexString(dataSetIterator.getString(columnIdx))
      case TimestampType => dataSetIterator.getLong(columnIdx)
    }
  }