Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
Locality |
SimpleSlot.getLocality()
Gets the locality information attached to this slot.
|
Modifier and Type | Method and Description |
---|---|
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
CoLocationConstraint constraint) |
SimpleSlot |
SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot(SharedSlot sharedSlot,
Locality locality,
JobVertexID groupId) |
void |
SimpleSlot.setLocality(Locality locality)
Attached locality information to this slot.
|
Modifier and Type | Method and Description |
---|---|
static Locality |
Locality.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Locality[] |
Locality.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.