Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.jobmanager.scheduler |
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 |
---|---|
void |
JobVertex.setSlotSharingGroup(SlotSharingGroup grp)
Associates this vertex with a slot sharing group for scheduling.
|
Modifier and Type | Method and Description |
---|---|
SlotSharingGroup |
ScheduledUnit.getSlotSharingGroup() |
Constructor and Description |
---|
ScheduledUnit(Execution task,
SlotSharingGroup sharingUnit) |
ScheduledUnit(Execution task,
SlotSharingGroup sharingUnit,
CoLocationConstraint locationConstraint) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.