org.springframework.xd.dirt.server

Class ArrivingContainerModuleRedeployer

java.lang.Object

org.springframework.xd.dirt.server.ModuleRedeployer

org.springframework.xd.dirt.server.ArrivingContainerModuleRedeployer

public class ArrivingContainerModuleRedeployer
extends ModuleRedeployer

The ModuleRedeployer that deploys the unallocated stream/job modules upon a new container arrival.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.xd.dirt.server.ModuleRedeployer

ModuleRedeployer.ModuleDeployment

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.curator.framework.recipes.cache.PathChildrenCache	jobDeployments Cache of children under the job deployment path.
protected org.slf4j.Logger	logger Logger.

Fields inherited from class org.springframework.xd.dirt.server.ModuleRedeployer

jobFactory, moduleDeploymentRequests, streamFactory

Constructor Summary

Constructors

Constructor and Description

ArrivingContainerModuleRedeployer(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, StreamFactory streamFactory, JobFactory jobFactory, org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments, org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator) Constructs ArrivingContainerModuleRedeployer

Method Summary

Methods

Modifier and Type	Method and Description
protected void	deployModules(Container container) Handle the arrival of a container.

Methods inherited from class org.springframework.xd.dirt.server.ModuleRedeployer

getAllModuleDeploymentRequests, getClient, instantiateContainerMatcher, logUnwantedRedeployment, redeployModule, updateDeploymentUnitState

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

Logger.

jobDeployments

protected final org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments

Cache of children under the job deployment path.

Constructor Detail

ArrivingContainerModuleRedeployer

public ArrivingContainerModuleRedeployer(ZooKeeperConnection zkConnection,
                                 ContainerRepository containerRepository,
                                 StreamFactory streamFactory,
                                 JobFactory jobFactory,
                                 org.apache.curator.framework.recipes.cache.PathChildrenCache streamDeployments,
                                 org.apache.curator.framework.recipes.cache.PathChildrenCache jobDeployments,
                                 org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
                                 ContainerMatcher containerMatcher,
                                 DeploymentUnitStateCalculator stateCalculator)

Constructs ArrivingContainerModuleRedeployer

Parameters:

zkConnection - ZooKeeper connection

containerRepository - the repository to find the containers

streamFactory - factory to construct Stream

jobFactory - factory to construct Job

streamDeployments - cache of children for stream deployments path

jobDeployments - cache of children for job deployments path

moduleDeploymentRequests - cache of children for requested module deployments path

containerMatcher - matches modules to containers

stateCalculator - calculator for stream/job state

Method Detail

deployModules

protected void deployModules(Container container)
                      throws java.lang.Exception

Handle the arrival of a container. This implementation will scan the existing streams/jobs and determine if any modules should be deployed to the new container.

Specified by:

deployModules in class ModuleRedeployer

Parameters:

container - the arriving container

Throws:

java.lang.Exception