svn commit: r1201462 - /mahout/trunk/core/src/main/java/org/apache/mahout/graph/linkanalysis/RandomWalk.java

[ssc]

Author: ssc
Date: Sun Nov 13 17:13:32 2011
New Revision: 1201462

URL: http://svn.apache.org/viewvc?rev=1201462&view=rev
Log:
MAHOUT-879 Remove all graph algorithms with the exception of PageRank

Modified:
    
mahout/trunk/core/src/main/java/org/apache/mahout/graph/linkanalysis/RandomWalk.java

Modified: 
mahout/trunk/core/src/main/java/org/apache/mahout/graph/linkanalysis/RandomWalk.java
URL: 
http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/graph/linkanalysis/RandomWalk.java?rev=1201462&r1=1201461&r2=1201462&view=diff
==============================================================================
--- 
mahout/trunk/core/src/main/java/org/apache/mahout/graph/linkanalysis/RandomWalk.java
 (original)
+++ 
mahout/trunk/core/src/main/java/org/apache/mahout/graph/linkanalysis/RandomWalk.java
 Sun Nov 13 17:13:32 2011
@@ -179,8 +179,9 @@ abstract class RandomWalk extends Abstra
     @Override
     protected void setup(Context ctx) throws IOException, InterruptedException 
{
       Path pageRankPath = new 
Path(ctx.getConfiguration().get(RANK_PATH_PARAM));
-      DataInputStream in = FileSystem.get(pageRankPath.toUri(), 
ctx.getConfiguration()).open(pageRankPath);
+      DataInputStream in = null;
       try {
+        in = FileSystem.get(pageRankPath.toUri(), 
ctx.getConfiguration()).open(pageRankPath);
         ranks = VectorWritable.readVector(in);
       } finally {
         Closeables.closeQuietly(in);