org.apache.reef.runtime.common.client.api

Class JobSubmissionEventImpl

java.lang.Object

org.apache.reef.runtime.common.client.api.JobSubmissionEventImpl

All Implemented Interfaces:

JobSubmissionEvent

public final class JobSubmissionEventImpl
extends Object
implements JobSubmissionEvent

Default POJO implementation of JobSubmissionEvent. Use newBuilder to construct an instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JobSubmissionEventImpl.Builder Builder used to create JobSubmissionEvent instances.

Method Summary

Methods

Modifier and Type	Method and Description
Configuration	getConfiguration()
Optional<Integer>	getDriverMemory()
Set<FileResource>	getGlobalFileSet()
String	getIdentifier()
Set<FileResource>	getLocalFileSet()
Optional<Integer>	getMaxApplicationSubmissions() Returns the number of time that the driver should be started by the resource manager if it fails unexpectedly.
Optional<Boolean>	getPreserveEvaluators()
Optional<Integer>	getPriority()
String	getRemoteId()
String	getUserName()
static JobSubmissionEventImpl.Builder	newBuilder()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface JobSubmissionEvent

Returns:

Id of the Job

getRemoteId

public String getRemoteId()

Specified by:

getRemoteId in interface JobSubmissionEvent

Returns:

Remote Id for the error handler

getConfiguration

public Configuration getConfiguration()

Specified by:

getConfiguration in interface JobSubmissionEvent

Returns:

Driver configuration

getUserName

public String getUserName()

Specified by:

getUserName in interface JobSubmissionEvent

Returns:

Owner's username

getGlobalFileSet

public Set<FileResource> getGlobalFileSet()

Specified by:

getGlobalFileSet in interface JobSubmissionEvent

Returns:

List of global files

getLocalFileSet

public Set<FileResource> getLocalFileSet()

Specified by:

getLocalFileSet in interface JobSubmissionEvent

Returns:

List of local files

getDriverMemory

public Optional<Integer> getDriverMemory()

Specified by:

getDriverMemory in interface JobSubmissionEvent

Returns:

Memory to be allocated to the Driver

getPriority

public Optional<Integer> getPriority()

Specified by:

getPriority in interface JobSubmissionEvent

Returns:

Priority to be given to the Job

getPreserveEvaluators

public Optional<Boolean> getPreserveEvaluators()

Specified by:

getPreserveEvaluators in interface JobSubmissionEvent

Returns:

True if evaluators are to be preserved across driver failures.

getMaxApplicationSubmissions

public Optional<Integer> getMaxApplicationSubmissions()

Description copied from interface: JobSubmissionEvent

Returns the number of time that the driver should be started by the resource manager if it fails unexpectedly.

Specified by:

getMaxApplicationSubmissions in interface JobSubmissionEvent

newBuilder

public static JobSubmissionEventImpl.Builder newBuilder()