Class SlotSharingGroup
- java.lang.Object
-
- org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup
-
- All Implemented Interfaces:
Serializable
public class SlotSharingGroup extends Object implements Serializable
A slot sharing units defines which different task (from different job vertices) can be deployed together within a slot. This is a soft permission, in contrast to the hard constraint defined by a co-location hint.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SlotSharingGroup()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addVertexToGroup(JobVertexID id)
Set<JobVertexID>
getJobVertexIds()
ResourceProfile
getResourceProfile()
SlotSharingGroupId
getSlotSharingGroupId()
void
removeVertexFromGroup(JobVertexID id)
void
setResourceProfile(ResourceProfile resourceProfile)
String
toString()
-
-
-
Method Detail
-
addVertexToGroup
public void addVertexToGroup(JobVertexID id)
-
removeVertexFromGroup
public void removeVertexFromGroup(JobVertexID id)
-
getJobVertexIds
public Set<JobVertexID> getJobVertexIds()
-
getSlotSharingGroupId
public SlotSharingGroupId getSlotSharingGroupId()
-
setResourceProfile
public void setResourceProfile(ResourceProfile resourceProfile)
-
getResourceProfile
public ResourceProfile getResourceProfile()
-
-