讓我們假設我創建了一個木文件,如下所示: case class A (i:Int,j:Double,s:String)
var l1 = List(A(1,2.0,"s1"),A(2,3.0,"S2"))
val ds = spark.createDataset(l1)
ds.write.parquet("/tmp/test.parquet")
是否有可能將其與不同的模式,其中唯一的
我有案例類是這樣的: case class Ais(NotImportant)
extends Serializable {
var flag = Ais.Flag.NotFlagged
var cluster = Ais.Unknown
var visited = false
override def toString(): String