org.apache.reef.client

Interface RunningJob

All Superinterfaces:

AutoCloseable, Identifiable

All Known Implementing Classes:

RunningJobImpl

@DefaultImplementation(value=RunningJobImpl.class)
public interface RunningJob
extends Identifiable, AutoCloseable

Represents a running REEF job.

Method Summary

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	send(byte[] message) Send a message to the Driver.

Method Detail

close

void close()

Cancels the running Job.

Specified by:

close in interface AutoCloseable

close

void close(byte[] message)

Cancels the running Job.

Parameters:

message - delivered along with cancel request.

getId

String getId()

Description copied from interface: Identifiable

Returns an identifier of this object.

Specified by:

getId in interface Identifiable

Returns:

the ID of the running job.

send

void send(byte[] message)

Send a message to the Driver.

Parameters:

message - to send to the running driver