public class StreamDeployer extends AbstractInstancePersistingDeployer<StreamDefinition,Stream>
StreamDefinitionRepository
と StreamRepository
を使用してストリームデプロイとアンデプロイメントリクエストを永続化する StreamDeployer
のデフォルト実装。deploymentHandler, instanceRepository
composedJobParser, 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, validateBeforeUndeploy
afterSave, basicDeploy, createModuleDefinitions, delete, findAll, findAll, findOne, getDefinitionRepository, getZooKeeperConnection, save, throwAlreadyDeployedException, throwDefinitionAlreadyExistsException, throwDefinitionNotDeployable, throwNoSuchDefinitionException, throwNoSuchDefinitionException, throwNotDeployedException, validateBeforeDelete, validateBeforeSave
public 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
- パスを取得する定義