HIVE-16712 : StringBuffer v.s. StringBuilder (Beluga Behr via Ashutosh Chauhan)
authorBELUGA BEHR <dam6923@gmail.com>
Tue, 23 May 2017 20:32:38 +0000 (13:32 -0700)
committerAshutosh Chauhan <hashutosh@apache.org>
Tue, 23 May 2017 20:32:38 +0000 (13:32 -0700)
Signed-off-by: Ashutosh Chauhan <hashutosh@apache.org>
19 files changed:
common/src/java/org/apache/hadoop/hive/common/jsonexplain/DagJsonParserUtils.java
common/src/java/org/apache/hadoop/hive/common/jsonexplain/Op.java
hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/mutate/worker/GroupingValidator.java
hcatalog/streaming/src/test/org/apache/hive/hcatalog/streaming/TestStreaming.java
hplsql/src/main/java/org/apache/hive/hplsql/Utils.java
itests/util/src/main/java/org/apache/hadoop/hive/ql/security/DummyHiveMetastoreAuthorizationProvider.java
llap-client/src/java/org/apache/hadoop/hive/llap/LlapRowRecordReader.java
llap-common/src/java/org/apache/hadoop/hive/llap/Schema.java
llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java
metastore/src/java/org/apache/hadoop/hive/metastore/RetryingHMSHandler.java
metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseFilterPlanUtil.java
metastore/src/java/org/apache/hadoop/hive/metastore/hbase/HBaseUtils.java
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/fast/VectorMapJoinFastValueStore.java
ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
ql/src/java/org/apache/hadoop/hive/ql/plan/TableScanDesc.java
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/expressions/TestVectorStringExpressions.java
serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/BinarySortableDeserializeRead.java
serde/src/java/org/apache/hadoop/hive/serde2/lazy/fast/LazySimpleDeserializeRead.java
serde/src/java/org/apache/hadoop/hive/serde2/lazybinary/fast/LazyBinaryDeserializeRead.java

