com.netflix.genie.core.services.impl

Class LocalJobRunner

java.lang.Object

com.netflix.genie.core.services.impl.LocalJobRunner

All Implemented Interfaces:

JobSubmitterService

public class LocalJobRunner
extends java.lang.Object
implements JobSubmitterService

Implementation of the Job Submitter service that runs the job locally on the same host.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
LocalJobRunner(JobPersistenceService jobPersistenceService, org.springframework.context.ApplicationEventPublisher eventPublisher, org.springframework.context.event.ApplicationEventMulticaster eventMulticaster, java.util.List<WorkflowTask> workflowTasks, org.springframework.core.io.Resource genieWorkingDir, com.netflix.spectator.api.Registry registry) Constructor create the object.

Method Summary

Modifier and Type	Method and Description
void	submitJob(JobRequest jobRequest, Cluster cluster, Command command, java.util.List<Application> applications, int memory) Submit the job for appropriate execution based on environment.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalJobRunner

public LocalJobRunner(@NotNull
                      JobPersistenceService jobPersistenceService,
                      @NotNull
                      org.springframework.context.ApplicationEventPublisher eventPublisher,
                      @NotNull
                      org.springframework.context.event.ApplicationEventMulticaster eventMulticaster,
                      @NotNull
                      java.util.List<WorkflowTask> workflowTasks,
                      @NotNull
                      org.springframework.core.io.Resource genieWorkingDir,
                      @NotNull
                      com.netflix.spectator.api.Registry registry)

Constructor create the object.

Parameters:

jobPersistenceService - Implementation of the job persistence service

eventPublisher - The synchronous event publisher to use

eventMulticaster - Instance of the asynchronous event publisher to use

workflowTasks - List of all the workflow tasks to be executed

genieWorkingDir - Working directory for genie where it creates jobs directories

registry - The metrics registry to use

Method Detail

submitJob

public void submitJob(@NotNull(message="No job provided. Unable to submit job for execution.")
                      JobRequest jobRequest,
                      @NotNull(message="No cluster provided. Unable to submit job for execution")
                      Cluster cluster,
                      @NotNull(message="No command provided. Unable to submit job for execution")
                      Command command,
                      @NotNull(message="No applications provided. Unable to submit job for execution")
                      java.util.List<Application> applications,
                      @Min(value=1L,message="Memory can\'t be less than 1 MB")
                      int memory)
               throws GenieException

Submit the job for appropriate execution based on environment.

Specified by:

submitJob in interface JobSubmitterService

Parameters:

jobRequest - of job to run

cluster - The cluster this job should run on

command - the command to run this job with

applications - Any applications that are needed to run the command

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

Throws:

GenieException - if there is an error