SparkSQL

作者: 红袖者 | 来源:发表于2017-07-27 11:08 被阅读0次

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