org.apache.flink.runtime.instance

Class InstanceManager

java.lang.Object

org.apache.flink.runtime.instance.InstanceManager

public class InstanceManager
extends Object

Simple manager that keeps track of which TaskManager are available and alive.

Constructor Summary

Constructors

Constructor and Description
InstanceManager() Creates an new instance manager.

Method Summary

Modifier and Type	Method and Description
void	addInstanceListener(InstanceListener listener)
Collection<Instance>	getAllRegisteredInstances()
int	getNumberOfAvailableSlots()
int	getNumberOfRegisteredTaskManagers()
Instance	getRegisteredInstance(akka.actor.ActorRef ref)
Instance	getRegisteredInstanceById(InstanceID instanceID)
int	getTotalNumberOfSlots()
boolean	isRegistered(akka.actor.ActorRef taskManager)
InstanceID	registerTaskManager(akka.actor.ActorRef taskManager, InstanceConnectionInfo connectionInfo, HardwareDescription resources, int numberOfSlots, UUID leaderSessionID) Registers a task manager.
void	removeInstanceListener(InstanceListener listener)
boolean	reportHeartBeat(InstanceID instanceId, byte[] lastMetricsReport)
void	shutdown()
void	unregisterAllTaskManagers() Unregisters all currently registered TaskManagers from the InstanceManager.
void	unregisterTaskManager(akka.actor.ActorRef taskManager, boolean terminated) Unregisters the TaskManager with the given ActorRef.

Methods inherited from class java.lang.Object

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

Constructor Detail

InstanceManager

public InstanceManager()

Creates an new instance manager.

Method Detail

shutdown

public void shutdown()

reportHeartBeat

public boolean reportHeartBeat(InstanceID instanceId,
                               byte[] lastMetricsReport)

registerTaskManager

public InstanceID registerTaskManager(akka.actor.ActorRef taskManager,
                                      InstanceConnectionInfo connectionInfo,
                                      HardwareDescription resources,
                                      int numberOfSlots,
                                      UUID leaderSessionID)

Registers a task manager. Registration of a task manager makes it available to be used for the job execution.

Parameters:

taskManager - ActorRef to the TaskManager which wants to be registered

connectionInfo - ConnectionInfo of the TaskManager

resources - Hardware description of the TaskManager

numberOfSlots - Number of available slots on the TaskManager

leaderSessionID - The current leader session ID of the JobManager

Returns:

unregisterTaskManager

public void unregisterTaskManager(akka.actor.ActorRef taskManager,
                                  boolean terminated)

Unregisters the TaskManager with the given ActorRef. Unregistering means to mark the given instance as dead and notify InstanceListener about the dead instance.

Parameters:

taskManager - TaskManager which is about to be marked dead.

unregisterAllTaskManagers

public void unregisterAllTaskManagers()

Unregisters all currently registered TaskManagers from the InstanceManager.

isRegistered

public boolean isRegistered(akka.actor.ActorRef taskManager)

getNumberOfRegisteredTaskManagers

public int getNumberOfRegisteredTaskManagers()

getTotalNumberOfSlots

public int getTotalNumberOfSlots()

getNumberOfAvailableSlots

public int getNumberOfAvailableSlots()

getAllRegisteredInstances

public Collection<Instance> getAllRegisteredInstances()

getRegisteredInstanceById

public Instance getRegisteredInstanceById(InstanceID instanceID)

getRegisteredInstance

public Instance getRegisteredInstance(akka.actor.ActorRef ref)

addInstanceListener

public void addInstanceListener(InstanceListener listener)

removeInstanceListener

public void removeInstanceListener(InstanceListener listener)