HBASE-27234 Clean up error-prone warnings in hbase-examples

Close #4647

Co-authored-by: Duo Zhang <zhangduo@apache.org>
Signed-off-by: Duo Zhang <zhangduo@apache.org>
Signed-off-by: Viraj Jasani <vjasani@apache.org>
(cherry picked from commit 35fb37c)

Conflicts:
	hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java
	hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java
	hbase-examples/src/test/java/org/apache/hadoop/hbase/security/provider/example/TestShadeSaslAuthenticationProvider.java

hbase-examples/src/main/java/org/apache/hadoop/hbase/client/example/HttpProxyExample.java

@@ -22,6 +22,8 @@
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
+import java.util.Iterator;
+import java.util.List;
 import java.util.concurrent.ExecutionException;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.hbase.HBaseConfiguration;
@@ -35,6 +37,7 @@
 import org.apache.yetus.audience.InterfaceAudience;
 
 import org.apache.hbase.thirdparty.com.google.common.base.Preconditions;
+import org.apache.hbase.thirdparty.com.google.common.base.Splitter;
 import org.apache.hbase.thirdparty.com.google.common.base.Throwables;
 import org.apache.hbase.thirdparty.io.netty.bootstrap.ServerBootstrap;
 import org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf;
@@ -158,12 +161,20 @@ private void write(ChannelHandlerContext ctx, HttpResponseStatus status, String
     }
 
     private Params parse(FullHttpRequest req) {
-      String[] components = new QueryStringDecoder(req.uri()).path().split("/");
-      Preconditions.checkArgument(components.length == 4, "Unrecognized uri: %s", req.uri());
+      List<String> components =
+        Splitter.on('/').splitToList(new QueryStringDecoder(req.uri()).path());
+      Preconditions.checkArgument(components.size() == 4, "Unrecognized uri: %s", req.uri());
+      Iterator<String> i = components.iterator();
       // path is start with '/' so split will give an empty component
-      String[] cfAndCq = components[3].split(":");
-      Preconditions.checkArgument(cfAndCq.length == 2, "Unrecognized uri: %s", req.uri());
-      return new Params(components[1], components[2], cfAndCq[0], cfAndCq[1]);
+      i.next();
+      String table = i.next();
+      String row = i.next();
+      List<String> cfAndCq = Splitter.on(':').splitToList(i.next());
+      Preconditions.checkArgument(cfAndCq.size() == 2, "Unrecognized uri: %s", req.uri());
+      i = cfAndCq.iterator();
+      String family = i.next();
+      String qualifier = i.next();
+      return new Params(table, row, family, qualifier);
     }
 
     private void get(ChannelHandlerContext ctx, FullHttpRequest req) {

hbase-examples/src/main/java/org/apache/hadoop/hbase/client/example/MultiThreadedClientExample.java

@@ -30,7 +30,6 @@
 import java.util.concurrent.TimeUnit;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.hbase.Cell;
-import org.apache.hadoop.hbase.Cell.Type;
 import org.apache.hadoop.hbase.CellBuilderFactory;
 import org.apache.hadoop.hbase.CellBuilderType;
 import org.apache.hadoop.hbase.TableName;
@@ -240,7 +239,7 @@ public Boolean call() throws Exception {
         byte[] rk = Bytes.toBytes(ThreadLocalRandom.current().nextLong());
         Put p = new Put(rk);
         p.add(CellBuilderFactory.create(CellBuilderType.SHALLOW_COPY).setRow(rk).setFamily(FAMILY)
-          .setQualifier(QUAL).setTimestamp(p.getTimestamp()).setType(Type.Put).setValue(value)
+          .setQualifier(QUAL).setTimestamp(p.getTimestamp()).setType(Cell.Type.Put).setValue(value)
           .build());
         t.put(p);
       }

hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java

@@ -31,7 +31,6 @@
 import org.apache.hadoop.hbase.CellUtil;
 import org.apache.hadoop.hbase.CoprocessorEnvironment;
 import org.apache.hadoop.hbase.HConstants;
-import org.apache.hadoop.hbase.HConstants.OperationStatusCode;
 import org.apache.hadoop.hbase.client.Delete;
 import org.apache.hadoop.hbase.client.Mutation;
 import org.apache.hadoop.hbase.client.Scan;
@@ -41,7 +40,6 @@
 import org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.BulkDeleteRequest;
 import org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.BulkDeleteRequest.DeleteType;
 import org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.BulkDeleteResponse;
-import org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.BulkDeleteResponse.Builder;
 import org.apache.hadoop.hbase.coprocessor.example.generated.BulkDeleteProtos.BulkDeleteService;
 import org.apache.hadoop.hbase.filter.FirstKeyOnlyFilter;
 import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils;
@@ -155,7 +153,7 @@ public void delete(RpcController controller, BulkDeleteRequest request,
           }
           OperationStatus[] opStatus = region.batchMutate(deleteArr);
           for (i = 0; i < opStatus.length; i++) {
-            if (opStatus[i].getOperationStatusCode() != OperationStatusCode.SUCCESS) {
+            if (opStatus[i].getOperationStatusCode() != HConstants.OperationStatusCode.SUCCESS) {
               break;
             }
             totalRowsDeleted++;
@@ -181,7 +179,7 @@ public void delete(RpcController controller, BulkDeleteRequest request,
         }
       }
     }
-    Builder responseBuilder = BulkDeleteResponse.newBuilder();
+    BulkDeleteResponse.Builder responseBuilder = BulkDeleteResponse.newBuilder();
     responseBuilder.setRowsDeleted(totalRowsDeleted);
     if (deleteType == DeleteType.VERSION) {
       responseBuilder.setVersionsDeleted(totalVersionsDeleted);

hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/ExampleRegionObserverWithMetrics.java

@@ -109,6 +109,8 @@ private void performCostlyOperation() {
         // simulate the operation by sleeping.
         Thread.sleep(ThreadLocalRandom.current().nextLong(100));
       } catch (InterruptedException ignore) {
+        // Restore the interrupt status
+        Thread.currentThread().interrupt();
       }
     }
   }

