diff --git a/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/JobSchedulerImpl.java b/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/JobSchedulerImpl.java index 8a30c75fa..b93d2bf46 100644 --- a/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/JobSchedulerImpl.java +++ b/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 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> workers = this.resourceManager.createWorkers(getPlanWorker()); - ExecutionGraph executionGraph = this.taskAssign.assign(this.plan, workers); + ExecutionGraph executionGraph = this.taskAssigner.assign(this.plan, workers); List executionNodes = executionGraph.getExecutionNodeList(); List> waits = new ArrayList<>(); diff --git a/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/ITaskAssign.java b/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssigner.java similarity index 89% rename from streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/ITaskAssign.java rename to streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssigner.java index 9fc1d0cdb..f826bdd4b 100644 --- a/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/ITaskAssign.java +++ b/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. diff --git a/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssignImpl.java b/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssignerImpl.java similarity index 97% rename from streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssignImpl.java rename to streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssignerImpl.java index 20b3e8971..1c15be9c2 100644 --- a/streaming/java/streaming-runtime/src/main/java/org/ray/streaming/runtime/schedule/TaskAssignImpl.java +++ b/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. diff --git a/streaming/java/streaming-runtime/src/test/java/org/ray/streaming/runtime/schedule/TaskAssignImplTest.java b/streaming/java/streaming-runtime/src/test/java/org/ray/streaming/runtime/schedule/TaskAssignerImplTest.java similarity index 93% rename from streaming/java/streaming-runtime/src/test/java/org/ray/streaming/runtime/schedule/TaskAssignImplTest.java rename to streaming/java/streaming-runtime/src/test/java/org/ray/streaming/runtime/schedule/TaskAssignerImplTest.java index f6057f289..c4ee3a005 100644 --- a/streaming/java/streaming-runtime/src/test/java/org/ray/streaming/runtime/schedule/TaskAssignImplTest.java +++ b/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 executionNodeList = executionGraph.getExecutionNodeList();