public class PartitionRouter
extends java.lang.Object
Constructor and Description |
---|
PartitionRouter(LogicalPlan plan,
java.util.Set<java.lang.Integer> srscs,
java.util.Set<java.lang.Integer> dests)
Create a direct router
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> |
getExternalSendTasks() |
java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> |
getInternalSendTasks() |
int |
mainTaskOfExecutor() |
java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> |
partialExpectedTaskIds() |
java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> |
receiveExpectedTaskIds() |
java.util.Set<java.lang.Integer> |
receivingExecutors() |
public PartitionRouter(LogicalPlan plan, java.util.Set<java.lang.Integer> srscs, java.util.Set<java.lang.Integer> dests)
public java.util.Set<java.lang.Integer> receivingExecutors()
public java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> receiveExpectedTaskIds()
public java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> partialExpectedTaskIds()
public java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> getInternalSendTasks()
public java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> getExternalSendTasks()
public int mainTaskOfExecutor()