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");
}