Author: tommaso
Date: Tue Feb  5 08:12:24 2013
New Revision: 1442492

URL: http://svn.apache.org/viewvc?rev=1442492&view=rev
Log:
HAMA-572 - fixed some declaration redundancies

Modified:
    
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/GradientDescentBSP.java
    
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/VectorDoubleFileInputFormat.java

Modified: 
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/GradientDescentBSP.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/GradientDescentBSP.java?rev=1442492&r1=1442491&r2=1442492&view=diff
==============================================================================
--- 
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/GradientDescentBSP.java
 (original)
+++ 
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/GradientDescentBSP.java
 Tue Feb  5 08:12:24 2013
@@ -273,8 +273,8 @@ public class GradientDescentBSP
     }
   }
 
-  public void getInitialTheta(
-      BSPPeer<VectorWritable, DoubleWritable, VectorWritable, DoubleWritable, 
VectorWritable> peer)
+  void getInitialTheta(
+          BSPPeer<VectorWritable, DoubleWritable, VectorWritable, 
DoubleWritable, VectorWritable> peer)
       throws IOException, SyncException, InterruptedException {
     if (theta == null) {
       if (master) {

Modified: 
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/VectorDoubleFileInputFormat.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/VectorDoubleFileInputFormat.java?rev=1442492&r1=1442491&r2=1442492&view=diff
==============================================================================
--- 
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/VectorDoubleFileInputFormat.java
 (original)
+++ 
hama/trunk/ml/src/main/java/org/apache/hama/ml/regression/VectorDoubleFileInputFormat.java
 Tue Feb  5 08:12:24 2013
@@ -59,7 +59,7 @@ public class VectorDoubleFileInputFormat
     private long pos;
     private long end;
     private LineReader in;
-    int maxLineLength;
+    final int maxLineLength;
 
     /**
      * A class that provides a line reader from an input stream.
@@ -155,7 +155,7 @@ public class VectorDoubleFileInputFormat
           return false;
         }
 
-        String[] kv = new String(textVal.getBytes()).split("\\>");
+        String[] kv = new String(textVal.getBytes()).split(">");
         if (kv.length != 2) {
           throw new IOException("a line was not parsed correctly");
         }


Reply via email to