diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java index d9f0679..9162962 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java @@ -1505,6 +1505,10 @@ public final class CellUtil { } return new FirstOnRowCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); } + + public static Cell createFirstOnRow(final byte [] row, int roffset, short rlength) { + return new FirstOnRowCell(row, roffset, rlength); + } /** * Create a Cell that is smaller than all other possible Cells for the given Cell's row. diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/Import.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/Import.java index 7668ac9..c7d5912 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/Import.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/Import.java @@ -209,7 +209,7 @@ public class Import extends Configured implements Tool { + Bytes.toString(row.get(), row.getOffset(), row.getLength())); } if (filter == null - || !filter.filterRowKey(KeyValueUtil.createFirstOnRow(row.get(), row.getOffset(), + || !filter.filterRowKey(CellUtil.createFirstOnRow(row.get(), row.getOffset(), (short) row.getLength()))) { for (Cell kv : value.rawCells()) { kv = filterKv(filter, kv); @@ -275,7 +275,7 @@ public class Import extends Configured implements Tool { + Bytes.toString(row.get(), row.getOffset(), row.getLength())); } if (filter == null - || !filter.filterRowKey(KeyValueUtil.createFirstOnRow(row.get(), row.getOffset(), + || !filter.filterRowKey(CellUtil.createFirstOnRow(row.get(), row.getOffset(), (short) row.getLength()))) { for (Cell kv : value.rawCells()) { kv = filterKv(filter, kv); @@ -332,7 +332,7 @@ public class Import extends Configured implements Tool { + Bytes.toString(key.get(), key.getOffset(), key.getLength())); } if (filter == null - || !filter.filterRowKey(KeyValueUtil.createFirstOnRow(key.get(), key.getOffset(), + || !filter.filterRowKey(CellUtil.createFirstOnRow(key.get(), key.getOffset(), (short) key.getLength()))) { processKV(key, result, context, put, delete); }