hbase-examples/src/main/java/org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java

@@ -24,6 +24,7 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
+import org.apache.commons.io.IOUtils;
 import org.apache.hadoop.hbase.Cell;
 import org.apache.hadoop.hbase.CellUtil;
 import org.apache.hadoop.hbase.CoprocessorEnvironment;
@@ -38,6 +39,8 @@
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.yetus.audience.InterfaceAudience;
 
+import org.apache.hbase.thirdparty.com.google.common.collect.Iterables;
+
 /**
  * Sample coprocessor endpoint exposing a Service interface for counting rows and key values.
  * <p>
@@ -93,10 +96,7 @@ public void getRowCount(RpcController controller, ExampleProtos.CountRequest req
       CoprocessorRpcUtils.setControllerException(controller, ioe);
     } finally {
       if (scanner != null) {
-        try {
-          scanner.close();
-        } catch (IOException ignored) {
-        }
+        IOUtils.closeQuietly(scanner);
       }
     }
     done.run(response);
@@ -117,9 +117,7 @@ public void getKeyValueCount(RpcController controller, ExampleProtos.CountReques
       long count = 0;
       do {
         hasMore = scanner.next(results);
-        for (Cell kv : results) {
-          count++;
-        }
+        count += Iterables.size(results);
         results.clear();
       } while (hasMore);
 
@@ -128,10 +126,7 @@ public void getKeyValueCount(RpcController controller, ExampleProtos.CountReques
       CoprocessorRpcUtils.setControllerException(controller, ioe);
     } finally {
       if (scanner != null) {
-        try {
-          scanner.close();
-        } catch (IOException ignored) {
-        }
+        IOUtils.closeQuietly(scanner);
       }
     }
     done.run(response);

hbase-examples/src/main/java/org/apache/hadoop/hbase/mapreduce/IndexBuilder.java

@@ -131,6 +131,7 @@ public static Job configureJob(Configuration conf, String[] args) throws IOExcep
     return job;
   }
 
+  @Override
   public int run(String[] args) throws Exception {
     Configuration conf = HBaseConfiguration.create(getConf());
     if (args.length < 3) {

hbase-examples/src/main/java/org/apache/hadoop/hbase/mapreduce/SampleUploader.java

@@ -18,6 +18,8 @@
 package org.apache.hadoop.hbase.mapreduce;
 
 import java.io.IOException;
+import java.util.Iterator;
+import java.util.List;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.fs.Path;
@@ -35,6 +37,8 @@
 import org.apache.hadoop.util.ToolRunner;
 import org.apache.yetus.audience.InterfaceAudience;
 
+import org.apache.hbase.thirdparty.com.google.common.base.Splitter;
+
 /**
  * Sample Uploader MapReduce
  * <p>
@@ -77,16 +81,16 @@ public void map(LongWritable key, Text line, Context context) throws IOException
       // Each line is comma-delimited; row,family,qualifier,value
 
       // Split CSV line
-      String[] values = line.toString().split(",");
-      if (values.length != 4) {
+      List<String> values = Splitter.on(',').splitToList(line.toString());
+      if (values.size() != 4) {
         return;
       }
-
+      Iterator<String> i = values.iterator();
       // Extract each value
-      byte[] row = Bytes.toBytes(values[0]);
-      byte[] family = Bytes.toBytes(values[1]);
-      byte[] qualifier = Bytes.toBytes(values[2]);
-      byte[] value = Bytes.toBytes(values[3]);
+      byte[] row = Bytes.toBytes(i.next());
+      byte[] family = Bytes.toBytes(i.next());
+      byte[] qualifier = Bytes.toBytes(i.next());
+      byte[] value = Bytes.toBytes(i.next());
 
       // Create Put
       Put put = new Put(row);
@@ -132,6 +136,7 @@ public static Job configureJob(Configuration conf, String[] args) throws IOExcep
    * @param otherArgs The command line parameters after ToolRunner handles standard.
    * @throws Exception When running the job fails.
    */
