HBASE-2024 [stargate] Deletes not working as expected
HBASE-2122 [stargate] Initializing scanner column families doesn't work git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@899154 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
56497da881
commit
2c4289f284
|
@ -159,6 +159,10 @@ Release 0.21.0 - Unreleased
|
||||||
HBASE-2120 [stargate] Unable to delete column families (Greg Lu via Andrew
|
HBASE-2120 [stargate] Unable to delete column families (Greg Lu via Andrew
|
||||||
Purtell)
|
Purtell)
|
||||||
HBASE-2123 Remove 'master' command-line option from PE
|
HBASE-2123 Remove 'master' command-line option from PE
|
||||||
|
HBASE-2024 [stargate] Deletes not working as expected (Greg Lu via Andrew
|
||||||
|
Purtell)
|
||||||
|
HBASE-2122 [stargate] Initializing scanner column families doesn't work
|
||||||
|
(Greg Lu via Andrew Purtell)
|
||||||
|
|
||||||
IMPROVEMENTS
|
IMPROVEMENTS
|
||||||
HBASE-1760 Cleanup TODOs in HTable
|
HBASE-1760 Cleanup TODOs in HTable
|
||||||
|
|
|
@ -277,7 +277,13 @@ public class RowResource implements Constants {
|
||||||
if (LOG.isDebugEnabled()) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.debug("DELETE " + uriInfo.getAbsolutePath());
|
LOG.debug("DELETE " + uriInfo.getAbsolutePath());
|
||||||
}
|
}
|
||||||
Delete delete = new Delete(rowspec.getRow());
|
|
||||||
|
Delete delete = null;
|
||||||
|
if (rowspec.hasTimestamp())
|
||||||
|
delete = new Delete(rowspec.getRow(), rowspec.getTimestamp(), null);
|
||||||
|
else
|
||||||
|
delete = new Delete(rowspec.getRow());
|
||||||
|
|
||||||
for (byte[] column: rowspec.getColumns()) {
|
for (byte[] column: rowspec.getColumns()) {
|
||||||
byte[][] split = KeyValue.parseColumn(column);
|
byte[][] split = KeyValue.parseColumn(column);
|
||||||
if (rowspec.hasTimestamp()) {
|
if (rowspec.hasTimestamp()) {
|
||||||
|
|
|
@ -59,7 +59,7 @@ public class ScannerResultGenerator extends ResultGenerator {
|
||||||
byte[][] columns = rowspec.getColumns();
|
byte[][] columns = rowspec.getColumns();
|
||||||
for (byte[] column: columns) {
|
for (byte[] column: columns) {
|
||||||
byte[][] split = KeyValue.parseColumn(column);
|
byte[][] split = KeyValue.parseColumn(column);
|
||||||
if (split.length == 2) {
|
if (split.length == 2 && split[1].length != 0) {
|
||||||
scan.addColumn(split[0], split[1]);
|
scan.addColumn(split[0], split[1]);
|
||||||
} else {
|
} else {
|
||||||
scan.addFamily(split[0]);
|
scan.addFamily(split[0]);
|
||||||
|
|
Loading…
Reference in New Issue