public class DepartingContainerModuleRedeployer extends ModuleRedeployer
ModuleRedeployer that re-deploys the stream/job modules that were
deployed into the departing container.ModuleRedeployer.ModuleDeployment| Modifier and Type | Field and Description |
|---|---|
protected org.slf4j.Logger |
logger
Logger.
|
jobFactory, moduleDeploymentRequests, streamFactory| Constructor and Description |
|---|
DepartingContainerModuleRedeployer(ZooKeeperConnection zkConnection,
ContainerRepository containerRepository,
StreamFactory streamFactory,
JobFactory jobFactory,
org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests,
ContainerMatcher containerMatcher,
DeploymentUnitStateCalculator stateCalculator)
Constructs
DepartingContainerModuleRedeployer |
| Modifier and Type | Method and Description |
|---|---|
protected void |
deployModules(Container container)
Handle the departure of a container.
|
getAllModuleDeploymentRequests, getClient, instantiateContainerMatcher, logUnwantedRedeployment, redeployModule, updateDeploymentUnitStatepublic DepartingContainerModuleRedeployer(ZooKeeperConnection zkConnection, ContainerRepository containerRepository, StreamFactory streamFactory, JobFactory jobFactory, org.apache.curator.framework.recipes.cache.PathChildrenCache moduleDeploymentRequests, ContainerMatcher containerMatcher, DeploymentUnitStateCalculator stateCalculator)
DepartingContainerModuleRedeployerzkConnection - ZooKeeper connectioncontainerRepository - the repository to find the containersstreamFactory - factory to construct StreamjobFactory - factory to construct JobmoduleDeploymentRequests - cache of children for requested module deployments pathcontainerMatcher - matches modules to containersstateCalculator - calculator for stream/job stateprotected void deployModules(Container container) throws java.lang.Exception
deployModules in class ModuleRedeployercontainer - the container that departedjava.lang.Exception