Converts a DataFrame schema output (StructType) into something you can paste as a schema, as valid Scala code. Useful when working with Apache Zeppelin or any other REPL.

schemaAsScala.scala

import org.apache.spark.sql.types._ // You'll need this to evaluate its output

object StructFmt {
  def asScala(field: StructField): String = field.dataType match {
      case struct: StructType =>  s"""StructField("${field.name}",""" + asScala(struct) + s", ${field.nullable})"
      case _ => s"""StructField("${field.name}", ${field.dataType}, ${field.nullable})"""
  }

  def asScala(struct: StructType): String = "StructType(Seq(" + (for(field <- struct) yield asScala(field)).mkString(",") + "))"
}