Are there corrections up on github for v1 of the book? What you are doing looks fine. And you have TableOutputFormat hooked up to the reducer?
Maybe you need a close so the edits are flushed out to HBase? Can you work with 0.90.0 rather than 0.20.6? St.Ack On Thu, Jan 27, 2011 at 3:52 PM, Mark Kerzner <[email protected]> wrote: > 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 >
