我有一个数据流,其中元组为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)
}
暂无答案!
目前还没有任何答案,快来回答吧!