用saveAsNewAPIHadoopDataset的方式向hbase存入資料,現有資料是RDD[List[Put]], 需要變成RDD[((new ImmutableBytesWritable, Put))]才能呼叫這個save方法,flatMap?但是RDD里本身就是list,flatmap該如何寫?如何變成多個RDD[Put]?
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/23938.html
標籤:Spark
上一篇:SpringMVC體系結構and處理請求控制器 筆記Demo
下一篇:鴻蒙OS 2.0 開源蹭熱淺讀
