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	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)
void	removeInstanceListener(InstanceListener listener)
boolean	reportHeartBeat(InstanceID instanceId, byte[] lastMetricsReport)
void	shutdown()
void	unregisterTaskManager(akka.actor.ActorRef taskManager)

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)

unregisterTaskManager

public void unregisterTaskManager(akka.actor.ActorRef taskManager)

isRegistered

public boolean isRegistered(akka.actor.ActorRef taskManager)

getNumberOfRegisteredTaskManagers

public int getNumberOfRegisteredTaskManagers()

getTotalNumberOfSlots

public int getTotalNumberOfSlots()

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)