byte[] rowkey = HBaseUtils.formatRowkey(point.getUnit(), point.getTimestamp());
ImmutableBytesWritable rk = new ImmutableBytesWritable(rowkey);
BatchUpdate update = new BatchUpdate(rowkey);
Projection p = new Projection(point);
update.put(p.toHBaseCFQ(), n);
// dispatch to HBase.
output.collect(rk, update);
}
}