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

Interface JobSubmissionEvent

All Known Implementing Classes:

JobSubmissionEventImpl

@DefaultImplementation(value=JobSubmissionEventImpl.class)
public interface JobSubmissionEvent

Event sent to Driver Runtime. Submission of a Job to the Driver Runtime

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()

Method Detail

getIdentifier

String getIdentifier()

Returns:

Id of the Job

getRemoteId

String getRemoteId()

Returns:

Remote Id for the error handler

getConfiguration

Configuration getConfiguration()

Returns:

Driver configuration

getUserName

String getUserName()

Returns:

Owner's username

getGlobalFileSet

Set<FileResource> getGlobalFileSet()

Returns:

List of global files

getLocalFileSet

Set<FileResource> getLocalFileSet()

Returns:

List of local files

getDriverMemory

Optional<Integer> getDriverMemory()

Returns:

Memory to be allocated to the Driver

getPriority

Optional<Integer> getPriority()

Returns:

Priority to be given to the Job

getPreserveEvaluators

Optional<Boolean> getPreserveEvaluators()

Returns:

True if evaluators are to be preserved across driver failures.

getMaxApplicationSubmissions

Optional<Integer> getMaxApplicationSubmissions()

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