spark中yield的用法

⛶ 全屏阅读 标签:   更新于: 2017/09/19 阅读:1904

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