private[kusto] def convertRow()

in connector/src/main/scala/com/microsoft/kusto/spark/datasink/KustoCsvSerializationUtils.scala [19:31]

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

  private[kusto] def convertRow(row: InternalRow) = {
    val values = new Array[String](row.numFields)
    for (i <- 0 until row.numFields if !row.isNullAt(i)) {
      val dataType = schema.fields(i).dataType
      values(i) = dataType match {
        case DateType => DateTimeUtils.toJavaDate(row.getInt(i)).toString
        case TimestampType => DateFormat.format(DateTimeUtils.toJavaTimestamp(row.getLong(i)))
        case _ => row.get(i, dataType).toString
      }
    }

    values
  }