You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ap...@apache.org on 2013/01/08 15:08:53 UTC
svn commit: r1430289 -
/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
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