hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Abir Chokraborty <abir.chokrabort...@gmail.com>
Subject Reading data for a particular column-cell with 2 or more values of a same row-key
Date Sat, 25 Feb 2017 07:38:13 GMT
HBase table contains the following:

ROW              COLUMN+CELL
Product01        column=cf:ProductFeature,  timestamp=1487917201238,value=
Product01        column=cf:ProductFeature,  timestamp=1487917201239,value=
Product01        column=cf:ProductFeature,  timestamp=1487917201240,value=
Product01        column=cf:Price,  timestamp=1487917201242,value=\x012A\xF8
Product01        column=cf:Location,  timestamp=1487917201244,value= Texas
Here VERSIONS is 3. So it is keeping 3 different values for ProductFeature
column. I wrote the following to create an RDD

val hbaseRDD = sc.newAPIHadoopRDD(conf, classOf[TableInputFormat],
  val resultRDD = hbaseRDD.map(tuple => tuple._2)
  val testRDD = resultRDD.map(Row.parseRow)
  val testDF = testRDD.toDF()
Here, parseRow is a method that returns tuple of
(ROW,ProductFeature,Price,Location). I am only getting

|             Row|  ProductFeature|  Price| Location|
|       Product01|       Feature03|       65|    Texas| 
Where do I have to change in the code so that I can create DataFrame for
different values of ProductFeature like the following:

|                Row|  ProductFeature|       Price| Location|
|        Product01|       Feature01|          65|    Texas| 
|        Product01|       Feature02|          65|    Texas| 
|        Product01|       Feature03|          65|    Texas| 

View this message in context: http://apache-hbase.679495.n3.nabble.com/Reading-data-for-a-particular-column-cell-with-2-or-more-values-of-a-same-row-key-tp4086420.html
Sent from the HBase User mailing list archive at Nabble.com.

View raw message