From ece98345dfcc98dd79db43aa5e3273d5c8ceaae9 Mon Sep 17 00:00:00 2001 From: KennethCheng Date: Thu, 17 Sep 2026 18:44:55 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E7=BA=BF=E4=B8=8B=E8=AF=BE=EF=BC=9A?= =?UTF-8?q?=E5=88=9B=E5=BB=BADataFrame?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/example/sql/CreateDataFrame.scala | 22 +++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 src/main/scala/org/example/sql/CreateDataFrame.scala 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() + } +}