com.netflix.genie.core.jobs

Class JobLauncher

java.lang.Object

com.netflix.genie.core.jobs.JobLauncher

All Implemented Interfaces:

java.lang.Runnable

public class JobLauncher
extends java.lang.Object
implements java.lang.Runnable

Class to wrap launching a job in an asynchronous thread from the HTTP request thread to free up the system to respond to the user.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
JobLauncher(JobSubmitterService jobSubmitterService, JobRequest jobRequest, Cluster cluster, Command command, java.util.List<Application> applications, int memory, com.netflix.spectator.api.Registry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
void	run() Starts the job setup and launch process once the thread is activated.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobLauncher

public JobLauncher(@NotNull
                   JobSubmitterService jobSubmitterService,
                   @NotNull
                   JobRequest jobRequest,
                   @NotNull
                   Cluster cluster,
                   @NotNull
                   Command command,
                   @NotNull
                   java.util.List<Application> applications,
                   @Min(value=1L)
                   int memory,
                   @NotNull
                   com.netflix.spectator.api.Registry registry)

Constructor.

Parameters:

jobSubmitterService - The job submission service to use

jobRequest - The job request to be submitted

cluster - The cluster to use for the job

command - The command to use for the job

applications - The applications to use for the job (if any)

memory - The amount of memory (in MB) to use to run the job

registry - The registry to use for metrics

Method Detail

run

public void run()

Starts the job setup and launch process once the thread is activated.

Specified by:

run in interface java.lang.Runnable