2
我使用spark 1.6.1,并在java中的代码。当我使用callUDF()时,它显示为什么我不能使用callUDF方法?
The method callUDF(String, Column) is undefined for the type PhaseOne
和callUdf()不起作用。我的代码如下:
sqlContext.udf().register("stringToLong", new UDF1<String, Long>() {
@Override
public Long call(String arg0) throws Exception {
// TODO Auto-generated method stub
IPTypeConvert itc = new IPTypeConvert();
return itc.stringtoLong(arg0);
}
}, DataTypes.LongType);
DataFrame interDF = initInterDF.withColumn("interIPInt", callUDF("stringToLong", initInterDF.col("interIP")));
它的工作原理,谢谢! – volity