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

Class ClientConnection

java.lang.Object

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

public final class ClientConnection
extends Object

Represents the communication channel to the client.

Constructor Summary

Constructors

Constructor and Description
ClientConnection(RemoteManager remoteManager, String clientRID, String jobIdentifier)

Method Summary

Methods

Modifier and Type	Method and Description
void	send(ReefServiceProtos.JobStatusProto status) Send the given JobStatus to the client.
void	sendMessage(byte[] message) Send the given byte[] as a message to the client.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientConnection

@Inject
public ClientConnection(RemoteManager remoteManager,
                       String clientRID,
                       String jobIdentifier)

Method Detail

send

public void send(ReefServiceProtos.JobStatusProto status)

Send the given JobStatus to the client.

Parameters:

status -

sendMessage

public void sendMessage(byte[] message)

Send the given byte[] as a message to the client.

Parameters:

message -