You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ni...@apache.org on 2009/07/10 01:27:09 UTC
svn commit: r792746 - in /hadoop/hbase/trunk: CHANGES.txt
src/java/org/apache/hadoop/hbase/client/Delete.java
Author: nitay
Date: Thu Jul 9 23:27:09 2009
New Revision: 792746
URL: http://svn.apache.org/viewvc?rev=792746&view=rev
Log:
HBASE-1637 Delete client class methods should return itself like Put, Get, Scan (Jon Gray via Nitay)
Modified:
hadoop/hbase/trunk/CHANGES.txt
hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/Delete.java
Modified: hadoop/hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/CHANGES.txt?rev=792746&r1=792745&r2=792746&view=diff
==============================================================================
--- hadoop/hbase/trunk/CHANGES.txt (original)
+++ hadoop/hbase/trunk/CHANGES.txt Thu Jul 9 23:27:09 2009
@@ -454,6 +454,8 @@
HBASE-1626 Allow emitting Deletes out of new TableReducer
(Lars George via Stack)
HBASE-1551 HBase should manage multiple node ZooKeeper quorum
+ HBASE-1637 Delete client class methods should return itself like Put, Get,
+ Scan (Jon Gray via Nitay)
OPTIMIZATIONS
HBASE-1412 Change values for delete column and column family in KeyValue
Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/Delete.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/Delete.java?rev=792746&r1=792745&r2=792746&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/Delete.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/Delete.java Thu Jul 9 23:27:09 2009
@@ -132,8 +132,9 @@
* specified family.
* @param family family name
*/
- public void deleteFamily(byte [] family) {
- this.deleteFamily(family, HConstants.LATEST_TIMESTAMP);
+ public Delete deleteFamily(byte [] family) {
+ this.deleteFamily(family, HConstants.LATEST_TIMESTAMP);
+ return this;
}
/**
@@ -145,7 +146,7 @@
* @param family family name
* @param timestamp maximum version timestamp
*/
- public void deleteFamily(byte [] family, long timestamp) {
+ public Delete deleteFamily(byte [] family, long timestamp) {
List<KeyValue> list = familyMap.get(family);
if(list == null) {
list = new ArrayList<KeyValue>();
@@ -154,6 +155,7 @@
}
list.add(new KeyValue(row, family, null, timestamp, KeyValue.Type.DeleteFamily));
familyMap.put(family, list);
+ return this;
}
/**
@@ -161,8 +163,9 @@
* @param family family name
* @param qualifier column qualifier
*/
- public void deleteColumns(byte [] family, byte [] qualifier) {
+ public Delete deleteColumns(byte [] family, byte [] qualifier) {
this.deleteColumns(family, qualifier, HConstants.LATEST_TIMESTAMP);
+ return this;
}
/**
@@ -172,7 +175,7 @@
* @param qualifier column qualifier
* @param timestamp maximum version timestamp
*/
- public void deleteColumns(byte [] family, byte [] qualifier, long timestamp) {
+ public Delete deleteColumns(byte [] family, byte [] qualifier, long timestamp) {
List<KeyValue> list = familyMap.get(family);
if (list == null) {
list = new ArrayList<KeyValue>();
@@ -180,6 +183,7 @@
list.add(new KeyValue(this.row, family, qualifier, timestamp,
KeyValue.Type.DeleteColumn));
familyMap.put(family, list);
+ return this;
}
/**
@@ -189,9 +193,10 @@
* @param column colon-delimited family and qualifier
* @param timestamp maximum version timestamp
*/
- public void deleteColumns(byte [] column, long timestamp) {
+ public Delete deleteColumns(byte [] column, long timestamp) {
byte [][] parts = KeyValue.parseColumn(column);
this.deleteColumns(parts[0], parts[1], timestamp);
+ return this;
}
/**
@@ -202,8 +207,9 @@
* @param family family name
* @param qualifier column qualifier
*/
- public void deleteColumn(byte [] family, byte [] qualifier) {
+ public Delete deleteColumn(byte [] family, byte [] qualifier) {
this.deleteColumn(family, qualifier, HConstants.LATEST_TIMESTAMP);
+ return this;
}
/**
@@ -212,7 +218,7 @@
* @param qualifier column qualifier
* @param timestamp version timestamp
*/
- public void deleteColumn(byte [] family, byte [] qualifier, long timestamp) {
+ public Delete deleteColumn(byte [] family, byte [] qualifier, long timestamp) {
List<KeyValue> list = familyMap.get(family);
if(list == null) {
list = new ArrayList<KeyValue>();
@@ -220,6 +226,7 @@
list.add(new KeyValue(
this.row, family, qualifier, timestamp, KeyValue.Type.Delete));
familyMap.put(family, list);
+ return this;
}
/**
@@ -227,9 +234,10 @@
* <code>family:qualifier</code> notation.
* @param column colon-delimited family and qualifier
*/
- public void deleteColumn(byte [] column) {
+ public Delete deleteColumn(byte [] column) {
byte [][] parts = KeyValue.parseColumn(column);
this.deleteColumn(parts[0], parts[1], HConstants.LATEST_TIMESTAMP);
+ return this;
}
/**