rename interface and class for task assigner based on suitable pattern. (#6664)

streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/JobSchedulerImpl.java

@@ -24,11 +24,11 @@ public class JobSchedulerImpl implements JobScheduler {
   private Plan plan;
   private Map<String, Object> jobConfig;
   private ResourceManager resourceManager;
-  private ITaskAssign taskAssign;
+  private TaskAssigner taskAssigner;
 
   public JobSchedulerImpl() {
     this.resourceManager = new ResourceManager();
-    this.taskAssign = new TaskAssignImpl();
+    this.taskAssigner = new TaskAssignerImpl();
   }
 
   /**
@@ -42,7 +42,7 @@ public class JobSchedulerImpl implements JobScheduler {
     Ray.init();
 
     List<RayActor<JobWorker>> workers = this.resourceManager.createWorkers(getPlanWorker());
-    ExecutionGraph executionGraph = this.taskAssign.assign(this.plan, workers);
+    ExecutionGraph executionGraph = this.taskAssigner.assign(this.plan, workers);
 
     List<ExecutionNode> executionNodes = executionGraph.getExecutionNodeList();
     List<RayObject<Boolean>> waits = new ArrayList<>();

streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssigner.java

@@ -10,7 +10,7 @@ import org.ray.streaming.runtime.worker.JobWorker;
 /**
  * Interface of the task assigning strategy.
  */
-public interface ITaskAssign extends Serializable {
+public interface TaskAssigner extends Serializable {
 
   /**
    * Assign logical plan to physical execution graph.

streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssignerImpl.java

@@ -17,7 +17,7 @@ import org.ray.streaming.runtime.core.processor.ProcessBuilder;
 import org.ray.streaming.runtime.core.processor.StreamProcessor;
 import org.ray.streaming.runtime.worker.JobWorker;
 
-public class TaskAssignImpl implements ITaskAssign {
+public class TaskAssignerImpl implements TaskAssigner {
 
   /**
    * Assign an optimized logical plan to execution graph.

streaming/java/streaming-runtime/src/test/java/org/ray/streaming/runtime/schedule/TaskAssignerImplTest.java

@@ -25,9 +25,9 @@ import org.slf4j.LoggerFactory;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-public class TaskAssignImplTest {
+public class TaskAssignerImplTest {
 
-  private static final Logger LOGGER = LoggerFactory.getLogger(TaskAssignImplTest.class);
+  private static final Logger LOGGER = LoggerFactory.getLogger(TaskAssignerImplTest.class);
 
   @Test
   public void testTaskAssignImpl() {
@@ -38,8 +38,8 @@ public class TaskAssignImplTest {
       workers.add(new LocalModeRayActor(ActorId.fromRandom(), ObjectId.fromRandom()));
     }
 
-    ITaskAssign taskAssign = new TaskAssignImpl();
-    ExecutionGraph executionGraph = taskAssign.assign(plan, workers);
+    TaskAssigner taskAssigner = new TaskAssignerImpl();
+    ExecutionGraph executionGraph = taskAssigner.assign(plan, workers);
 
     List<ExecutionNode> executionNodeList = executionGraph.getExecutionNodeList();