Class CoLocationConstraint
- java.lang.Object
-
- org.apache.flink.runtime.jobmanager.scheduler.CoLocationConstraint
-
public class CoLocationConstraint extends Object
ACoLocationConstraint
stores the ID ofCoLocationGroup
and an ID referring to the actual subtask (i.e.ExecutionVertex
). In co-location groups, the different subtasks of differentJobVertex
instances need to be executed on the same slot. This is realized by creating a special shared slot that holds these tasks.