spark里的hbase的ImmutableBytesWritable的打印问题scala
spark里的hbase的ImmutableBytesWritable的打印问题scala
gzq大数据
发布于 2021-05-18 11:27:29
发布于 2021-05-18 11:27:29
文章被收录于专栏：大数据那些事
ImmutableBytesWritable其实就是hbase把其封装成的rowkey，如果要通过collect算子收集到客户端driver，涉及到序列化的操作：
new SparkConf().set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")接下来如果要打印出rowkey：
hbaseRDD.map {
//new String(rowkey.get()),new String(res.getRow)都可以拿到rowkey
case (rowkey, res) => (new String(rowkey.get()),new String(res.getRow))
}即可
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2021/05/14 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
腾讯云开发者
