org.springframework.xd.dirt.stream

Class JobDeployer

java.lang.Object

org.springframework.xd.dirt.stream.AbstractDeployer<D>

org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer<JobDefinition,Job>

org.springframework.xd.dirt.stream.JobDeployer

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, ResourceDeployer<JobDefinition>, DeploymentValidator

public class JobDeployer
extends AbstractInstancePersistingDeployer<JobDefinition,Job>
implements org.springframework.beans.factory.DisposableBean

Author:

Glenn Renfro, Luke Taylor, Ilayaperumal Gopinathan, Gunnar Hillert

Field Summary

Fields inherited from class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

deploymentHandler, instanceRepository

Fields inherited from class org.springframework.xd.dirt.stream.AbstractDeployer

composedJobParser, definitionKind, parser

Constructor Summary

Constructors

Constructor and Description
JobDeployer(ZooKeeperConnection zkConnection, JobDefinitionRepository definitionRepository, JobRepository instanceRepository, XDParser parser, MessageBus messageBus, DeploymentHandler deploymentHandler)

Method Summary

Methods

Modifier and Type	Method and Description
protected JobDefinition	createDefinition(java.lang.String name, java.lang.String definition)
void	destroy()
protected java.lang.String	getDeploymentPath(JobDefinition definition) Return the ZooKeeper path used for deployment requests for the given definition.
void	launch(java.lang.String name, java.lang.String jobParameters)
protected Job	makeInstance(JobDefinition definition) Create an running instance out of the given definition;

Methods inherited from class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

beforeDelete, deleteAll, deploy, deploymentInfo, deploymentInfo, deployResource, undeploy, undeployAll, undeployResource, validateBeforeDeploy, validateBeforeUndeploy

Methods inherited from class org.springframework.xd.dirt.stream.AbstractDeployer

afterSave, basicDeploy, createModuleDefinitions, delete, findAll, findAll, findOne, getDefinitionRepository, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException, validateBeforeDelete, validateBeforeSave

Methods inherited from class java.lang.Object

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

Constructor Detail

JobDeployer

public JobDeployer(ZooKeeperConnection zkConnection,
           JobDefinitionRepository definitionRepository,
           JobRepository instanceRepository,
           XDParser parser,
           MessageBus messageBus,
           DeploymentHandler deploymentHandler)

Method Detail

makeInstance

protected Job makeInstance(JobDefinition definition)

Description copied from class: AbstractInstancePersistingDeployer

Create an running instance out of the given definition;

Specified by:

makeInstance in class AbstractInstancePersistingDeployer<JobDefinition,Job>

launch

public void launch(java.lang.String name,
          java.lang.String jobParameters)

createDefinition

protected JobDefinition createDefinition(java.lang.String name,
                             java.lang.String definition)

Specified by:

createDefinition in class AbstractDeployer<JobDefinition>

getDeploymentPath

protected java.lang.String getDeploymentPath(JobDefinition definition)

Description copied from class: AbstractDeployer

Return the ZooKeeper path used for deployment requests for the given definition.

Specified by:

getDeploymentPath in class AbstractDeployer<JobDefinition>

Parameters:

definition - definition for which to obtain path

Returns:

ZooKeeper path for deployment requests

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

java.lang.Exception