Add DeleteFamilyVersion function and corresponding test cases (#85)

* add DepentdentFilter and SingleColumnValueExcludeFilter

* add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases

* add single cf timerange setting in Get

* single cf setColumnFamilyTimeRange in Get and Scan

* optimize code

* add DeleteFamilyVersion and test cases

* add DeleteFamilyVersion; optimize test cases

* add DeleteFamilyVersion test case and pass

* format code

* delete useless self-defined table

Author: JackShi148

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

@@ -1656,9 +1656,9 @@ private com.alipay.oceanbase.rpc.mutation.Mutation buildMutation(KeyValue kv,
                 switch (kvType) {
                     case Delete:
                         return com.alipay.oceanbase.rpc.mutation.Mutation.getInstance(DEL,
-                            ROW_KEY_COLUMNS,
-                            new Object[] { kv.getRow(), kv.getQualifier(), kv.getTimestamp() },
-                            null, null);
+                                ROW_KEY_COLUMNS,
+                                new Object[] { kv.getRow(), kv.getQualifier(), kv.getTimestamp() },
+                                null, null);
                     case Maximum:
                         return com.alipay.oceanbase.rpc.mutation.Mutation.getInstance(DEL,
                                 ROW_KEY_COLUMNS,
@@ -1671,9 +1671,14 @@ private com.alipay.oceanbase.rpc.mutation.Mutation buildMutation(KeyValue kv,
                                 null, null);
                     case DeleteFamily:
                         return com.alipay.oceanbase.rpc.mutation.Mutation.getInstance(DEL,
-                            ROW_KEY_COLUMNS,
-                            new Object[] { kv.getRow(), isTableGroup?kv.getQualifier():null, -kv.getTimestamp() },
-                            null, null);
+                                ROW_KEY_COLUMNS,
+                                new Object[] { kv.getRow(), isTableGroup ? kv.getQualifier() : null, -kv.getTimestamp() },
+                                null, null);
+                    case DeleteFamilyVersion:
+                        return com.alipay.oceanbase.rpc.mutation.Mutation.getInstance(DEL,
+                                ROW_KEY_COLUMNS,
+                                new Object[] { kv.getRow(), isTableGroup ? kv.getQualifier() : null, kv.getTimestamp() },
+                                null, null);
                     default:
                         throw new IllegalArgumentException("illegal mutation type " + kvType);
                 }

src/main/java/com/alipay/oceanbase/hbase/filter/HBaseFilterUtils.java

@@ -169,7 +169,8 @@ private static void toParseableByteArray(ByteArrayOutputStream byteStream,
 
     // SingleColumnValueExcludeFilter('cf1','col1',=,'binary:123',true,true)
     private static void toParseableByteArray(ByteArrayOutputStream byteStream,
-                                             SingleColumnValueExcludeFilter filter) throws IOException {
+                                             SingleColumnValueExcludeFilter filter)
+                                                                                   throws IOException {
         byteStream.write(filter.getClass().getSimpleName().getBytes());
         byteStream.write("('".getBytes());
         writeBytesWithEscape(byteStream, filter.getFamily());
@@ -329,12 +330,13 @@ private static void toParseableByteArray(ByteArrayOutputStream byteStream, Times
     }
 
     // MultiRowRangeFilter('a',true,'b',false,'c',true,'d',false);
-    private static void toParseableByteArray(ByteArrayOutputStream byteStream, MultiRowRangeFilter filter) throws IOException {
+    private static void toParseableByteArray(ByteArrayOutputStream byteStream,
+                                             MultiRowRangeFilter filter) throws IOException {
         byteStream.write(filter.getClass().getSimpleName().getBytes());
         byteStream.write('(');
 
         List<MultiRowRangeFilter.RowRange> ranges = filter.getRowRanges();
-        for (int i = 0; i < ranges.size(); i ++) {
+        for (int i = 0; i < ranges.size(); i++) {
             MultiRowRangeFilter.RowRange range = ranges.get(i);
             byteStream.write("'".getBytes());
             byteStream.write(range.getStartRow());
@@ -354,7 +356,8 @@ private static void toParseableByteArray(ByteArrayOutputStream byteStream, Multi
     }
 
     // InclusiveStopFilter('aaa');
-    private static void toParseableByteArray(ByteArrayOutputStream byteStream, InclusiveStopFilter filter) throws IOException {
+    private static void toParseableByteArray(ByteArrayOutputStream byteStream,
+                                             InclusiveStopFilter filter) throws IOException {
         byteStream.write(filter.getClass().getSimpleName().getBytes());
         byteStream.write('(');
         byteStream.write('\'');
@@ -364,7 +367,8 @@ private static void toParseableByteArray(ByteArrayOutputStream byteStream, Inclu
     }
 
     // ColumnRangeFilter('a',true,'b',false);
-    private static void toParseableByteArray(ByteArrayOutputStream byteStream, ColumnRangeFilter filter) throws IOException {
+    private static void toParseableByteArray(ByteArrayOutputStream byteStream,
+                                             ColumnRangeFilter filter) throws IOException {
         byteStream.write(filter.getClass().getSimpleName().getBytes());
         byteStream.write('(');
 
@@ -382,12 +386,13 @@ private static void toParseableByteArray(ByteArrayOutputStream byteStream, Colum
     }
 
     // MultipleColumnPrefixFilter('a','b','d');
-    private static void toParseableByteArray(ByteArrayOutputStream byteStream, MultipleColumnPrefixFilter filter) throws IOException {
+    private static void toParseableByteArray(ByteArrayOutputStream byteStream,
+                                             MultipleColumnPrefixFilter filter) throws IOException {
         byteStream.write(filter.getClass().getSimpleName().getBytes());
         byteStream.write('(');
 
         byte[][] ranges = filter.getPrefix();
-        for (int i = 0; i < ranges.length; i ++) {
+        for (int i = 0; i < ranges.length; i++) {
             byte[] range = ranges[i];
             byteStream.write("'".getBytes());
             byteStream.write(range);

src/main/java/com/alipay/oceanbase/hbase/util/BatchError.java

@@ -9,11 +9,11 @@
 
 public class BatchError {
     private final List<Throwable> throwables = new ArrayList<Throwable>();
-    private final List<Row> actions = new ArrayList<Row>();
-    private final List<String> addresses = new ArrayList<String>();
+    private final List<Row>       actions    = new ArrayList<Row>();
+    private final List<String>    addresses  = new ArrayList<String>();
 
     public synchronized void add(Throwable ex, Row row, ServerName serverName) {
-        if (row == null){
+        if (row == null) {
             throw new IllegalArgumentException("row cannot be null. location=" + serverName);
         }
 
@@ -27,9 +27,8 @@ public boolean hasErrors() {
     }
 
     public synchronized RetriesExhaustedWithDetailsException makeException() {
-        return new RetriesExhaustedWithDetailsException(
-                new ArrayList<Throwable>(throwables),
-                new ArrayList<Row>(actions), new ArrayList<String>(addresses));
+        return new RetriesExhaustedWithDetailsException(new ArrayList<Throwable>(throwables),
+            new ArrayList<Row>(actions), new ArrayList<String>(addresses));
     }
 
     public synchronized void clear() {