org.apache.reef.runtime.hdinsight.client

Class HDInsightJobSubmissionHandler

java.lang.Object

org.apache.reef.runtime.hdinsight.client.HDInsightJobSubmissionHandler

All Implemented Interfaces:

AutoCloseable, JobSubmissionHandler, EventHandler<JobSubmissionEvent>

public final class HDInsightJobSubmissionHandler
extends Object
implements JobSubmissionHandler

Handles job submission to a HDInsight instance.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
String	getApplicationId() Get the RM application ID.
void	onNext(JobSubmissionEvent jobSubmissionEvent) 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 jobSubmissionEvent)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<JobSubmissionEvent>

Parameters:

jobSubmissionEvent - 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.