Modifier and Type | Method and Description |
---|---|
SlotSharingGroup |
ExecutionJobVertex.getSlotSharingGroup() |
Modifier and Type | Method and Description |
---|---|
SlotSharingGroup |
JobVertex.getSlotSharingGroup()
Gets the slot sharing group that this vertex is associated with.
|
Modifier and Type | Method and Description |
---|---|
Set<SlotSharingGroup> |
JobGraph.getSlotSharingGroups() |
Modifier and Type | Method and Description |
---|---|
void |
JobVertex.setSlotSharingGroup(SlotSharingGroup grp)
Associates this vertex with a slot sharing group for scheduling.
|
Modifier and Type | Method and Description |
---|---|
static void |
SsgNetworkMemoryCalculationUtils.enrichNetworkMemory(SlotSharingGroup ssg,
java.util.function.Function<JobVertexID,ExecutionJobVertex> ejvs,
ShuffleMaster<?> shuffleMaster)
Calculates network memory requirement of
ExecutionJobVertex and update ResourceProfile of corresponding slot sharing group. |
Modifier and Type | Method and Description |
---|---|
Collection<SlotSharingGroup> |
JobGraphJobInformation.getSlotSharingGroups() |
Modifier and Type | Method and Description |
---|---|
SlotSharingGroup |
JobInformation.VertexInformation.getSlotSharingGroup() |
Modifier and Type | Method and Description |
---|---|
Collection<SlotSharingGroup> |
JobInformation.getSlotSharingGroups()
Returns all slot-sharing groups of the job.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.