private def convertArrayToJson()

in connector/src/main/scala/com/microsoft/kusto/spark/datasink/RowCSVWriterUtils.scala [144:164]

• 19 lines of code
• 5 McCabe index (conditional complexity)

  private def convertArrayToJson(
      ar: ArrayData,
      fieldsType: DataType,
      timeZone: ZoneId): String = {
    if (ar.numElements() == 0) "[]"
    else {
      val writer = EscapedWriter(new CharArrayWriter())

      writer.write('[')
      if (ar.isNullAt(0)) writer.write("null")
      else writeField(ar, fieldIndexInRow = 0, fieldsType, timeZone, writer, nested = true)
      for (x <- 1 until ar.numElements()) {
        writer.write(',')
        if (ar.isNullAt(x)) writer.write("null")
        else writeField(ar, x, fieldsType, timeZone, writer, nested = true)
      }
      writer.write(']')

      writer.out.toString
    }
  }