Package org.springframework.xd.dirt.stream

Base package for processing DeploymentUnit (Stream/Job).

See: Description

Interface Summary

Interface	Description
JobDefinitionRepository	A repository for persisting JobDefinitions.
JobRepository	A repository for persisting Job instances.
StreamDefinitionRepository	A repository for persisting StreamDefinitions.
StreamRepository	A repository for persisting Streams.
XDParser	Parser to convert a DSL string for a deployable unit (i.e.

Class Summary

Class	Description
AbstractDeployer<D extends BaseDefinition>	Abstract implementation of the @link ResourceDeployer interface.
AbstractInstancePersistingDeployer<D extends BaseDefinition,I extends BaseInstance<D>>	Base support class for deployers that know how to deal with instances of a definition.
BaseInstance<D extends BaseDefinition>	A runtime representation of a Definition.
CompositeModuleDefinitionService	Provides save, delete and dependency operations for managing a composite module definition.
Job	Captures runtime information about a deployed JobDefinition.
JobDefinition	Represents a job in the system.
JobDeployer
Stream	A runtime representation of a running stream.
StreamDefinition	Represents a model for a data flow in the system.
StreamDefinitionRepositoryUtils	Encapsulate shared functionality between implementations of StreamDefinitionRepository that can't be done using inheritance
StreamDeployer	Default implementation of StreamDeployer that uses provided StreamDefinitionRepository and StreamRepository to persist stream deployment and undeployment requests.
StreamFactory	Factory class that builds Stream instances.
XDStreamParser	Parser to convert a DSL string for a stream into a list of ModuleDescriptor objects that comprise the given stream.

Enum Summary

Enum	Description
ParsingContext	Captures the context in which a parse operation is made.
ParsingContext.Position	Represents the position of a module in an XD DSL declaration.

Exception Summary

Exception	Description
AlreadyDeployedException	Thrown when an attempt is made to deploy a definition that is already deployed.
DefinitionAlreadyExistsException	Exception which is raised when a resource definition with the same name already exists.
NoSuchDefinitionException	Exception which is raised when a named resource definition cannot be found.
NotDeployedException	Thrown when a definition was assumed to be deployed when it actually was not.

Package org.springframework.xd.dirt.stream Description

Base package for processing DeploymentUnit (Stream/Job).