Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



# Classes and Interfaces in #Spring XD - 951 results found.
NameDescriptionTypePackageFramework
AbstractBatchJobsControllerAbstract controller that all the XD batch admin controllers extend.Classorg.springframework.xd.dirt.restSpring XD
AbstractBusPropertiesAccessorClassorg.springframework.xd.dirt.integration.busSpring XD
AbstractComponentScanningBeanDefinitionProviderClassorg.springframework.xd.dirt.container.initializerSpring XD
AbstractDeployerAbstract implementation of the @link ResourceDeployer interface.Classorg.springframework.xd.dirt.streamSpring XD
AbstractEventClassorg.springframework.xd.dirt.eventSpring XD
AbstractExternalResourceTestSupportAbstract base class for JUnit Rules that detect the presence of some external resource.Classorg.springframework.xd.testSpring XD
AbstractExternalTableBase settings for all external tables;Since:1.Classorg.springframework.xd.greenplum.supportSpring XD
AbstractFieldMappingAwareDataMapperClassorg.springframework.xd.analytics.mlSpring XD
AbstractFromMessageConverterBase class for converters applied via Spring Integration 4.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
AbstractGPFDistMessageHandlerBase implementation of Spring Integration MessageHandler handling Message.Classorg.springframework.xd.greenplum.gpfdistSpring XD
AbstractHdfsItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XD
AbstractHdfsWriterClassorg.springframework.xd.hadoop.fsSpring XD
AbstractImportToJdbcOptionsMetadataFactors out options that are common to modules/jobs that import into a db table.Classorg.springframework.xd.jdbcSpring XD
AbstractInMemoryRepositoryBase implementation for an in-memory store, using a Map internally.Classorg.springframework.xd.storeSpring XD
AbstractInstancePersistingDeployerBase support class for deployers that know how to deal with instances of aAuthor:Eric Bottard, Ilayaperumal GopinathanClassorg.springframework.xd.dirt.streamSpring XD
AbstractJobPluginAbstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related toAuthor:Ilayaperumal Gopinathan, Gary RussellClassorg.springframework.xd.dirt.pluginsSpring XD
AbstractMailSourceBase class support for both "mail" and "imap".Classorg.springframework.xd.test.fixturesSpring XD
AbstractMessageBusBinderPluginAbstract Plugin that has common implementation methods to bind/unbind Module's message producers andconsumers to/from MessageBus.Classorg.springframework.xd.dirt.pluginsSpring XD
AbstractMetricsCommandsBase class to factor out similar behavior for all related metrics commands.Classorg.springframework.xd.shell.commandSpring XD
AbstractMetricSinkBase class for Metrics related sinks, makes sure named metric is deleted at end of test.Classorg.springframework.xd.test.fixturesSpring XD
AbstractModuleBase support class for modules, wrapping ModuleDescriptor and ModuleDeploymentProperties.Classorg.springframework.xd.module.coreSpring XD
AbstractModuleEventClassorg.springframework.xd.dirt.eventSpring XD
AbstractModuleFixtureBase class for objects that can be incorporated in a stream definition by calling their toString() method.Classorg.springframework.xd.test.fixturesSpring XD
AbstractPluginAbstract Plugin that contains no-op and common implementing methods.Classorg.springframework.xd.dirt.pluginsSpring XD
AbstractProcessBuilderTaskletAbstract tasklet for running code in a separate process and capturing the log output.Classorg.springframework.batch.step.tasklet.xSpring XD
AbstractReactorMessageHandlerAbstract base class for Reactor based MessageHandlers.Classorg.springframework.xd.reactorSpring XD
AbstractRedisRepositoryBase implementation for a store, using Redis behind the scenes.Classorg.springframework.xd.storeSpring XD
AbstractRepositoryHelper class for repositories, implementing some behavior in terms of unit methods.Classorg.springframework.xd.storeSpring XD
AbstractResourceBeanDefinitionProviderA OrderedContextInitializer base class for loading XML or Groovy Bean Definitions into the target ContainerAuthor:David TuranskiClassorg.springframework.xd.dirt.container.initializerSpring XD
AbstractSingleNodeNamedChannelModuleBase class for SingleNodeNamedChannel resources used to bind a MessageChannel to a shared channel using aAuthor:David TuranskiClassorg.springframework.xd.dirt.testSpring XD
AbstractSingleNodeNamedChannelModuleFactoryBase class for factories used to create NamedChannelSource and NamedChannelSink.Classorg.springframework.xd.dirt.testSpring XD
AbstractSingleNodeNamedChannelSinkBase class for SingleNode named channel sink types.Classorg.springframework.xd.dirt.test.sinkSpring XD
AbstractSingleNodeNamedChannelSourceBase class for SingleNode named channel source types.Classorg.springframework.xd.dirt.test.sourceSpring XD
AbstractSingleNodeProcessingChainA helper class for building single node streams that use a NamedChannelSource and NamedChannelSink.Classorg.springframework.xd.dirt.test.processSpring XD
AbstractStreamPluginAbstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related toAuthor:Ilayaperumal Gopinathan, Mark Fisher, Gary RussellClassorg.springframework.xd.dirt.pluginsSpring XD
AbstractTcpConnectionFactoryOptionsMetadataBase class for options metadata that deal with a tcp connection factory in some way.Classorg.springframework.xd.tcpSpring XD
AbstractTwitterInboundChannelAdapterClassorg.springframework.integration.x.twitterSpring XD
AddModuleOptionsExpansionStrategyAdds missing module options at the end of a well formed stream definition.Classorg.springframework.xd.dirt.stream.completionSpring XD
AdminDomain object for an XD admin runtime.Classorg.springframework.xd.dirt.clusterSpring XD
AdminAttributesRuntime metadata for a Admin server instance.Classorg.springframework.xd.dirt.clusterSpring XD
AdminControllerClassorg.springframework.xd.dirt.restSpring XD
AdminOptionsHolds configuration options that are valid for the Admin server, when using distributed mode.Classorg.springframework.xd.dirt.server.optionsSpring XD
AdminPortNotAvailableExceptionException thrown when the configured admin port is not available to use.Classorg.springframework.xd.dirt.server.adminSpring XD
AdminRepositoryRepository for persisting Admin entities for admins.Interfaceorg.springframework.xd.dirt.container.storeSpring XD
AdminServerApplicationClassorg.springframework.xd.dirt.server.adminSpring XD
AggregateCountRepresents the data returned from an aggregate count query.Classorg.springframework.xd.analytics.metrics.coreSpring XD
AggregateCounterCommandsCommands for interacting with aggregate counter analytics.Classorg.springframework.xd.shell.commandSpring XD
AggregateCounterHandlerHandles incoming messages for the aggregate-counter module, resolves SpEL expressionsas needed and delegate the heavy lifting to an AggregateCounterRepository.Classorg.springframework.xd.analytics.metrics.integrationSpring XD
AggregateCounterOperationsInterface defining operations available when dealing with Aggregate Counters.Interfaceorg.springframework.xd.rest.clientSpring XD
AggregateCounterRepositoryA repository to interact with Aggregate Counters.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
AggregateCountersControllerExposes representations of AggregateCounts.Classorg.springframework.xd.dirt.rest.metricsSpring XD
AggregateCounterSinkFixture class for an aggregate counter.Classorg.springframework.xd.test.fixturesSpring XD
AggregateCounterSinkOptionsMetadataCaptures options for the aggregate-counter sink module.Classorg.springframework.xd.analytics.metrics.metadataSpring XD
AggregateCounterTemplateClassorg.springframework.xd.rest.client.implSpring XD
AggregateCountResolutionenum AggregateCountResolutionThe resolution options available for querying an aggregate counter.Classorg.springframework.xd.analytics.metrics.coreSpring XD
AggregateCountsResourceThe REST representation of an Aggregate Count.Classorg.springframework.xd.rest.domain.metricsSpring XD
AggregatorProcessorModuleOptionsMetadataDescribes options to the aggregator processor module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
AlreadyDeployedExceptionThrown when an attempt is made to deploy a definition that is already deployed.Classorg.springframework.xd.dirt.streamSpring XD
AnalyticBase interface for the definition of analytical logic.Interfaceorg.springframework.xd.analytics.mlSpring XD
ApplicationUtilsClassorg.springframework.xd.dirt.serverSpring XD
AppmasterApplicationBoot appmaster application.Classorg.springframework.xd.yarnSpring XD
ArchiveResourceLoaderSpring ResourceLoader that can locate nested boot archives inside a root archive.Classorg.springframework.xd.module.supportSpring XD
ArgumentNodeRepresents an argument like "--name=value".Classorg.springframework.xd.dirt.job.dslSpring XD
ArgumentNodeRepresents an argument like "--name=value".Classorg.springframework.xd.dirt.stream.dslSpring XD
AsciidocLinkCheckerA tool that checks that for files that will form the whole "concatenated" documentation, any link of the form link::[Classorg.springframework.xd.documentationSpring XD
AssertionsVarious utility methods when dealing with shell commands.Classorg.springframework.xd.shell.utilSpring XD
AstNodeAST base class for AST nodes in a parsed Job specification.Classorg.springframework.xd.dirt.job.dslSpring XD
AstNodeCommon supertype for the ast nodes built during stream parsing.Classorg.springframework.xd.dirt.stream.dslSpring XD
AuthenticationRequestClassorg.springframework.xd.dirt.web.controller.supportSpring XD
AutoOffsetResetStrategyenum AutoOffsetResetStrategyThe possible values for automatically resetting the offset of Kafka clientClassorg.springframework.integration.x.kafkaSpring XD
AvailableSocketPortsUtility class to find available server ports.Classorg.springframework.xd.test.fixtures.utilSpring XD
BannerUtilsProvides utilities for rendering graphical console output.Classorg.springframework.xd.dirt.utilSpring XD
BaseDefinitionRepresents the base model for a data flow in the system.Classorg.springframework.xd.dirt.coreSpring XD
BaseInstanceA runtime representation of a Definition.Classorg.springframework.xd.dirt.streamSpring XD
BatchJobAlreadyExistsExceptionException thrown when the batch job with the given name already exists.Classorg.springframework.xd.dirt.jobSpring XD
BatchJobAlreadyExistsInRegistryExceptionException thrown when a batch job already exists in the JobRegistry.Classorg.springframework.xd.dirt.plugins.jobSpring XD
BatchJobCommitIntervalOptionMixinBatch job option for commit-interval.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchJobDeleteFilesOptionMixinBatch job option for delete files after import.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchJobExecutionsControllerController for batch job executions.Classorg.springframework.xd.dirt.restSpring XD
BatchJobFieldDelimiterOptionMixinBatch job option for the delimiter in the file (csv file etc.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchJobFieldNamesOptionMixinBatch job option for fields names in the file (csv file etc.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchJobHeadersHeaders definitions used by the batch job plugin.Classorg.springframework.xd.dirt.plugins.jobSpring XD
BatchJobInstancesControllerController for batch job instances.Classorg.springframework.xd.dirt.restSpring XD
BatchJobListenerAbstract batch job listener that sends batch job listener payload to the SubscribableChannel notificationAuthor:Ilayaperumal GopinathanClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
BatchJobRegistryBeanPostProcessorJobRegistryBeanPostProcessor that processes batch job from the job module.Classorg.springframework.xd.dirt.plugins.jobSpring XD
BatchJobResourcesOptionMixinBatch job option for resources (Spring resources) to import.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchJobRestartableOptionMixinBatch job option for restartable.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchJobsControllerController for batch jobs and job instances, job executions on a given batch job.Classorg.springframework.xd.dirt.restSpring XD
BatchJobSinglestepPartitionSupportOptionMixinCaptures options made available via the import of singlestep-partition-support.Classorg.springframework.xd.module.options.mixinsSpring XD
BatchListenerEventTypeenum BatchListenerEventTypeEnumerations to help identify various Batch job events being issued.Classorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
BatchStepExecutionsControllerController for returning Batch StepExecutions.Classorg.springframework.xd.dirt.restSpring XD
BeanPropertiesPropertySourceA PropertySource that exposes the javabeans properties of an object as properties.Classorg.springframework.xd.dirt.server.optionsSpring XD
BindingRepresents a binding between a module's channel and an adapter endpoint that connects to the MessageBus.Classorg.springframework.xd.dirt.integration.busSpring XD
BroadcasterMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to a StreamClassorg.springframework.xd.reactorSpring XD
BusCleanerInterface for implementations that perform cleanup for message buses.Interfaceorg.springframework.xd.dirt.integration.busSpring XD
BusPropertiesCommon bus properties.Interfaceorg.springframework.xd.dirt.integration.busSpring XD
BusTestUtilsClassorg.springframework.xd.dirt.integration.busSpring XD
BusUtilsMessage Bus utilities.Classorg.springframework.xd.dirt.integration.busSpring XD
ByteArrayToStringMessageConverterto convert from byte[] to String applying the Charset provided inthe content-type header if any.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
CacheServerA simple driver class to run a Gemfire cache server.Classorg.springframework.xd.gemfire.serverSpring XD
CassandraConfigurationClassorg.springframework.xd.cassandraSpring XD
CassandraConnectionMixinClassorg.springframework.xd.cassandra.mixinsSpring XD
CassandraSinkConfigurationClassorg.springframework.xd.cassandraSpring XD
CassandraSinkOptionsMetadataClassorg.springframework.xd.cassandraSpring XD
ChannelNodeClassorg.springframework.xd.dirt.stream.dslSpring XD
ChannelTypeClassorg.springframework.xd.dirt.stream.dslSpring XD
CheckpointedJobDefinitionExceptionAn extension of JobSpecificationException that remembers the point up to which parsing went OK (signaled by a '*' inthe dumped message).Classorg.springframework.xd.dirt.job.dslSpring XD
CheckpointedStreamDefinitionExceptionAn extension of StreamDefinitionException that remembers the point up to which parsing went OK (signaled by a '*' inthe dumped message).Classorg.springframework.xd.dirt.stream.dslSpring XD
ChildPathIteratorIterator over ChildData instances that are managed by PathChildrenCache.Classorg.springframework.xd.dirt.zookeeperSpring XD
ChunkContextInfoClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
ClasspathEnvironmentProviderClassorg.springframework.batch.step.tasklet.xSpring XD
ClientApplicationCli for controlling XD instances on an application master.Classorg.springframework.xd.yarnSpring XD
ClientTcpConnectionFactoryOptionsMetadataMixinMixin for options metadata that configure a client tcp connection factory.Classorg.springframework.xd.tcpSpring XD
CommandLinePropertySourceOverridingListenerAn ApplicationListener that will parse command line options and also replace the default boot commandlinePropertySource with those values.Classorg.springframework.xd.dirt.server.optionsSpring XD
CommonDistributedOptionsHolds options that are common to both admin and container servers, when used in distributed mode.Classorg.springframework.xd.dirt.server.optionsSpring XD
CommonOptionsBase class for command line options that are common to absolutely every setup (single and distributed).Classorg.springframework.xd.dirt.server.optionsSpring XD
CommonUtilsContains common non-ui related helper methods for rendering text to the console.Classorg.springframework.xd.shell.utilSpring XD
CompletionConverterA converter that provides DSL completion wherever parts of stream definitions may appear.Classorg.springframework.xd.shell.converterSpring XD
CompletionExpansionStrategyUsed to enhance a well formed stream definition by adding yet more text to it (e.Interfaceorg.springframework.xd.dirt.stream.completionSpring XD
CompletionKindUsed to represent the context in which the code completion facility is invoked.Classorg.springframework.xd.rest.domainSpring XD
CompletionOperationsProvides access to the dsl completion facility.Interfaceorg.springframework.xd.rest.clientSpring XD
CompletionProviderProvides code completion on a (maybe ill-formed) stream definition.Classorg.springframework.xd.dirt.stream.completionSpring XD
CompletionRecoveryStrategyUsed to provide completions on ill-formed stream definitions, after an initial (failed) parse.Interfaceorg.springframework.xd.dirt.stream.completionSpring XD
CompletionsControllerExposes completion for stream-like definitions as a REST endpoint.Classorg.springframework.xd.dirt.restSpring XD
CompletionTemplateClassorg.springframework.xd.rest.client.implSpring XD
ComposedJobUtilClassorg.springframework.xd.dirt.job.dslSpring XD
CompositeMessageConverterFactoryA factory for creating an instance of CompositeMessageConverter for a given target MIME typeAuthor:David TuranskiClassorg.springframework.xd.dirt.integration.bus.converterSpring XD
CompositeModuleClassorg.springframework.xd.module.coreSpring XD
CompositeModuleDefinitionA module definition for a module which has been custom created as the composition of several othermodules (either simple orClassorg.springframework.xd.moduleSpring XD
ConfigCommandsDefines several shell commands in order to configure the shell itself.Classorg.springframework.xd.shell.commandSpring XD
ConfigLocationsStatic constants for configuration locations.Classorg.springframework.xd.dirt.utilSpring XD
ConfigurationEncapsulates various configuration properties for the shell such as Targetand the configurable TimeZone.Classorg.springframework.xd.shellSpring XD
ConfigurationAwareUtility base class for components monitoring Configuration changes in order to update state.Classorg.springframework.xd.shell.hadoopSpring XD
ConfigurationCommandsCommand for configuring the global Hadoop Configuration object used by other components.Classorg.springframework.xd.shell.hadoopSpring XD
ConfigurationModifiedEventNotification event that a Configuration object (attached) has been modified.Classorg.springframework.xd.shell.hadoopSpring XD
ConfigUtilTools to create and read configuration files for an environment deployed on EC2.Classorg.springframework.xd.integration.utilSpring XD
ConnectionFactorySettingsConfigures the connection factory used by the rabbit message bus.Classorg.springframework.xd.dirt.integration.rabbitSpring XD
ConsoleUserInputUserInput that uses Standard in and out.Classorg.springframework.xd.shell.commandSpring XD
ContainerDomain object for an XD container.Classorg.springframework.xd.dirt.clusterSpring XD
ContainerAttributesMetadata for a Container instance.Classorg.springframework.xd.dirt.clusterSpring XD
ContainerBootstrapContextPackage private class to bootstrap the Container process.Classorg.springframework.xd.dirt.server.containerSpring XD
ContainerConfigurationContainer Application ContextAuthor:David Turanski, Ilayaperumal Gopinathan, Marius BogoeviciClassorg.springframework.xd.dirt.server.containerSpring XD
ContainerFilterA filter interface that applies filter for the given containers and returnseligible containers for deployment.Interfaceorg.springframework.xd.dirt.clusterSpring XD
ContainerInfoPluginA plugin that exposes information about the container to the Environment.Classorg.springframework.xd.dirt.pluginsSpring XD
ContainerListenerListener implementation that is invoked when containers are added/removed/modified.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ContainerMatcherModuleDescriptor to.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
ContainerMatchingModuleRedeployerThe ModuleRedeployer that deploys the unallocated stream/job modules.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ContainerOptionsHolds configuration options that are valid for the Container node, when using distributed mode.Classorg.springframework.xd.dirt.server.optionsSpring XD
ContainerRegistrarAn 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.Classorg.springframework.xd.dirt.server.containerSpring XD
ContainerRepositoryRepository for persisting Container entities.Interfaceorg.springframework.xd.dirt.container.storeSpring XD
ContainerResolverResolve runtime hosts for modules.Classorg.springframework.xd.integration.fixturesSpring XD
ContainersControllerHandles interaction with the runtime containers/and its modules.Classorg.springframework.xd.dirt.restSpring XD
ContainerServerApplicationThe boot application class for a Container server.Classorg.springframework.xd.dirt.server.containerSpring XD
ContainerShutdownExceptionException thrown when shutting down the containerAuthor:Ilayaperumal GopinathanSee Also:Serialized FormClassorg.springframework.xd.dirt.clusterSpring XD
ControlFileClassorg.springframework.xd.greenplum.supportSpring XD
ControlFileFactoryBeanClassorg.springframework.xd.greenplum.supportSpring XD
ConversionExceptionException thrown when an error is encountered during message conversion.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
CounterRepresents the data stored in a valueer of a single value.Classorg.springframework.xd.analytics.metrics.coreSpring XD
CounterCommandsCommands for interacting with Counter analytics.Classorg.springframework.xd.shell.commandSpring XD
CounterOperationsInterface defining operations available when dealing with Counters.Interfaceorg.springframework.xd.rest.clientSpring XD
CounterRepositoryInterface for repositories that now how to deal with Counters.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
CounterResourceThe REST representation of a Counter.Classorg.springframework.xd.rest.domain.metricsSpring XD
CountersControllerExposes representations of Counters.Classorg.springframework.xd.dirt.rest.metricsSpring XD
CounterSinkFixture class for an "simple" counter.Classorg.springframework.xd.test.fixturesSpring XD
CounterTemplateClassorg.springframework.xd.rest.client.implSpring XD
CronExpressionThe annotated element must be a valid Spring cron expression (6 fields).Classorg.springframework.xd.module.options.validationSpring XD
CronValidationClassorg.springframework.xd.rest.domain.validationSpring XD
CustomLoggerConverterClassorg.springframework.xd.dirt.util.loggingSpring XD
CustomMimeTypeConverterA custom converter for MediaType that accepts a plain java class name as a shorthand forapplication/x-java-object;type=the.Classorg.springframework.xd.dirt.plugins.streamSpring XD
CustomModuleRegistryFactoryBeanWill create a SynchronizingModuleRegistry for hosting custom modules if necessary, depending on theprotocol scheme (using a synchronizing registry for everything but file:// protocol).Classorg.springframework.xd.dirt.moduleSpring XD
DatabaseVendorFriendlyNameFactoryBeanA factory bean that returns a friendly string name from database metadata.Classorg.springframework.xd.dirt.jdbc.utilSpring XD
DatasetDefinitionFactoryBeanFactoryBean that creates a default DatasetDefinitionAuthor:Thomas RisbergClassorg.springframework.xd.hadoop.fsSpring XD
DatasetOutboundChannelAdapterParserParser for the 'dataset-outbound-channel-adapter' element.Classorg.springframework.xd.integration.hadoop.configSpring XD
DatasetWriterClassorg.springframework.xd.hadoop.fsSpring XD
DatasetWriterFactoryClassorg.springframework.xd.hadoop.fsSpring XD
DatasetWritingMessageHandlerFactoryBeanFactory bean used to create HdfsWritingMessageHandlerAuthor:Thomas RisbergClassorg.springframework.xd.integration.hadoop.configSpring XD
DateFormatThe annotated must be a valid SimpleDateFormat pattern.Classorg.springframework.xd.module.options.validationSpring XD
DateFormatMixinProvides a dateFormat module option, meant to hold a pattern that conforms to SimpleDateFormat.Classorg.springframework.xd.module.options.mixinsSpring XD
DateTriggerA Trigger implementation that enables execution on a series of Dates.Classorg.springframework.xd.module.supportSpring XD
DateWithCustomFormatUsed as a class level annotation to cross-validate a String representation of a date according to a date formatwhich is itself a property of the annotated class.Classorg.springframework.xd.module.options.validationSpring XD
DeepAggregateCountResourceAssemblerKnows how to construct AggregateCountsResource out of AggregateCount.Classorg.springframework.xd.dirt.rest.metricsSpring XD
DeepCounterResourceAssemblerKnows how to assemble CounterResources out of Counters.Classorg.springframework.xd.dirt.rest.metricsSpring XD
DeepFieldValueCounterResourceAssemblerKnows how to create rich representations of FieldValueCounter.Classorg.springframework.xd.dirt.rest.metricsSpring XD
DefaultDeploymentStateRecalculatorStream/Job deployment state re-calculator upon leadership election.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DefaultDeploymentUnitStateCalculatorDefault DeploymentUnitStateCalculatorIf all expected modules are deployed, the state is consideredClassorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DefaultDistributedTestSupportClassorg.springframework.xd.distributed.utilSpring XD
DefaultGreenplumLoadClassorg.springframework.xd.greenplum.supportSpring XD
DefaultLoadServiceClassorg.springframework.xd.greenplum.supportSpring XD
DefaultModuleDeploymentPropertiesProviderDefault implementation that retrieves the ModuleDeploymentProperties for the givenAuthor:Ilayaperumal GopinathanClassorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DefaultModuleOptionsMetadataCollectorClassorg.springframework.xd.module.optionsSpring XD
DefaultModuleOptionsMetadataResolverThe default implementation of ModuleOptionsMetadataResolver that deals with simple modules and reads thecompanion .Classorg.springframework.xd.module.optionsSpring XD
DefaultSimpleModuleInformationResolverDefault implementation of ModuleInformationResolver that supportsSimpleModuleDefinitions and that reads Strings fromClassorg.springframework.xd.module.infoSpring XD
DefaultSparkStreamingModuleOptionsMetadataDefault module options for SparkStreamingSupport.Classorg.springframework.xd.spark.streamingSpring XD
DefaultTupleDefault implementation of Tuple interfaceAuthor:Mark Pollack, David Turanski, Michael MinellaClassorg.springframework.xd.tupleSpring XD
DefaultTupleConversionServiceBase ConversionService implementation suitable for use with TupleAuthor:David TuranskiClassorg.springframework.xd.tupleSpring XD
DefaultTupleSerializerDeserializes Tuples by writing the field names and then the values as class/object pairsfollowed by the tuple Id and timestamp.Classorg.springframework.xd.tuple.serializer.kryoSpring XD
DefinitionAlreadyExistsExceptionException which is raised when a resource definition with the same name already exists.Classorg.springframework.xd.dirt.streamSpring XD
DelegatingModuleInformationResolverA composite resolver that will try delegates until one returns a non null result.Classorg.springframework.xd.module.infoSpring XD
DelegatingModuleOptionsMetadataResolverA ModuleOptionsMetadataResolver that will invoke several other ModuleOptionsMetadataResolverinstances in turn and merge their results (flattening them).Classorg.springframework.xd.module.optionsSpring XD
DelegatingModuleRegistryA ModuleRegistry that delegates to several ModuleRegistries, in order.Classorg.springframework.xd.dirt.moduleSpring XD
DelimitedStringToMapPropertyEditorConverts a String of comma delimited name-value pairs to a Map.Classorg.springframework.xd.extension.processSpring XD
DepartedContainerModuleRedeployerThe ModuleRedeployer that re-deploys the stream/job modules that weredeployed into the departing container.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DependencyExceptionThrown when performing an action cannot be carried over because some dependency would be broken.Classorg.springframework.xd.dirt.moduleSpring XD
DeployableResourceAbstract base class for resources that represent deployable units.Classorg.springframework.xd.rest.domainSpring XD
DeploymentActionenum DeploymentActionEnum class for the supported deployment actions.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentConfigurationConfiguration class that holds the beans required for deployment management.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DeploymentExceptionException thrown when DeploymentHandler encounters problemwhen deploying/un-deploying stream/job.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentHandlerDeployment handler that is responsible for deploying/un-deploying theDeploymentUnit (Stream/Job) to/from the container.Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentLoaderUtility for loading streams and jobs for the purpose of deployment.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DeploymentMessageThe message that wraps the details of a deployment request.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentMessageConsumerConsumer for DeploymentMessagewhich delegates to the corresponding @ResourceDeployerClassorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DeploymentMessagePublisherPublisher that defines the contract to publish the DeploymentMessage.Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentOptionKeysUsed to factor out names of the options that are shared by all deploy commands.Classorg.springframework.xd.shell.commandSpring XD
DeploymentPropertiesFormatProvides utility methods for formatting and parsing deployment properties.Classorg.springframework.xd.rest.domain.supportSpring XD
DeploymentPropertiesUtilityClass that provides utility methods to handle module deployment properties.Classorg.springframework.xd.dirt.utilSpring XD
DeploymentQueueThis class controls the lifecycle operations of the ZK distributed queue thatholds the DeploymentMessages.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DeploymentStatusRepositoryInterface definition for repositories that support the reportingof deployment unit state.Interfaceorg.springframework.xd.dirt.coreSpring XD
DeploymentSupervisorProcess that watches ZooKeeper for Container arrivals and departures fromthe XD cluster.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
DeploymentUnitDeploymentUnit is a collection of modules that are intended to bedeployed as a single unit.Interfaceorg.springframework.xd.dirt.coreSpring XD
DeploymentUnitStateCalculatorCalculates the overall status for a deployment unit (stream or job).Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentUnitStatusStatus for a DeploymentUnit.Classorg.springframework.xd.dirt.coreSpring XD
DeploymentUnitTypeenum DeploymentUnitTypeEnum class that defines the deployment unit type.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
DeploymentValidatorThis interface defines validation methods that verify a stream or jobcan be saved, deployed, undeployed, or deleted.Interfaceorg.springframework.xd.dirt.streamSpring XD
DetailedContainerDomain object for an XD container with detailed info (deployed modules, messageRates etc.Classorg.springframework.xd.dirt.container.storeSpring XD
DetailedContainerResourceRepresents container info model.Classorg.springframework.xd.rest.domainSpring XD
DetailedJobInfoA job info for batch jobs that provides more details than the base JobInfoAuthor:Andrew Eisenberg, Ilayaperumal GopinathanClassorg.springframework.xd.dirt.jobSpring XD
DetailedJobInfoResourceRepresents Expanded Batch job info that has more details on batch jobs.Classorg.springframework.xd.rest.domainSpring XD
DetailedJobInfoResourceAssemblerKnows how to build a REST resource out of our domain model DetailedJobInfo.Classorg.springframework.xd.dirt.restSpring XD
DetailedModuleDefinitionResourceClassorg.springframework.xd.rest.domainSpring XD
DetailedModuleDefinitionResourceAssemblerKnows how to build DetailedModuleDefinitionResource out of a ModuleDefinition.Classorg.springframework.xd.dirt.restSpring XD
DirtExceptionRoot of the hierarchy of exceptions for DIRT (Distributed Integration RunTime).Classorg.springframework.xd.dirtSpring XD
DisposableTo be implemented by fixtures that need special cleanup when a test is done.Interfaceorg.springframework.xd.test.fixturesSpring XD
DisposableFileSupportBase class for stream elements that deal with file locations.Classorg.springframework.xd.test.fixturesSpring XD
DisposableMailSupportBase class for fixtures that interact with a mail server.Classorg.springframework.xd.test.fixturesSpring XD
DistributedJobLocatorto work with batch jobs in a distributed environment.Classorg.springframework.xd.dirt.plugins.jobSpring XD
DistributedJobServiceSimpleJobService in distributed modeAuthor:Ilayaperumal Gopinathan, Andrew Eisenberg, Gunnar HillertClassorg.springframework.xd.dirt.plugins.jobSpring XD
DistributedTestSupportProvides support methods for building distributed system tests.Interfaceorg.springframework.xd.distributed.utilSpring XD
DocumentParseResultRepresents the result of parsing a multiline document, made of several definitions.Classorg.springframework.xd.dirt.streamSpring XD
DocumentParseResultResourceRepresents the result of parsing a multiline definition document.Classorg.springframework.xd.rest.domainSpring XD
DocumentParseResultResourceAssemblerThis class is responsible for creating a REST representation of a DocumentParseResult.Classorg.springframework.xd.dirt.restSpring XD
DomainRepositoryInterfaceorg.springframework.xd.storeSpring XD
EmbeddedHeadersMessageConverterEncodes requested headers into payload with format0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] .Classorg.springframework.xd.dirt.integration.busSpring XD
EmbeddedZooKeeperHelper class to start an embedded instance of standalone (non clustered) ZooKeeper.Classorg.springframework.xd.dirt.zookeeperSpring XD
EmbeddedZookeeperA port of kafka.Classorg.springframework.xd.test.kafkaSpring XD
EmptyStartYieldsModulesRecoveryStrategyClassorg.springframework.xd.dirt.stream.completionSpring XD
EncoderDecoderMixinsProvides mixins for encoder/decoder options.Classorg.springframework.xd.tcp.encdecSpring XD
EnvironmentAwareModuleOptionsMetadataResolverA decorator around another ModuleOptionsMetadataResolver that will provide default values for module optionsusing the environment.Classorg.springframework.xd.module.optionsSpring XD
EventuallyMatcherA matcher that will evaluate another matcher repeatedly until it matches, or fail after some number of attempts.Classorg.springframework.xd.test.fixturesSpring XD
ExclusivesUtility class for assisting in checking that mutually exclusive options are correctly set.Classorg.springframework.xd.module.options.validationSpring XD
ExecutionContextJacksonMixInJackson MixIn for the JSON serialization of the ExecutionContext class, which is used by theStepExecution class.Classorg.springframework.xd.dirt.plugins.job.supportSpring XD
ExecutionContextJacksonMixInJackson MixIn for ExecutionContext de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
ExistingXDEntityConverterA no-op converter from String to String, but that helps with completion in names of already existing entities.Classorg.springframework.xd.shell.converterSpring XD
ExpandedJobParametersConverterMore flexible implementation of the JobParametersConverter.Classorg.springframework.xd.dirt.plugins.jobSpring XD
ExpandOneDashToTwoDashesRecoveryStrategyProvides completion when the user has typed in the first dash to a module option.Classorg.springframework.xd.dirt.stream.completionSpring XD
ExpressionOrScriptMixinA standard mixin for modules that do some transformation based on either a script or a SpEL expression.Classorg.springframework.xd.module.options.mixinsSpring XD
ExtendedResourceA wrapper around a Resource that adds capabilities lacking in the original interface.Classorg.springframework.xd.dirt.moduleSpring XD
FieldSetConverterA converter that maps from the batch FieldSet world to Mongo's DBObject.Classorg.springframework.xd.mongodbSpring XD
FieldSetSqlParameterSourceProviderAn ItemSqlParameterSourceProvider that will derive parameters from a FieldSet.Classorg.springframework.xd.batch.item.jdbcSpring XD
FieldSetTypeEnum used to provide typing information when reading from a file.Classorg.springframework.xd.tuple.batchSpring XD
FieldValueCounterRepresents the data stored in a Counter for multiple field-value pairs.Classorg.springframework.xd.analytics.metrics.coreSpring XD
FieldValueCounterCommandsCommands for interacting with field value counter analytics.Classorg.springframework.xd.shell.commandSpring XD
FieldValueCounterHandlerCounts the occurrence of values for a set of JavaBean properties or Tuple fields using a FieldValueCounterRepository.Classorg.springframework.xd.analytics.metrics.integrationSpring XD
FieldValueCounterOperationsInterface defining operations available when dealing with Field Value Counters.Interfaceorg.springframework.xd.rest.clientSpring XD
FieldValueCounterRepositoryA repository to save, delete and find FieldValueCounter instances.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
FieldValueCounterResourceClassorg.springframework.xd.rest.domain.metricsSpring XD
FieldValueCountersControllerController that exposes FieldValueCounter related representations.Classorg.springframework.xd.dirt.rest.metricsSpring XD
FieldValueCounterSinkOptionsMetadataCaptures options for the field-value-counter sink module.Classorg.springframework.xd.analytics.metrics.metadataSpring XD
FieldValueCounterTemplateClassorg.springframework.xd.rest.client.implSpring XD
FileAsRefMixinA mixin that can be used every time a module dealing with Files offersthe choice to pass along the File itself or its contents.Classorg.springframework.xd.dirt.modules.metadataSpring XD
FileAuthenticationConfigurationA security configuration that conditionally sets up in-memory users from a file.Classorg.springframework.xd.dirt.server.securitySpring XD
FileDeletionStepExecutionListenerStep listener which can be used to delete files once they have been successfully processed by XD.Classorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
FileJdbcJobClassorg.springframework.xd.test.fixturesSpring XD
FileJdbcJobOptionsMetadataCaptures options for the filejdbc job.Classorg.springframework.xd.jdbcSpring XD
FileLoggerClassorg.springframework.xd.spark.streaming.examples.javaSpring XD
FileLoggerModuleOptionsMetadataClassorg.springframework.xd.spark.streaming.examples.javaSpring XD
FilePollHdfsJobTest fixture that creates a File Poll Hdfs Job.Classorg.springframework.xd.test.fixturesSpring XD
FilePollHdfsJobOptionsMetadataDescribes the options for the filepollhdfs job.Classorg.springframework.xd.dirt.modules.metadataSpring XD
FileReadingModeenum FileReadingModeDefines the supported modes of reading and processing files for theClassorg.springframework.xd.dirt.modules.metadataSpring XD
FileSinkSupport class to capture output of a sink in a File.Classorg.springframework.xd.test.fixturesSpring XD
FileSinkOptionsMetadataHolds options to the 'file' sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
FileSourceSupport class that represents the file source module.Classorg.springframework.xd.test.fixturesSpring XD
FileSourceOptionsMetadataHolds module options metadata about the file source.Classorg.springframework.xd.dirt.modules.metadataSpring XD
FixtureUtilsUtility to support common tasks done by fixtures.Classorg.springframework.xd.test.fixtures.utilSpring XD
FlattenedCompositeModuleOptionsMetadataA composite ModuleOptionsMetadata made of several ModuleOptionsMetadata that will appear "flattened".Classorg.springframework.xd.module.optionsSpring XD
FlowThe AST node representing a flow.Classorg.springframework.xd.dirt.job.dslSpring XD
FormatClassorg.springframework.xd.greenplum.supportSpring XD
FromMongoDbOptionMixinAn option class to mix-in when reading from MongoDB.Classorg.springframework.xd.module.options.mixinsSpring XD
FromStringCharsetMixinA standard mixin for modules that do conversion from String to bytes.Classorg.springframework.xd.module.options.mixinsSpring XD
FsShellCommandsClassorg.springframework.xd.shell.hadoopSpring XD
FtpConnectionMixinA mixin that can be used anytime a connection to an FTP server is needed.Classorg.springframework.xd.module.options.mixinsSpring XD
FtpHdfsJobTest fixture that creates a Ftp Hdfs Job.Classorg.springframework.xd.test.fixturesSpring XD
FtpHdfsJobOptionsMetadataDescribes the options for the ftphdfs job.Classorg.springframework.xd.dirt.modules.metadataSpring XD
FtpSinkA fixture that helps testing the ftp sink.Classorg.springframework.xd.test.fixturesSpring XD
FtpSinkOptionsMetadataModule options for the FTP sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
FtpSourceA fixture that helps testing the ftp source.Classorg.springframework.xd.test.fixturesSpring XD
FtpSourceOptionsMetadataModule options for FTP source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
GaugeRepresents the data stored in a Gauge which can be set to any integral value.Classorg.springframework.xd.analytics.metrics.coreSpring XD
GaugeCommandsCommands for interacting with Gauge analytics.Classorg.springframework.xd.shell.commandSpring XD
GaugeHandlerClassorg.springframework.xd.analytics.metrics.integrationSpring XD
GaugeOperationsInterface defining operations available when dealing with Gauge.Interfaceorg.springframework.xd.rest.clientSpring XD
GaugeRepositoryA marker interface for Gauge repositories.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
GaugeResourceThe REST representation of a Gauge.Classorg.springframework.xd.rest.domain.metricsSpring XD
GaugesControllerExposes representations of Gauges.Classorg.springframework.xd.dirt.rest.metricsSpring XD
GaugeTemplateClassorg.springframework.xd.rest.client.implSpring XD
GemFireCQSourceCreate a gemfire CQ (continuous query) source.Classorg.springframework.xd.test.fixturesSpring XD
GemfireCQSourceOptionsMetadataDescribes options to the gemfire-cq source module.Classorg.springframework.xd.gemfireSpring XD
GemfireHostPortMixinClassorg.springframework.xd.gemfireSpring XD
GemFireServerSinkCreate a gemfire-server or gemfire-json-server sink.Classorg.springframework.xd.test.fixturesSpring XD
GemfireServerSinkModuleOptionsMetadataCaptures module options for the "gemfire-server" and "gemfire-json-server" sink modules.Classorg.springframework.xd.gemfireSpring XD
GemFireSourceCreate a gemfire sourceAuthor:David TuranskiClassorg.springframework.xd.test.fixturesSpring XD
GemfireSourceOptionsMetadataDescribes options to the gemfire source module.Classorg.springframework.xd.gemfireSpring XD
GeneratorExceptionCore exception for generators.Classorg.springframework.xd.test.generatorSpring XD
GPFDistCodecClassorg.springframework.xd.greenplum.gpfdistSpring XD
GPFDistMessageHandlerClassorg.springframework.xd.greenplum.gpfdistSpring XD
GPFDistServerClassorg.springframework.xd.greenplum.gpfdistSpring XD
GPFDistSinkOptionsMetadataConfig options for gpfdist sink.Classorg.springframework.xd.greenplum.configSpring XD
GploadEnvironmentProviderClassorg.springframework.xd.gploadSpring XD
GploadOptionsMetadataModule options for Gpload batch job module.Classorg.springframework.xd.gploadSpring XD
GploadTaskletTasklet used for running gpload tool.Classorg.springframework.xd.gploadSpring XD
GraphRepresents a Graph that Flo will display.Classorg.springframework.xd.dirt.job.dslSpring XD
GreenplumDataSourceFactoryBeanFactory bean for configuring a DataSource.Classorg.springframework.xd.greenplum.supportSpring XD
HadoopConfigurationMixinFactors out common configuration options for Hadoop.Classorg.springframework.xd.module.options.mixinsSpring XD
HadoopNamespaceHandlerNamespace handler for Spring Integration's 'hadoop' namespace.Classorg.springframework.xd.integration.hadoop.configSpring XD
HadoopUtilsClassorg.springframework.xd.integration.utilSpring XD
HdfsDataStoreMessageHandlerSpring Integration MessageHandler handling Message writing into hdfs using DataStoreWriter.Classorg.springframework.xd.integration.hadoop.outboundSpring XD
HdfsJdbcJobClassorg.springframework.xd.test.fixturesSpring XD
HdfsMongoDbJobClassorg.springframework.xd.test.fixturesSpring XD
HdfsMongodbJobOptionsMetadataOptions for Hdfs to Mongodb export job module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
HdfsOutboundChannelAdapterParserParser for the 'hdfs-outbound-channel-adapter' element.Classorg.springframework.xd.integration.hadoop.configSpring XD
HdfsPartitionDataStoreMessageHandlerSpring Integration MessageHandler handling Message writing into hdfs using PartitionDataStoreWriter.Classorg.springframework.xd.integration.hadoop.outboundSpring XD
HdfsSinkA test fixture that allows testing of the 'hdfs' sink module.Classorg.springframework.xd.test.fixturesSpring XD
HdfsStoreMessageHandlerBase implementation of Spring Integration MessageHandler handling Message.Classorg.springframework.xd.integration.hadoop.outboundSpring XD
HdfsStoreMessageHandlerFactoryBeanA message handler factory bean which differentiates whether HdfsStoreMessageHandlershould be based on either HdfsPartitionDataStoreMessageHandler or HdfsDataStoreMessageHandler.Classorg.springframework.xd.integration.hadoop.configSpring XD
HdfsTextFileWriterClassorg.springframework.xd.hadoop.fsSpring XD
HdfsTextFileWriterFactoryClassorg.springframework.xd.hadoop.fsSpring XD
HdfsTextItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XD
HdfsWriterInterfaceorg.springframework.xd.hadoop.fsSpring XD
HdfsWritingMessageHandlerSpring Integration MessageHandler handling Message writing into hdfs using HdfsWriter.Classorg.springframework.xd.integration.hadoop.outboundSpring XD
HdfsWritingMessageHandlerFactoryBeanClassorg.springframework.xd.integration.hadoop.configSpring XD
HierarchicalCompositeModuleOptionsMetadataA composite ModuleOptionsMetadata made of several ModuleOptionsMetadata, each assigned to a name,that will appear in a hierarchy.Classorg.springframework.xd.module.optionsSpring XD
HostNotWindowsRuleClassorg.springframework.xd.testSpring XD
HsqlDatasourceConfigurationDatasource configuration for HSQL database.Classorg.springframework.xd.batch.hsqldb.serverSpring XD
HsqlServerApplicationSpring Application to operate life-cycle methods on HSQLServerBean.Classorg.springframework.xd.batch.hsqldb.serverSpring XD
HSQLServerBeanClassorg.springframework.xd.batch.hsqldb.serverSpring XD
HttpClientProcessorOptionsMetadataCaptures options for the http-client processor module.Classorg.springframework.xd.httpSpring XD
HttpCommandsClassorg.springframework.xd.shell.commandSpring XD
HttpGeneratorGenerate a single http request from a string or file payload.Interfaceorg.springframework.xd.test.generatorSpring XD
HttpSourceOptionsMetadataDescribes options to the http source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
IncrementalColumnRangePartitionerProvides the ability to partition a job and append additional conditions to supportincremental imports.Classorg.springframework.batch.integration.xSpring XD
IncrementalJdbcHdfsJobA test fixture that represents the JdbcHdfs JobAuthor:Glenn Renfro, Michael MinellaClassorg.springframework.xd.test.fixturesSpring XD
InitialOffsetsFactoryBeanParses the list of initial offsets and creates a map to initialize the OffsetManagerAuthor:Marius Bogoevici, Ilayaperumal GopinathanClassorg.springframework.integration.x.kafkaSpring XD
InMemoryAggregateCounterRepositoryIn-memory aggregate counter with minute resolution.Classorg.springframework.xd.analytics.metrics.memorySpring XD
InMemoryCounterRepositoryMemory backed implementation of Counter repository that uses a ConcurrentMap.Classorg.springframework.xd.analytics.metrics.memorySpring XD
InMemoryFieldValueCounterRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XD
InMemoryGaugeRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XD
InMemoryMetricRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XD
InMemoryRichGaugeRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XD
InputMapperAn InputMapper maps a given domain input I to an appropriate model input MI for the givenAuthor:Thomas DarimontInterfaceorg.springframework.xd.analytics.mlSpring XD
IntegerEncoderDecoderA Kafka encoder / decoder used to serialize a single int, used as the kafka partition key.Classorg.springframework.xd.dirt.integration.kafkaSpring XD
IntegrationHadoopNamespaceUtilsUtility methods for namespace.Classorg.springframework.xd.integration.hadoop.configSpring XD
IntegrationHadoopSystemConstantsVarious constants throughout the spring integration hadoop libraries.Classorg.springframework.xd.integration.hadoopSpring XD
IntoMongoDbOptionMixinAn option class to mix-in when writing to MongoDB.Classorg.springframework.xd.module.options.mixinsSpring XD
InvalidResultExceptionClassorg.springframework.xd.integration.utilSpring XD
ISO8601DateFormatWithMilliSecondsImproved version of the ISO8601DateFormat that also serializes milliseconds.Classorg.springframework.xd.rest.domain.utilSpring XD
JavaConfiguredModuleA SimpleModule configured by an @Configuration class.Classorg.springframework.xd.module.coreSpring XD
JavaMailPropertiesFactoryBeanPropertiesFactoryBean thatreads comma separated (ex: key1=value1,key2=value2) values and make them as properties.Classorg.springframework.xd.mailSpring XD
JavaToSerializedMessageConverterto convert from a POJO to byte[] with Java.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
JdbcCommandsUtility class helping to execute jdbc operations within a load session.Classorg.springframework.xd.greenplum.supportSpring XD
JdbcConnectionMixinBasic JDBC module/job options.Classorg.springframework.xd.jdbcSpring XD
JdbcConnectionPoolMixinBasic JDBC module/job connection pool options.Classorg.springframework.xd.jdbcSpring XD
JdbcHdfsJobClassorg.springframework.xd.test.fixturesSpring XD
JdbcHdfsOptionsMetadataCaptures options for the jdbchdfs job.Classorg.springframework.xd.jdbcSpring XD
JdbcMessagePayloadTransformerTransforms a payload to a Map representation based on provided column names.Classorg.springframework.xd.jdbcSpring XD
JdbcSinkRepresents the jdbc sink module.Classorg.springframework.xd.test.fixturesSpring XD
JdbcSinkModuleOptionsMetadataCaptures module options for the "jdbc" sink module.Classorg.springframework.xd.jdbcSpring XD
JdbcSourceRepresents the jdbc source module.Classorg.springframework.xd.test.fixturesSpring XD
JdbcSourceModuleOptionsMetadataCaptures options for the jdbc source module.Classorg.springframework.xd.jdbcSpring XD
JmsSourceA test fixture that allows testing of the 'jms' source module.Classorg.springframework.xd.test.fixturesSpring XD
JmsSourceModuleOptionsMetadataCaptures options for the jms source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
JMXChannelResultThe Module/Channel that is returned when a JMX Query is exected against XD.Classorg.springframework.xd.integration.util.jmxresultSpring XD
JMXRequestThe request to retrieve the Module MBean.Classorg.springframework.xd.integration.util.jmxresultSpring XD
JMXResultThe Object that is returned when a JMX Query is exected against XD.Classorg.springframework.xd.integration.util.jmxresultSpring XD
JMXValueThe JMXValue returned from JMX Request.Classorg.springframework.xd.integration.util.jmxresultSpring XD
JobDomain model for Job runtime module.Classorg.springframework.xd.dirt.coreSpring XD
JobCaptures runtime information about a deployed JobDefinition.Classorg.springframework.xd.dirt.streamSpring XD
JobCommandsClassorg.springframework.xd.shell.commandSpring XD
JobCommandsUtilsProvides helper methods for the JobCommands class, e.Classorg.springframework.xd.shell.command.supportSpring XD
JobDefinitionRepresents an inlined job definition in a job specification.Classorg.springframework.xd.dirt.job.dslSpring XD
JobDefinitionRepresents a job in the system.Classorg.springframework.xd.dirt.streamSpring XD
JobDefinitionRepositoryA repository for persisting JobDefinitions.Interfaceorg.springframework.xd.dirt.streamSpring XD
JobDefinitionResourceRepresents a Job Definition.Classorg.springframework.xd.rest.domainSpring XD
JobDefinitionResourceAssemblerKnows how to build a REST resource out of our domain model JobDefinition.Classorg.springframework.xd.dirt.restSpring XD
JobDeployerClassorg.springframework.xd.dirt.streamSpring XD
JobDeploymentsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XD
JobDescriptorCommon AST base class for nodes representing job definitions or job references.Classorg.springframework.xd.dirt.job.dslSpring XD
JobDSLMessageContains all the messages that can be produced during Spring XD Job DSL parsing.Classorg.springframework.xd.dirt.job.dslSpring XD
JobEventsListenerPluginPlugin to enable the registration of out of the box job listeners.Classorg.springframework.xd.dirt.plugins.jobSpring XD
JobExceptionRoot of the hierarchy of exceptions for Job processing in DIRT.Classorg.springframework.xd.dirt.jobSpring XD
JobExecutionAlreadyRunningExceptionException that is raised when JobExecutionAuthor:Gunnar HillertSee Also:Serialized FormClassorg.springframework.xd.dirt.jobSpring XD
JobExecutionInfoRepresents Batch job execution info.Classorg.springframework.xd.dirt.jobSpring XD
JobExecutionInfoResourceRepresents job execution info resource.Classorg.springframework.xd.rest.domainSpring XD
JobExecutionInfoResourceAssemblerKnows how to build a REST resource out of our domain model JobExecutionInfo.Classorg.springframework.xd.dirt.restSpring XD
JobExecutionJacksonMixInJackson MixIn for JobExecution de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
JobExecutionNotRunningExceptionException for the job execution that is not running.Classorg.springframework.xd.dirt.jobSpring XD
JobFactoryFactory class that builds Job instances.Classorg.springframework.xd.dirt.jobSpring XD
JobInfoRepresents Batch job info.Classorg.springframework.xd.dirt.jobSpring XD
JobInfoResourceRepresents Batch job info.Classorg.springframework.xd.rest.domainSpring XD
JobInfoResourceAssemblerKnows how to build a REST resource out of our domain model JobInfo.Classorg.springframework.xd.dirt.restSpring XD
JobInstanceAlreadyCompleteExceptionException thrown when the JobInstance is already complete.Classorg.springframework.xd.dirt.jobSpring XD
JobInstanceInfoRepresents Batch job instance info.Classorg.springframework.xd.dirt.jobSpring XD
JobInstanceInfoResourceRepresents JobInstance info resource.Classorg.springframework.xd.rest.domainSpring XD
JobInstanceInfoResourceAssemblerResource assembler that builds the REST resource JobInstanceInfoResource out of domain modelAuthor:Ilayaperumal GopinathanClassorg.springframework.xd.dirt.restSpring XD
JobInstanceJacksonMixInJackson MixIn for JobInstance de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
JobLaunchingJobRepositoryThis JobRepository implementationprovides the same functionality as Spring Batch'sClassorg.springframework.xd.dirt.plugins.job.supportSpring XD
JobLaunchingJobRepositoryFactoryBeanA FactoryBean for creating an instance ofJobLaunchingJobRepositoryClassorg.springframework.xd.dirt.plugins.job.supportSpring XD
JobLaunchingTaskletA Tasklet implementation that uses the Spring XD MessageBus to launchjobs deployed within the same Spring XD cluster.Classorg.springframework.xd.dirt.batch.taskletSpring XD
JobLaunchRequestTransformerExecutes all jobs defined within a given stream once the context has been started.Classorg.springframework.xd.dirt.plugins.jobSpring XD
JobNodeAST node base type for all elements in an AST parsed from a job specification.Classorg.springframework.xd.dirt.job.dslSpring XD
JobOperationsInterface defining operations available against jobs.Interfaceorg.springframework.xd.rest.clientSpring XD
JobParameterJacksonDeserializerJackson Deserializer for JobParameter de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
JobParameterJacksonMixInJackson MixIn for JobParameter de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
JobParametersBeanPrepares the JobParameters for the Spring Bach Jobs.Classorg.springframework.xd.dirt.plugins.jobSpring XD
JobParametersInvalidExceptionException thrown when the job parameters are invalid.Classorg.springframework.xd.dirt.jobSpring XD
JobParametersJacksonMixInJackson MixIn for JobParameters de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
JobParserParse a Batch DSL Job specification.Classorg.springframework.xd.dirt.job.dslSpring XD
JobPartitionerPluginPlugin to enable job partitioning.Classorg.springframework.xd.dirt.plugins.jobSpring XD
JobPluginPlugin to enable the registration of jobs in a central registry.Classorg.springframework.xd.dirt.plugins.jobSpring XD
JobPluginMetadataResolverA ModuleOptionsMetadataResolver that will dynamically add the module options (such as makeUnique)supported by job modules.Classorg.springframework.xd.dirt.plugins.jobSpring XD
JobReferenceRepresents a simple job reference.Classorg.springframework.xd.dirt.job.dslSpring XD
JobRepositoryA repository for persisting Job instances.Interfaceorg.springframework.xd.dirt.streamSpring XD
JobRestartExceptionException thrown where the batch job is not restartable.Classorg.springframework.xd.dirt.jobSpring XD
JobsA factory that provides fully instantiated job fixtures using default values.Classorg.springframework.xd.integration.fixturesSpring XD
JobsControllerHandles all Job related interactions.Classorg.springframework.xd.dirt.restSpring XD
JobSeriesCommon AST base class for nodes representing splits or flows.Classorg.springframework.xd.dirt.job.dslSpring XD
JobSpecificationThe root AST node for any AST parsed from a job specification.Classorg.springframework.xd.dirt.job.dslSpring XD
JobSpecificationExceptionRoot exception for Job Flow DSL parsing related exceptions.Classorg.springframework.xd.dirt.job.dslSpring XD
JobSpecificationVisitorvery basic visitor pattern for a JobSpecVisitor.Classorg.springframework.xd.dirt.job.dslSpring XD
JobTemplateClassorg.springframework.xd.rest.client.implSpring XD
JsonBytesToTupleConverterClassorg.springframework.xd.tupleSpring XD
JsonNodeToTupleConverterClassorg.springframework.xd.tupleSpring XD
JsonStringToObjectTransformerClassorg.springframework.integration.x.gemfireSpring XD
JsonStringToTupleConverterClassorg.springframework.xd.tupleSpring XD
JsonToPojoMessageConverterClassorg.springframework.xd.dirt.integration.bus.converterSpring XD
JsonToTupleMessageConverterto convert from a JSON (byte[] or String) to a Tuple.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
JsonToTupleTransformerConverts from a json string into a tuple data structure.Classorg.springframework.xd.tuple.integrationSpring XD
JsonUtilSome JSON helper utilities.Classorg.springframework.xd.shell.utilSpring XD
KafkaConsumerOptionsMixinModule options for Kafka consumer configuration.Classorg.springframework.integration.x.kafkaSpring XD
KafkaMessageBusA message bus that uses Kafka as the underlying middleware.Classorg.springframework.xd.dirt.integration.kafkaSpring XD
KafkaMessageTransformerA transformer that transforms the Kafka messages into Map of partition and payload.Classorg.springframework.integration.x.kafkaSpring XD
KafkaOffsetTopicOptionsMixinClassorg.springframework.integration.x.kafkaSpring XD
KafkaPartitionAllocatorIs responsible for managing the partition allocation between multiple instances of a Kafka source moduledeployed in a stream.Classorg.springframework.integration.x.kafkaSpring XD
KafkaProducerOptionsMixinModule options for Kafka Producer configuration.Classorg.springframework.integration.x.kafkaSpring XD
KafkaSinkClassorg.springframework.xd.test.fixturesSpring XD
KafkaSinkModuleOptionsMetadataModule options for Kafka sink module.Classorg.springframework.integration.x.kafkaSpring XD
KafkaSourceClassorg.springframework.xd.test.fixturesSpring XD
KafkaSourceModuleOptionsMetadataModule options for Kafka source module.Classorg.springframework.integration.x.kafkaSpring XD
KafkaTestSupportJUnit Rule that starts an embedded Kafka server (with an associated Zookeeper)Since:1.Classorg.springframework.xd.test.kafkaSpring XD
KafkaUtilsUtility methods for working with Kafka.Classorg.springframework.xd.test.fixtures.utilSpring XD
KafkaZKOptionMixinKafka module options mixin for ZK configuration.Classorg.springframework.integration.x.kafkaSpring XD
LabelNodeRepresents a label attached to a module.Classorg.springframework.xd.dirt.stream.dslSpring XD
LdapAuthenticationConfigurationClassorg.springframework.xd.dirt.server.securitySpring XD
LinkRepresents a link in a Graph object that Flo will display as a block.Classorg.springframework.xd.dirt.job.dslSpring XD
LoadConfigurationClassorg.springframework.xd.greenplum.supportSpring XD
LoadConfigurationFactoryBeanClassorg.springframework.xd.greenplum.supportSpring XD
LoadFactoryBeanFactoryBean for easy creation and configuration of GreenplumLoadAuthor:Janne ValkealahtiClassorg.springframework.xd.greenplum.supportSpring XD
LoadServiceInterfaceorg.springframework.xd.greenplum.supportSpring XD
LocaleAwareStringToNumberConverterFactoryConverts from a String any JDK-standard Number implementation.Classorg.springframework.xd.tupleSpring XD
LocalizedQueueConnectionFactoryA RoutingConnectionFactory that determines the node on which a queue is located andreturns a factory that connects directly to that node.Classorg.springframework.xd.dirt.integration.rabbitSpring XD
LocalMessageBusA simple implementation of MessageBus for in-process use.Classorg.springframework.xd.dirt.integration.bus.localSpring XD
LoggerAbbreviatorClassorg.springframework.xd.dirt.util.loggingSpring XD
LoggingCacheListenerA simple cache listener that will log events.Classorg.springframework.xd.gemfire.serverSpring XD
LoggingRecoveryCallbackClassorg.springframework.xd.analytics.metrics.redisSpring XD
LoginControllerController responsible for handling web-logins as well as basic redirects forAuthor:Gunnar HillertClassorg.springframework.xd.dirt.web.controllerSpring XD
LogSinkClassorg.springframework.xd.test.fixturesSpring XD
LogSinkOptionsMetadataCaptures options for the log sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
MailProtocolThe list of supported mail protocols.Classorg.springframework.xd.mailSpring XD
MailServerMixinTypical options for configuring connection to a mail server.Classorg.springframework.xd.mailSpring XD
MailSinkA fixture to help test the mail sink module.Classorg.springframework.xd.test.fixturesSpring XD
MailSinkOptionsMetadataCaptures options for the mail sink module.Classorg.springframework.xd.mailSpring XD
MailSourceOptionsMetadataCaptures options for the mail source module.Classorg.springframework.xd.mailSpring XD
MappedAnalyticAn Analytic that supports the mapping of input and outputto and from internal representations by applying the given InputMapperClassorg.springframework.xd.analytics.mlSpring XD
MappedRequestHeadersMixinBase class for mixins that add the mappedRequestHeaders option.Classorg.springframework.xd.module.options.mixinsSpring XD
MappedResponseHeadersMixinBase class for mixins that add the mappedResponseHeaders option.Classorg.springframework.xd.module.options.mixinsSpring XD
MapreduceConfigurationMixinFactors out common configuration options for Hadoop MapReduce.Classorg.springframework.xd.module.options.mixinsSpring XD
MapToTupleTransformerConverts from a Map to the Tuple data structure.Classorg.springframework.xd.tuple.integrationSpring XD
MaxMessagesDefaultOneMixinMixin for polled sources where the default is 1 message per poll.Classorg.springframework.xd.module.options.mixinsSpring XD
MaxMessagesDefaultUnlimitedMixinMixin for polled sources where the default is unlimited messages per poll.Classorg.springframework.xd.module.options.mixinsSpring XD
MBeanExportingPluginExports MBeans from a module using a unique domain name xd.Classorg.springframework.xd.dirt.pluginsSpring XD
MD5StalenessCheckA StalenessCheck that expects to find a .Classorg.springframework.xd.dirt.moduleSpring XD
MediaTypeConverterKnows how to parse String representations of MediaType.Classorg.springframework.xd.shell.converterSpring XD
MessageBusA strategy interface used to bind a MessageChannel to a logical name.Interfaceorg.springframework.xd.dirt.integration.busSpring XD
MessageBusAwareChannelResolverA DestinationResolver implementation that first checks for any channelwhose name begins with a colon in the MessageBus.Classorg.springframework.xd.dirt.integration.busSpring XD
MessageBusAwareRouterBeanPostProcessorA BeanPostProcessor that sets a MessageBusAwareChannelResolver on any bean of typeAbstractMappingMessageRouter within the context.Classorg.springframework.xd.dirt.integration.busSpring XD
MessageBusClassLoaderFactoryAn 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.Classorg.springframework.xd.dirt.serverSpring XD
MessageBusExceptionException thrown to indicate a message bus error (mostlikely a configuration error).Classorg.springframework.xd.dirt.integration.busSpring XD
MessageBusExtensionsConfigurationConfiguration class for Codec and possibly other MessageBus extensionsSince:1.Classorg.springframework.xd.dirt.serverSpring XD
MessageBusSupportClassorg.springframework.xd.dirt.integration.busSpring XD
MessageConverterUtilsMessage conversion utility methods.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
MessageCounterHandlerCounts the number of non-null messages using an underlying CounterRepository.Classorg.springframework.xd.analytics.metrics.integrationSpring XD
MessageExpressionMethodsHelper class to work with a spel expressions resolving valuesfrom a Message.Classorg.springframework.xd.integration.hadoop.expressionSpring XD
MessagePartitionKeyMethodResolverA Message specific MethodResolver.Classorg.springframework.xd.integration.hadoop.expressionSpring XD
MessagePartitionKeyPropertyAccessorA PropertyAccessor reading values from a backing Message used by apartition key.Classorg.springframework.xd.integration.hadoop.expressionSpring XD
MessagePartitionStrategyA PartitionStrategy which is used to provide a generic partitioning support using Spring SpEL.Classorg.springframework.xd.integration.hadoop.partitionSpring XD
MessageValuesA mutable type for allowing MessageBus implementations to transform and enrich message content moreAuthor:David TuranskiClassorg.springframework.xd.dirt.integration.busSpring XD
MetricSuper interface for all metrics.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
MetricHasSimpleValueMatcherA matcher that will assert that the display xxx shell command displays the expected value.Classorg.springframework.xd.test.fixturesSpring XD
MetricNameMixinAdds a name option, intended to capture the name of the metric.Classorg.springframework.xd.analytics.metrics.metadataSpring XD
MetricRepositoryA repository to save, delete and find Metric instances.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
MetricResourceBase class for resources that adhere to the Metric interface.Classorg.springframework.xd.rest.domain.metricsSpring XD
MetricUtilsUtility class, primarily to avoid exposing mutable objects beyond the core package.Classorg.springframework.xd.analytics.metrics.coreSpring XD
MixinInstructs the runtime to mix in other POJO bases module option metadata classes into the one that is annotated withthis annotation.Classorg.springframework.xd.module.options.spiSpring XD
ModeClassorg.springframework.xd.greenplum.supportSpring XD
ModuleRepresents an XD Module that is returned from a JMX Query.Classorg.springframework.xd.integration.util.jmxresultSpring XD
ModuleInterfaceorg.springframework.xd.module.coreSpring XD
ModuleAlreadyExistsExceptionThrown when trying to create a new module with the given name and type, but one already exists.Classorg.springframework.xd.dirt.moduleSpring XD
ModuleCommandsCommands for working with modules.Classorg.springframework.xd.shell.commandSpring XD
ModuleConfigurationExceptionThrown when something is wrong with options passed to a module.Classorg.springframework.xd.dirt.pluginsSpring XD
ModuleDefinitionAn instance of ModuleDefinition reflects the fact that a given module (identified by its type and name) is'available', i.Classorg.springframework.xd.moduleSpring XD
ModuleDefinitionRepositoryUtilsClassorg.springframework.xd.dirt.module.supportSpring XD
ModuleDefinitionResourceRepresents a Module Definition.Classorg.springframework.xd.rest.domainSpring XD
ModuleDefinitionResourceAssemblerKnows how to build a REST resource out of our domain model ModuleDefinition.Classorg.springframework.xd.dirt.restSpring XD
ModuleDefinitionsFactory class to create ModuleDefinitions.Classorg.springframework.xd.moduleSpring XD
ModuleDefinitionServiceA service that knows how to handle registration of new module definitions, be it through composition orupload of actual 'bytecode'.Classorg.springframework.xd.dirt.module.supportSpring XD
ModuleDependencyRepositoryUsed to track usage of modules from streams and composed modules.Interfaceorg.springframework.xd.dirt.moduleSpring XD
ModuleDeployedEventClassorg.springframework.xd.dirt.eventSpring XD
ModuleDeployerHandles the creation, deployment, and un-deployment of modules.Classorg.springframework.xd.dirt.moduleSpring XD
ModuleDeploymentPropertiesDeployment properties for a module.Classorg.springframework.xd.moduleSpring XD
ModuleDeploymentPropertiesProviderCallback interface to obtain ModuleDeploymentPropertiesfor a ModuleDescriptor.Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XD
ModuleDeploymentRequestsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XD
ModuleDeploymentsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XD
ModuleDeploymentStatusStatus of a module deployment for a container.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
ModuleDeploymentWriterUtility class to write module deployment requests under /xd/deployments/modules.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ModuleDescriptorRepresentation of a module in the context of a defined stream or job.Classorg.springframework.xd.moduleSpring XD
ModuleEnvironmentA dedicated Environment for a module, which restricts the values exposed to thePropertySourcesPlaceholderConfigurer living in the module context.Classorg.springframework.xd.module.coreSpring XD
ModuleExceptionRoot of the hierarchy of exceptions for Module processing in DIRT.Classorg.springframework.xd.dirt.moduleSpring XD
ModuleExecutorInvokes the process method of a Processorand handles the output DStream if present.Classorg.springframework.xd.spark.streaming.javaSpring XD
ModuleFactoryDetermines the type of Module to create from the Module's metadata and creates a module instance.Classorg.springframework.xd.module.coreSpring XD
ModuleFixtureEstablishes the base behavior for Acceptance Test Module Factories.Classorg.springframework.xd.integration.fixturesSpring XD
ModuleInfoPluginA plugin that exposes information such as the module name, index, sequence or count to be available inside theAuthor:Eric Bottard, Marius Bogoevici, Ilayaperumal GopinathanClassorg.springframework.xd.dirt.pluginsSpring XD
ModuleInformationHolder object for various bits of information about a module, such as description, etc.Classorg.springframework.xd.module.infoSpring XD
ModuleInformationResolverInterfaceorg.springframework.xd.module.infoSpring XD
ModuleJobLauncherExecutes all jobs defined within a given stream once the context has been started.Classorg.springframework.xd.dirt.plugins.jobSpring XD
ModuleMessageRateNotFoundExceptionException thrown when getting message rate forAuthor:Ilayaperumal GopinathanSee Also:Serialized FormClassorg.springframework.xd.dirt.clusterSpring XD
ModuleMetadataMetadata class for modules at runtime.Classorg.springframework.xd.dirt.module.storeSpring XD
ModuleMetadataRepositoryRepository for persisting ModuleMetadataAuthor:Ilayaperumal GopinathanInterfaceorg.springframework.xd.dirt.module.storeSpring XD
ModuleMetadataResourceRepresents a runtime module.Classorg.springframework.xd.rest.domainSpring XD
ModuleMetadataResourceAssemblerKnows how to assemble ModuleMetadataResources out of ModuleMetadatas.Classorg.springframework.xd.dirt.restSpring XD
ModuleNodeClassorg.springframework.xd.dirt.stream.dslSpring XD
ModuleNotDeployedExceptionException thrown when a module doesn't exist in the container.Classorg.springframework.xd.dirt.moduleSpring XD
ModuleObjectNamingStrategyObject naming strategy for XD module.Classorg.springframework.xd.dirt.module.jmxSpring XD
ModuleOperationsInterface defining operations available against Module.Interfaceorg.springframework.xd.rest.clientSpring XD
ModuleOptionProvides information about an option that a user can set to customize the behavior of a module.Classorg.springframework.xd.module.optionsSpring XD
ModuleOptionUsed to annotate the setter methods of a POJO Module Options class to provide the framework with additional optionRequired Element SummaryClassorg.springframework.xd.module.options.spiSpring XD
ModuleOptionsRepresents runtime information about a module once user provided values are known.Classorg.springframework.xd.module.optionsSpring XD
ModuleOptionsMetadataEncapsulates metadata about the accepted options for a module.Interfaceorg.springframework.xd.module.optionsSpring XD
ModuleOptionsMetadataResolverNote that basic metadata derived from a module may be enriched by collaborators.Interfaceorg.springframework.xd.module.optionsSpring XD
ModuleOptionsReferenceDocA class that generates asciidoc snippets for each module's options.Classorg.springframework.xd.documentationSpring XD
ModulePlaceholdersDefines constants for well known XD keys that are available at runtime for a module.Classorg.springframework.xd.module.options.spiSpring XD
ModuleRedeployerAbstract ModuleRedeployer that deploy/re-deploys the unallocated/orphaned modules.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ModuleRegistryA module registry is used to lookup modules by name and/or type.Interfaceorg.springframework.xd.dirt.moduleSpring XD
ModulesAfterPipeRecoveryStrategyProvides completions for the case where the user has entered a pipe symbol and a module reference is expected next.Classorg.springframework.xd.dirt.stream.completionSpring XD
ModulesControllerHandles all Module related interactions.Classorg.springframework.xd.dirt.restSpring XD
ModulesMetadataControllerController that handles the interaction with the deployed modules.Classorg.springframework.xd.dirt.restSpring XD
ModuleTemplateClassorg.springframework.xd.rest.client.implSpring XD
ModuleTypeEnumeration of different module typesEnum Constant SummaryClassorg.springframework.xd.integration.fixturesSpring XD
ModuleTypeRepresents the kind of modules that make up a stream or job.Classorg.springframework.xd.moduleSpring XD
ModuleTypeConversionPluginA Plugin for processing module message conversion parameters (inputType and outputType).Classorg.springframework.xd.dirt.plugins.streamSpring XD
ModuleTypeConversionPluginMetadataResolverA ModuleOptionsMetadataResolver that will dynamically add inputType and outputType options toevery module, according to their type.Classorg.springframework.xd.dirt.plugins.streamSpring XD
ModuleTypeConversionSupportSupport class that configures the message converters for the module input/output channel.Classorg.springframework.xd.dirt.plugins.streamSpring XD
ModuleUndeployedEventClassorg.springframework.xd.dirt.eventSpring XD
ModuleUtilsContains utility methods for accessing a module's properties and dealing with ClassLoaders.Classorg.springframework.xd.module.optionsSpring XD
MongoDbConnectionMixinA mixin to add anytime a connection to MongoDB is required.Classorg.springframework.xd.module.options.mixinsSpring XD
MqttConnectionMixinFactors out common options about configuring a connection to an MQTT broker.Classorg.springframework.xd.dirt.modules.metadataSpring XD
MqttSinkTest fixture that creates a mqtt sink.Classorg.springframework.xd.test.fixturesSpring XD
MqttSinkOptionsMetadataDescribes options to the mqtt sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
MqttSourceA test fixture that allows testing of the mqtt source module.Classorg.springframework.xd.test.fixturesSpring XD
MqttSourceOptionsMetadataDescribes options to the mqtt source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
MqttTestSupportClassorg.springframework.xd.test.mqttSpring XD
MultipleBroadcasterMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to a Stream based on a partitionExpression.Classorg.springframework.xd.reactorSpring XD
MultipleSubjectMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to an Observable based on a partitionExpression.Classorg.springframework.xd.rxjavaSpring XD
NamedChannelSinkA Sink bound to a named channel.Interfaceorg.springframework.xd.dirt.test.sinkSpring XD
NamedChannelSourceA Source that binds to a named channel.Interfaceorg.springframework.xd.dirt.test.sourceSpring XD
NamedColumnJdbcBatchItemWriterJdbcBatchItemWriter which is customized for use with the XDSets the SQL insert property based on the column names and table nameClassorg.springframework.xd.jdbcSpring XD
NamedColumnJdbcItemReaderReader which reads a row from a database as a delimited string from apredefined list of column names.Classorg.springframework.xd.jdbcSpring XD
NamedColumnJdbcItemReaderFactoryFactory for configuring a NamedColumnJdbcItemReader.Classorg.springframework.xd.jdbcSpring XD
NamedResourceAbstract base class for all resources that have a name.Classorg.springframework.xd.rest.domainSpring XD
NamespaceDelegatingMetadataStoreWraps a delegate MetadataStore and adds a prefix to all the handled keys.Classorg.springframework.integration.x.kafkaSpring XD
NamingStrategyParserParser for the 'naming-strategy' element.Classorg.springframework.xd.integration.hadoop.configSpring XD
NestedArchiveResourceRepresents a resource as resolved inside a boot Archive.Classorg.springframework.xd.module.supportSpring XD
NettyHttpInboundChannelAdapterClassorg.springframework.integration.x.httpSpring XD
NettyInboundMessageConverterMessage converter (inbound only) to convert a Netty Http MessageEvent toa Message.Classorg.springframework.integration.x.httpSpring XD
NetworkUtilsVarious network utilities.Classorg.springframework.xd.greenplum.supportSpring XD
NewJsonPathUtilsSimilar to org.Classorg.springframework.xd.dirt.integration.jsonSpring XD
NoContainerExceptionException thrown when there are no containers availablefor module deployment.Classorg.springframework.xd.dirt.clusterSpring XD
NodeRepresents a node in a Graph object that Flo will display as a block.Classorg.springframework.xd.dirt.job.dslSpring XD
NonBindingResourceConfiguredModuleA module type that chooses not to bind to the MessageBus.Classorg.springframework.xd.module.coreSpring XD
NonPollingImapSourceRepresents the imap source module, that does not use polling.Classorg.springframework.xd.test.fixturesSpring XD
NoSuchBatchJobExceptionException thrown when there is no such batch job with the given name.Classorg.springframework.xd.dirt.jobSpring XD
NoSuchBatchJobInstanceExceptionException thrown when there is no such batch job instance with the given instanceId.Classorg.springframework.xd.dirt.jobSpring XD
NoSuchContainerExceptionException thrown when the container in search could not be found.Classorg.springframework.xd.dirt.clusterSpring XD
NoSuchDefinitionExceptionException which is raised when a named resource definition cannot be found.Classorg.springframework.xd.dirt.streamSpring XD
NoSuchJobExecutionExceptionThrown when attempting to refer to JobExecution that does not exist.Classorg.springframework.xd.dirt.jobSpring XD
NoSuchMetricExceptionThrown when trying to access a named metric that does not exist.Classorg.springframework.xd.dirt.analyticsSpring XD
NoSuchModuleExceptionThrown when attempting to refer to a module that does not exist.Classorg.springframework.xd.dirt.moduleSpring XD
NoSuchStepExecutionExceptionThrown when attempting to refer to StepExecution that does not exist.Classorg.springframework.xd.dirt.jobSpring XD
NotDeployedExceptionThrown when a definition was assumed to be deployed when it actually was not.Classorg.springframework.xd.dirt.streamSpring XD
NothingToDeleteExceptionThrown when a delete operation has nothing to delete.Classorg.springframework.xd.dirt.integration.bus.rabbitSpring XD
NullClassLoaderA ClassLoader that can't find or load anything.Classorg.springframework.xd.module.supportSpring XD
NumberFormatConverterKnows how to convert from a String to a new NumberFormat instance.Classorg.springframework.xd.shell.converterSpring XD
OptionNameAfterDashDashRecoveryStrategyProvides completion proposals when the user has typed the two dashes that precede a module option name.Classorg.springframework.xd.dirt.stream.completionSpring XD
OrderedContextInitializerAllows any necessary changes to the Target Context.Interfaceorg.springframework.xd.dirt.container.initializerSpring XD
OutputMapperAn OutputMapper maps a given model input MO to an appropriate domain input O for the givenanalytic A by potentially using data from the original input I.Interfaceorg.springframework.xd.analytics.mlSpring XD
PackageSuiteRunnerA Suite to run all concrete classes ending in Tests in the same package.Classorg.springframework.xd.testSpring XD
PageNotFoundExceptionException thrown when a Pageable requests a page that does not exist.Classorg.springframework.xd.dirt.utilSpring XD
PagingUtilityUtility class for paging support in repository accessor methods.Classorg.springframework.xd.dirt.utilSpring XD
ParentConfigurationBeans defined and imported here are in the global parent context, hence available to the entire hierarchy, includingAdmins, Containers, and Modules.Classorg.springframework.xd.dirt.serverSpring XD
ParentLastURLClassLoaderExtension for URLClassLoader that uses a parent-last (or child first) delegation.Classorg.springframework.xd.module.supportSpring XD
ParsingContextCaptures the context in which a parse operation is made.Classorg.springframework.xd.dirt.streamSpring XD
PartitionedJdbcHdfsJobA test fixture that represents a partitioned JdbcHdfs JobAuthor:Glenn Renfro, Thomas RisbergClassorg.springframework.xd.test.fixturesSpring XD
PartitionKeyExtractorStrategyStrategy for extracting a partition key from a Message.Interfaceorg.springframework.xd.dirt.integration.busSpring XD
PartitionSelectorStrategyStrategy for determining the partition to which a message should be sent.Interfaceorg.springframework.xd.dirt.integration.busSpring XD
PassthruModuleOptionsMetadataClassorg.springframework.xd.module.optionsSpring XD
PasswordThis module option type represents a password.Classorg.springframework.xd.module.options.typesSpring XD
PasswordUtilsProvides common utility methods for JobDefinitions andStreamDefinitions (BaseDefinition), e.Classorg.springframework.xd.dirt.restSpring XD
PathsCommon paths and path utilities for XD components.Classorg.springframework.xd.dirt.zookeeperSpring XD
PeriodicTriggerMixinMixin for options that include a periodic fixed-delay trigger.Classorg.springframework.xd.module.options.mixinsSpring XD
PipeIntoOtherModulesExpansionStrategyContinues a well-formed stream definition by adding a pipe symbol and another module, provided that the streamdefinition hasn't reached its end yet.Classorg.springframework.xd.dirt.stream.completionSpring XD
PluginTo be implemented by classes that want to alter how a Module works.Interfaceorg.springframework.xd.module.coreSpring XD
PluginContextComponentScanningExtensionsInitializerAn OrderedContextInitializer to scan for annotation configured beans in xd.Classorg.springframework.xd.dirt.container.initializerSpring XD
PluginContextResourceExtensionsInitializerAn OrderedContextInitializer to scan resource locations xd.Classorg.springframework.xd.dirt.container.initializerSpring XD
PluginsInitializerAn OrderedContextInitializer to load out-of-the-box XD Plugins.Classorg.springframework.xd.dirt.container.initializerSpring XD
PojoModuleOptionsMetadataAn implementation of ModuleOptionsMetadata that derives its information from a plain old java object:public setters are reported as valid optionsthe type of the option is derived from the accepted type by the setterClassorg.springframework.xd.module.optionsSpring XD
PojoToJsonMessageConverterto convert a Java object to a JSON StringAuthor:David Turanski, David LiuClassorg.springframework.xd.dirt.integration.bus.converterSpring XD
PojoToStringMessageConverterto convert a Java object to a String using toString()Author:David TuranskiClassorg.springframework.xd.dirt.integration.bus.converterSpring XD
PollingMailSourceFixture that represents the mail source module, which uses polling (here forced to 1s).Classorg.springframework.xd.test.fixturesSpring XD
PrefixNarrowingModuleOptionsA decorator on another instance of ModuleOptions (in practice, one representing options to a composed module)that will filter and remap property values exposed through its property source.Classorg.springframework.xd.module.optionsSpring XD
ProcessorContract for performing stream processing using Reactor within an XD processor moduleAuthor:Mark Pollack, Stephane MaldiniInterfaceorg.springframework.xd.reactorSpring XD
ProcessorInterfaceorg.springframework.xd.rxjavaSpring XD
ProcessorInterface for the Java based modules using the Spark Streaming API to process messages from the Message Bus.Interfaceorg.springframework.xd.spark.streaming.javaSpring XD
ProcessorsA factory that provides fully instantiated processor fixtures.Classorg.springframework.xd.integration.fixturesSpring XD
ProfileNamesProviderTo be implemented by classes that instruct the framework to activate some named profiles.Interfaceorg.springframework.xd.module.options.spiSpring XD
QualifiedModuleNameConverterKnows how to build and query ModuleCommands.Classorg.springframework.xd.shell.converterSpring XD
RabbitAdminExceptionExceptions thrown while interfacing with the RabbitMQ admin plugin.Classorg.springframework.xd.dirt.integration.busSpring XD
RabbitAdminTestSupportJUnit Rule that detects the fact that RabbitMQ is available on localhost withthe management plugin enabled.Classorg.springframework.xd.test.rabbitSpring XD
RabbitBusCleanerClassorg.springframework.xd.dirt.integration.bus.rabbitSpring XD
RabbitConnectionMixinFactors out options for the typical connection setup to RabbitMQ.Classorg.springframework.xd.dirt.modules.metadataSpring XD
RabbitManagementUtilsClassorg.springframework.xd.dirt.integration.busSpring XD
RabbitMessageBusA MessageBus implementation backed by RabbitMQ.Classorg.springframework.xd.dirt.integration.rabbitSpring XD
RabbitSinkA test fixture that allows testing of the rabbit sink module.Classorg.springframework.xd.test.fixturesSpring XD
RabbitSinkOptionsMetadataCaptures options to the rabbit sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
RabbitSourceA test fixture that allows testing of the rabbit source module.Classorg.springframework.xd.test.fixturesSpring XD
RabbitSourceOptionsMetadataDescribes options to the rabbit source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
RabbitTestSupportJUnit Rule that detects the fact that RabbitMQ is available on localhost.Classorg.springframework.xd.test.rabbitSpring XD
RandomConfigurationSupportSupport class to have random configuration for tests.Classorg.springframework.xd.testSpring XD
RangeCapableRepositoryTo be implemented by repositories that know how to return a slice of their data.Interfaceorg.springframework.xd.storeSpring XD
ReactorNamespaceHandlerClassorg.springframework.xd.integration.reactor.configSpring XD
ReactorNetSourceOptionsMetadataProvides metadata about the configuration options of a ReactorPeer in Spring XD.Classorg.springframework.xd.integration.reactor.netSpring XD
ReactorPeerFactoryBeanClassorg.springframework.xd.integration.reactor.netSpring XD
ReactorPeerInboundChannelAdapterInbound ChannelAdapter that uses ReactorPeer abstraction to provide high-speed TCP or UDP ingest.Classorg.springframework.xd.integration.reactor.netSpring XD
ReactorPeerInboundChannelAdapterConfigurationClassorg.springframework.xd.integration.reactor.netSpring XD
ReactorReflectionUtilsUtility class for working with the reflection API for Reactor based processors.Classorg.springframework.xd.reactorSpring XD
ReadableTableSettings for readable external table.Classorg.springframework.xd.greenplum.supportSpring XD
ReadableTableFactoryBeanClassorg.springframework.xd.greenplum.supportSpring XD
RedisAggregateCounterRepositoryRedis implementation of AggregateCounterRepository.Classorg.springframework.xd.analytics.metrics.redisSpring XD
RedisConnectionMixinMixin for Redis connection options.Classorg.springframework.xd.dirt.modules.metadataSpring XD
RedisCounterRepositoryClassorg.springframework.xd.analytics.metrics.redisSpring XD
RedisFieldValueCounterRepositoryClassorg.springframework.xd.analytics.metrics.redisSpring XD
RedisGaugeRepositoryRedis backed implementation that uses Redis keys to store and update the value.Classorg.springframework.xd.analytics.metrics.redisSpring XD
RedisMessageBusA MessageBus implementation backed by Redis.Classorg.springframework.xd.dirt.integration.redisSpring XD
RedisRetryTemplateClassorg.springframework.xd.analytics.metrics.redisSpring XD
RedisRichGaugeRepositoryRepository for rich-gauges backed by Redis.Classorg.springframework.xd.analytics.metrics.redisSpring XD
RedisSinkConfigurationClassorg.springframework.xd.redisSpring XD
RedisSinkOptionsMetadataOptions metadata for Redis sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
RedisTestSupportJUnit Rule that detects the fact that a Redis server is running on localhost.Classorg.springframework.xd.test.redisSpring XD
RemoteFilePartitionerTakes the result of an (S)FTP Gateway LS (list of FileInfo) and creates a StepExecution for each file.Classorg.springframework.batch.integration.xSpring XD
RemoteFileToHadoopTaskletRetrieves a fileName from the step execution context; uses the RemoteFileTemplate to retrieve the file as aString and writes to hdfs.Classorg.springframework.batch.integration.xSpring XD
RepositoryConnectionListenerZooKeeper connection listener that ensures path creation fornodes required by the various repository implementations thatClassorg.springframework.xd.dirt.stream.zookeeperSpring XD
ResourceConfiguredModuleA SimpleModule configured using a bean definition resource (XML orAuthor:David Turanski, Eric BottardClassorg.springframework.xd.module.coreSpring XD
ResourceDefinitionExceptionThrown when a problem is detected with the (DSL) definition of an XD resource.Classorg.springframework.xd.dirt.moduleSpring XD
ResourceDeployerInterface for XD Resource Services.Interfaceorg.springframework.xd.dirt.coreSpring XD
ResourceModuleRegistryResource based implementation of ModuleRegistry.Classorg.springframework.xd.dirt.moduleSpring XD
ResourceOperationsOperations common to resources like Stream and Job.Interfaceorg.springframework.xd.rest.clientSpring XD
ResourcePatternScanningOptionHandlerAn 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.Classorg.springframework.xd.dirt.server.optionsSpring XD
ResourcePatternScanningOptionHandlersHolds definitions of ResourcePatternScanningOptionHandlers used in Spring XD.Classorg.springframework.xd.dirt.server.optionsSpring XD
ResourcesIntoJdbcJobModuleOptionsMetadataTypical class for metadata about jobs that slurp delimited resources into jdbc.Classorg.springframework.xd.jdbcSpring XD
ResourceStateVerifierVerifies the state of resources (job or stream) by polling repository state until theresource is in the expected state or the operation times out.Classorg.springframework.xd.dirt.testSpring XD
RestConfigurationTakes care of infrastructure setup for the web/rest layer.Classorg.springframework.xd.dirt.restSpring XD
RestControllerAdviceCentral class for behavior common to all REST controllers.Classorg.springframework.xd.dirt.restSpring XD
RESTDeploymentStateenum RESTDeploymentStateREST domain representation of org.Classorg.springframework.xd.rest.domainSpring XD
RestLogoutSuccessHandlerstatus code of 200.Classorg.springframework.xd.dirt.web.controller.supportSpring XD
RESTModuleTypeSibling of org.Classorg.springframework.xd.rest.domainSpring XD
RestTemplateMessageConverterUtilUtility class that does two things:Resets a RestTemplate's message converters list to have json support come before xml.Classorg.springframework.xd.rest.domain.supportSpring XD
RichGaugeA gauge which stores the maximum, minimum and average in addition to the current value.Classorg.springframework.xd.analytics.metrics.coreSpring XD
RichGaugeCommandsCommands for interacting with RichGauge analytics.Classorg.springframework.xd.shell.commandSpring XD
RichGaugeHandlerClassorg.springframework.xd.analytics.metrics.integrationSpring XD
RichGaugeOperationsInterface defining operations available when dealing with Rich Gauge.Interfaceorg.springframework.xd.rest.clientSpring XD
RichGaugeRepositoryA service for managing RichGauge instances.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XD
RichGaugeResourceThe REST representation of a RichGauge.Classorg.springframework.xd.rest.domain.metricsSpring XD
RichGaugesControllerExposes representations of Gauges.Classorg.springframework.xd.dirt.rest.metricsSpring XD
RichGaugeSinkOptionsMetadataCaptures options for the rich-gauge sink module.Classorg.springframework.xd.analytics.metrics.metadataSpring XD
RichGaugeTemplateClassorg.springframework.xd.rest.client.implSpring XD
RolloverStrategyParserParser for the 'rollover-policy' element.Classorg.springframework.xd.integration.hadoop.configSpring XD
RuntimeBatchConfigurerSpring XD runtime specific BatchConfigurer.Classorg.springframework.xd.dirt.batchSpring XD
RuntimeCommandsCommands to interact with cluster for containers/modules.Classorg.springframework.xd.shell.commandSpring XD
RuntimeContainerResourceAssemblerKnows how to assemble DetailedContainerResources out of DetailedContainer instances.Classorg.springframework.xd.dirt.restSpring XD
RuntimeContextRuntime context for load operations.Classorg.springframework.xd.greenplum.supportSpring XD
RuntimeIOExceptionThrown when something goes wrong during some IO operation.Classorg.springframework.xd.dirt.coreSpring XD
RuntimeModuleDeploymentPropertiesRuntime ModuleDeploymentProperties for a module.Classorg.springframework.xd.moduleSpring XD
RuntimeModuleDeploymentPropertiesProviderDefault implementation of ModuleDeploymentPropertiesProviderfor type RuntimeModuleDeploymentProperties.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
RuntimeOperationsInterface defining operations available against runtime container/modules.Interfaceorg.springframework.xd.rest.clientSpring XD
RuntimeTemplateClassorg.springframework.xd.rest.client.implSpring XD
RuntimeTimeoutExceptionException thrown when a blocking operation times out.Classorg.springframework.xd.dirt.coreSpring XD
RuntimeUtilsUtilities for obtaining runtime information for the running process.Classorg.springframework.xd.dirt.utilSpring XD
ScriptMixinA standard mixin for modules that do some transformation based on a script.Classorg.springframework.xd.module.options.mixinsSpring XD
ScriptModulePropertiesFactoryBeanClassorg.springframework.xd.extension.scriptSpring XD
SecurityConfigurationSetup Spring Security for the http endpoints of the application.Classorg.springframework.xd.dirt.web.configSpring XD
SecurityControllerProvides security-related meta information.Classorg.springframework.xd.dirt.rest.securitySpring XD
SecurityInfoResourceProvides security related meta-information.Classorg.springframework.xd.rest.domain.securitySpring XD
SegmentRejectTypeenum SegmentRejectTypeEnum Constant SummaryClassorg.springframework.xd.greenplum.supportSpring XD
SerializationExceptionThrown when something goes wrong with inter-module communication.Classorg.springframework.xd.dirt.integration.busSpring XD
SerializedToJavaMessageConverterto deserialize Serializable Java objects.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
ServerProcessUtilsCollection of utilities for starting external processes requiredfor a distributed XD system.Classorg.springframework.xd.distributed.utilSpring XD
ServerTcpConnectionFactoryOptionsMetadataMixinMixin for options metadata that configure a server tcp connection factory.Classorg.springframework.xd.tcpSpring XD
SftpSourceOptionsMetadataModule options for SFTP source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
ShallowMetricResourceAssemblerBase class for a ResourceAssembler that builds shallow resources for metrics (exposing only their names, andhence their "self" rel).Classorg.springframework.xd.dirt.rest.metricsSpring XD
SharedServerContextConfigurationBeans defined and imported here are shared by the XD Admin Server and Container Server.Classorg.springframework.xd.dirt.serverSpring XD
ShellCommandProcessorCreates a process to run a shell command and communicate with it using String payloads over stdin and stdout.Classorg.springframework.xd.extension.processSpring XD
ShellModuleOptionsMetadataOptions Metadata for shell processor and sink modules.Classorg.springframework.xd.extension.processSpring XD
SimpleAbstractHdfsItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XD
SimpleCounterSinkUsed to generate the counter sink portion of a stream.Classorg.springframework.xd.test.fixturesSpring XD
SimpleFileSinkUsed to generate the file sink portion of a stream.Classorg.springframework.xd.test.fixturesSpring XD
SimpleFileSourceA FileSource for integration tests.Classorg.springframework.xd.test.fixturesSpring XD
SimpleHdfsTextItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XD
SimpleHttpGeneratorUsed to generate basic http posts for string and file contentsAuthor:Glenn Renfro, Mark PollackClassorg.springframework.xd.test.generatorSpring XD
SimpleHttpSourceAn HTTP source that default to using localhost:9000Author:Glenn Renfro, Mark PollackClassorg.springframework.xd.test.fixturesSpring XD
SimpleModuleA Module implementation backed by a Spring ApplicationContext.Classorg.springframework.xd.module.coreSpring XD
SimpleModuleDefinitionA module definition for a "simple", single module whose code and supporting resourcescan be located somewhere.Classorg.springframework.xd.moduleSpring XD
SimpleModuleOptionsMetadataAn implementation of ModuleOptionsMetadata that only knows how to list options and does not support advancedfacilities such as derived options, profile activation or validation.Classorg.springframework.xd.module.optionsSpring XD
SimpleTailSourceA tail source for integration tests.Classorg.springframework.xd.test.fixturesSpring XD
SimpleXdChunkListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
SimpleXdItemListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
SimpleXdJobExecutionListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
SimpleXdSkipListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
SimpleXdStepExecutionListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
SingleNodeApplicationSingle Node XD Runtime.Classorg.springframework.xd.dirt.server.singlenodeSpring XD
SingleNodeIntegrationTestSupportA helper class that provides methods used for testing streams with SingleNodeApplication.Classorg.springframework.xd.dirt.testSpring XD
SingleNodeNamedChannelSinkFactoryA factory for creating NamedChannelSinks.Classorg.springframework.xd.dirt.test.sinkSpring XD
SingleNodeNamedChannelSourceFactoryA factory for creating NamedChannelSources.Classorg.springframework.xd.dirt.test.sourceSpring XD
SingleNodeNamedQueueSinkA NamedChannelSink implementation that binds to a Queue Channel.Classorg.springframework.xd.dirt.test.sinkSpring XD
SingleNodeNamedQueueSourceA NamedChannelSource implementation that binds to a Queue Channel.Classorg.springframework.xd.dirt.test.sourceSpring XD
SingleNodeNamedTopicSinkA NamedChannelSink implementation that binds to a PubSub Channel.Classorg.springframework.xd.dirt.test.sinkSpring XD
SingleNodeNamedTopicSourceA NamedChannelSource implementation that binds to a PubSub Channel.Classorg.springframework.xd.dirt.test.sourceSpring XD
SingleNodeOptionsHolds options that can be used in single-node mode.Classorg.springframework.xd.dirt.server.optionsSpring XD
SingleNodeProcessingChainCreates a stream to test a processing chain p1 p2 .Classorg.springframework.xd.dirt.test.processSpring XD
SingleNodeProcessingChainConsumerCreates a stream to test a processing chain including a source but no sink and adds a NamedChannelSink tocreate a complete stream.Classorg.springframework.xd.dirt.test.processSpring XD
SingleNodeProcessingChainProducerCreates a stream to test a processing chain including a sink but no source and adds a NamedChannelSource tocreate a complete stream.Classorg.springframework.xd.dirt.test.processSpring XD
SingleNodeProcessingChainSupportA helper class to easily create AbstractSingleNodeProcessingChains using static methods.Classorg.springframework.xd.dirt.test.processSpring XD
SingleTableDatabaseInitializerClass that's intended for initializing a single table and the script used can use a placeholder #table for the tablename.Classorg.springframework.xd.jdbcSpring XD
SingletonModuleRegistryAn implementation of ModuleRegistry suitable to lookup a module that is atthe root of the classpath.Classorg.springframework.xd.dirt.testSpring XD
SinkChannelNodeClassorg.springframework.xd.dirt.stream.dslSpring XD
SinksA factory that provides fully instantiated sink fixtures based on the environment selected at test startup.Classorg.springframework.xd.integration.fixturesSpring XD
SourceChannelNodeClassorg.springframework.xd.dirt.stream.dslSpring XD
SourcesA convenience class for creating instances of sources to be used for integration testing.Classorg.springframework.xd.integration.fixturesSpring XD
SparkAppJobClassorg.springframework.xd.test.fixturesSpring XD
SparkAppOptionsMetadataModule options for Spark application module.Classorg.springframework.xd.sparkSpring XD
SparkMessageSenderAbstract class that defines abstract methods to support sending the computed messages out of Spark clusterto XD MessageBus etc.Classorg.springframework.xd.spark.streamingSpring XD
SparkPiSparkPi Sample Code that utilizes spark master calls to generate a rough estimate of pi.ClasssparkSpring XD
SparkStreamingChannelThe DirectChannel that provides support forspark streaming configurations.Classorg.springframework.xd.dirt.plugins.spark.streamingSpring XD
SparkStreamingContainerFilterA ContainerFilter which filters out the containers that have a sparkstreaming module running.Classorg.springframework.xd.dirt.sparkSpring XD
SparkStreamingModuleExecutorThe interface that streaming module executor will implement that runs the computation logic on the input DStreamand send the output via $SparkMessageSender.Interfaceorg.springframework.xd.spark.streamingSpring XD
SparkStreamingPluginPlugin for Spark Streaming support.Classorg.springframework.xd.dirt.plugins.spark.streamingSpring XD
SparkStreamingSupportBase interface for spring XD and spark streaming integration.Interfaceorg.springframework.xd.spark.streamingSpring XD
SparkTaskletTasklet for running Spark application.Classorg.springframework.xd.spark.taskletSpring XD
SplitThe AST node representing a split.Classorg.springframework.xd.dirt.job.dslSpring XD
SplitterProcessorOptionsMetadataCaptures options for the splitter processor module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
SplunkSinkOptionsMetadataCaptures options to the splunk sink module.Classorg.springframework.xd.splunkSpring XD
SplunkTransformerMessage consumer that will push the payload to a splunk instance via a TCP-Port.Classorg.springframework.integration.x.splunkSpring XD
SpringXDExceptionA Java exception that wraps the serialized VndErrors object.Classorg.springframework.xd.rest.client.implSpring XD
SpringXDOperationsMain entry point for interacting with a running XD system.Interfaceorg.springframework.xd.rest.clientSpring XD
SpringXDTemplateClassorg.springframework.xd.rest.client.implSpring XD
SqlUtilsClassorg.springframework.xd.greenplum.supportSpring XD
SqoopEnvironmentProviderClassorg.springframework.xd.sqoopSpring XD
SqoopOptionsMetadataModule options for Sqoop application module.Classorg.springframework.xd.sqoopSpring XD
SqoopRunnerClass for running Sqoop tool.Classorg.springframework.xd.sqoopSpring XD
SqoopTaskletTasklet used for running Sqoop tool.Classorg.springframework.xd.sqoopSpring XD
StacktraceFingerprintingCompletionRecoveryStrategyA recovery strategy that will trigger if the parser failure is similar to that of some sample unfinished streamdefinition.Classorg.springframework.xd.dirt.stream.completionSpring XD
StalenessCheckA strategy interface for deciding whether a target definition is stale compared to a source definition.Interfaceorg.springframework.xd.dirt.moduleSpring XD
StandAloneUiAppStarts the Web UI without needing the full Spring XD setup.Classorg.springframework.xd.dirt.webSpring XD
StepExecutionHistoryJacksonMixInJackson MixIn for StepExecutionHistory de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
StepExecutionInfoRepresents Batch step execution info.Classorg.springframework.xd.dirt.jobSpring XD
StepExecutionInfoResourceRepresents the step execution info resource.Classorg.springframework.xd.rest.domainSpring XD
StepExecutionInfoResourceAssemblerKnows how to build a REST resource out of our domain model StepExecutionInfo.Classorg.springframework.xd.dirt.restSpring XD
StepExecutionJacksonMixInJackson MixIn for StepExecution serialization.Classorg.springframework.xd.dirt.plugins.job.supportSpring XD
StepExecutionJacksonMixInJackson MixIn for StepExecution de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XD
StepExecutionProgressInfoRepresents Batch job step execution progress info.Classorg.springframework.xd.dirt.jobSpring XD
StepExecutionProgressInfoResourceRepresents the step execution progress info resource.Classorg.springframework.xd.rest.domainSpring XD
StepExecutionProgressInfoResourceAssemblerKnows how to build a REST resource out of our domain model StepExecutionProgressInfo.Classorg.springframework.xd.dirt.restSpring XD
StepTypeThe types of Spring Batch Step implementations that are known to the system.Classorg.springframework.xd.dirt.jobSpring XD
StoreWriterFactoryBeanA FactoryBean creating a DataStoreWriter.Classorg.springframework.xd.integration.hadoop.configSpring XD
StoreWriterParserParser for the 'storage' element.Classorg.springframework.xd.integration.hadoop.configSpring XD
StreamDomain model for runtime Stream modules.Classorg.springframework.xd.dirt.coreSpring XD
StreamA runtime representation of a running stream.Classorg.springframework.xd.dirt.streamSpring XD
StreamCommandsClassorg.springframework.xd.shell.commandSpring XD
StreamConfigParserClassorg.springframework.xd.dirt.stream.dslSpring XD
StreamDefinitionRepresents a model for a data flow in the system.Classorg.springframework.xd.dirt.streamSpring XD
StreamDefinitionExceptionRoot exception for DSL parsing related exceptions.Classorg.springframework.xd.dirt.stream.dslSpring XD
StreamDefinitionRepositoryA repository for persisting StreamDefinitions.Interfaceorg.springframework.xd.dirt.streamSpring XD
StreamDefinitionRepositoryUtilsClassorg.springframework.xd.dirt.streamSpring XD
StreamDefinitionResourceRepresents a stream definition, i.Classorg.springframework.xd.rest.domainSpring XD
StreamDefinitionResourceAssemblerKnows how to build a REST resource out of our domain model StreamDefinition.Classorg.springframework.xd.dirt.restSpring XD
StreamDeployerDefault implementation of StreamDeployer that uses providedStreamDefinitionRepository and StreamRepository toClassorg.springframework.xd.dirt.streamSpring XD
StreamDeploymentsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XD
StreamExceptionRoot of the hierarchy of exceptions for Module processing in DIRT.Classorg.springframework.xd.dirt.streamSpring XD
StreamFactoryFactory class that builds Stream instances.Classorg.springframework.xd.dirt.streamSpring XD
StreamLookupEnvironmentA lookup environment is used to resolve a stream.Interfaceorg.springframework.xd.dirt.stream.dslSpring XD
StreamNodeClassorg.springframework.xd.dirt.stream.dslSpring XD
StreamOperationsInterface defining operations available against streams.Interfaceorg.springframework.xd.rest.clientSpring XD
StreamPluginClassorg.springframework.xd.dirt.plugins.streamSpring XD
StreamRepositoryA repository for persisting Streams.Interfaceorg.springframework.xd.dirt.streamSpring XD
StreamRuntimePropertiesProviderRuntimeModuleDeploymentPropertiesProvider that provides the stream partition/short circuitproperties for the given ModuleDescriptor.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XD
StreamsControllerHandles all Stream related interaction.Classorg.springframework.xd.dirt.restSpring XD
StreamTemplateClassorg.springframework.xd.rest.client.implSpring XD
StreamUtilsUtilities for creating and monitoring streams and the JMX hooks for those strings.Classorg.springframework.xd.integration.utilSpring XD
StrictContentTypeResolverA StringConvertingContentTypeResolver that requires a the content-type to be present.Classorg.springframework.xd.dirt.integration.busSpring XD
StringConvertingContentTypeResolverA DefaultContentTypeResolver that can parse String values.Classorg.springframework.xd.dirt.integration.busSpring XD
StringRedisRetryTemplateString-focused extension of RedisRetryTemplate.Classorg.springframework.xd.analytics.metrics.redisSpring XD
StringToByteArrayMessageConverterto convert a String to a byte[], applying the provided Charset inthe content-type header if any.Classorg.springframework.xd.dirt.integration.bus.converterSpring XD
StringToDateConverterClassorg.springframework.xd.tupleSpring XD
StringToEnumIgnoringCaseConverterFactoryCopied from org.Classorg.springframework.xd.module.options.supportSpring XD
SubjectMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to a Observable.Classorg.springframework.xd.rxjavaSpring XD
SupervisorElectedEventEvent that is fired after a admin leader is elected.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
SupervisorElectionListenerEvent listener for SupervisorElectedEvents.Interfaceorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
SynchronizingModuleRegistryA ModuleRegistry that is configured with two delegates: a remote (source) and a local (target) registry.Classorg.springframework.xd.dirt.moduleSpring XD
SyslogInboundChannelAdapterInboundChannelAdapter implementation that uses the Reactor TCP support to read in syslog messages andtransform them to a Map for use in downstream modules.Classorg.springframework.xd.integration.reactor.syslogSpring XD
SyslogInboundChannelAdapterConfigurationClassorg.springframework.xd.integration.reactor.syslogSpring XD
SyslogInboundChannelAdapterParserClassorg.springframework.xd.integration.reactor.configSpring XD
SyslogSourceOptionsMetadataCaptures options for the syslog-udp source module.Classorg.springframework.xd.syslogSpring XD
SyslogTcpSourceA test fixture that allows testing of the syslog tcp source module.Classorg.springframework.xd.test.fixturesSpring XD
SyslogTcpSourceOptionsMetadataCaptures options for the syslog-tcp source module.Classorg.springframework.xd.syslogSpring XD
SyslogUdpSourceA test fixture that allows testing of the syslog udp source module.Classorg.springframework.xd.test.fixturesSpring XD
TableProvide a basic concept of a table structure containing a map of column headers and a collection of rows.Classorg.springframework.xd.shell.utilSpring XD
TableHeaderDefines table column headers used by Table.Classorg.springframework.xd.shell.utilSpring XD
TableRowHolds the table rows used by Table.Classorg.springframework.xd.shell.utilSpring XD
TailSourceSupport class that represents a tail source.Classorg.springframework.xd.test.fixturesSpring XD
TailSourceOptionsMetadataDescribes options to the tail source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
TapTest fixture that creates a tap.Classorg.springframework.xd.test.fixturesSpring XD
TargetEncapsulates various data points related to the Admin Server Target, such as target URI, success/error state,exception messages that may have occurred.Classorg.springframework.xd.shellSpring XD
TaskletTypeTypes of Tasklet implementations known by Spring XD.Classorg.springframework.xd.dirt.jobSpring XD
TcpClientSourceA test fixture that allows testing of the 'tcp-client' source module.Classorg.springframework.xd.test.fixturesSpring XD
TcpClientSourceOptionsMetadataCaptures options available to the tcp-client source module.Classorg.springframework.xd.tcpSpring XD
TcpSinkTest fixture that creates a simple socket server, ready to accept connections from a 'tcp' sink module.Classorg.springframework.xd.test.fixturesSpring XD
TcpSinkOptionsMetadataCaptures the options to the tcp sink module.Classorg.springframework.xd.tcpSpring XD
TcpSourceA test fixture that allows testing of the 'tcp' source module.Classorg.springframework.xd.test.fixturesSpring XD
TcpSourceOptionsMetadataCaptures options for the tcp source module.Classorg.springframework.xd.tcpSpring XD
TestModuleDefinitionsUtility class for creating ModuleDefinitions in the context of tests.Classorg.springframework.xd.moduleSpring XD
ThreadContextClassLoaderSetterAdviceAn advice that will set the thread context ClassLoader to theenclosing ApplicationContext's class loader before invocation and resetClassorg.springframework.xd.dirt.module.supportSpring XD
ThroughputSamplerMessageHandlerSamples throughput by counting messages over an elapsed time between receiving aMessage with the given startMessage and a endMessage andClassorg.springframework.xd.integration.throughputSpring XD
ThroughputSamplerOptionsMetadataClassorg.springframework.xd.integration.throughputSpring XD
TimeSourceOptionsMetadataDescribes options to the time source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
TimestampFileJobOptionsMetadataOptions for the timestampfile job module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
TimestampFileTaskletA Tasklet implementationthat writes the current timestamp to a file.Classorg.springframework.batch.integration.xSpring XD
TimeUtilsProvides a commons set of time-related helper methods and also defines commonSince:1.Classorg.springframework.xd.rest.domain.utilSpring XD
TokenHolder for a kind of token, the associated data and its position in the input data stream (start/end).Classorg.springframework.xd.dirt.job.dslSpring XD
TokenHolder for a kind of token, the associated data and its position in the input data stream (start/end).Classorg.springframework.xd.dirt.stream.dslSpring XD
TokenKindEnumeration of all the token types that may be found in a Job DSL specification.Classorg.springframework.xd.dirt.job.dslSpring XD
TokenKindEnumeration of all the token types that may be found in a DSL definition stream.Classorg.springframework.xd.dirt.stream.dslSpring XD
TokensClass that converts an expression into a list of tokens.Classorg.springframework.xd.dirt.job.dslSpring XD
ToolsControllerA controller for integrating with frontend tools.Classorg.springframework.xd.dirt.restSpring XD
ToStringCharsetMixinA standard mixin for modules that do conversion from bytes to String.Classorg.springframework.xd.module.options.mixinsSpring XD
TransformTest fixture that creates a Transform.Classorg.springframework.xd.test.fixturesSpring XD
TransitionAn AST node representing a transition found in the parsed Job specification.Classorg.springframework.xd.dirt.job.dslSpring XD
TriggerSourceOptionsMetadataDescribes options to the trigger source module.Classorg.springframework.xd.dirt.modules.metadataSpring XD
TupleData structure that stores a fixed number of ordered key-value pairs and adds convenience methods to access values inThe structure is immutable once created and values to not need to be of the same type.Interfaceorg.springframework.xd.tupleSpring XD
TupleBuilderBuilder class to create Tuple instances.Classorg.springframework.xd.tupleSpring XD
TupleFieldExtractorNames - The fields will be extracted from the item in the order they are specified via the names in the providedList.Classorg.springframework.xd.tuple.batchSpring XD
TupleFieldSetMapperA FieldSetMapper implementation intended to allow a user use a Tuple as the item.Classorg.springframework.xd.tuple.batchSpring XD
TupleJsonMarshallerClassorg.springframework.xd.tupleSpring XD
TupleKryoRegistrarused to register a Tuple serializer.Classorg.springframework.xd.tuple.serializer.kryoSpring XD
TuplePropertyAccessorA PropertyAccessor implementation that enables reading of Tuple values using dot notation within SpELexpressions.Classorg.springframework.xd.tuple.spelSpring XD
TupleRowMapperA RowMapper implementation to be used with the Tuple data structure.Classorg.springframework.xd.tuple.batchSpring XD
TupleSqlParameterSourceClassorg.springframework.xd.tuple.batchSpring XD
TupleSqlParameterSourceProviderA factory for TupleSqlParameterSourcesAuthor:Michael MinellaClassorg.springframework.xd.tuple.batchSpring XD
TupleStringMarshallerClassorg.springframework.xd.tupleSpring XD
TupleToJsonMessageConverterto convert a Tuple to a JSON StringAuthor:David TuranskiClassorg.springframework.xd.dirt.integration.bus.converterSpring XD
TupleToJsonStringConverterConverts a Tuple to JSON representationAuthor:David Turanski, Gunnar HillertClassorg.springframework.xd.tupleSpring XD
TupleWriteConverterClassorg.springframework.xd.mongodbSpring XD
TwitterMixinOptions common to twitter source modulesAuthor:David TuranskiClassorg.springframework.integration.x.twitterSpring XD
TwitterSearchChannelAdapterMessage producer which reads form Twitter's public search endpoints.Classorg.springframework.integration.x.twitterSpring XD
TwitterSearchOptionsMetadataClassorg.springframework.integration.x.twitterSpring XD
TwitterSearchSourceA test fixture that allows testing of the 'TwitterSearch' source module.Classorg.springframework.xd.test.fixturesSpring XD
TwitterStreamChannelAdapterMessage producer which reads form Twitter's public stream endpoints.Classorg.springframework.integration.x.twitterSpring XD
TwitterStreamOptionsMetadataClassorg.springframework.integration.x.twitterSpring XD
TwitterStreamSourceA test fixture that allows testing of the 'TwitterStream' source module.Classorg.springframework.xd.test.fixturesSpring XD
UiUtilsContains utility methods for rendering data to a formatted console output.Classorg.springframework.xd.shell.utilSpring XD
UnfinishedModuleNameRecoveryStrategyClassorg.springframework.xd.dirt.stream.completionSpring XD
UnfinishedOptionNameRecoveryStrategyClassorg.springframework.xd.dirt.stream.completionSpring XD
UploadedModuleDefinitionA module definition that serves as a temporary vehicle for the payload of an uploaded module.Classorg.springframework.xd.dirt.moduleSpring XD
UserInputAbstraction for a mechanism used to get user interactive user input.Interfaceorg.springframework.xd.shell.commandSpring XD
ValidationControllerProvides server-validation services.Classorg.springframework.xd.dirt.rest.validationSpring XD
ValidationGroupsProviderTo be implemented by classes change their validation behavior based on which properties have been set by the user.Interfaceorg.springframework.xd.module.options.spiSpring XD
VersionControllerController to retrieve version control information.Classorg.springframework.xd.dirt.rest.metaSpring XD
VersionPatternConverterthat returns the "Implementation-Version" string obtained from themanifest of the jar that this class was loaded from.Classorg.springframework.xd.dirt.util.loggingSpring XD
VersionPatternLayoutExtension of Log4j's EnhancedPatternLayoutwhich supports logging of the "Implementation-Version" stringClassorg.springframework.xd.dirt.util.loggingSpring XD
VersionPatternParserExtension of Log4j's PatternParserthat recognizes the pattern %v which is used to log theClassorg.springframework.xd.dirt.util.loggingSpring XD
VersionResourceProvides the version information for Spring XD.Classorg.springframework.xd.rest.domain.metaSpring XD
VndErrorResponseErrorHandlerExtension of DefaultResponseErrorHandler that knows how to de-serialize a VndErrors.Classorg.springframework.xd.rest.client.implSpring XD
WebConfigurationProvides Spring MVC configuration.Classorg.springframework.xd.dirt.webSpring XD
WindowingOffsetManagerAn OffsetManager that aggregates writes over a time or count window, using an underlying delegate todo the actual operations.Classorg.springframework.integration.x.kafkaSpring XD
WordCountClassorg.springframework.xd.spark.streaming.examples.javaSpring XD
WritableModuleRegistryBase interface for registries that know how to create (and hence how to delete) new module definitions.Interfaceorg.springframework.xd.dirt.moduleSpring XD
WritableResourceModuleRegistryWritable extension of ResourceModuleRegistry.Classorg.springframework.xd.dirt.moduleSpring XD
XdAppmasterCustom application master handling XD containers grouping settingfor launch commands.Classorg.springframework.xd.yarnSpring XD
XdBatchDatabaseInitializerA BatchDatabaseInitializer for XD batch datasource.Classorg.springframework.xd.batchSpring XD
XdConfigLoggingInitializerInitializer that can print useful stuff about an XD context on startup.Classorg.springframework.xd.dirt.utilSpring XD
XDControllerBase Class for XD Controllers.Classorg.springframework.xd.dirt.restSpring XD
XDDSLMessagesContains all the messages that can be produced during Spring XD DSL parsing.Classorg.springframework.xd.dirt.stream.dslSpring XD
XdEc2ValidationValidates that all instances of the cluster is up and running.Classorg.springframework.xd.integration.utilSpring XD
XdEnvironmentExtracts the host and port information for the XD Instances.Classorg.springframework.xd.integration.utilSpring XD
XdErrorControllerErrorController that causes 404 errors to be redirected to the Admin-UI 404 page.Classorg.springframework.xd.dirt.restSpring XD
XdHeadersSpring Integration message headers for XD.Classorg.springframework.xd.dirt.integration.busSpring XD
XdJdbcSearchableJobExecutionDaoClassorg.springframework.xd.dirt.job.daoSpring XD
XDJobListenerConstantsInterface holdings constants related to XD JobListeners.Interfaceorg.springframework.xd.dirt.plugins.job.support.listenerSpring XD
XDParserParser to convert a DSL string for a deployable unit (i.Interfaceorg.springframework.xd.dirt.streamSpring XD
XdProfilesStatic constants for XD server's spring profile names.Classorg.springframework.xd.dirt.utilSpring XD
XDRuntimeRepresents information about the XD Runtime.Classorg.springframework.xd.rest.domainSpring XD
XDShellClassorg.springframework.xd.shellSpring XD
XDShellBannerProviderProvides the Spring XD specific BannerProvider.Classorg.springframework.xd.shellSpring XD
XDShellPromptProviderA provider that sets the shell prompt to xd:>Since:1.Classorg.springframework.xd.shellSpring XD
XDStreamParserParser to convert a DSL string for a stream into a list ofobjects that comprise the given stream.Classorg.springframework.xd.dirt.streamSpring XD
XdUtilsProvides general utilities for Spring XD.Classorg.springframework.xd.dirt.utilSpring XD
XdYarnAdminInfoCommandA custom command for listing the http ports used by admin servers.Classorg.springframework.xd.yarnSpring XD
XdYarnClusterCreateCommandA custom YarnClusterCreateCommand adding option for defininga groups for XD's containers.Classorg.springframework.xd.yarnSpring XD
ZKDeploymentHandlerAbstract class that has common implementations of ZK based deployments.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ZKDeploymentMessagePublisherZooKeeper based DeploymentMessagePublisher that publishesdeployment messages into a ZooKeeper/CuratorClassorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ZKJobDeploymentHandlerDeployment handler that is responsible for the deployment of a Job.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ZKStreamDeploymentHandlerDeployment handler that is responsible for deploying Stream.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XD
ZooKeeperAccessExceptionRuntime exception used to wrap native ZooKeeper checked exceptions thrown whileaccessing ZooKeeper nodes.Classorg.springframework.xd.dirt.zookeeperSpring XD
ZooKeeperAdminRepositoryZooKeeper backed repository for runtime info about Admins.Classorg.springframework.xd.dirt.container.storeSpring XD
ZooKeeperComposedModuleDefinitionRegistryAn implementation of WriteableModuleRegistry dedicated to CompositeModuleDefinitions and that usesZooKeeper as storage mechanism.Classorg.springframework.xd.dirt.module.storeSpring XD
ZooKeeperConnectionA wrapper for a CuratorFramework instance whose lifecycle is managed as a Spring bean.Classorg.springframework.xd.dirt.zookeeperSpring XD
ZooKeeperConnectionConfigurerA strategy interface for configuring ZooKeeperConnection at start up.Interfaceorg.springframework.xd.dirt.zookeeperSpring XD
ZooKeeperConnectionListenerListener for ZooKeeper connection and disconnection events.Interfaceorg.springframework.xd.dirt.zookeeperSpring XD
ZookeeperConnectionPluginSupplies plugins with a reference to the Spring XD ZooKeeperConnectionAuthor:Marius BogoeviciClassorg.springframework.xd.dirt.pluginsSpring XD
ZooKeeperContainerRepositoryZooKeeper backed repository for runtime info about Containers.Classorg.springframework.xd.dirt.container.storeSpring XD
ZooKeeperJobDefinitionRepositoryA Zookeeper backed repository for persisting JobDefinitions.Classorg.springframework.xd.dirt.stream.zookeeperSpring XD
ZooKeeperJobRepositoryJob instance repository.Classorg.springframework.xd.dirt.stream.zookeeperSpring XD
ZooKeeperModuleDependencyRepositoryZooKeeper based implementation of ModuleDependencyRepository that writes each dependency to a node, such as:/xd/modules/[moduletype]/[modulename]/dependencies/[target].Classorg.springframework.xd.dirt.module.storeSpring XD
ZooKeeperModuleMetadataRepositoryZooKeeper backed repository for runtime info about deployed modules.Classorg.springframework.xd.dirt.module.storeSpring XD
ZooKeeperStreamDefinitionRepositoryClassorg.springframework.xd.dirt.stream.zookeeperSpring XD
ZooKeeperStreamRepositoryStream instance repository.Classorg.springframework.xd.dirt.stream.zookeeperSpring XD
ZooKeeperUtilsUtility methods for ZooKeeper.Classorg.springframework.xd.dirt.zookeeperSpring XD