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