用法代码如下:
data.mapPartitions {
it => {
val jedis = new Jedis("*", 6379)
for (item <- it) yield {
item._1 + "\t" + item._2
}
}
}用法代码如下:
data.mapPartitions {
it => {
val jedis = new Jedis("*", 6379)
for (item <- it) yield {
item._1 + "\t" + item._2
}
}
}