Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-2257 [stargate] multiuser mode; fix error introduced with KV.parseColumn 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@916167 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Andrew Kyle Purtell 2010-02-25 07:57:24 +00:00
parent 1d4cace954
commit afc58b13d7
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
contrib/stargate/src/java/org/apache/hadoop/hbase/stargate/RowResource.java
View File

@ -156,7 +156,11 @@ public class RowResource implements Constants {
Put put = new Put(key);
for (CellModel cell: row.getCells()) {
byte [][] parts = KeyValue.parseColumn(cell.getColumn());
put.add(parts[0], parts[1], cell.getTimestamp(), cell.getValue());
if (parts.length == 2 && parts[1].length > 0) {
put.add(parts[0], parts[1], cell.getTimestamp(), cell.getValue());
} else {
put.add(parts[0], null, cell.getTimestamp(), cell.getValue());
}
}
table.put(put);
if (LOG.isDebugEnabled()) {
@ -205,7 +209,11 @@ public class RowResource implements Constants {
}
Put put = new Put(row);
byte parts[][] = KeyValue.parseColumn(column);
put.add(parts[0], parts[1], timestamp, message);
if (parts.length == 2 && parts[1].length > 0) {
put.add(parts[0], parts[1], timestamp, message);
} else {
put.add(parts[0], null, timestamp, message);
}
table = pool.getTable(actualTableName);
table.put(put);
if (LOG.isDebugEnabled()) {