Hi,
this is how I write to a 0.20 HBase
public void reduce(Text k2, Iterator<IntWritable> itrtr,
OutputCollector<ImmutableBytesWritable, BatchUpdate> oc, Reporter rprtr)
throws IOException {
int sum = 0;
while (itrtr.hasNext()) {
IntWritable val = itrtr.next();
sum += val.get();
}
String family = "stats:";
String familyCell = family + k2.toString();
oc.collect(new ImmutableBytesWritable(familyCell.getBytes()),
new BatchUpdate("" + sum));
}
and the function is called, I step through it and see the correct values,
but then I see no rows in the output table. No error messages either.
Could you please help?
Thank you,
Mark