index a518ac1..8ea25d5 100644 (file)
@@ -38,7 +38,7 @@ public class DagJsonParserUtils {
   }
 
   public static String attrsToString(Map<String, String> attrs) {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     boolean first = true;
     for (Entry<String, String> entry : attrs.entrySet()) {
       if (first) {
index 2b853ef..39c44f1 100644 (file)
@@ -170,7 +170,7 @@ public final class Op {
         }
       }
       this.attrs.remove("keys:");
-      StringBuffer sb = new StringBuffer();
+      StringBuilder sb = new StringBuilder();
       JSONArray conditionMap = opObject.getJSONArray("condition map:");
       for (int index = 0; index < conditionMap.length(); index++) {
         JSONObject cond = conditionMap.getJSONObject(index);
@@ -250,7 +250,7 @@ public final class Op {
       }
       // update the attrs
       this.attrs.remove("keys:");
-      StringBuffer sb = new StringBuffer();
+      StringBuilder sb = new StringBuilder();
       JSONArray conditionMap = opObject.getJSONArray("condition map:");
       for (int index = 0; index < conditionMap.length(); index++) {
         JSONObject cond = conditionMap.getJSONObject(index);
@@ -273,7 +273,7 @@ public final class Op {
   }
 
   private String getNameWithOpIdStats() {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     sb.append(DagJsonParserUtils.renameReduceOutputOperator(name, vertex));
     if (operatorId != null) {
       sb.append(" [" + operatorId + "]");
index 18754f2..f28b8ff 100644 (file)
@@ -31,14 +31,14 @@ import java.util.Set;
 class GroupingValidator {
 
   private final Map<String, Set<Integer>> visited;
-  private final StringBuffer partitionKeyBuilder;
+  private final StringBuilder partitionKeyBuilder;
   private long groups;
   private String lastPartitionKey;
   private int lastBucketId = -1;
 
   GroupingValidator() {
     visited = new HashMap<String, Set<Integer>>();
-    partitionKeyBuilder = new StringBuffer(64);
+    partitionKeyBuilder = new StringBuilder(64);
   }
 
   /**
index 097de9b..5e8fe62 100644 (file)
@@ -1952,7 +1952,7 @@ public class TestStreaming {
   }
 
   private static String getTableColumnsStr(String[] colNames, String[] colTypes) {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     for (int i=0; i < colNames.length; ++i) {
       sb.append(colNames[i] + " " + colTypes[i]);
       if (i<colNames.length-1) {
@@ -1967,7 +1967,7 @@ public class TestStreaming {
     if (partNames==null || partNames.length==0) {
       return "";
     }
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     for (int i=0; i < partNames.length; ++i) {
       sb.append(partNames[i] + " string");
       if (i < partNames.length-1) {
@@ -1979,7 +1979,7 @@ public class TestStreaming {
 
   // converts partNames,partVals into "partName1=val1, partName2=val2"
   private static String getPartsSpec(String[] partNames, List<String> partVals) {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     for (int i=0; i < partVals.size(); ++i) {
       sb.append(partNames[i] + " = '" + partVals.get(i) + "'");
       if(i < partVals.size()-1) {
@@ -1992,7 +1992,7 @@ public class TestStreaming {
   private static String join(String[] values, String delimiter) {
     if(values==null)
       return null;
-    StringBuffer strbuf = new StringBuffer();
+    StringBuilder strbuf = new StringBuilder();
 
     boolean first = true;
 
index a768b00..d261df1 100644 (file)
@@ -32,7 +32,7 @@ public class Utils {
          }
          
          int len = s.length();
-         StringBuffer s2 = new StringBuffer(len);        
+         StringBuilder s2 = new StringBuilder(len);      
          
          for (int i = 0; i < len; i++) {
                char ch = s.charAt(i);
index 346abd6..93637d4 100644 (file)
@@ -187,7 +187,7 @@ public class DummyHiveMetastoreAuthorizationProvider implements HiveMetastoreAut
   }
 
   private String debugPrivPrint(Privilege[] privileges) {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     sb.append("Privileges{");
     if (privileges != null){
     for (Privilege p : privileges){
index c50d226..7e38356 100644 (file)
@@ -233,8 +233,8 @@ public class LlapRowRecordReader implements RecordReader<NullWritable, Row> {
 
   protected AbstractSerDe initSerDe(Configuration conf) throws SerDeException {
     Properties props = new Properties();
-    StringBuffer columnsBuffer = new StringBuffer();
-    StringBuffer typesBuffer = new StringBuffer();
+    StringBuilder columnsBuffer = new StringBuilder();
+    StringBuilder typesBuffer = new StringBuilder();
     boolean isFirst = true;
     for (FieldDesc colDesc : schema.getColumns()) {
       if (!isFirst) {
index c1bf4ea..08cc54d 100644 (file)
@@ -43,7 +43,7 @@ public class Schema implements Writable {
 
   @Override
   public String toString() {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     boolean first = true;
     for (FieldDesc colDesc : getColumns()) {
       if (!first) {
index e90f0df..f34b385 100644 (file)
@@ -813,7 +813,7 @@ public class ShuffleHandler implements AttemptRegistrationListener {
     }
 
     private String getErrorMessage(Throwable t) {
-      StringBuffer sb = new StringBuffer(t.getMessage());
+      StringBuilder sb = new StringBuilder(t.getMessage());
       while (t.getCause() != null) {
         sb.append(t.getCause().getMessage());
         t = t.getCause();
index b1c8e39..a08c5bd 100644 (file)
@@ -109,7 +109,7 @@ public class RetryingHMSHandler implements InvocationHandler {
       error = false;
       return result.result;
     } finally {
-      StringBuffer additionalInfo = new StringBuffer();
+      StringBuilder additionalInfo = new StringBuilder();
       additionalInfo.append("threadId=").append(threadId).append(" retryCount=").append(retryCount)
         .append(" error=").append(error);
       perfLogger.PerfLogEnd(CLASS_NAME, method.getName(), additionalInfo.toString());
index 9762309..3c03846 100644 (file)
@@ -473,7 +473,7 @@ class HBaseFilterPlanUtil {
 
     @Override
     public String toString() {
-      StringBuffer sb = new StringBuffer();
+      StringBuilder sb = new StringBuilder();
       sb.append("ScanPlan:\n");
       for (Map.Entry<String, ScanMarkerPair> entry : markers.entrySet()) {
         sb.append("key=" + entry.getKey() + "[startMarker=" + entry.getValue().startMarker
index 7dfa38f..64082e8 100644 (file)
@@ -956,9 +956,9 @@ public class HBaseUtils {
 
   private static List<String> desierliazeDbNameTableNameFromPartitionKey(byte[] key,
                                                                          Configuration conf) {
-    StringBuffer names = new StringBuffer();
+    StringBuilder names = new StringBuilder();
     names.append("dbName,tableName,");
-    StringBuffer types = new StringBuffer();
+    StringBuilder types = new StringBuilder();
     types.append("string,string,");
     BinarySortableSerDe serDe = new BinarySortableSerDe();
     Properties props = new Properties();
@@ -990,9 +990,9 @@ public class HBaseUtils {
   // Deserialize a partition key and return _only_ the partition values.
   private static List<String> deserializePartitionKey(List<FieldSchema> partitions, byte[] key,
       Configuration conf) {
-    StringBuffer names = new StringBuffer();
+    StringBuilder names = new StringBuilder();
     names.append("dbName,tableName,");
-    StringBuffer types = new StringBuffer();
+    StringBuilder types = new StringBuilder();
     types.append("string,string,");
     for (int i=0;i<partitions.size();i++) {
       names.append(partitions.get(i).getName());
index 3cd06e8..ff6dcd1 100644 (file)
@@ -165,7 +165,7 @@ public class VectorMapJoinFastValueStore implements MemoryEstimate {
      */
     @Override
     public String getDetailedHashMapResultPositionString() {
-      StringBuffer sb = new StringBuffer();
+      StringBuilder sb = new StringBuilder();
 
       sb.append("Read index ");
       sb.append(readIndex);
index 35fc68a..d68f832 100644 (file)
@@ -10938,7 +10938,7 @@ public class SemanticAnalyzer extends BaseSemanticAnalyzer {
       ASTNode astNode = (ASTNode) queue.poll();
       if (astNode.getToken().getType() == HiveParser.TOK_TABREF) {
         int aliasIndex = 0;
-        StringBuffer additionalTabInfo = new StringBuffer();
+        StringBuilder additionalTabInfo = new StringBuilder();
         for (int index = 1; index < astNode.getChildCount(); index++) {
           ASTNode ct = (ASTNode) astNode.getChild(index);
           if (ct.getToken().getType() == HiveParser.TOK_TABLEBUCKETSAMPLE
index 3daa83f..04686f7 100644 (file)
@@ -148,7 +148,7 @@ public class TableScanDesc extends AbstractOperatorDesc {
 
   @Explain(explainLevels = { Level.USER })
   public String getTbl() {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     sb.append(this.tableMetadata.getCompleteName());
     sb.append("," + alias);
     if (isAcidTable()) {
index d97152f..aa60878 100644 (file)
@@ -4344,14 +4344,14 @@ public class TestVectorStringExpressions {
       return value.toLowerCase();
     }
     case 8: {
-      StringBuffer sb = new StringBuffer(8);
+      StringBuilder sb = new StringBuilder();
       for (int i = 0; i < control.nextInt(12); i++) {
         sb.append((char) ('a' + control.nextInt(26)));
       }
       return sb.toString();
     }
     case 9: {
-      StringBuffer sb = new StringBuffer(8);
+      StringBuilder sb = new StringBuilder();
       for (int i = 0; i < control.nextInt(12); i++) {
         sb.append((char) ('A' + control.nextInt(26)));
       }
@@ -4361,7 +4361,7 @@ public class TestVectorStringExpressions {
   }
 
   private String generateCandidate(Random control, String pattern) {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
     final StringTokenizer tokens = new StringTokenizer(pattern, "%");
     final boolean leftAnchor = pattern.startsWith("%");
     final boolean rightAnchor = pattern.endsWith("%");
index d9160d7..b5ac842 100644 (file)
@@ -175,7 +175,7 @@ public final class BinarySortableDeserializeRead extends DeserializeRead {
    * Get detailed read position information to help diagnose exceptions.
    */
   public String getDetailedReadPositionString() {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder(64);
 
     sb.append("Reading inputByteBuffer of length ");
     sb.append(inputByteBuffer.getEnd());
index 64e316b..9b3f3d0 100644 (file)
@@ -360,7 +360,7 @@ public final class LazySimpleDeserializeRead extends DeserializeRead {
    * Get detailed read position information to help diagnose exceptions.
    */
   public String getDetailedReadPositionString() {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder(64);
 
     sb.append("Reading byte[] of length ");
     sb.append(bytes.length);
index 8e0a499..c0c4d91 100644 (file)
@@ -173,7 +173,7 @@ public final class LazyBinaryDeserializeRead extends DeserializeRead {
    * Get detailed read position information to help diagnose exceptions.
    */
   public String getDetailedReadPositionString() {
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder(64);
 
     sb.append("Reading byte[] of length ");
     sb.append(bytes.length);