我试着让这个例子从这本关于地图匹配的公开书籍开始工作。我正在使用Scala2.10和Spark2.0.2。
不幸的是,语法和功能发生了变化。
case class NodeEntry(nodeId: Long, latitude: Double, longitude: Double, tags: Array[String])
val nodeDS = nodes.map{node =>
NodeEntry(node.getId,
node.getLatitude,
node.getLongitude,
node.getTags.map(_.getValue).toArray
)}.toDS.cache我得到了错误“值映射不是java.util.Listorg.openstreetmap.osmosis.core.domain.v0_6.WayNode”的成员
"value toDS不是scala.collection.mutable.ArrayBufferNothing可能的原因:也许在‘value toDS’之前缺少分号?“
我试图将nodes.map更改为:
val nodeDS = nodes.map { node =>
NodeEntry(node.getId,
node.getLatitude,
node.getLongitude,
node.getTags.toArray()
)}但是,我得到了这个错误:类型不匹配;发现: ArrayObject必需: ArrayString注释: Object >:String,但是类数组在类型T中是不变的。您可能希望研究一个通配符类型,例如_ >:String。(补充劳工3.2.10)
发布于 2016-12-08 10:08:00
map在import JavaConversions集合中不可用,以便使其可用import JavaConversions
import scala.collection.JavaConversions._示例
Scala REPL
scala> val l = new java.util.ArrayList[String]()
l: java.util.ArrayList[String] = []
scala> l.add("scala")
res0: Boolean = true
scala> l.add("haskell")
res1: Boolean = true
scala> l.map(x => x.reverse)
<console>:13: error: value map is not a member of java.util.ArrayList[String]
l.map(x => x.reverse)
^
scala> import scala.collection.JavaConversions._
import scala.collection.JavaConversions._
scala> l.map(x => x.reverse)
res3: scala.collection.mutable.Buffer[String] = ArrayBuffer(alacs, lleksah)请注意,导入映射之后,java ArrayList上就可以使用了。
发布于 2016-12-08 11:43:55
啊,我明白了。在建议的导入之后,以下工作完成:
val nodeDS = nodes.map { node =>
NodeEntry(node.getId,
node.getLatitude,
node.getLongitude,
node.getTags.map(_.getValue).toArray
)}https://stackoverflow.com/questions/41036564
复制相似问题