元组中的scalaMap元素

6l7fqoea  于 2021-05-17  发布在  Spark
关注(0)|答案(0)|浏览(258)

我有一个数据流,其中元组为date,字符串为value,我想将元组的字符串部分转换为hashset[string],当我试图将它Map到另一个Map中时,由于某种原因它不起作用,这是我迄今为止尝试的,任何指针都会有所帮助

val enTextTupleStream: DStream[(Date, String)]

def extractStrings(data: String): HashSet[String]= HashSet(data)

val ddstream = enTextTupleStream.map {            
  t =>
    val e1 = t._1
    val e2 = t._2.map(extractStrings)
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题