Hi,
I am new to hbase and am trying to achieve the following.
I am reading data from hdfs in mapper and parsing it..
So, in reducer I want my output to write to hbase instead of hdfs
But here is the thing.
public static class MyTableReducer extends TableReducer<Text, Text,
ImmutableBytesWritable> {
public void reduce(Text key, Iterable<Text> values, Context context)
throws IOException, InterruptedException {
int type = getType(values.toString());
if (type == 1) // put data to table 1
if (type==2) // put data to table 2
}
}
How do I do this?
Thanks