feat:线下课:创建DataFrame
This commit is contained in:
@@ -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()
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user