1
条回答
写回答
写回答
-
HBase是一个分布式的、面向列的开源数据库,一个结构化数据的分布式存储系统。HBase不同于一般的关系数据库，它是一个适合于非结构化数据存储的数据库。阿里云HBase技术团队共同探讨HBase及其生态的问题。http://spark.apache.org/docs/latest/rdd-programming-guide.html#understanding-closures-
把这段理解了，上面的问题就动了
出了foreach的大括号 ArrayBuffer的生命周期就结束了
问：那该用什么算子达到我要的效果啊
答1：你声明的变量是driver端的，executor使用的话会实例化通过网络传过去，但是在task结束的时候，这个改变的内容是跟着jvm销毁了，并不会传回给driver其实你在这里看的是一个，其实是两个不同的对象
答2: sourceRDD.foreachPartition{x =>
val mutator = conn.getBufferedMutator(table)
x.foreach{rowkey => mutator.delete(rowkey)}
mutator.close
}2019-07-17 23:37:04赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
