spark里的hbase的ImmutableBytesWritable的打印问题scala
生活随笔
收集整理的這篇文章主要介紹了
spark里的hbase的ImmutableBytesWritable的打印问题scala
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
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)都可以拿到rowkeycase (rowkey, res) => (new String(rowkey.get()),new String(res.getRow))}即可
與50位技術專家面對面20年技術見證,附贈技術全景圖總結
以上是生活随笔為你收集整理的spark里的hbase的ImmutableBytesWritable的打印问题scala的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Spring中BeanPostProce
- 下一篇: xsync脚本