diff --git a/src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java b/src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java index 2d28fb39f4..d6080248a3 100644 --- a/src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java +++ b/src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java @@ -8,6 +8,8 @@ public interface HMapping { byte[] getQualifier(String columnName); + byte[] getRow(Result result, String columnName); + boolean isRow(String columnName); Object getObject(Result result, String name); diff --git a/src/main/java/com/alibaba/druid/hbase/mapping/HMappingDefaultImpl.java b/src/main/java/com/alibaba/druid/hbase/mapping/HMappingDefaultImpl.java index 2277c23d49..77689365f8 100644 --- a/src/main/java/com/alibaba/druid/hbase/mapping/HMappingDefaultImpl.java +++ b/src/main/java/com/alibaba/druid/hbase/mapping/HMappingDefaultImpl.java @@ -13,7 +13,7 @@ public class HMappingDefaultImpl implements HMapping { byte[] bytes; if (isRow(columnName)) { - bytes = result.getRow(); + bytes = getRow(result, columnName); } else { byte[] qualifier = Bytes.toBytes(columnName); bytes = result.getValue(family, qualifier); @@ -25,6 +25,10 @@ public class HMappingDefaultImpl implements HMapping { public byte[] getFamily(String columnName) { return family; } + + public byte[] getRow(Result result, String columnName) { + return result.getRow(); + } @Override public byte[] getQualifier(String columnName) {