org.apache.reef.runtime.common.client

Class RunningJobImpl

java.lang.Object

org.apache.reef.runtime.common.client.RunningJobImpl

All Implemented Interfaces:

AutoCloseable, RunningJob, Identifiable, EventHandler<ReefServiceProtos.JobStatusProto>

public final class RunningJobImpl
extends Object
implements RunningJob, EventHandler<ReefServiceProtos.JobStatusProto>

Implementation of RunningJob.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Cancels the running Job.
void	close(byte[] message) Cancels the running Job.
String	getId() Returns an identifier of this object.
void	onNext(ReefServiceProtos.JobStatusProto value) Handles an event.
void	send(byte[] message) Send a message to the Driver.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

close

public void close()

Description copied from interface: RunningJob

Cancels the running Job.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RunningJob

close

public void close(byte[] message)

Description copied from interface: RunningJob

Cancels the running Job.

Specified by:

close in interface RunningJob

Parameters:

message - delivered along with cancel request.

getId

public String getId()

Description copied from interface: Identifiable

Returns an identifier of this object.

Specified by:

getId in interface RunningJob

Specified by:

getId in interface Identifiable

Returns:

the ID of the running job.

send

public void send(byte[] message)

Description copied from interface: RunningJob

Send a message to the Driver.

Specified by:

send in interface RunningJob

Parameters:

message - to send to the running driver

onNext

public void onNext(ReefServiceProtos.JobStatusProto value)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<ReefServiceProtos.JobStatusProto>

Parameters:

value - an event

toString

public String toString()

Overrides:

toString in class Object