Class CoLocationGroupImpl
- java.lang.Object
-
- org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroupImpl
-
- All Implemented Interfaces:
Serializable
,CoLocationGroup
public class CoLocationGroupImpl extends Object implements CoLocationGroup, Serializable
ACoLocationGroup
implementation.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CoLocationGroupImpl(JobVertex... vertices)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addVertex(JobVertex vertex)
AbstractID
getId()
Returns the unique identifier describing this co-location constraint as a group.CoLocationConstraint
getLocationConstraint(int subTaskIndex)
Returns theCoLocationConstraint
for a specificsubTaskIndex
.List<JobVertexID>
getVertexIds()
Returns the IDs of theJobVertex
instances participating in this group.void
mergeInto(CoLocationGroupImpl other)
-
-
-
Constructor Detail
-
CoLocationGroupImpl
public CoLocationGroupImpl(JobVertex... vertices)
-
-
Method Detail
-
addVertex
public void addVertex(JobVertex vertex)
-
getVertexIds
public List<JobVertexID> getVertexIds()
Description copied from interface:CoLocationGroup
Returns the IDs of theJobVertex
instances participating in this group.- Specified by:
getVertexIds
in interfaceCoLocationGroup
- Returns:
- The group's members represented by their
JobVertexID
s.
-
getLocationConstraint
public CoLocationConstraint getLocationConstraint(int subTaskIndex)
Description copied from interface:CoLocationGroup
Returns theCoLocationConstraint
for a specificsubTaskIndex
.- Specified by:
getLocationConstraint
in interfaceCoLocationGroup
- Parameters:
subTaskIndex
- The index of the subtasks for which aCoLocationConstraint
shall be returned.- Returns:
- The corresponding
CoLocationConstraint
instance.
-
mergeInto
public void mergeInto(CoLocationGroupImpl other)
-
getId
public AbstractID getId()
Description copied from interface:CoLocationGroup
Returns the unique identifier describing this co-location constraint as a group.- Specified by:
getId
in interfaceCoLocationGroup
- Returns:
- The group's identifier.
-
-