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

Reply via email to