public interface CoLocationGroup
CoLocationGrouprefers to a list of
JobVertexinstances, where the i-th subtask of one vertex has to be executed on the same
TaskManageras the i-th subtask of all other
JobVertexinstances in the same group.
The co-location group is used to make sure that the i-th subtasks for iteration head and iteration tail are scheduled on the same TaskManager.
|Modifier and Type||Method and Description|
Returns the unique identifier describing this co-location constraint as a group.
Returns the IDs of the
JobVertexinstances participating in this group.
CoLocationConstraint getLocationConstraint(int subTaskIndex)
CoLocationConstraintfor a specific
subTaskIndex- The index of the subtasks for which a
CoLocationConstraintshall be returned.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.