我是scala的新手。我已经开始在我的Spark项目中使用scala。我正在使用一些Java代码。在下面的行中,我得到了错误。
case class docDisplay( id :String,name :String, session :String,
time :String, docguid: scala.collection.immutable.List[String]
)
我的ParseDocumentGuid的代码是java类,如下所示。
public static List<String> ParseGuid(String Data, String type,String Name) {
boolean validJson=checkValidJson(Data);
if(validJson==true)
{
try
{
JSONObject json = null;
json = new JSONObject (Data);
List<String> singleDocGuidList= new ArrayList<String>();
if(json!=null && json.getString("guid").equalsIgnoreCase("guid") )
{
singleDocGuidList.add(json.getString("guid"));
}
return singleDocGuidList;
}
catch(Exception e)
{
List<String> singleDocGuidList= new ArrayList<String>();
singleDocGuidList.add(e.getMessage());
return singleDocGuidList;
}
}
else
{
List<String> singleDocGuidList= new ArrayList<String>();
singleDocGuidList.add("unKnownDocumentGuid");
return singleDocGuidList;
}
}
这是上面方法调用的代码
def selectColumnsPerDocdisplayRows(row:Row):List[String]= {
docDisplay(
row.getAs[String]("id"),
row.getAs[String]("name"),
row.getAs[String]("session"),
row.getAs[String]("time"),
Utils.ParseDocumentGuid(row.getAs("Data"),Utils.DOCDISRELATED,row.getAs[String]("name"))
);
}
所以我在我的方法def selectColumnsPerDocdisplayRows()上遇到了错误
类型不匹配; 找到:java.util.List [String]必需:List [String]
您好,谢谢Brian Kent和Chris Shain的建议,我从def中删除了List [String],它可以与
导入collection.JavaConverters._
和.asScala.toList
def selectColumnsPerDocdisplayRows(row:Row)= {
docDisplay(
row.getAs[String]("id"),
row.getAs[String]("name"),
row.getAs[String]("session"),
row.getAs[String]("time"),
Utils.ParseDocumentGuid(row.getAs("Data"),Utils.DOCDISRELATED,row.getAs[String]("name")).asScala.toList
);
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句