import org.apache.spark.sql.Row // Seq[org.apache.spark.sql.Row] data = logData.getSeq[Row](logData.fieldIndex("object")); val rdd = sc.parallelize(data) val df = sqlContext.createDataFrame(rdd, data.apply(0).schema) df.show()