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.DriverRestartActiveContextStateHandler Receive notification that a new Context is available.
class	ReefEventStateManager.DriverRestartHandler Job Driver has been restarted.
class	ReefEventStateManager.DriverRestartTaskRunningStateHandler Receive event during driver restart that a task is running in previous evaluator.
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.