public class JobDeployer extends AbstractInstancePersistingDeployer<JobDefinition,Job> implements org.springframework.beans.factory.DisposableBean
deploymentHandler, instanceRepository
composedJobParser, definitionKind, parser
コンストラクターと説明 |
---|
JobDeployer(ZooKeeperConnection zkConnection, JobDefinitionRepository definitionRepository, JobRepository instanceRepository, XDParser parser, MessageBus messageBus, DeploymentHandler deploymentHandler) |
修飾子と型 | メソッドと説明 |
---|---|
protected JobDefinition | createDefinition(java.lang.String name, java.lang.String definition) |
void | destroy() |
protected java.lang.String | getDeploymentPath(JobDefinition definition) 指定された定義の デプロイリクエストに使用される ZooKeeper パスを返します。 |
void | launch(java.lang.String name, java.lang.String jobParameters) |
protected Job | makeInstance(JobDefinition definition) 指定された定義から実行インスタンスを作成します。 |
beforeDelete, deleteAll, deploy, deploymentInfo, deploymentInfo, deployResource, undeploy, undeployAll, undeployResource, validateBeforeDeploy, validateBeforeUndeploy
afterSave, basicDeploy, createModuleDefinitions, delete, findAll, findAll, findOne, getDefinitionRepository, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException, validateBeforeDelete, validateBeforeSave
public JobDeployer(ZooKeeperConnection zkConnection, JobDefinitionRepository definitionRepository, JobRepository instanceRepository, XDParser parser, MessageBus messageBus, DeploymentHandler deploymentHandler)
protected Job makeInstance(JobDefinition definition)
AbstractInstancePersistingDeployer
AbstractInstancePersistingDeployer<JobDefinition, Job>
の makeInstance
public void launch(java.lang.String name, java.lang.String jobParameters)
protected JobDefinition createDefinition(java.lang.String name, java.lang.String definition)
AbstractDeployer<JobDefinition>
の createDefinition
protected java.lang.String getDeploymentPath(JobDefinition definition)
AbstractDeployer
AbstractDeployer<JobDefinition>
の getDeploymentPath
definition
- パスを取得する定義 public void destroy() throws java.lang.Exception
org.springframework.beans.factory.DisposableBean
の destroy
java.lang.Exception