Name | Description | Type | Package | Framework |
AbstractBatchJobsController | Abstract controller that all the XD batch admin controllers extend. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
AbstractBusPropertiesAccessor | | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
AbstractComponentScanningBeanDefinitionProvider | | Class | org.springframework.xd.dirt.container.initializer | Spring XD |
|
AbstractDeployer | Abstract implementation of the @link ResourceDeployer interface. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
AbstractEvent | | Class | org.springframework.xd.dirt.event | Spring XD |
|
AbstractFromMessageConverter | Base class for converters applied via Spring Integration 4. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
AbstractInstancePersistingDeployer | Base support class for deployers that know how to deal with instances of aAuthor:Eric Bottard, Ilayaperumal Gopinathan | Class | org.springframework.xd.dirt.stream | Spring XD |
|
AbstractJobPlugin | Abstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related toAuthor:Ilayaperumal Gopinathan, Gary Russell | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
AbstractMessageBusBinderPlugin | Abstract Plugin that has common implementation methods to bind/unbind Module's message producers andconsumers to/from MessageBus. | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
AbstractModuleEvent | | Class | org.springframework.xd.dirt.event | Spring XD |
|
AbstractPlugin | Abstract Plugin that contains no-op and common implementing methods. | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
AbstractResourceBeanDefinitionProvider | A OrderedContextInitializer base class for loading XML or Groovy Bean Definitions into the target ContainerAuthor:David Turanski | Class | org.springframework.xd.dirt.container.initializer | Spring XD |
|
AbstractSingleNodeNamedChannelModule | Base class for SingleNodeNamedChannel resources used to bind a MessageChannel to a shared channel using aAuthor:David Turanski | Class | org.springframework.xd.dirt.test | Spring XD |
|
AbstractSingleNodeNamedChannelModuleFactory | Base class for factories used to create NamedChannelSource and NamedChannelSink. | Class | org.springframework.xd.dirt.test | Spring XD |
|
AbstractSingleNodeNamedChannelSink | Base class for SingleNode named channel sink types. | Class | org.springframework.xd.dirt.test.sink | Spring XD |
|
AbstractSingleNodeNamedChannelSource | Base class for SingleNode named channel source types. | Class | org.springframework.xd.dirt.test.source | Spring XD |
|
AbstractSingleNodeProcessingChain | A helper class for building single node streams that use a NamedChannelSource and NamedChannelSink. | Class | org.springframework.xd.dirt.test.process | Spring XD |
|
AbstractStreamPlugin | Abstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related toAuthor:Ilayaperumal Gopinathan, Mark Fisher, Gary Russell | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
AddModuleOptionsExpansionStrategy | Adds missing module options at the end of a well formed stream definition. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
Admin | Domain object for an XD admin runtime. | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
AdminAttributes | Runtime metadata for a Admin server instance. | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
AdminController | | Class | org.springframework.xd.dirt.rest | Spring XD |
|
AdminOptions | Holds configuration options that are valid for the Admin server, when using distributed mode. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
AdminPortNotAvailableException | Exception thrown when the configured admin port is not available to use. | Class | org.springframework.xd.dirt.server.admin | Spring XD |
|
AdminRepository | Repository for persisting Admin entities for admins. | Interface | org.springframework.xd.dirt.container.store | Spring XD |
|
AdminServerApplication | | Class | org.springframework.xd.dirt.server.admin | Spring XD |
|
AggregateCountersController | Exposes representations of AggregateCounts. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
AggregatorProcessorModuleOptionsMetadata | Describes options to the aggregator processor module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
AggregatorProcessorModuleOptionsMetadata .StoreKind | | Class | org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata | Spring XD |
|
AlreadyDeployedException | Thrown when an attempt is made to deploy a definition that is already deployed. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
ApplicationUtils | | Class | org.springframework.xd.dirt.server | Spring XD |
|
ArgumentNode | Represents an argument like "--name=value". | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
ArgumentNode | Represents an argument like "--name=value". | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
AstNode | AST base class for AST nodes in a parsed Job specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
AstNode | Common supertype for the ast nodes built during stream parsing. | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
AuthenticationRequest | | Class | org.springframework.xd.dirt.web.controller.support | Spring XD |
|
BannerUtils | Provides utilities for rendering graphical console output. | Class | org.springframework.xd.dirt.util | Spring XD |
|
BaseDefinition | Represents the base model for a data flow in the system. | Class | org.springframework.xd.dirt.core | Spring XD |
|
BaseInstance | A runtime representation of a Definition. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
BatchJobAlreadyExistsException | Exception thrown when the batch job with the given name already exists. | Class | org.springframework.xd.dirt.job | Spring XD |
|
BatchJobAlreadyExistsInRegistryException | Exception thrown when a batch job already exists in the JobRegistry. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
BatchJobExecutionsController | Controller for batch job executions. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
BatchJobHeaders | Headers definitions used by the batch job plugin. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
BatchJobInstancesController | Controller for batch job instances. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
BatchJobListener | Abstract batch job listener that sends batch job listener payload to the SubscribableChannel notificationAuthor:Ilayaperumal Gopinathan | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
BatchJobRegistryBeanPostProcessor | JobRegistryBeanPostProcessor that processes batch job from the job module. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
BatchJobsController | Controller for batch jobs and job instances, job executions on a given batch job. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
BatchListenerEventType | enum BatchListenerEventTypeEnumerations to help identify various Batch job events being issued. | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
BatchStepExecutionsController | Controller for returning Batch StepExecutions. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
BeanPropertiesPropertySource | A PropertySource that exposes the javabeans properties of an object as properties. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
Binding | Represents a binding between a module's channel and an adapter endpoint that connects to the MessageBus. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
BusCleaner | Interface for implementations that perform cleanup for message buses. | Interface | org.springframework.xd.dirt.integration.bus | Spring XD |
|
BusProperties | Common bus properties. | Interface | org.springframework.xd.dirt.integration.bus | Spring XD |
|
BusTestUtils | | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
BusUtils | Message Bus utilities. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
ByteArrayToStringMessageConverter | to convert from byte[] to String applying the Charset provided inthe content-type header if any. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
ChannelNode | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
ChannelType | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
CheckpointedJobDefinitionException | An extension of JobSpecificationException that remembers the point up to which parsing went OK (signaled by a '*' inthe dumped message). | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
CheckpointedStreamDefinitionException | An extension of StreamDefinitionException that remembers the point up to which parsing went OK (signaled by a '*' inthe dumped message). | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
ChildPathIterator | Iterator over ChildData instances that are managed by PathChildrenCache. | Class | org.springframework.xd.dirt.zookeeper | Spring XD |
|
ChunkContextInfo | | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
CommandLinePropertySourceOverridingListener | An ApplicationListener that will parse command line options and also replace the default boot commandlinePropertySource with those values. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
CommonDistributedOptions | Holds options that are common to both admin and container servers, when used in distributed mode. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
CommonOptions | Base class for command line options that are common to absolutely every setup (single and distributed). | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
CompletionExpansionStrategy | Used to enhance a well formed stream definition by adding yet more text to it (e. | Interface | org.springframework.xd.dirt.stream.completion | Spring XD |
|
CompletionProvider | Provides code completion on a (maybe ill-formed) stream definition. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
CompletionRecoveryStrategy | Used to provide completions on ill-formed stream definitions, after an initial (failed) parse. | Interface | org.springframework.xd.dirt.stream.completion | Spring XD |
|
CompletionsController | Exposes completion for stream-like definitions as a REST endpoint. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
ComposedJobUtil | | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
CompositeMessageConverterFactory | A factory for creating an instance of CompositeMessageConverter for a given target MIME typeAuthor:David Turanski | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
ConfigLocations | Static constants for configuration locations. | Class | org.springframework.xd.dirt.util | Spring XD |
|
ConnectionFactorySettings | Configures the connection factory used by the rabbit message bus. | Class | org.springframework.xd.dirt.integration.rabbit | Spring XD |
|
ConnectionFactorySettings .RabbitPropertiesLoader | | Class | org.springframework.xd.dirt.integration.rabbit.ConnectionFactorySettings | Spring XD |
|
Container | Domain object for an XD container. | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
ContainerAttributes | Metadata for a Container instance. | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
ContainerBootstrapContext | Package private class to bootstrap the Container process. | Class | org.springframework.xd.dirt.server.container | Spring XD |
|
ContainerConfiguration | Container Application ContextAuthor:David Turanski, Ilayaperumal Gopinathan, Marius Bogoevici | Class | org.springframework.xd.dirt.server.container | Spring XD |
|
ContainerFilter | A filter interface that applies filter for the given containers and returnseligible containers for deployment. | Interface | org.springframework.xd.dirt.cluster | Spring XD |
|
ContainerInfoPlugin | A plugin that exposes information about the container to the Environment. | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
ContainerListener | Listener implementation that is invoked when containers are added/removed/modified. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ContainerMatcher | ModuleDescriptor to. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
ContainerMatchingModuleRedeployer | The ModuleRedeployer that deploys the unallocated stream/job modules. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ContainerOptions | Holds configuration options that are valid for the Container node, when using distributed mode. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
ContainerRegistrar | An instance of this class, registered as a bean in the context for a Container, will handle the registration of thatContainer's metadata with ZooKeeper by creating an ephemeral node. | Class | org.springframework.xd.dirt.server.container | Spring XD |
|
ContainerRepository | Repository for persisting Container entities. | Interface | org.springframework.xd.dirt.container.store | Spring XD |
|
ContainersController | Handles interaction with the runtime containers/and its modules. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
ContainerServerApplication | The boot application class for a Container server. | Class | org.springframework.xd.dirt.server.container | Spring XD |
|
ContainerShutdownException | Exception thrown when shutting down the containerAuthor:Ilayaperumal GopinathanSee Also:Serialized Form | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
ConversionException | Exception thrown when an error is encountered during message conversion. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
CountersController | Exposes representations of Counters. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
CustomLoggerConverter | | Class | org.springframework.xd.dirt.util.logging | Spring XD |
|
CustomMimeTypeConverter | A custom converter for MediaType that accepts a plain java class name as a shorthand forapplication/x-java-object;type=the. | Class | org.springframework.xd.dirt.plugins.stream | Spring XD |
|
CustomModuleRegistryFactoryBean | Will create a SynchronizingModuleRegistry for hosting custom modules if necessary, depending on theprotocol scheme (using a synchronizing registry for everything but file:// protocol). | Class | org.springframework.xd.dirt.module | Spring XD |
|
DatabaseVendorFriendlyNameFactoryBean | A factory bean that returns a friendly string name from database metadata. | Class | org.springframework.xd.dirt.jdbc.util | Spring XD |
|
DeepAggregateCountResourceAssembler | Knows how to construct AggregateCountsResource out of AggregateCount. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
DeepCounterResourceAssembler | Knows how to assemble CounterResources out of Counters. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
DeepFieldValueCounterResourceAssembler | Knows how to create rich representations of FieldValueCounter. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
DefaultDeploymentStateRecalculator | Stream/Job deployment state re-calculator upon leadership election. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DefaultDeploymentUnitStateCalculator | Default DeploymentUnitStateCalculatorIf all expected modules are deployed, the state is considered | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DefaultModuleDeploymentPropertiesProvider | Default implementation that retrieves the ModuleDeploymentProperties for the givenAuthor:Ilayaperumal Gopinathan | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DefinitionAlreadyExistsException | Exception which is raised when a resource definition with the same name already exists. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
DelegatingModuleRegistry | A ModuleRegistry that delegates to several ModuleRegistries, in order. | Class | org.springframework.xd.dirt.module | Spring XD |
|
DepartedContainerModuleRedeployer | The ModuleRedeployer that re-deploys the stream/job modules that weredeployed into the departing container. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DependencyException | Thrown when performing an action cannot be carried over because some dependency would be broken. | Class | org.springframework.xd.dirt.module | Spring XD |
|
DeploymentAction | enum DeploymentActionEnum class for the supported deployment actions. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentConfiguration | Configuration class that holds the beans required for deployment management. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DeploymentException | Exception thrown when DeploymentHandler encounters problemwhen deploying/un-deploying stream/job. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentHandler | Deployment handler that is responsible for deploying/un-deploying theDeploymentUnit (Stream/Job) to/from the container. | Interface | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentLoader | Utility for loading streams and jobs for the purpose of deployment. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DeploymentMessage | The message that wraps the details of a deployment request. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentMessageConsumer | Consumer for DeploymentMessagewhich delegates to the corresponding @ResourceDeployer | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DeploymentMessagePublisher | Publisher that defines the contract to publish the DeploymentMessage. | Interface | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentPropertiesUtility | Class that provides utility methods to handle module deployment properties. | Class | org.springframework.xd.dirt.util | Spring XD |
|
DeploymentQueue | This class controls the lifecycle operations of the ZK distributed queue thatholds the DeploymentMessages. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DeploymentStatusRepository | Interface definition for repositories that support the reportingof deployment unit state. | Interface | org.springframework.xd.dirt.core | Spring XD |
|
DeploymentSupervisor | Process that watches ZooKeeper for Container arrivals and departures fromthe XD cluster. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
DeploymentUnit | DeploymentUnit is a collection of modules that are intended to bedeployed as a single unit. | Interface | org.springframework.xd.dirt.core | Spring XD |
|
DeploymentUnitStateCalculator | Calculates the overall status for a deployment unit (stream or job). | Interface | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentUnitStatus | Status for a DeploymentUnit. | Class | org.springframework.xd.dirt.core | Spring XD |
|
DeploymentUnitStatus .State | Deployment unit states. | Class | org.springframework.xd.dirt.core.DeploymentUnitStatus | Spring XD |
|
DeploymentUnitType | enum DeploymentUnitTypeEnum class that defines the deployment unit type. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
DeploymentValidator | This interface defines validation methods that verify a stream or jobcan be saved, deployed, undeployed, or deleted. | Interface | org.springframework.xd.dirt.stream | Spring XD |
|
DetailedContainer | Domain object for an XD container with detailed info (deployed modules, messageRates etc. | Class | org.springframework.xd.dirt.container.store | Spring XD |
|
DetailedJobInfo | A job info for batch jobs that provides more details than the base JobInfoAuthor:Andrew Eisenberg, Ilayaperumal Gopinathan | Class | org.springframework.xd.dirt.job | Spring XD |
|
DetailedJobInfoResourceAssembler | Knows how to build a REST resource out of our domain model DetailedJobInfo. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
DetailedModuleDefinitionResourceAssembler | Knows how to build DetailedModuleDefinitionResource out of a ModuleDefinition. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
DirtException | Root of the hierarchy of exceptions for DIRT (Distributed Integration RunTime). | Class | org.springframework.xd.dirt | Spring XD |
|
DistributedJobLocator | to work with batch jobs in a distributed environment. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
DistributedJobService | SimpleJobService in distributed modeAuthor:Ilayaperumal Gopinathan, Andrew Eisenberg, Gunnar Hillert | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
DocumentParseResult | Represents the result of parsing a multiline document, made of several definitions. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
DocumentParseResult .Line | The parse result of an individual line. | Class | org.springframework.xd.dirt.stream.DocumentParseResult | Spring XD |
|
DocumentParseResultResourceAssembler | This class is responsible for creating a REST representation of a DocumentParseResult. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
EmbeddedHeadersMessageConverter | Encodes requested headers into payload with format0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] . | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
EmbeddedZooKeeper | Helper class to start an embedded instance of standalone (non clustered) ZooKeeper. | Class | org.springframework.xd.dirt.zookeeper | Spring XD |
|
EmptyStartYieldsModulesRecoveryStrategy | | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
ExecutionContextJacksonMixIn | Jackson MixIn for the JSON serialization of the ExecutionContext class, which is used by theStepExecution class. | Class | org.springframework.xd.dirt.plugins.job.support | Spring XD |
|
ExpandedJobParametersConverter | More flexible implementation of the JobParametersConverter. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
ExpandOneDashToTwoDashesRecoveryStrategy | Provides completion when the user has typed in the first dash to a module option. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
ExtendedResource | A wrapper around a Resource that adds capabilities lacking in the original interface. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ExtendedResource .FileSystemExtendedResource | | Class | org.springframework.xd.dirt.module.ExtendedResource | Spring XD |
|
ExtendedResource .HdfsExtendedResource | | Class | org.springframework.xd.dirt.module.ExtendedResource | Spring XD |
|
FieldValueCountersController | Controller that exposes FieldValueCounter related representations. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
FileAsRefMixin | A mixin that can be used every time a module dealing with Files offersthe choice to pass along the File itself or its contents. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
FileAuthenticationConfiguration | A security configuration that conditionally sets up in-memory users from a file. | Class | org.springframework.xd.dirt.server.security | Spring XD |
|
FileDeletionStepExecutionListener | Step listener which can be used to delete files once they have been successfully processed by XD. | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
FilePollHdfsJobOptionsMetadata | Describes the options for the filepollhdfs job. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
FileReadingMode | enum FileReadingModeDefines the supported modes of reading and processing files for the | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
FileSinkOptionsMetadata | Holds options to the 'file' sink module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
FileSinkOptionsMetadata .Mode | | Class | org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata | Spring XD |
|
FileSourceOptionsMetadata | Holds module options metadata about the file source. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
Flow | The AST node representing a flow. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
FtpHdfsJobOptionsMetadata | Describes the options for the ftphdfs job. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
FtpSinkOptionsMetadata | Module options for the FTP sink module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
FtpSourceOptionsMetadata | Module options for FTP source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
GaugesController | Exposes representations of Gauges. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
Graph | Represents a Graph that Flo will display. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
HdfsMongodbJobOptionsMetadata | Options for Hdfs to Mongodb export job module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
HttpSourceOptionsMetadata | Describes options to the http source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
IntegerEncoderDecoder | A Kafka encoder / decoder used to serialize a single int, used as the kafka partition key. | Class | org.springframework.xd.dirt.integration.kafka | Spring XD |
|
JavaToSerializedMessageConverter | to convert from a POJO to byte[] with Java. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
JmsSourceModuleOptionsMetadata | Captures options for the jms source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
Job | Domain model for Job runtime module. | Class | org.springframework.xd.dirt.core | Spring XD |
|
Job | Captures runtime information about a deployed JobDefinition. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
Job .Builder | Builder object for Job that supports fluent style configuration. | Class | org.springframework.xd.dirt.core.Job | Spring XD |
|
JobDefinition | Represents an inlined job definition in a job specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobDefinition | Represents a job in the system. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
JobDefinitionRepository | A repository for persisting JobDefinitions. | Interface | org.springframework.xd.dirt.stream | Spring XD |
|
JobDefinitionResourceAssembler | Knows how to build a REST resource out of our domain model JobDefinition. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
JobDeployer | | Class | org.springframework.xd.dirt.stream | Spring XD |
|
JobDeploymentsPath | Builder object for paths under Paths. | Class | org.springframework.xd.dirt.core | Spring XD |
|
JobDescriptor | Common AST base class for nodes representing job definitions or job references. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobDSLMessage | Contains all the messages that can be produced during Spring XD Job DSL parsing. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobDSLMessage .Kind | | Class | org.springframework.xd.dirt.job.dsl.JobDSLMessage | Spring XD |
|
JobEventsListenerPlugin | Plugin to enable the registration of out of the box job listeners. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
JobException | Root of the hierarchy of exceptions for Job processing in DIRT. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobExecutionAlreadyRunningException | Exception that is raised when JobExecutionAuthor:Gunnar HillertSee Also:Serialized Form | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobExecutionInfo | Represents Batch job execution info. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobExecutionInfoResourceAssembler | Knows how to build a REST resource out of our domain model JobExecutionInfo. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
JobExecutionNotRunningException | Exception for the job execution that is not running. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobFactory | Factory class that builds Job instances. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobInfo | Represents Batch job info. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobInfoResourceAssembler | Knows how to build a REST resource out of our domain model JobInfo. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
JobInstanceAlreadyCompleteException | Exception thrown when the JobInstance is already complete. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobInstanceInfo | Represents Batch job instance info. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobInstanceInfoResourceAssembler | Resource assembler that builds the REST resource JobInstanceInfoResource out of domain modelAuthor:Ilayaperumal Gopinathan | Class | org.springframework.xd.dirt.rest | Spring XD |
|
JobLaunchingJobRepository | This JobRepository implementationprovides the same functionality as Spring Batch's | Class | org.springframework.xd.dirt.plugins.job.support | Spring XD |
|
JobLaunchingJobRepositoryFactoryBean | A FactoryBean for creating an instance ofJobLaunchingJobRepository | Class | org.springframework.xd.dirt.plugins.job.support | Spring XD |
|
JobLaunchingTasklet | A Tasklet implementation that uses the Spring XD MessageBus to launchjobs deployed within the same Spring XD cluster. | Class | org.springframework.xd.dirt.batch.tasklet | Spring XD |
|
JobLaunchRequestTransformer | Executes all jobs defined within a given stream once the context has been started. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
JobNode | AST node base type for all elements in an AST parsed from a job specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobParametersBean | Prepares the JobParameters for the Spring Bach Jobs. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
JobParametersInvalidException | Exception thrown when the job parameters are invalid. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobParser | Parse a Batch DSL Job specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobPartitionerPlugin | Plugin to enable job partitioning. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
JobPlugin | Plugin to enable the registration of jobs in a central registry. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
JobPluginMetadataResolver | A ModuleOptionsMetadataResolver that will dynamically add the module options (such as makeUnique)supported by job modules. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
JobPluginMetadataResolver .JobOptionsMetadata | | Class | org.springframework.xd.dirt.plugins.job.JobPluginMetadataResolver | Spring XD |
|
JobReference | Represents a simple job reference. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobRepository | A repository for persisting Job instances. | Interface | org.springframework.xd.dirt.stream | Spring XD |
|
JobRestartException | Exception thrown where the batch job is not restartable. | Class | org.springframework.xd.dirt.job | Spring XD |
|
JobsController | Handles all Job related interactions. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
JobSeries | Common AST base class for nodes representing splits or flows. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobSpecification | The root AST node for any AST parsed from a job specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobSpecificationException | Root exception for Job Flow DSL parsing related exceptions. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JobSpecificationVisitor | very basic visitor pattern for a JobSpecVisitor. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
JsonToPojoMessageConverter | | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
JsonToTupleMessageConverter | to convert from a JSON (byte[] or String) to a Tuple. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
KafkaMessageBus | A message bus that uses Kafka as the underlying middleware. | Class | org.springframework.xd.dirt.integration.kafka | Spring XD |
|
KafkaMessageBus .Mode | | Class | org.springframework.xd.dirt.integration.kafka.KafkaMessageBus | Spring XD |
|
KafkaMessageBus .OffsetManagement | | Class | org.springframework.xd.dirt.integration.kafka.KafkaMessageBus | Spring XD |
|
LabelNode | Represents a label attached to a module. | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
LdapAuthenticationConfiguration | | Class | org.springframework.xd.dirt.server.security | Spring XD |
|
Link | Represents a link in a Graph object that Flo will display as a block. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
LocalizedQueueConnectionFactory | A RoutingConnectionFactory that determines the node on which a queue is located andreturns a factory that connects directly to that node. | Class | org.springframework.xd.dirt.integration.rabbit | Spring XD |
|
LocalMessageBus | A simple implementation of MessageBus for in-process use. | Class | org.springframework.xd.dirt.integration.bus.local | Spring XD |
|
LoggerAbbreviator | | Class | org.springframework.xd.dirt.util.logging | Spring XD |
|
LoginController | Controller responsible for handling web-logins as well as basic redirects forAuthor:Gunnar Hillert | Class | org.springframework.xd.dirt.web.controller | Spring XD |
|
LogSinkOptionsMetadata | Captures options for the log sink module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
MBeanExportingPlugin | Exports MBeans from a module using a unique domain name xd. | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
MD5StalenessCheck | A StalenessCheck that expects to find a . | Class | org.springframework.xd.dirt.module | Spring XD |
|
MessageBus | A strategy interface used to bind a MessageChannel to a logical name. | Interface | org.springframework.xd.dirt.integration.bus | Spring XD |
|
MessageBus .Capability | When a bus supports durable subscriptions to a pub/sub channel, the streamname will be included in the consumer name. | Class | org.springframework.xd.dirt.integration.bus.MessageBus | Spring XD |
|
MessageBusAwareChannelResolver | A DestinationResolver implementation that first checks for any channelwhose name begins with a colon in the MessageBus. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
MessageBusAwareRouterBeanPostProcessor | A BeanPostProcessor that sets a MessageBusAwareChannelResolver on any bean of typeAbstractMappingMessageRouter within the context. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
MessageBusClassLoaderFactory | An ApplicationListener which tracks which MessageBus implementation ought to be used so that it exposes a ClassLoaderthat knows about the correct jar files for that bus. | Class | org.springframework.xd.dirt.server | Spring XD |
|
MessageBusException | Exception thrown to indicate a message bus error (mostlikely a configuration error). | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
MessageBusExtensionsConfiguration | Configuration class for Codec and possibly other MessageBus extensionsSince:1. | Class | org.springframework.xd.dirt.server | Spring XD |
|
MessageBusSupport | | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
MessageBusSupport .DirectHandler | | Class | org.springframework.xd.dirt.integration.bus.MessageBusSupport | Spring XD |
|
MessageBusSupport .PartitioningMetadata | | Class | org.springframework.xd.dirt.integration.bus.MessageBusSupport | Spring XD |
|
MessageBusSupport .SetBuilder | | Class | org.springframework.xd.dirt.integration.bus.MessageBusSupport | Spring XD |
|
MessageConverterUtils | Message conversion utility methods. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
MessageValues | A mutable type for allowing MessageBus implementations to transform and enrich message content moreAuthor:David Turanski | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
ModuleAlreadyExistsException | Thrown when trying to create a new module with the given name and type, but one already exists. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ModuleConfigurationException | Thrown when something is wrong with options passed to a module. | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
ModuleDefinitionRepositoryUtils | | Class | org.springframework.xd.dirt.module.support | Spring XD |
|
ModuleDefinitionResourceAssembler | Knows how to build a REST resource out of our domain model ModuleDefinition. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
ModuleDefinitionService | A service that knows how to handle registration of new module definitions, be it through composition orupload of actual 'bytecode'. | Class | org.springframework.xd.dirt.module.support | Spring XD |
|
ModuleDependencyRepository | Used to track usage of modules from streams and composed modules. | Interface | org.springframework.xd.dirt.module | Spring XD |
|
ModuleDeployedEvent | | Class | org.springframework.xd.dirt.event | Spring XD |
|
ModuleDeployer | Handles the creation, deployment, and un-deployment of modules. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ModuleDeploymentPropertiesProvider | Callback interface to obtain ModuleDeploymentPropertiesfor a ModuleDescriptor. | Interface | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
ModuleDeploymentRequestsPath | Builder object for paths under Paths. | Class | org.springframework.xd.dirt.core | Spring XD |
|
ModuleDeploymentsPath | Builder object for paths under Paths. | Class | org.springframework.xd.dirt.core | Spring XD |
|
ModuleDeploymentStatus | Status of a module deployment for a container. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
ModuleDeploymentStatus .State | Module deployment states. | Class | org.springframework.xd.dirt.server.admin.deployment.ModuleDeploymentStatus | Spring XD |
|
ModuleDeploymentWriter | Utility class to write module deployment requests under /xd/deployments/modules. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ModuleException | Root of the hierarchy of exceptions for Module processing in DIRT. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ModuleInfoPlugin | A plugin that exposes information such as the module name, index, sequence or count to be available inside theAuthor:Eric Bottard, Marius Bogoevici, Ilayaperumal Gopinathan | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
ModuleJobLauncher | Executes all jobs defined within a given stream once the context has been started. | Class | org.springframework.xd.dirt.plugins.job | Spring XD |
|
ModuleMessageRateNotFoundException | Exception thrown when getting message rate forAuthor:Ilayaperumal GopinathanSee Also:Serialized Form | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
ModuleMetadata | Metadata class for modules at runtime. | Class | org.springframework.xd.dirt.module.store | Spring XD |
|
ModuleMetadata .Id | Identity object for instances of ModuleMetadata. | Class | org.springframework.xd.dirt.module.store.ModuleMetadata | Spring XD |
|
ModuleMetadataRepository | Repository for persisting ModuleMetadataAuthor:Ilayaperumal Gopinathan | Interface | org.springframework.xd.dirt.module.store | Spring XD |
|
ModuleMetadataResourceAssembler | Knows how to assemble ModuleMetadataResources out of ModuleMetadatas. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
ModuleNode | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
ModuleNotDeployedException | Exception thrown when a module doesn't exist in the container. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ModuleObjectNamingStrategy | Object naming strategy for XD module. | Class | org.springframework.xd.dirt.module.jmx | Spring XD |
|
ModuleRedeployer | Abstract ModuleRedeployer that deploy/re-deploys the unallocated/orphaned modules. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ModuleRedeployer .ModuleDeployment | Holds information about a module that needs to be re-deployed. | Class | org.springframework.xd.dirt.server.admin.deployment.zk.ModuleRedeployer | Spring XD |
|
ModuleRegistry | A module registry is used to lookup modules by name and/or type. | Interface | org.springframework.xd.dirt.module | Spring XD |
|
ModulesAfterPipeRecoveryStrategy | Provides completions for the case where the user has entered a pipe symbol and a module reference is expected next. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
ModulesController | Handles all Module related interactions. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
ModulesMetadataController | Controller that handles the interaction with the deployed modules. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
ModuleTypeConversionPlugin | A Plugin for processing module message conversion parameters (inputType and outputType). | Class | org.springframework.xd.dirt.plugins.stream | Spring XD |
|
ModuleTypeConversionPluginMetadataResolver | A ModuleOptionsMetadataResolver that will dynamically add inputType and outputType options toevery module, according to their type. | Class | org.springframework.xd.dirt.plugins.stream | Spring XD |
|
ModuleTypeConversionSupport | Support class that configures the message converters for the module input/output channel. | Class | org.springframework.xd.dirt.plugins.stream | Spring XD |
|
ModuleUndeployedEvent | | Class | org.springframework.xd.dirt.event | Spring XD |
|
MqttConnectionMixin | Factors out common options about configuring a connection to an MQTT broker. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
MqttSinkOptionsMetadata | Describes options to the mqtt sink module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
MqttSourceOptionsMetadata | Describes options to the mqtt source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
NamedChannelSink | A Sink bound to a named channel. | Interface | org.springframework.xd.dirt.test.sink | Spring XD |
|
NamedChannelSource | A Source that binds to a named channel. | Interface | org.springframework.xd.dirt.test.source | Spring XD |
|
NewJsonPathUtils | Similar to org. | Class | org.springframework.xd.dirt.integration.json | Spring XD |
|
NoContainerException | Exception thrown when there are no containers availablefor module deployment. | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
Node | Represents a node in a Graph object that Flo will display as a block. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
NoSuchBatchJobException | Exception thrown when there is no such batch job with the given name. | Class | org.springframework.xd.dirt.job | Spring XD |
|
NoSuchBatchJobInstanceException | Exception thrown when there is no such batch job instance with the given instanceId. | Class | org.springframework.xd.dirt.job | Spring XD |
|
NoSuchContainerException | Exception thrown when the container in search could not be found. | Class | org.springframework.xd.dirt.cluster | Spring XD |
|
NoSuchDefinitionException | Exception which is raised when a named resource definition cannot be found. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
NoSuchJobExecutionException | Thrown when attempting to refer to JobExecution that does not exist. | Class | org.springframework.xd.dirt.job | Spring XD |
|
NoSuchMetricException | Thrown when trying to access a named metric that does not exist. | Class | org.springframework.xd.dirt.analytics | Spring XD |
|
NoSuchModuleException | Thrown when attempting to refer to a module that does not exist. | Class | org.springframework.xd.dirt.module | Spring XD |
|
NoSuchStepExecutionException | Thrown when attempting to refer to StepExecution that does not exist. | Class | org.springframework.xd.dirt.job | Spring XD |
|
NotDeployedException | Thrown when a definition was assumed to be deployed when it actually was not. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
NothingToDeleteException | Thrown when a delete operation has nothing to delete. | Class | org.springframework.xd.dirt.integration.bus.rabbit | Spring XD |
|
OptionNameAfterDashDashRecoveryStrategy | Provides completion proposals when the user has typed the two dashes that precede a module option name. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
OrderedContextInitializer | Allows any necessary changes to the Target Context. | Interface | org.springframework.xd.dirt.container.initializer | Spring XD |
|
PageNotFoundException | Exception thrown when a Pageable requests a page that does not exist. | Class | org.springframework.xd.dirt.util | Spring XD |
|
PagingUtility | Utility class for paging support in repository accessor methods. | Class | org.springframework.xd.dirt.util | Spring XD |
|
ParentConfiguration | Beans defined and imported here are in the global parent context, hence available to the entire hierarchy, includingAdmins, Containers, and Modules. | Class | org.springframework.xd.dirt.server | Spring XD |
|
ParsingContext | Captures the context in which a parse operation is made. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
ParsingContext .Position | Represents the position of a module in an XD DSL declaration. | Class | org.springframework.xd.dirt.stream.ParsingContext | Spring XD |
|
PartitionKeyExtractorStrategy | Strategy for extracting a partition key from a Message. | Interface | org.springframework.xd.dirt.integration.bus | Spring XD |
|
PartitionSelectorStrategy | Strategy for determining the partition to which a message should be sent. | Interface | org.springframework.xd.dirt.integration.bus | Spring XD |
|
PasswordUtils | Provides common utility methods for JobDefinitions andStreamDefinitions (BaseDefinition), e. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
Paths | Common paths and path utilities for XD components. | Class | org.springframework.xd.dirt.zookeeper | Spring XD |
|
PipeIntoOtherModulesExpansionStrategy | Continues a well-formed stream definition by adding a pipe symbol and another module, provided that the streamdefinition hasn't reached its end yet. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
PluginContextComponentScanningExtensionsInitializer | An OrderedContextInitializer to scan for annotation configured beans in xd. | Class | org.springframework.xd.dirt.container.initializer | Spring XD |
|
PluginContextResourceExtensionsInitializer | An OrderedContextInitializer to scan resource locations xd. | Class | org.springframework.xd.dirt.container.initializer | Spring XD |
|
PluginsInitializer | An OrderedContextInitializer to load out-of-the-box XD Plugins. | Class | org.springframework.xd.dirt.container.initializer | Spring XD |
|
PojoToJsonMessageConverter | to convert a Java object to a JSON StringAuthor:David Turanski, David Liu | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
PojoToStringMessageConverter | to convert a Java object to a String using toString()Author:David Turanski | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
RabbitAdminException | Exceptions thrown while interfacing with the RabbitMQ admin plugin. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
RabbitBusCleaner | | Class | org.springframework.xd.dirt.integration.bus.rabbit | Spring XD |
|
RabbitConnectionMixin | Factors out options for the typical connection setup to RabbitMQ. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
RabbitManagementUtils | | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
RabbitMessageBus | A MessageBus implementation backed by RabbitMQ. | Class | org.springframework.xd.dirt.integration.rabbit | Spring XD |
|
RabbitSinkOptionsMetadata | Captures options to the rabbit sink module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
RabbitSourceOptionsMetadata | Describes options to the rabbit source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
RedisConnectionMixin | Mixin for Redis connection options. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
RedisMessageBus | A MessageBus implementation backed by Redis. | Class | org.springframework.xd.dirt.integration.redis | Spring XD |
|
RedisSinkOptionsMetadata | Options metadata for Redis sink module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
RepositoryConnectionListener | ZooKeeper connection listener that ensures path creation fornodes required by the various repository implementations that | Class | org.springframework.xd.dirt.stream.zookeeper | Spring XD |
|
ResourceDefinitionException | Thrown when a problem is detected with the (DSL) definition of an XD resource. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ResourceDeployer | Interface for XD Resource Services. | Interface | org.springframework.xd.dirt.core | Spring XD |
|
ResourceModuleRegistry | Resource based implementation of ModuleRegistry. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ResourcePatternScanningOptionHandler | An OptionHandler that scans a resource pattern for existing resources (using a single '*' wildcard) andallows all String values s that would fit if that single wildcard was replaced by s. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
ResourcePatternScanningOptionHandlers | Holds definitions of ResourcePatternScanningOptionHandlers used in Spring XD. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
ResourcePatternScanningOptionHandlers .DistributedAnalyticsOptionHandler | Computes values for --analytics in the distributed case (memory is NOT supported). | Class | org.springframework.xd.dirt.server.options.ResourcePatternScanningOptionHandlers | Spring XD |
|
ResourcePatternScanningOptionHandlers .HadoopDistroOptionHandler | Computes values for --hadoopDistro out of names of subdirectories of the lib/ dir. | Class | org.springframework.xd.dirt.server.options.ResourcePatternScanningOptionHandlers | Spring XD |
|
ResourcePatternScanningOptionHandlers .SingleNodeAnalyticsOptionHandler | Computes values for --analytics in the single node case (accepts memory). | Class | org.springframework.xd.dirt.server.options.ResourcePatternScanningOptionHandlers | Spring XD |
|
ResourcePatternScanningOptionHandlers .SingleNodeDataTransportOptionHandler | Computes values for (data) --transport for the singlenode case. | Class | org.springframework.xd.dirt.server.options.ResourcePatternScanningOptionHandlers | Spring XD |
|
ResourceStateVerifier | Verifies the state of resources (job or stream) by polling repository state until theresource is in the expected state or the operation times out. | Class | org.springframework.xd.dirt.test | Spring XD |
|
RestConfiguration | Takes care of infrastructure setup for the web/rest layer. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
RestControllerAdvice | Central class for behavior common to all REST controllers. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
RestLogoutSuccessHandler | status code of 200. | Class | org.springframework.xd.dirt.web.controller.support | Spring XD |
|
RichGaugesController | Exposes representations of Gauges. | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
RuntimeBatchConfigurer | Spring XD runtime specific BatchConfigurer. | Class | org.springframework.xd.dirt.batch | Spring XD |
|
RuntimeContainerResourceAssembler | Knows how to assemble DetailedContainerResources out of DetailedContainer instances. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
RuntimeIOException | Thrown when something goes wrong during some IO operation. | Class | org.springframework.xd.dirt.core | Spring XD |
|
RuntimeModuleDeploymentPropertiesProvider | Default implementation of ModuleDeploymentPropertiesProviderfor type RuntimeModuleDeploymentProperties. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
RuntimeTimeoutException | Exception thrown when a blocking operation times out. | Class | org.springframework.xd.dirt.core | Spring XD |
|
RuntimeUtils | Utilities for obtaining runtime information for the running process. | Class | org.springframework.xd.dirt.util | Spring XD |
|
SecurityConfiguration | Setup Spring Security for the http endpoints of the application. | Class | org.springframework.xd.dirt.web.config | Spring XD |
|
SecurityConfiguration .AuthorizationConfig | Holds configuration for the authorization aspects of security. | Class | org.springframework.xd.dirt.web.config.SecurityConfiguration | Spring XD |
|
SecurityController | Provides security-related meta information. | Class | org.springframework.xd.dirt.rest.security | Spring XD |
|
SerializationException | Thrown when something goes wrong with inter-module communication. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
SerializedToJavaMessageConverter | to deserialize Serializable Java objects. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
SftpSourceOptionsMetadata | Module options for SFTP source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
ShallowMetricResourceAssembler | Base class for a ResourceAssembler that builds shallow resources for metrics (exposing only their names, andhence their "self" rel). | Class | org.springframework.xd.dirt.rest.metrics | Spring XD |
|
SharedServerContextConfiguration | Beans defined and imported here are shared by the XD Admin Server and Container Server. | Class | org.springframework.xd.dirt.server | Spring XD |
|
SharedServerContextConfiguration .ZookeeperConnectionConfig | | Class | org.springframework.xd.dirt.server.SharedServerContextConfiguration | Spring XD |
|
SimpleXdChunkListener | | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
SimpleXdItemListener | | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
SimpleXdJobExecutionListener | | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
SimpleXdSkipListener | | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
SimpleXdStepExecutionListener | | Class | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
SingleNodeApplication | Single Node XD Runtime. | Class | org.springframework.xd.dirt.server.singlenode | Spring XD |
|
SingleNodeIntegrationTestSupport | A helper class that provides methods used for testing streams with SingleNodeApplication. | Class | org.springframework.xd.dirt.test | Spring XD |
|
SingleNodeNamedChannelSinkFactory | A factory for creating NamedChannelSinks. | Class | org.springframework.xd.dirt.test.sink | Spring XD |
|
SingleNodeNamedChannelSourceFactory | A factory for creating NamedChannelSources. | Class | org.springframework.xd.dirt.test.source | Spring XD |
|
SingleNodeNamedQueueSink | A NamedChannelSink implementation that binds to a Queue Channel. | Class | org.springframework.xd.dirt.test.sink | Spring XD |
|
SingleNodeNamedQueueSource | A NamedChannelSource implementation that binds to a Queue Channel. | Class | org.springframework.xd.dirt.test.source | Spring XD |
|
SingleNodeNamedTopicSink | A NamedChannelSink implementation that binds to a PubSub Channel. | Class | org.springframework.xd.dirt.test.sink | Spring XD |
|
SingleNodeNamedTopicSource | A NamedChannelSource implementation that binds to a PubSub Channel. | Class | org.springframework.xd.dirt.test.source | Spring XD |
|
SingleNodeOptions | Holds options that can be used in single-node mode. | Class | org.springframework.xd.dirt.server.options | Spring XD |
|
SingleNodeProcessingChain | Creates a stream to test a processing chain p1 p2 . | Class | org.springframework.xd.dirt.test.process | Spring XD |
|
SingleNodeProcessingChainConsumer | Creates a stream to test a processing chain including a source but no sink and adds a NamedChannelSink tocreate a complete stream. | Class | org.springframework.xd.dirt.test.process | Spring XD |
|
SingleNodeProcessingChainProducer | Creates a stream to test a processing chain including a sink but no source and adds a NamedChannelSource tocreate a complete stream. | Class | org.springframework.xd.dirt.test.process | Spring XD |
|
SingleNodeProcessingChainSupport | A helper class to easily create AbstractSingleNodeProcessingChains using static methods. | Class | org.springframework.xd.dirt.test.process | Spring XD |
|
SingletonModuleRegistry | An implementation of ModuleRegistry suitable to lookup a module that is atthe root of the classpath. | Class | org.springframework.xd.dirt.test | Spring XD |
|
SinkChannelNode | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
SourceChannelNode | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
SparkStreamingChannel | The DirectChannel that provides support forspark streaming configurations. | Class | org.springframework.xd.dirt.plugins.spark.streaming | Spring XD |
|
SparkStreamingContainerFilter | A ContainerFilter which filters out the containers that have a sparkstreaming module running. | Class | org.springframework.xd.dirt.spark | Spring XD |
|
SparkStreamingPlugin | Plugin for Spark Streaming support. | Class | org.springframework.xd.dirt.plugins.spark.streaming | Spring XD |
|
Split | The AST node representing a split. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
SplitterProcessorOptionsMetadata | Captures options for the splitter processor module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
StacktraceFingerprintingCompletionRecoveryStrategy | A recovery strategy that will trigger if the parser failure is similar to that of some sample unfinished streamdefinition. | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
StalenessCheck | A strategy interface for deciding whether a target definition is stale compared to a source definition. | Interface | org.springframework.xd.dirt.module | Spring XD |
|
StandAloneUiApp | Starts the Web UI without needing the full Spring XD setup. | Class | org.springframework.xd.dirt.web | Spring XD |
|
StepExecutionInfo | Represents Batch step execution info. | Class | org.springframework.xd.dirt.job | Spring XD |
|
StepExecutionInfoResourceAssembler | Knows how to build a REST resource out of our domain model StepExecutionInfo. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
StepExecutionJacksonMixIn | Jackson MixIn for StepExecution serialization. | Class | org.springframework.xd.dirt.plugins.job.support | Spring XD |
|
StepExecutionProgressInfo | Represents Batch job step execution progress info. | Class | org.springframework.xd.dirt.job | Spring XD |
|
StepExecutionProgressInfoResourceAssembler | Knows how to build a REST resource out of our domain model StepExecutionProgressInfo. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
StepType | The types of Spring Batch Step implementations that are known to the system. | Class | org.springframework.xd.dirt.job | Spring XD |
|
Stream | Domain model for runtime Stream modules. | Class | org.springframework.xd.dirt.core | Spring XD |
|
Stream | A runtime representation of a running stream. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
Stream .Builder | Builder object for Stream that supports fluent style configuration. | Class | org.springframework.xd.dirt.core.Stream | Spring XD |
|
StreamConfigParser | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
StreamDefinition | Represents a model for a data flow in the system. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
StreamDefinitionException | Root exception for DSL parsing related exceptions. | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
StreamDefinitionRepository | A repository for persisting StreamDefinitions. | Interface | org.springframework.xd.dirt.stream | Spring XD |
|
StreamDefinitionRepositoryUtils | | Class | org.springframework.xd.dirt.stream | Spring XD |
|
StreamDefinitionResourceAssembler | Knows how to build a REST resource out of our domain model StreamDefinition. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
StreamDeployer | Default implementation of StreamDeployer that uses providedStreamDefinitionRepository and StreamRepository to | Class | org.springframework.xd.dirt.stream | Spring XD |
|
StreamDeploymentsPath | Builder object for paths under Paths. | Class | org.springframework.xd.dirt.core | Spring XD |
|
StreamException | Root of the hierarchy of exceptions for Module processing in DIRT. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
StreamFactory | Factory class that builds Stream instances. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
StreamLookupEnvironment | A lookup environment is used to resolve a stream. | Interface | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
StreamNode | | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
StreamPlugin | | Class | org.springframework.xd.dirt.plugins.stream | Spring XD |
|
StreamRepository | A repository for persisting Streams. | Interface | org.springframework.xd.dirt.stream | Spring XD |
|
StreamRuntimePropertiesProvider | RuntimeModuleDeploymentPropertiesProvider that provides the stream partition/short circuitproperties for the given ModuleDescriptor. | Class | org.springframework.xd.dirt.server.admin.deployment | Spring XD |
|
StreamsController | Handles all Stream related interaction. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
StrictContentTypeResolver | A StringConvertingContentTypeResolver that requires a the content-type to be present. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
StringConvertingContentTypeResolver | A DefaultContentTypeResolver that can parse String values. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
StringToByteArrayMessageConverter | to convert a String to a byte[], applying the provided Charset inthe content-type header if any. | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
SupervisorElectedEvent | Event that is fired after a admin leader is elected. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
SupervisorElectionListener | Event listener for SupervisorElectedEvents. | Interface | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
SynchronizingModuleRegistry | A ModuleRegistry that is configured with two delegates: a remote (source) and a local (target) registry. | Class | org.springframework.xd.dirt.module | Spring XD |
|
TailSourceOptionsMetadata | Describes options to the tail source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
TaskletType | Types of Tasklet implementations known by Spring XD. | Class | org.springframework.xd.dirt.job | Spring XD |
|
ThreadContextClassLoaderSetterAdvice | An advice that will set the thread context ClassLoader to theenclosing ApplicationContext's class loader before invocation and reset | Class | org.springframework.xd.dirt.module.support | Spring XD |
|
TimeSourceOptionsMetadata | Describes options to the time source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
TimestampFileJobOptionsMetadata | Options for the timestampfile job module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
Token | Holder for a kind of token, the associated data and its position in the input data stream (start/end). | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
Token | Holder for a kind of token, the associated data and its position in the input data stream (start/end). | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
TokenKind | Enumeration of all the token types that may be found in a Job DSL specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
TokenKind | Enumeration of all the token types that may be found in a DSL definition stream. | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
Tokens | Class that converts an expression into a list of tokens. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
ToolsController | A controller for integrating with frontend tools. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
Transition | An AST node representing a transition found in the parsed Job specification. | Class | org.springframework.xd.dirt.job.dsl | Spring XD |
|
TriggerSourceOptionsMetadata | Describes options to the trigger source module. | Class | org.springframework.xd.dirt.modules.metadata | Spring XD |
|
TupleToJsonMessageConverter | to convert a Tuple to a JSON StringAuthor:David Turanski | Class | org.springframework.xd.dirt.integration.bus.converter | Spring XD |
|
UnfinishedModuleNameRecoveryStrategy | | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
UnfinishedOptionNameRecoveryStrategy | | Class | org.springframework.xd.dirt.stream.completion | Spring XD |
|
UploadedModuleDefinition | A module definition that serves as a temporary vehicle for the payload of an uploaded module. | Class | org.springframework.xd.dirt.module | Spring XD |
|
ValidationController | Provides server-validation services. | Class | org.springframework.xd.dirt.rest.validation | Spring XD |
|
VersionController | Controller to retrieve version control information. | Class | org.springframework.xd.dirt.rest.meta | Spring XD |
|
VersionPatternConverter | that returns the "Implementation-Version" string obtained from themanifest of the jar that this class was loaded from. | Class | org.springframework.xd.dirt.util.logging | Spring XD |
|
VersionPatternLayout | Extension of Log4j's EnhancedPatternLayoutwhich supports logging of the "Implementation-Version" string | Class | org.springframework.xd.dirt.util.logging | Spring XD |
|
VersionPatternParser | Extension of Log4j's PatternParserthat recognizes the pattern %v which is used to log the | Class | org.springframework.xd.dirt.util.logging | Spring XD |
|
WebConfiguration | Provides Spring MVC configuration. | Class | org.springframework.xd.dirt.web | Spring XD |
|
WritableModuleRegistry | Base interface for registries that know how to create (and hence how to delete) new module definitions. | Interface | org.springframework.xd.dirt.module | Spring XD |
|
WritableResourceModuleRegistry | Writable extension of ResourceModuleRegistry. | Class | org.springframework.xd.dirt.module | Spring XD |
|
XdConfigLoggingInitializer | Initializer that can print useful stuff about an XD context on startup. | Class | org.springframework.xd.dirt.util | Spring XD |
|
XDController | Base Class for XD Controllers. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
XDController .QueryOptions | Data holder class for controlling how the list methods should behave. | Class | org.springframework.xd.dirt.rest.XDController | Spring XD |
|
XDDSLMessages | Contains all the messages that can be produced during Spring XD DSL parsing. | Class | org.springframework.xd.dirt.stream.dsl | Spring XD |
|
XDDSLMessages .Kind | | Class | org.springframework.xd.dirt.stream.dsl.XDDSLMessages | Spring XD |
|
XdErrorController | ErrorController that causes 404 errors to be redirected to the Admin-UI 404 page. | Class | org.springframework.xd.dirt.rest | Spring XD |
|
XdHeaders | Spring Integration message headers for XD. | Class | org.springframework.xd.dirt.integration.bus | Spring XD |
|
XdJdbcSearchableJobExecutionDao | | Class | org.springframework.xd.dirt.job.dao | Spring XD |
|
XDJobListenerConstants | Interface holdings constants related to XD JobListeners. | Interface | org.springframework.xd.dirt.plugins.job.support.listener | Spring XD |
|
XDParser | Parser to convert a DSL string for a deployable unit (i. | Interface | org.springframework.xd.dirt.stream | Spring XD |
|
XdProfiles | Static constants for XD server's spring profile names. | Class | org.springframework.xd.dirt.util | Spring XD |
|
XDStreamParser | Parser to convert a DSL string for a stream into a list ofobjects that comprise the given stream. | Class | org.springframework.xd.dirt.stream | Spring XD |
|
XDStreamParser .MultiLineDocumentParser | A wrapper around the canonical parser that supports multiline "document" parsing. | Class | org.springframework.xd.dirt.stream.XDStreamParser | Spring XD |
|
XdUtils | Provides general utilities for Spring XD. | Class | org.springframework.xd.dirt.util | Spring XD |
|
ZKDeploymentHandler | Abstract class that has common implementations of ZK based deployments. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ZKDeploymentMessagePublisher | ZooKeeper based DeploymentMessagePublisher that publishesdeployment messages into a ZooKeeper/Curator | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ZKJobDeploymentHandler | Deployment handler that is responsible for the deployment of a Job. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ZKStreamDeploymentHandler | Deployment handler that is responsible for deploying Stream. | Class | org.springframework.xd.dirt.server.admin.deployment.zk | Spring XD |
|
ZooKeeperAccessException | Runtime exception used to wrap native ZooKeeper checked exceptions thrown whileaccessing ZooKeeper nodes. | Class | org.springframework.xd.dirt.zookeeper | Spring XD |
|
ZooKeeperAdminRepository | ZooKeeper backed repository for runtime info about Admins. | Class | org.springframework.xd.dirt.container.store | Spring XD |
|
ZooKeeperComposedModuleDefinitionRegistry | An implementation of WriteableModuleRegistry dedicated to CompositeModuleDefinitions and that usesZooKeeper as storage mechanism. | Class | org.springframework.xd.dirt.module.store | Spring XD |
|
ZooKeeperConnection | A wrapper for a CuratorFramework instance whose lifecycle is managed as a Spring bean. | Class | org.springframework.xd.dirt.zookeeper | Spring XD |
|
ZooKeeperConnectionConfigurer | A strategy interface for configuring ZooKeeperConnection at start up. | Interface | org.springframework.xd.dirt.zookeeper | Spring XD |
|
ZooKeeperConnectionListener | Listener for ZooKeeper connection and disconnection events. | Interface | org.springframework.xd.dirt.zookeeper | Spring XD |
|
ZookeeperConnectionPlugin | Supplies plugins with a reference to the Spring XD ZooKeeperConnectionAuthor:Marius Bogoevici | Class | org.springframework.xd.dirt.plugins | Spring XD |
|
ZooKeeperContainerRepository | ZooKeeper backed repository for runtime info about Containers. | Class | org.springframework.xd.dirt.container.store | Spring XD |
|
ZooKeeperJobDefinitionRepository | A Zookeeper backed repository for persisting JobDefinitions. | Class | org.springframework.xd.dirt.stream.zookeeper | Spring XD |
|
ZooKeeperJobRepository | Job instance repository. | Class | org.springframework.xd.dirt.stream.zookeeper | Spring XD |
|
ZooKeeperModuleDependencyRepository | ZooKeeper based implementation of ModuleDependencyRepository that writes each dependency to a node, such as:/xd/modules/[moduletype]/[modulename]/dependencies/[target]. | Class | org.springframework.xd.dirt.module.store | Spring XD |
|
ZooKeeperModuleMetadataRepository | ZooKeeper backed repository for runtime info about deployed modules. | Class | org.springframework.xd.dirt.module.store | Spring XD |
|
ZooKeeperStreamDefinitionRepository | | Class | org.springframework.xd.dirt.stream.zookeeper | Spring XD |
|
ZooKeeperStreamRepository | Stream instance repository. | Class | org.springframework.xd.dirt.stream.zookeeper | Spring XD |
|
ZooKeeperUtils | Utility methods for ZooKeeper. | Class | org.springframework.xd.dirt.zookeeper | Spring XD |
|
ZooKeeperUtils .StripPathConverter | Converter from ChildData to leaf name string. | Class | org.springframework.xd.dirt.zookeeper.ZooKeeperUtils | Spring XD |