+  @Override
   public int run(String[] otherArgs) throws Exception {
     if (otherArgs.length != 2) {
       System.err.println("Wrong number of arguments: " + otherArgs.length);

hbase-examples/src/main/java/org/apache/hadoop/hbase/security/provider/example/ShadeSaslServerAuthenticationProvider.java

@@ -20,6 +20,7 @@
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
@@ -86,8 +87,8 @@ Map<String, char[]> readPasswordDB(Configuration conf) throws IOException {
     }
 
     Map<String, char[]> passwordDb = new HashMap<>();
-    try (FSDataInputStream fdis = fs.open(passwordFile);
-      BufferedReader reader = new BufferedReader(new InputStreamReader(fdis))) {
+    try (FSDataInputStream fdis = fs.open(passwordFile); BufferedReader reader =
+      new BufferedReader(new InputStreamReader(fdis, StandardCharsets.UTF_8))) {
       String line = null;
       int offset = 0;
       while ((line = reader.readLine()) != null) {

hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/DemoClient.java

@@ -130,15 +130,15 @@ private void run() throws Exception {
     System.out.println("scanning tables...");
 
     for (ByteBuffer name : client.getTableNames()) {
-      System.out.println("  found: " + ClientUtils.utf8(name.array()));
+      System.out.println("  found: " + ClientUtils.utf8(name));
 
       if (name.equals(demoTable) || name.equals(disabledTable)) {
         if (client.isTableEnabled(name)) {
-          System.out.println("    disabling table: " + ClientUtils.utf8(name.array()));
+          System.out.println("    disabling table: " + ClientUtils.utf8(name));
           client.disableTable(name);
         }
 
-        System.out.println("    deleting table: " + ClientUtils.utf8(name.array()));
+        System.out.println("    deleting table: " + ClientUtils.utf8(name));
         client.deleteTable(name);
       }
     }
@@ -326,7 +326,7 @@ private void run() throws Exception {
     columnNames.clear();
 
     for (ColumnDescriptor col2 : client.getColumnDescriptors(demoTable).values()) {
-      System.out.println("column with name: " + new String(col2.name.array()));
+      System.out.println("column with name: " + ClientUtils.utf8(col2.name));
       System.out.println(col2.toString());
 
       columnNames.add(col2.name);
@@ -358,7 +358,7 @@ private void printVersions(ByteBuffer row, List<TCell> versions) {
       rowStr.append("; ");
     }
 
-    System.out.println("row: " + ClientUtils.utf8(row.array()) + ", values: " + rowStr);
+    System.out.println("row: " + ClientUtils.utf8(row) + ", values: " + rowStr);
   }
 
   private void printRow(TRowResult rowResult) {

hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/HttpDoAsClient.java

@@ -26,7 +26,6 @@
 import java.util.Base64;
 import java.util.HashMap;
 import java.util.HashSet;
-import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import javax.security.auth.Subject;
@@ -37,8 +36,6 @@
 import org.apache.hadoop.hbase.thrift.generated.AlreadyExists;
 import org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor;
 import org.apache.hadoop.hbase.thrift.generated.Hbase;
-import org.apache.hadoop.hbase.thrift.generated.TCell;
-import org.apache.hadoop.hbase.thrift.generated.TRowResult;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.hbase.util.ClientUtils;
 import org.apache.thrift.protocol.TBinaryProtocol;
@@ -132,13 +129,13 @@ private void run() throws Exception {
     //
     System.out.println("scanning tables...");
     for (ByteBuffer name : refresh(client, httpClient).getTableNames()) {
-      System.out.println("  found: " + ClientUtils.utf8(name.array()));
-      if (ClientUtils.utf8(name.array()).equals(ClientUtils.utf8(t))) {
+      System.out.println("  found: " + ClientUtils.utf8(name));
+      if (ClientUtils.utf8(name).equals(ClientUtils.utf8(t))) {
         if (refresh(client, httpClient).isTableEnabled(name)) {
-          System.out.println("    disabling table: " + ClientUtils.utf8(name.array()));
+          System.out.println("    disabling table: " + ClientUtils.utf8(name));
           refresh(client, httpClient).disableTable(name);
         }
-        System.out.println("    deleting table: " + ClientUtils.utf8(name.array()));
+        System.out.println("    deleting table: " + ClientUtils.utf8(name));
         refresh(client, httpClient).deleteTable(name);
       }
     }
@@ -170,8 +167,8 @@ private void run() throws Exception {
     Map<ByteBuffer, ColumnDescriptor> columnMap =
       refresh(client, httpClient).getColumnDescriptors(ByteBuffer.wrap(t));
     for (ColumnDescriptor col2 : columnMap.values()) {
-      System.out.println(
-        "  column: " + ClientUtils.utf8(col2.name.array()) + ", maxVer: " + col2.maxVersions);
+      System.out
+        .println("  column: " + ClientUtils.utf8(col2.name) + ", maxVer: " + col2.maxVersions);
     }
 
     transport.close();
@@ -208,26 +205,13 @@ private String generateTicket() throws GSSException {
     context.requestInteg(true);
 
     final byte[] outToken = context.initSecContext(new byte[0], 0, 0);
-    StringBuffer outputBuffer = new StringBuffer();
+    StringBuilder outputBuffer = new StringBuilder();
     outputBuffer.append("Negotiate ");
     outputBuffer.append(Bytes.toString(Base64.getEncoder().encode(outToken)));
     System.out.print("Ticket is: " + outputBuffer);
     return outputBuffer.toString();
   }
 
-  private void printVersions(ByteBuffer row, List<TCell> versions) {
-    StringBuilder rowStr = new StringBuilder();
-    for (TCell cell : versions) {
-      rowStr.append(ClientUtils.utf8(cell.value.array()));
-      rowStr.append("; ");
-    }
-    System.out.println("row: " + ClientUtils.utf8(row.array()) + ", values: " + rowStr);
-  }
-
-  private void printRow(TRowResult rowResult) {
-    ClientUtils.printRow(rowResult);
-  }
-
   static Subject getSubject() throws Exception {
     if (!secure) {
       return new Subject();

hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift2/DemoClient.java

@@ -139,11 +139,11 @@ public void run() throws Exception {
 
     TResult result = client.get(table, get);
 
-    System.out.print("row = " + new String(result.getRow()));
+    System.out.print("row = " + ClientUtils.utf8(result.getRow()));
     for (TColumnValue resultColumnValue : result.getColumnValues()) {
-      System.out.print("family = " + new String(resultColumnValue.getFamily()));
-      System.out.print("qualifier = " + new String(resultColumnValue.getFamily()));
-      System.out.print("value = " + new String(resultColumnValue.getValue()));
+      System.out.print("family = " + ClientUtils.utf8(resultColumnValue.getFamily()));
+      System.out.print("qualifier = " + ClientUtils.utf8(resultColumnValue.getFamily()));
+      System.out.print("value = " + ClientUtils.utf8(resultColumnValue.getValue()));
       System.out.print("timestamp = " + resultColumnValue.getTimestamp());
     }