com.netflix.genie.web.jobs

Class JobLauncher

java.lang.Object

com.netflix.genie.web.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(@NotNull JobSubmitterService jobSubmitterService, @NotNull JobRequest jobRequest, @NotNull Cluster cluster, @NotNull Command command, @NotNull java.util.List<Application> applications, @Min(value=1L) int memory, @NotNull io.micrometer.core.instrument.MeterRegistry 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
                   @NotNull JobSubmitterService jobSubmitterService,
                   @NotNull
                   @NotNull JobRequest jobRequest,
                   @NotNull
                   @NotNull Cluster cluster,
                   @NotNull
                   @NotNull Command command,
                   @NotNull
                   @NotNull java.util.List<Application> applications,
                   @Min(value=1L)
                   @Min(value=1L) int memory,
                   @NotNull
                   @NotNull io.micrometer.core.instrument.MeterRegistry 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