com.netflix.genie.common.internal.dto.v4

Class JobSpecification

java.lang.Object

com.netflix.genie.common.internal.dto.v4.JobSpecification

public class JobSpecification
extends java.lang.Object

This DTO represents all the information needed to execute a job by the Genie Agent.

Since:

4.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JobSpecification.ExecutionResource Common representation of resources used for job execution e.g.

Constructor Summary

Constructors

Constructor and Description

JobSpecification(java.util.List<java.lang.String> executableArgs, java.util.List<java.lang.String> jobArgs, JobSpecification.ExecutionResource job, JobSpecification.ExecutionResource cluster, JobSpecification.ExecutionResource command, java.util.List<JobSpecification.ExecutionResource> applications, java.util.Map<java.lang.String,java.lang.String> environmentVariables, boolean interactive, java.io.File jobDirectoryLocation, java.lang.String archiveLocation, java.lang.Integer timeout) Constructor.

Method Summary

Modifier and Type	Method and Description
java.util.List<JobSpecification.ExecutionResource>	getApplications() Returns an unmodifiable list of applications.
java.util.Optional<java.lang.String>	getArchiveLocation() Get the archive location for the job folder.
java.util.Map<java.lang.String,java.lang.String>	getEnvironmentVariables() Get the environment variables dictated by the server that should be set in the job execution environment.
java.util.List<java.lang.String>	getExecutableArgs() Returns an unmodifiable list of executable and arguments provided by the Command resolved to.
java.util.List<java.lang.String>	getJobArgs() Returns an unmodifiable list of arguments provided by the user for this job.
java.util.Optional<java.lang.Integer>	getTimeout() Get the job timeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobSpecification

public JobSpecification(@Nullable
                        java.util.List<java.lang.String> executableArgs,
                        @Nullable
                        java.util.List<java.lang.String> jobArgs,
                        JobSpecification.ExecutionResource job,
                        JobSpecification.ExecutionResource cluster,
                        JobSpecification.ExecutionResource command,
                        @Nullable
                        java.util.List<JobSpecification.ExecutionResource> applications,
                        @Nullable
                        java.util.Map<java.lang.String,java.lang.String> environmentVariables,
                        boolean interactive,
                        java.io.File jobDirectoryLocation,
                        @Nullable
                        java.lang.String archiveLocation,
                        @Nullable
                        java.lang.Integer timeout)

Constructor.

Parameters:

executableArgs - Executable and its fixed argument provided by the Command

jobArgs - Job arguments provided by the user for this job

job - The execution resources for a specific job

cluster - The execution resources for a specific cluster used for a job

command - The execution resources for a specific command used for a job

applications - The execution resources of all applications used for a job. Optional

environmentVariables - The environment variables the agent should set when running the job. Optional

interactive - Whether the job is interactive or not

jobDirectoryLocation - Location on disk where the job directory will be created

archiveLocation - Location where job folder is archived by the agent when job finishes. Optional

timeout - The number of seconds after a job starts that it should be killed due to timeout. Optional

Method Detail

getExecutableArgs

public java.util.List<java.lang.String> getExecutableArgs()

Returns an unmodifiable list of executable and arguments provided by the Command resolved to.

Returns:

A list of executable and arguments that will throw exception if modifications are attempted

getJobArgs

public java.util.List<java.lang.String> getJobArgs()

Returns an unmodifiable list of arguments provided by the user for this job.

Returns:

A list of arguments that will throw exception if modifications are attempted

getApplications

public java.util.List<JobSpecification.ExecutionResource> getApplications()

Returns an unmodifiable list of applications.

Returns:

A list of Applications that will throw exception if modifications are attempted

getEnvironmentVariables

public java.util.Map<java.lang.String,java.lang.String> getEnvironmentVariables()

Get the environment variables dictated by the server that should be set in the job execution environment.

Returns:

The variable name to value pairs that should be set in the execution environment of the job. This map will be immutable and any attempt to modify will result in an exception

getArchiveLocation

public java.util.Optional<java.lang.String> getArchiveLocation()

Get the archive location for the job folder.

Returns:

archive location for the job folder wrapped in an Optional

getTimeout

public java.util.Optional<java.lang.Integer> getTimeout()

Get the job timeout.

Returns:

The number of seconds after a job launch that this job should be killed by the agent due to timeout. Wrapped in Optional as it's not required. Optional.empty() means there is no timeout and the job can run indefinitely.