org.apache.reef.runtime.local.client

Class LocalJobSubmissionHandler

java.lang.Object

org.apache.reef.runtime.local.client.LocalJobSubmissionHandler

All Implemented Interfaces:

AutoCloseable, JobSubmissionHandler, EventHandler<JobSubmissionEvent>

public final class LocalJobSubmissionHandler
extends Object
implements JobSubmissionHandler

Handles Job Submissions for the Local and the Standalone Runtime.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
String	getApplicationId() Get the RM application ID.
void	onNext(JobSubmissionEvent t) Handles an event.

Methods inherited from class java.lang.Object

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

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

onNext

public void onNext(JobSubmissionEvent t)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<JobSubmissionEvent>

Parameters:

t - an event

getApplicationId

public String getApplicationId()

Get the RM application ID. Return null if the application has not been submitted yet, or was submitted unsuccessfully.

Specified by:

getApplicationId in interface JobSubmissionHandler

Returns:

string application ID or null if no app has been submitted yet.