在Scala中创建Java对象
发布时间:2020-12-16 18:39:14 所属栏目:安全 来源:网络整理
导读:我有一个 Java类“列表”.我在我的 Java MapReduce作业中使用它,如下所示: public void map(Object key,Text value,Context context) throws IOException,InterruptedException {Listings le = new Listings(value.toString());...} 我想在Spark上运行相同
我有一个
Java类“列表”.我在我的
Java MapReduce作业中使用它,如下所示:
public void map(Object key,Text value,Context context) throws IOException,InterruptedException { Listings le = new Listings(value.toString()); ... } 我想在Spark上运行相同的工作.所以,我现在正在Scala中写这个.我导入了Java类: import src.main.java.lists.Listings 我想在Scala中创建一个Listing对象.我这样做: val file_le = sc.textFile("file// Path to file") Listings lists = new Listings(file_le) 我收到一个错误:
这样做的正确方法是什么? 解决方法
根据您所说的,我认为您可能忘记了Scala语法和Java语法之间的差异.
试试这个: val lists: Listings = new Listings(SomeString) 请注意,在Scala中指定类型是完全可选的.此外,如果您要更改列表的值,请使用var. 你拥有它的方式,Scala试图通过调用没有’.’的对象的方法/访问值来解释它,所以你实际上是在告诉Scala: Listings.lists = new Listings(SomeString) (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |