You can use a map function like the following and do whatever you want with
the Result.
Function<Tuple2<ImmutableBytesWritable, Result>, Iterator<String>>{
> public Iterator<String> call(Tuple2<ImmutableBytesWritable,
> Result> test) {
> Result tmp = (Result) test._2;
> List<KeyValue> kvl = *tmp.getColumn("post".getBytes(),
> "title".getBytes());*
> for(KeyValue kl:kvl){
> String sb = new String(kl.getValue());
> System.out.println(sb);
> }
Thanks
Best Regards
On Thu, Jul 31, 2014 at 10:19 PM, Madabhattula Rajesh Kumar <
mrajaf...@gmail.com> wrote:
> Hi Team,
>
> I'm using below code to read table from hbase
>
> Configuration conf = HBaseConfiguration.create();
> conf.set(TableInputFormat.INPUT_TABLE, "table1");
>
> JavaPairRDD hBaseRDD = sc.newAPIHadoopRDD(
> conf,
> TableInputFormat.class,
> ImmutableBytesWritable.class,
> Result.class);
>
> I got hBaseRDD. I'm not able to read the column values from hBaseRDD.
>
> *Could you please let me know, how to read the column values from
> hBaseRDD?*
>
> Thank you for your help.
>
> Regards,
> Rajesh
>
>
