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>

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

Field Summary

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

instanceRepository

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

definitionKind

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	beforeDelete(StreamDefinition definition) Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.
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

deleteAll, deploy, deploymentInfo, deploymentInfo, undeploy, undeployAll

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

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

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)

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

beforeDelete

protected void beforeDelete(StreamDefinition definition)

Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.

Before deleting the stream, perform an undeploy. This causes a graceful shutdown of the modules in the stream before it is deleted from the repository.

Overrides:

beforeDelete in class AbstractInstancePersistingDeployer<StreamDefinition,Stream>