diff --git a/src/main/scala/org/example/sql/CreateDataFrame.scala b/src/main/scala/org/example/sql/CreateDataFrame.scala new file mode 100644 index 0000000..c43d7fa --- /dev/null +++ b/src/main/scala/org/example/sql/CreateDataFrame.scala @@ -0,0 +1,22 @@ +package org.example.sql + +import org.apache.spark.sql._ + + +object CreateDataFrame { + def main(args: Array[String]): Unit = { + val spark = SparkSession.builder() + .master("local[*]") + .appName("DataFrameDemo") + .getOrCreate() + val data = List( + (1, "zhangsan", 18), + (2, "lisi", 18), + (3, "wangwu", 18) + ) + import spark.implicits._ + val df = data.toDF() + df.show() + df.printSchema() + } +}