org.apache.reef.webserver

Class ReefEventStateManager

java.lang.Object

org.apache.reef.webserver.ReefEventStateManager

public final class ReefEventStateManager
extends Object

Reef Event Manager that manages Reef states

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ReefEventStateManager.ActiveContextStateHandler Receive notification that a new Context is available.
class	ReefEventStateManager.AllocatedEvaluatorStateHandler Receive notification that an Evaluator had been allocated
class	ReefEventStateManager.ClientMessageStateHandler Receive notification from the client.
class	ReefEventStateManager.DriverRestartTaskRunningStateHandler Receive event during driver restart that a task is running in previous evaluator
class	ReefEventStateManager.DrivrRestartActiveContextStateHandler Receive notification that a new Context is available.
class	ReefEventStateManager.StartStateHandler Job Driver is ready and the clock is set up
class	ReefEventStateManager.StopStateHandler Job driver stopped, log the stop time.
class	ReefEventStateManager.TaskRunningStateHandler Receive event when task is running

Constructor Summary

Constructors

Constructor and Description
ReefEventStateManager(RemoteManager remoteManager, DriverStatusManager driverStatusManager) ReefEventStateManager that keeps the states of Reef components

Method Summary

Methods

Modifier and Type	Method and Description
EvaluatorDescriptor	get(String key) get a value from evaluators by key
Map<String,ActiveContext>	getContexts() get a map of contexts
String	getDriverEndpointIdentifier() get driver endpoint identifier
EvaluatorDescriptor	getEvaluatorDescriptor(String evaluatorId) getEvaluatorDescriptor
NodeDescriptor	getEvaluatorNodeDescriptor(String evaluatorId) get Evaluator NodeDescriptor
Map<String,EvaluatorDescriptor>	getEvaluators() get evaluator map
List<AvroReefServiceInfo>	getServicesInfo()
String	getStartTime() get start time
String	getStopTime() get stop time
void	OnClientKill() Kill driver by calling onComplete() .
void	put(String key, EvaluatorDescriptor value) pus a entry to evaluators
void	registerServiceInfo(AvroReefServiceInfo serviceInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReefEventStateManager

@Inject
public ReefEventStateManager(RemoteManager remoteManager,
                            DriverStatusManager driverStatusManager)

ReefEventStateManager that keeps the states of Reef components

Method Detail

getStartTime

public String getStartTime()

get start time

Returns:

getStopTime

public String getStopTime()

get stop time

Returns:

getEvaluators

public Map<String,EvaluatorDescriptor> getEvaluators()

get evaluator map

Returns:

getDriverEndpointIdentifier

public String getDriverEndpointIdentifier()

get driver endpoint identifier

getServicesInfo

public List<AvroReefServiceInfo> getServicesInfo()

registerServiceInfo

public void registerServiceInfo(AvroReefServiceInfo serviceInfo)

getContexts

public Map<String,ActiveContext> getContexts()

get a map of contexts

Returns:

put

public void put(String key,
       EvaluatorDescriptor value)

pus a entry to evaluators

Parameters:

key -

value -

get

public EvaluatorDescriptor get(String key)

get a value from evaluators by key

Parameters:

key -

Returns:

getEvaluatorDescriptor

public EvaluatorDescriptor getEvaluatorDescriptor(String evaluatorId)

getEvaluatorDescriptor

Parameters:

evaluatorId -

Returns:

getEvaluatorNodeDescriptor

public NodeDescriptor getEvaluatorNodeDescriptor(String evaluatorId)

get Evaluator NodeDescriptor

Parameters:

evaluatorId -

Returns:

OnClientKill

public void OnClientKill()

Kill driver by calling onComplete() . This method is called when client wants to kill the driver and evaluators.