我正在构建一个spark结构化流应用程序,我有一个如下的结构类型来解析传入的事件,“value”列可以接收数字或字符串值。
如何将字符串和数值保存在同一“值”列中。是否有类似对象数据类型的东西同时接受字符串/数字数据类型?
val testSchema= new StructType()
.add("Name", StringType)
.add("Value", StringType)))
我尝试使用map()方法遍历dataframe中的行,以手动检查值是string还是numeric,并且一直在更改“value”列中的数据类型。
暂无答案!
目前还没有任何答案,快来回答吧!