You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by to...@apache.org on 2012/05/14 17:36:49 UTC

svn commit: r1338256 - in /incubator/hama/trunk/core/src/main/java/org/apache/hama/util: BSPServletUtil.java RunJar.java ZKUtil.java

Author: tommaso
Date: Mon May 14 15:36:49 2012
New Revision: 1338256

URL: http://svn.apache.org/viewvc?rev=1338256&view=rev
Log:
[HAMA-572] - removing + for concatenations and setting the collections initial size for boosting performance in util package

Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/util/BSPServletUtil.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/util/RunJar.java
    incubator/hama/trunk/core/src/main/java/org/apache/hama/util/ZKUtil.java

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/util/BSPServletUtil.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/util/BSPServletUtil.java?rev=1338256&r1=1338255&r2=1338256&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/util/BSPServletUtil.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/util/BSPServletUtil.java Mon May 14 15:36:49 2012
@@ -56,7 +56,7 @@ public class BSPServletUtil extends Serv
   public static String generateJobTable(String label, JobStatus[] jobs,
       int refresh, int rowId) throws IOException {
 
-    StringBuffer sb = new StringBuffer();
+    StringBuilder sb = new StringBuilder();
 
     if (jobs.length > 0) {
       sb.append("<table border=\"1\" cellpadding=\"5\" cellspacing=\"0\">\n");
@@ -64,8 +64,7 @@ public class BSPServletUtil extends Serv
           + "<th>SuperSteps</th>" + "<th>Tasks</th>" + "<th>Starttime</th>"
           + "</tr>\n");
       for (JobStatus status : jobs) {
-        sb.append("<tr><td><a href=\"bspjob.jsp?jobid=" + status.getJobID()
-            + "\">");
+        sb.append("<tr><td><a href=\"bspjob.jsp?jobid=").append(status.getJobID()).append("\">");
         sb.append(status.getJobID());
         sb.append("</a></td><td>");
         sb.append(status.getUsername());
@@ -103,12 +102,11 @@ public class BSPServletUtil extends Serv
     for (Entry<String, GroomServerStatus> entry : status
         .getActiveGroomServerStatus().entrySet()) {
       sb.append("<tr><td>");
-      sb.append(entry.getKey() + "</td><td>");
-      sb.append(entry.getValue().getGroomHostName() + "</td>" + "<td>"
-          + entry.getValue().getMaxTasks() + "</td><td>");
-      sb.append(entry.getValue().countTasks() + "</td><td>");
-      sb.append(entry.getValue().getFailures() + "</td><td>");
-      sb.append(entry.getValue().getLastSeen() + "</td>");
+      sb.append(entry.getKey()).append("</td><td>");
+      sb.append(entry.getValue().getGroomHostName()).append("</td>").append("<td>").append(entry.getValue().getMaxTasks()).append("</td><td>");
+      sb.append(entry.getValue().countTasks()).append("</td><td>");
+      sb.append(entry.getValue().getFailures()).append("</td><td>");
+      sb.append(entry.getValue().getLastSeen()).append("</td>");
       sb.append("</tr>\n");
     }
     sb.append("</table>\n");

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/util/RunJar.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/util/RunJar.java?rev=1338256&r1=1338255&r2=1338256&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/util/RunJar.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/util/RunJar.java Mon May 14 15:36:49 2012
@@ -128,19 +128,20 @@ public class RunJar {
     classPath.add(new File(workDir, "classes/").toURI().toURL());
     File[] libs = new File(workDir, "lib").listFiles();
     if (libs != null) {
-      for (int i = 0; i < libs.length; i++) {
-        classPath.add(libs[i].toURI().toURL());
+      for (File lib : libs) {
+        classPath.add(lib.toURI().toURL());
       }
     }
     ClassLoader loader = new URLClassLoader((URL[]) classPath
-        .toArray(new URL[0]));
+      .toArray(new URL[classPath.size()]));
 
     Thread.currentThread().setContextClassLoader(loader);
     Class<?> mainClass = loader.loadClass(mainClassName);
     Method main = mainClass.getMethod("main", new Class[] { Array.newInstance(
         String.class, 0).getClass() });
-    String[] newArgs = (String[]) Arrays.asList(args).subList(firstArg,
-        args.length).toArray(new String[0]);
+    List<String> var = Arrays.asList(args).subList(firstArg,
+      args.length);
+    String[] newArgs = (String[]) var.toArray(new String[var.size()]);
     try {
       main.invoke(null, new Object[] { newArgs });
     } catch (InvocationTargetException e) {

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/util/ZKUtil.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/util/ZKUtil.java?rev=1338256&r1=1338255&r2=1338256&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/util/ZKUtil.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/util/ZKUtil.java Mon May 14 15:36:49 2012
@@ -60,7 +60,7 @@ public class ZKUtil {
     StringBuilder builder = new StringBuilder();
     for (String part : parts) {
       try {
-        builder.append(ZKUtil.ZK_SEPARATOR + part);
+        builder.append(ZKUtil.ZK_SEPARATOR).append(part);
         if (null == zk.exists(builder.toString(), false)) {
           zk.create(builder.toString(), null, Ids.OPEN_ACL_UNSAFE,
               CreateMode.PERSISTENT);