org.apache.reef.runtime.hdinsight.client

Class HDInsightJobSubmissionHandler

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, JobSubmissionHandler, EventHandler<ClientRuntimeProtocol.JobSubmissionProto>

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()
void	onNext(ClientRuntimeProtocol.JobSubmissionProto jobSubmissionProto) 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

Specified by:

close in interface JobSubmissionHandler

onNext

public void onNext(ClientRuntimeProtocol.JobSubmissionProto jobSubmissionProto)

Description copied from interface: EventHandler

Handles an event

Specified by:

onNext in interface EventHandler<ClientRuntimeProtocol.JobSubmissionProto>

Parameters:

jobSubmissionProto - an event