我想为一个表指定一个模式,我使用以下代码在java中执行此操作:
StructType schema = new StructType(List
(
StructField("id", NumericType, true),
StructField("text", StringType, true),
StructField("user", StringType, true)
));
但是 NumericType
, StringType
表示“期望表达式”时出错。如何解决这个问题?
谢谢您。
1条答案
按热度按时间41ik7eoe1#
您的代码包含一些错误。你需要使用
new
要创建的关键字StructField
你不能使用List(StructField, ...)
. 而且,没有NumericType
在spark sql类型中,您可能希望使用IntegerType
. 请参阅可用的spark数据类型。也就是说,你可以试试这个:
或者将静态导入与中提供的方法一起使用
DataTypes
工厂: