【发布时间】:2017-01-06 03:37:52
【问题描述】:
我对 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]
【问题讨论】:
标签: scala apache-spark scala-java-interop