public class StreamDeployer extends AbstractInstancePersistingDeployer<StreamDefinition,Stream>
StreamDeployer that uses provided
StreamDefinitionRepository and StreamRepository to
persist stream deployment and undeployment requests.deploymentHandler, instanceRepositorydefinitionKind| Constructor and Description |
|---|
StreamDeployer(ZooKeeperConnection zkConnection,
StreamDefinitionRepository repository,
StreamRepository streamRepository,
XDParser parser,
DeploymentHandler deploymentHandler)
Construct a StreamDeployer.
|
| 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;
|
beforeDelete, deleteAll, deploy, deploymentInfo, deploymentInfo, deployResource, undeploy, undeployAll, undeployResource, validateBeforeDeploy, validateBeforeUndeployafterSave, basicDeploy, createModuleDefinitions, delete, findAll, findAll, findOne, getDefinitionRepository, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException, validateBeforeDelete, validateBeforeSavepublic StreamDeployer(ZooKeeperConnection zkConnection, StreamDefinitionRepository repository, StreamRepository streamRepository, XDParser parser, DeploymentHandler deploymentHandler)
zkConnection - ZooKeeper connectionrepository - repository for stream definitionsstreamRepository - repository for stream instancesparser - stream definition parserprotected Stream makeInstance(StreamDefinition definition)
makeInstance in class AbstractInstancePersistingDeployer<StreamDefinition,Stream>protected StreamDefinition createDefinition(java.lang.String name, java.lang.String definition)
createDefinition in class AbstractDeployer<StreamDefinition>protected java.lang.String getDeploymentPath(StreamDefinition definition)
getDeploymentPath in class AbstractDeployer<StreamDefinition>definition - definition for which to obtain path