Index: src/java/org/apache/hadoop/hbase/mapred/RowCounter.java =================================================================== --- src/java/org/apache/hadoop/hbase/mapred/RowCounter.java (revision 681571) +++ src/java/org/apache/hadoop/hbase/mapred/RowCounter.java (working copy) @@ -25,9 +25,11 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.io.HbaseMapWritable; import org.apache.hadoop.hbase.io.Cell; import org.apache.hadoop.hbase.io.ImmutableBytesWritable; import org.apache.hadoop.hbase.io.RowResult; +import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.mapred.JobClient; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.OutputCollector; @@ -47,7 +49,8 @@ static final String NAME = "rowcounter"; private Configuration conf; - private final RowResult EMPTY_RESULT_VALUE = new RowResult(); + private final RowResult EMPTY_RESULT_VALUE = + new RowResult(Bytes.toBytes("dummy"),new HbaseMapWritable()); private static enum Counters {ROWS} @Override @@ -119,8 +122,7 @@ public static void main(String[] args) throws Exception { HBaseConfiguration c = new HBaseConfiguration(); - c.set("hbase.master", args[0]); int errCode = ToolRunner.run(c, new RowCounter(), args); System.exit(errCode); } -} \ No newline at end of file +}