Hey! Yeah, that makes sense, just wanted to check, cause then you don't really have to output two things from the mapper, or? put just do something like:
Map(t1_rowkey , t1_rowresult ) {
for (Map.Entry<byte[], Cell> e: t1_rowresult.entrySet()) {
t2_rowresult = table2.get(e.getValue().getValue(),
"fam:column_to_fetch");
//Process data from table1 and table2
//output to reduce
output.collect(newKey, new Data);
}
}
Good luck!
Regards Erik
