org.apache.flink.runtime.jobmanager.scheduler

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 and Description
SlotSharingGroup()

Method Summary

Modifier and Type	Method and Description
void	addVertexToGroup(JobVertexID id, ResourceSpec resource)
Set<JobVertexID>	getJobVertexIds()
ResourceSpec	getResourceSpec()
SlotSharingGroupId	getSlotSharingGroupId()
void	removeVertexFromGroup(JobVertexID id, ResourceSpec resource)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SlotSharingGroup

public SlotSharingGroup()

Method Detail

addVertexToGroup

public void addVertexToGroup(JobVertexID id,
                             ResourceSpec resource)

removeVertexFromGroup

public void removeVertexFromGroup(JobVertexID id,
                                  ResourceSpec resource)

getJobVertexIds

public Set<JobVertexID> getJobVertexIds()

getSlotSharingGroupId

public SlotSharingGroupId getSlotSharingGroupId()

getResourceSpec

public ResourceSpec getResourceSpec()

toString

public String toString()

Overrides:

toString in class Object