From 2515413e934bc67e19307f2238a8a66b7a94655d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B8=A9=E5=B0=91?= Date: Mon, 21 May 2012 15:53:17 +0800 Subject: [PATCH] refactor --- src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java | 2 ++ .../alibaba/druid/hbase/mapping/HMappingDefaultImpl.java | 6 +++++- 2 files changed, 7 insertions(+), 1 deletion(-) 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) {