hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ap...@apache.org
Subject svn commit: r1430289 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
Date Tue, 08 Jan 2013 14:08:53 GMT
Author: apurv
Date: Tue Jan  8 14:08:53 2013
New Revision: 1430289

URL: http://svn.apache.org/viewvc?rev=1430289&view=rev
Log:
Fixed compile errors temporarily, TODO: initialize isPartitioned properly

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java?rev=1430289&r1=1430288&r2=1430289&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java Tue Jan  8 14:08:53 2013
@@ -47,6 +47,7 @@ public class BSPJob extends BSPJobContex
   private JobState state = JobState.DEFINE;
   private BSPJobClient jobClient;
   private RunningJob info;
+  private boolean isPartitioned = false; //TODO: If input is already partitioned init to
true
 
   public BSPJob() throws IOException {
     this(new HamaConfiguration());
@@ -220,8 +221,6 @@ public class BSPJob extends BSPJobContex
     state = JobState.RUNNING;
   }
 
-  boolean isPartitioned = false;
-
   public boolean waitForCompletion(boolean verbose) throws IOException,
       InterruptedException, ClassNotFoundException {
     if (this.getConfiguration().get("bsp.input.partitioner.class") != null



Mime
View raw message