You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by tj...@apache.org on 2011/09/29 19:38:02 UTC
svn commit: r1177379 - in
/incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp:
BSPJob.java BSPJobImpl.java
Author: tjungblut
Date: Thu Sep 29 17:38:02 2011
New Revision: 1177379
URL: http://svn.apache.org/viewvc?rev=1177379&view=rev
Log:
Added neat features.
Modified:
incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJob.java
incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJobImpl.java
Modified: incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJob.java
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJob.java?rev=1177379&r1=1177378&r2=1177379&view=diff
==============================================================================
--- incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJob.java (original)
+++ incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJob.java Thu Sep 29 17:38:02 2011
@@ -28,12 +28,18 @@ public interface BSPJob {
public enum JobState {
NEW, RUNNING, SUCCESS, FAILED, KILLED
}
+
+ public enum BSPPhase{
+ COMPUTATION, COMMUNICATION
+ }
BSPJobID getID();
String getName();
JobState getState();
+
+ BSPPhase getBSPPhase();
Map<TaskAttemptID, Task> getTasks();
Modified: incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJobImpl.java
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJobImpl.java?rev=1177379&r1=1177378&r2=1177379&view=diff
==============================================================================
--- incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJobImpl.java (original)
+++ incubator/hama/branches/HamaV2/server/src/main/java/org/apache/hama/bsp/BSPJobImpl.java Thu Sep 29 17:38:02 2011
@@ -65,4 +65,10 @@ public class BSPJobImpl implements BSPJo
return null;
}
+ @Override
+ public BSPPhase getBSPPhase() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
}