tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject [1/4] TEZ-1218. Make TaskScheduler an Abstract class instead of an Inteface. Contributed by Jeff Zhang.
Date Thu, 26 Jun 2014 17:26:08 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master af538639c -> 4dfd8341d


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/4dfd8341/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskSchedulerHelpers.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskSchedulerHelpers.java
b/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskSchedulerHelpers.java
index 5a0856b..b0ea644 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskSchedulerHelpers.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/rm/TestTaskSchedulerHelpers.java
@@ -55,8 +55,8 @@ import org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl;
 import org.apache.hadoop.yarn.event.Event;
 import org.apache.hadoop.yarn.event.EventHandler;
 import org.apache.tez.dag.app.AppContext;
-import org.apache.tez.dag.app.rm.TaskScheduler.CookieContainerRequest;
-import org.apache.tez.dag.app.rm.TaskScheduler.TaskSchedulerAppCallback;
+import org.apache.tez.dag.app.rm.YarnTaskSchedulerService.CookieContainerRequest;
+import org.apache.tez.dag.app.rm.TaskSchedulerService.TaskSchedulerAppCallback;
 import org.apache.tez.dag.app.rm.container.ContainerSignatureMatcher;
 
 import com.google.common.base.Preconditions;
@@ -133,20 +133,20 @@ class TestTaskSchedulerHelpers {
     }
 
     @Override
-    public TaskSchedulerInterface createTaskScheduler(String host, int port,
+    public TaskSchedulerService createTaskScheduler(String host, int port,
         String trackingUrl, AppContext appContext) {
       return new TaskSchedulerWithDrainableAppCallback(this,
           containerSignatureMatcher, host, port, trackingUrl, amrmClientAsync,
           appContext);
     }
 
-    public TaskSchedulerInterface getSpyTaskScheduler() {
+    public TaskSchedulerService getSpyTaskScheduler() {
       return this.taskScheduler;
     }
 
     @Override
     public void serviceStart() {
-      TaskSchedulerInterface taskSchedulerReal = createTaskScheduler("host", 0, "",
+      TaskSchedulerService taskSchedulerReal = createTaskScheduler("host", 0, "",
         appContext);
       // Init the service so that reuse configuration is picked up.
       ((AbstractService)taskSchedulerReal).init(getConfig());
@@ -190,7 +190,7 @@ class TestTaskSchedulerHelpers {
     }
   }
 
-  static class TaskSchedulerWithDrainableAppCallback extends TaskScheduler {
+  static class TaskSchedulerWithDrainableAppCallback extends YarnTaskSchedulerService {
 
     private TaskSchedulerAppCallbackDrainable drainableAppCallback;
 


Mime
View raw message