com.netflix.genie.web.services.impl

Class JobResolverServiceImpl

java.lang.Object

com.netflix.genie.web.services.impl.JobResolverServiceImpl

All Implemented Interfaces:

JobResolverService

@Validated
public class JobResolverServiceImpl
extends java.lang.Object
implements JobResolverService

Implementation of the JobResolverService APIs.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description

JobResolverServiceImpl(ApplicationPersistenceService applicationPersistenceService, ClusterPersistenceService clusterPersistenceService, CommandPersistenceService commandPersistenceService, JobPersistenceService jobPersistenceService, @NotEmpty java.util.List<ClusterLoadBalancer> clusterLoadBalancerImpls, io.micrometer.core.instrument.MeterRegistry registry, JobsProperties jobsProperties) Constructor.

Method Summary

Modifier and Type	Method and Description
ResolvedJob	resolveJob(java.lang.String id) Given the id of a job that was successfully submitted to the system this API will attempt to resolve all the concrete details (cluster, command, resources, etc) needed for the system to actually launch the job.
ResolvedJob	resolveJob(java.lang.String id, @Valid JobRequest jobRequest, boolean apiJob) Given a job request resolve all the details needed to run a job.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobResolverServiceImpl

public JobResolverServiceImpl(ApplicationPersistenceService applicationPersistenceService,
                              ClusterPersistenceService clusterPersistenceService,
                              CommandPersistenceService commandPersistenceService,
                              JobPersistenceService jobPersistenceService,
                              @NotEmpty
                              @NotEmpty java.util.List<ClusterLoadBalancer> clusterLoadBalancerImpls,
                              io.micrometer.core.instrument.MeterRegistry registry,
                              JobsProperties jobsProperties)

Constructor.

Parameters:

applicationPersistenceService - The ApplicationPersistenceService to use to manipulate applications

clusterPersistenceService - The ClusterPersistenceService to use to manipulate clusters

commandPersistenceService - The CommandPersistenceService to use to manipulate commands

jobPersistenceService - The JobPersistenceService instance to use

clusterLoadBalancerImpls - The ClusterLoadBalancer implementations to use

registry - The MeterRegistrymetrics repository to use

jobsProperties - The properties for running a job set by the user

Method Detail

resolveJob

@Nonnull
 @Transactional
public ResolvedJob resolveJob(java.lang.String id)
                                                throws GenieJobResolutionException

Given the id of a job that was successfully submitted to the system this API will attempt to resolve all the concrete details (cluster, command, resources, etc) needed for the system to actually launch the job. Once these details are determined they are persisted and the job is marked as JobStatus.RESOLVED.

Specified by:

resolveJob in interface JobResolverService

Parameters:

id - The id of the job to resolve. The job must exist and its status must return true from JobStatus#isResolvable()

Returns:

A ResolvedJob instance containing all the concrete information needed to execute the job

Throws:

GenieJobResolutionException - When there is an issue resolving the job based on the information provided by the user in conjunction with the configuration available in the system

resolveJob

@Nonnull
public ResolvedJob resolveJob(java.lang.String id,
                                       @Valid
                                       @Valid JobRequest jobRequest,
                                       boolean apiJob)
                                throws GenieJobResolutionException

Given a job request resolve all the details needed to run a job. This API is stateless and saves nothing.

Specified by:

resolveJob in interface JobResolverService

Parameters:

id - The id of the job

jobRequest - The job request containing all details a user wants to have for their job

apiJob - true if this job was submitted via the REST API. false otherwise.

Returns:

The completely resolved job information within a ResolvedJob instance

Throws:

GenieJobResolutionException - When there is an issue resolving the job based on the information provided by the user in conjunction with the configuration available in the system