import java.text.SimpleDateFormat import java.util.Date import org.apache.spark.{SparkConf, SparkContext} import org.apache.spark.sql.SQLContext import org.apache.spark.sql.hive.HiveContext object StartProcess { val spark:SparkSession = SparkSession.builder() .master("local[1]").appName("SparkByExamples.com") .getOrCreate() import spark.implicits._ val columns = Seq("language","users_count") val data = Seq(("Java", "20000"), ("Python", "100000"), ("Scala", "3000")) val rdd = spark.sparkContext.parallelize(data) val dfFromRDD1 = rdd.toDF() dfFromRDD1.Show(10) } def main(args: Array[String]) { StartProcess }