Uses of Class
org.apache.flink.runtime.instance.Instance

Packages that use Instance

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.instance
org.apache.flink.runtime.jobmanager.scheduler

Uses of Instance in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type Instance

Modifier and Type	Method and Description
Iterable<Instance>	ExecutionVertex.getPreferredLocations() Gets the location preferences of this task, determined by the locations of the predecessors from which it receives input data.

Method parameters in org.apache.flink.runtime.executiongraph with type arguments of type Instance

Modifier and Type	Method and Description
void	ExecutionVertex.setLocationConstraintHosts(List<Instance> instances)

Uses of Instance in org.apache.flink.runtime.instance

Methods in org.apache.flink.runtime.instance that return Instance

Modifier and Type	Method and Description
Instance	Slot.getInstance()
Instance	InstanceDiedException.getInstance()
Instance	InstanceManager.getRegisteredInstance(akka.actor.ActorRef ref)
Instance	InstanceManager.getRegisteredInstanceById(InstanceID instanceID)

Methods in org.apache.flink.runtime.instance that return types with arguments of type Instance

Modifier and Type	Method and Description
Collection<Instance>	InstanceManager.getAllRegisteredInstances()

Methods in org.apache.flink.runtime.instance with parameters of type Instance

Modifier and Type	Method and Description
void	InstanceListener.instanceDied(Instance instance) Called when an instance died.
void	InstanceListener.newInstanceAvailable(Instance instance) Called when a new instance becomes available.

Constructors in org.apache.flink.runtime.instance with parameters of type Instance

Constructor and Description
InstanceDiedException(Instance instance)
SharedSlot(JobID jobID, Instance instance, int slotNumber, SlotSharingGroupAssignment assignmentGroup, SharedSlot parent, AbstractID groupID)
SimpleSlot(JobID jobID, Instance instance, int slotNumber, SharedSlot parent, AbstractID groupID)
Slot(JobID jobID, Instance instance, int slotNumber, SharedSlot parent, AbstractID groupID)

Uses of Instance in org.apache.flink.runtime.jobmanager.scheduler

Methods in org.apache.flink.runtime.jobmanager.scheduler that return Instance

Modifier and Type	Method and Description
Instance	CoLocationConstraint.getLocation()

Methods in org.apache.flink.runtime.jobmanager.scheduler that return types with arguments of type Instance

Modifier and Type	Method and Description
Map<String,List<Instance>>	Scheduler.getInstancesByHost()

Methods in org.apache.flink.runtime.jobmanager.scheduler with parameters of type Instance

Modifier and Type	Method and Description
void	Scheduler.instanceDied(Instance instance)
void	Scheduler.newInstanceAvailable(Instance instance)
void	SlotAvailabilityListener.newSlotAvailable(Instance instance)
void	Scheduler.newSlotAvailable(Instance instance)

Method parameters in org.apache.flink.runtime.jobmanager.scheduler with type arguments of type Instance

Modifier and Type	Method and Description
protected SimpleSlot	Scheduler.getFreeSlotForTask(ExecutionVertex vertex, Iterable<Instance> requestedLocations, boolean localOnly) Gets a suitable instance to schedule the vertex execution to.
protected SimpleSlot	Scheduler.getFreeSubSlotForTask(ExecutionVertex vertex, Iterable<Instance> requestedLocations, SlotSharingGroupAssignment groupAssignment, CoLocationConstraint constraint, boolean localOnly)