hi i am running HBase 0.94.20 on Hadoop 2.2.0
i am using MultiTableOutputFormat,
for writing processed output to two different tables in hbase.
here's the code snippet
private ImmutableBytesWritable tab_cr = new ImmutableBytesWritable(
Bytes.toBytes("i1")); private ImmutableBytesWritable tab_cvs = new
ImmutableBytesWritable( Bytes.toBytes("i2"));
@Override
public void map(ImmutableBytesWritable row, final Result value,
final Context context) throws IOException, InterruptedException {
-----------------------------------------
Put pcvs = new Put(entry.getKey().getBytes());
pcvs.add("cf".getBytes(),"type".getBytes(),column.getBytes());
Put put = new Put(value.getRow());
put.add("Entity".getBytes(), "json".getBytes(),
entry.getValue().getBytes());
context.write(tab_cr, put);// table i1 context.write(tab_cvs, pcvs);//table
i2
}
job.setJarByClass(EntitySearcherMR.class);
job.setMapperClass(EntitySearcherMapper.class);
job.setOutputFormatClass(MultiTableOutputFormat.class); Scan scan = new
Scan(); scan.setCacheBlocks(false);
TableMapReduceUtil.initTableMapperJob(otherArgs[0], scan,
EntitySearcherMapper.class, ImmutableBytesWritable.class, Put.class,
job);//otherArgs[0]=i1 TableMapReduceUtil.initTableReducerJob(otherArgs[0],
null, job); job.setNumReduceTasks(0);
mapreduce job fails by saying nosuchcolumnfamily "cf" exception, in table i1
i am writing data to two different columnfamilies one in each table, cf
belongs to table i2.
does the columnfamilies should present in both tables??
is there anything i am missing
can someone point me in the right direction
thanks,
yeshwanth.
