org.springframework.xd.dirt.stream

Class StreamDeployer

java.lang.Object

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

org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer<StreamDefinition,Stream>

org.springframework.xd.dirt.stream.StreamDeployer

All Implemented Interfaces:

ResourceDeployer<StreamDefinition>, DeploymentValidator

public class StreamDeployer
extends AbstractInstancePersistingDeployer<StreamDefinition,Stream>

Default implementation of StreamDeployer that uses provided StreamDefinitionRepository and StreamRepository to persist stream deployment and undeployment requests.

Author:

Mark Fisher, Gary Russell, Andy Clement, Eric Bottard, Gunnar Hillert, Patrick Peralta, Ilayaperumal Gopinathan

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

Constructor Summary

Constructors

Constructor and Description
StreamDeployer(ZooKeeperConnection zkConnection, StreamDefinitionRepository repository, StreamRepository streamRepository, XDParser parser, DeploymentHandler deploymentHandler) Construct a StreamDeployer.

Method Summary

Methods

Modifier and Type	Method and Description
protected StreamDefinition	createDefinition(java.lang.String name, java.lang.String definition)
protected java.lang.String	getDeploymentPath(StreamDefinition definition) Return the ZooKeeper path used for deployment requests for the given definition.
protected Stream	makeInstance(StreamDefinition 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

StreamDeployer

public StreamDeployer(ZooKeeperConnection zkConnection,
              StreamDefinitionRepository repository,
              StreamRepository streamRepository,
              XDParser parser,
              DeploymentHandler deploymentHandler)

Construct a StreamDeployer.

Parameters:

zkConnection - ZooKeeper connection

repository - repository for stream definitions

streamRepository - repository for stream instances

parser - stream definition parser

Method Detail

makeInstance

protected Stream makeInstance(StreamDefinition definition)

Create an running instance out of the given definition;

Specified by:

makeInstance in class AbstractInstancePersistingDeployer<StreamDefinition,Stream>

createDefinition

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

Specified by:

createDefinition in class AbstractDeployer<StreamDefinition>

getDeploymentPath

protected java.lang.String getDeploymentPath(StreamDefinition definition)

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

Specified by:

getDeploymentPath in class AbstractDeployer<StreamDefinition>

Parameters:

definition - definition for which to obtain path

Returns:

ZooKeeper path for deployment requests