public class StreamDeployer extends AbstractInstancePersistingDeployer<StreamDefinition,Stream>
StreamDefinitionRepository と StreamRepository を使用してストリームデプロイとアンデプロイメントリクエストを永続化する StreamDeployer のデフォルト実装。deploymentHandler, instanceRepositorycomposedJobParser, definitionKind| コンストラクターと説明 |
|---|
StreamDeployer(ZooKeeperConnection zkConnection, StreamDefinitionRepository repository, StreamRepository streamRepository, XDParser parser, DeploymentHandler deploymentHandler)StreamDeployer を作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected StreamDefinition | createDefinition(java.lang.String name, java.lang.String definition) |
protected java.lang.String | getDeploymentPath(StreamDefinition definition) 指定された定義の デプロイリクエストに使用される ZooKeeper パスを返します。 |
protected Stream | makeInstance(StreamDefinition 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 接続 repository - ストリーム定義のリポジトリ streamRepository - ストリームインスタンスのリポジトリ parser - ストリーム定義パーサー protected Stream makeInstance(StreamDefinition definition)
AbstractInstancePersistingDeployer<StreamDefinition, Stream> の makeInstance protected StreamDefinition createDefinition(java.lang.String name, java.lang.String definition)
AbstractDeployer<StreamDefinition> の createDefinition protected java.lang.String getDeploymentPath(StreamDefinition definition)
AbstractDeployer<StreamDefinition> の getDeploymentPath definition - パスを取得する定義