org.apache.reef.runtime.common.driver.client

Class ClientManager

java.lang.Object

org.apache.reef.runtime.common.driver.client.ClientManager

All Implemented Interfaces:

EventHandler<ClientRuntimeProtocol.JobControlProto>

public final class ClientManager
extends Object
implements EventHandler<ClientRuntimeProtocol.JobControlProto>

Represents the Client in the Driver.

Method Summary

Methods

Modifier and Type	Method and Description
void	onNext(ClientRuntimeProtocol.JobControlProto jobControlProto) This method reacts to control messages passed by the client to the driver.

Methods inherited from class java.lang.Object

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

Method Detail

onNext

public void onNext(ClientRuntimeProtocol.JobControlProto jobControlProto)

This method reacts to control messages passed by the client to the driver. It will forward messages related to the ClientObserver interface to the Driver. It will also initiate a shutdown if the client indicates a close message.

Specified by:

onNext in interface EventHandler<ClientRuntimeProtocol.JobControlProto>

Parameters:

jobControlProto - contains the client initiated control message