1、Schema的定义
通过StructType和StructField等API来定义Schema。
StructType的构造器:new StructType(fields: Seq[StructField])
StructField的构造器:new StructField(name: String, dataType: DataType, nullable: Boolean)
其中StructType继承DataType。
1、Schema的定义
通过StructType和StructField等API来定义Schema。
StructType的构造器:new StructType(fields: Seq[StructField])
StructField的构造器:new StructField(name: String, dataType: DataType, nullable: Boolean)
其中StructType继承DataType。
本文标题:SparkSQL
本文链接:https://www.haomeiwen.com/subject/mtawkxtx.html
网友评论