Share

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.
NameDescriptionTypePackageFrameworkJavaDoc
AbstractBatchJobsControllerAbstract controller that all the XD batch admin controllers extend.Classorg.springframework.xd.dirt.restSpring XDjavadoc
AbstractBusPropertiesAccessorClassorg.springframework.xd.dirt.integration.busSpring XDjavadoc
AbstractComponentScanningBeanDefinitionProviderClassorg.springframework.xd.dirt.container.initializerSpring XDjavadoc
AbstractDeployerAbstract implementation of the @link ResourceDeployer interface.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
AbstractEventClassorg.springframework.xd.dirt.eventSpring XDjavadoc
AbstractExternalResourceTestSupportAbstract base class for JUnit Rules that detect the presence of some external resource.Classorg.springframework.xd.testSpring XDjavadoc
AbstractExternalTableBase settings for all external tables;Since:1.Classorg.springframework.xd.greenplum.supportSpring XDjavadoc
AbstractFieldMappingAwareDataMapperClassorg.springframework.xd.analytics.mlSpring XDjavadoc
AbstractFromMessageConverterBase class for converters applied via Spring Integration 4.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
AbstractGPFDistMessageHandlerBase implementation of Spring Integration MessageHandler handling Message.Classorg.springframework.xd.greenplum.gpfdistSpring XDjavadoc
AbstractHdfsItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XDjavadoc
AbstractHdfsWriterClassorg.springframework.xd.hadoop.fsSpring XDjavadoc
AbstractImportToJdbcOptionsMetadataFactors out options that are common to modules/jobs that import into a db table.Classorg.springframework.xd.jdbcSpring XDjavadoc
AbstractInMemoryRepositoryBase implementation for an in-memory store, using a Map internally.Classorg.springframework.xd.storeSpring XDjavadoc
AbstractInstancePersistingDeployerBase support class for deployers that know how to deal with instances of aAuthor:Eric Bottard, Ilayaperumal GopinathanClassorg.springframework.xd.dirt.streamSpring XDjavadoc
AbstractJobPluginAbstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related toAuthor:Ilayaperumal Gopinathan, Gary RussellClassorg.springframework.xd.dirt.pluginsSpring XDjavadoc
AbstractMailSourceBase class support for both "mail" and "imap".Classorg.springframework.xd.test.fixturesSpring XDjavadoc
AbstractMessageBusBinderPluginAbstract Plugin that has common implementation methods to bind/unbind Module's message producers andconsumers to/from MessageBus.Classorg.springframework.xd.dirt.pluginsSpring XDjavadoc
AbstractMetricsCommandsBase class to factor out similar behavior for all related metrics commands.Classorg.springframework.xd.shell.commandSpring XDjavadoc
AbstractMetricSinkBase class for Metrics related sinks, makes sure named metric is deleted at end of test.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
AbstractModuleBase support class for modules, wrapping ModuleDescriptor and ModuleDeploymentProperties.Classorg.springframework.xd.module.coreSpring XDjavadoc
AbstractModuleEventClassorg.springframework.xd.dirt.eventSpring XDjavadoc
AbstractModuleFixtureBase class for objects that can be incorporated in a stream definition by calling their toString() method.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
AbstractPluginAbstract Plugin that contains no-op and common implementing methods.Classorg.springframework.xd.dirt.pluginsSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

AbstractProcessBuilderTaskletAbstract tasklet for running code in a separate process and capturing the log output.Classorg.springframework.batch.step.tasklet.xSpring XDjavadoc
AbstractReactorMessageHandlerAbstract base class for Reactor based MessageHandlers.Classorg.springframework.xd.reactorSpring XDjavadoc
AbstractRedisRepositoryBase implementation for a store, using Redis behind the scenes.Classorg.springframework.xd.storeSpring XDjavadoc
AbstractRepositoryHelper class for repositories, implementing some behavior in terms of unit methods.Classorg.springframework.xd.storeSpring XDjavadoc
AbstractResourceBeanDefinitionProviderA OrderedContextInitializer base class for loading XML or Groovy Bean Definitions into the target ContainerAuthor:David TuranskiClassorg.springframework.xd.dirt.container.initializerSpring XDjavadoc
AbstractSingleNodeNamedChannelModuleBase class for SingleNodeNamedChannel resources used to bind a MessageChannel to a shared channel using aAuthor:David TuranskiClassorg.springframework.xd.dirt.testSpring XDjavadoc
AbstractSingleNodeNamedChannelModuleFactoryBase class for factories used to create NamedChannelSource and NamedChannelSink.Classorg.springframework.xd.dirt.testSpring XDjavadoc
AbstractSingleNodeNamedChannelSinkBase class for SingleNode named channel sink types.Classorg.springframework.xd.dirt.test.sinkSpring XDjavadoc
AbstractSingleNodeNamedChannelSourceBase class for SingleNode named channel source types.Classorg.springframework.xd.dirt.test.sourceSpring XDjavadoc
AbstractSingleNodeProcessingChainA helper class for building single node streams that use a NamedChannelSource and NamedChannelSink.Classorg.springframework.xd.dirt.test.processSpring XDjavadoc
AbstractStreamPluginAbstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related toAuthor:Ilayaperumal Gopinathan, Mark Fisher, Gary RussellClassorg.springframework.xd.dirt.pluginsSpring XDjavadoc
AbstractTcpConnectionFactoryOptionsMetadataBase class for options metadata that deal with a tcp connection factory in some way.Classorg.springframework.xd.tcpSpring XDjavadoc
AbstractTwitterInboundChannelAdapterClassorg.springframework.integration.x.twitterSpring XDjavadoc
AddModuleOptionsExpansionStrategyAdds missing module options at the end of a well formed stream definition.Classorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
AdminDomain object for an XD admin runtime.Classorg.springframework.xd.dirt.clusterSpring XDjavadoc
AdminAttributesRuntime metadata for a Admin server instance.Classorg.springframework.xd.dirt.clusterSpring XDjavadoc
AdminControllerClassorg.springframework.xd.dirt.restSpring XDjavadoc
AdminOptionsHolds configuration options that are valid for the Admin server, when using distributed mode.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
AdminPortNotAvailableExceptionException thrown when the configured admin port is not available to use.Classorg.springframework.xd.dirt.server.adminSpring XDjavadoc
AdminRepositoryRepository for persisting Admin entities for admins.Interfaceorg.springframework.xd.dirt.container.storeSpring XDjavadoc
AdminServerApplicationClassorg.springframework.xd.dirt.server.adminSpring XDjavadoc
AggregateCountRepresents the data returned from an aggregate count query.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
AggregateCounterCommandsCommands for interacting with aggregate counter analytics.Classorg.springframework.xd.shell.commandSpring XDjavadoc
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 XDjavadoc
AggregateCounterOperationsInterface defining operations available when dealing with Aggregate Counters.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

AggregateCounterRepositoryA repository to interact with Aggregate Counters.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
AggregateCountersControllerExposes representations of AggregateCounts.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
AggregateCounterSinkFixture class for an aggregate counter.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
AggregateCounterSinkOptionsMetadataCaptures options for the aggregate-counter sink module.Classorg.springframework.xd.analytics.metrics.metadataSpring XDjavadoc
AggregateCounterTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
AggregateCountResolutionenum AggregateCountResolutionThe resolution options available for querying an aggregate counter.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
AggregateCountsResourceThe REST representation of an Aggregate Count.Classorg.springframework.xd.rest.domain.metricsSpring XDjavadoc
AggregatorProcessorModuleOptionsMetadataDescribes options to the aggregator processor module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
AlreadyDeployedExceptionThrown when an attempt is made to deploy a definition that is already deployed.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
AnalyticBase interface for the definition of analytical logic.Interfaceorg.springframework.xd.analytics.mlSpring XDjavadoc
ApplicationUtilsClassorg.springframework.xd.dirt.serverSpring XDjavadoc
AppmasterApplicationBoot appmaster application.Classorg.springframework.xd.yarnSpring XDjavadoc
ArchiveResourceLoaderSpring ResourceLoader that can locate nested boot archives inside a root archive.Classorg.springframework.xd.module.supportSpring XDjavadoc
ArgumentNodeRepresents an argument like "--name=value".Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
ArgumentNodeRepresents an argument like "--name=value".Classorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
AsciidocLinkCheckerA tool that checks that for files that will form the whole "concatenated" documentation, any link of the form link::[Classorg.springframework.xd.documentationSpring XDjavadoc
AssertionsVarious utility methods when dealing with shell commands.Classorg.springframework.xd.shell.utilSpring XDjavadoc
AstNodeAST base class for AST nodes in a parsed Job specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
AstNodeCommon supertype for the ast nodes built during stream parsing.Classorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
AuthenticationRequestClassorg.springframework.xd.dirt.web.controller.supportSpring XDjavadoc
AutoOffsetResetStrategyenum AutoOffsetResetStrategyThe possible values for automatically resetting the offset of Kafka clientClassorg.springframework.integration.x.kafkaSpring XDjavadoc
AvailableSocketPortsUtility class to find available server ports.Classorg.springframework.xd.test.fixtures.utilSpring XDjavadoc
BannerUtilsProvides utilities for rendering graphical console output.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
BaseDefinitionRepresents the base model for a data flow in the system.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
BaseInstanceA runtime representation of a Definition.Classorg.springframework.xd.dirt.streamSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

BatchJobAlreadyExistsExceptionException thrown when the batch job with the given name already exists.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
BatchJobAlreadyExistsInRegistryExceptionException thrown when a batch job already exists in the JobRegistry.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
BatchJobCommitIntervalOptionMixinBatch job option for commit-interval.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchJobDeleteFilesOptionMixinBatch job option for delete files after import.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchJobExecutionsControllerController for batch job executions.Classorg.springframework.xd.dirt.restSpring XDjavadoc
BatchJobFieldDelimiterOptionMixinBatch job option for the delimiter in the file (csv file etc.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchJobFieldNamesOptionMixinBatch job option for fields names in the file (csv file etc.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchJobHeadersHeaders definitions used by the batch job plugin.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
BatchJobInstancesControllerController for batch job instances.Classorg.springframework.xd.dirt.restSpring XDjavadoc
BatchJobListenerAbstract batch job listener that sends batch job listener payload to the SubscribableChannel notificationAuthor:Ilayaperumal GopinathanClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
BatchJobRegistryBeanPostProcessorJobRegistryBeanPostProcessor that processes batch job from the job module.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
BatchJobResourcesOptionMixinBatch job option for resources (Spring resources) to import.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchJobRestartableOptionMixinBatch job option for restartable.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchJobsControllerController for batch jobs and job instances, job executions on a given batch job.Classorg.springframework.xd.dirt.restSpring XDjavadoc
BatchJobSinglestepPartitionSupportOptionMixinCaptures options made available via the import of singlestep-partition-support.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
BatchListenerEventTypeenum BatchListenerEventTypeEnumerations to help identify various Batch job events being issued.Classorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
BatchStepExecutionsControllerController for returning Batch StepExecutions.Classorg.springframework.xd.dirt.restSpring XDjavadoc
BeanPropertiesPropertySourceA PropertySource that exposes the javabeans properties of an object as properties.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
BindingRepresents a binding between a module's channel and an adapter endpoint that connects to the MessageBus.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
BroadcasterMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to a StreamClassorg.springframework.xd.reactorSpring XDjavadoc
BusCleanerInterface for implementations that perform cleanup for message buses.Interfaceorg.springframework.xd.dirt.integration.busSpring XDjavadoc
BusPropertiesCommon bus properties.Interfaceorg.springframework.xd.dirt.integration.busSpring XDjavadoc
BusTestUtilsClassorg.springframework.xd.dirt.integration.busSpring XDjavadoc
BusUtilsMessage Bus utilities.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
ByteArrayToStringMessageConverterto convert from byte[] to String applying the Charset provided inthe content-type header if any.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

CacheServerA simple driver class to run a Gemfire cache server.Classorg.springframework.xd.gemfire.serverSpring XDjavadoc
CassandraConfigurationClassorg.springframework.xd.cassandraSpring XDjavadoc
CassandraConnectionMixinClassorg.springframework.xd.cassandra.mixinsSpring XDjavadoc
CassandraSinkConfigurationClassorg.springframework.xd.cassandraSpring XDjavadoc
CassandraSinkOptionsMetadataClassorg.springframework.xd.cassandraSpring XDjavadoc
ChannelNodeClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
ChannelTypeClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
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 XDjavadoc
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 XDjavadoc
ChildPathIteratorIterator over ChildData instances that are managed by PathChildrenCache.Classorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
ChunkContextInfoClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
ClasspathEnvironmentProviderClassorg.springframework.batch.step.tasklet.xSpring XDjavadoc
ClientApplicationCli for controlling XD instances on an application master.Classorg.springframework.xd.yarnSpring XDjavadoc
ClientTcpConnectionFactoryOptionsMetadataMixinMixin for options metadata that configure a client tcp connection factory.Classorg.springframework.xd.tcpSpring XDjavadoc
CommandLinePropertySourceOverridingListenerAn ApplicationListener that will parse command line options and also replace the default boot commandlinePropertySource with those values.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
CommonDistributedOptionsHolds options that are common to both admin and container servers, when used in distributed mode.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
CommonOptionsBase class for command line options that are common to absolutely every setup (single and distributed).Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
CommonUtilsContains common non-ui related helper methods for rendering text to the console.Classorg.springframework.xd.shell.utilSpring XDjavadoc
CompletionConverterA converter that provides DSL completion wherever parts of stream definitions may appear.Classorg.springframework.xd.shell.converterSpring XDjavadoc
CompletionExpansionStrategyUsed to enhance a well formed stream definition by adding yet more text to it (e.Interfaceorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
CompletionKindUsed to represent the context in which the code completion facility is invoked.Classorg.springframework.xd.rest.domainSpring XDjavadoc
CompletionOperationsProvides access to the dsl completion facility.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
CompletionProviderProvides code completion on a (maybe ill-formed) stream definition.Classorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
CompletionRecoveryStrategyUsed to provide completions on ill-formed stream definitions, after an initial (failed) parse.Interfaceorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
CompletionsControllerExposes completion for stream-like definitions as a REST endpoint.Classorg.springframework.xd.dirt.restSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

CompletionTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
ComposedJobUtilClassorg.springframework.xd.dirt.job.dslSpring XDjavadoc
CompositeMessageConverterFactoryA factory for creating an instance of CompositeMessageConverter for a given target MIME typeAuthor:David TuranskiClassorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
CompositeModuleClassorg.springframework.xd.module.coreSpring XDjavadoc
CompositeModuleDefinitionA module definition for a module which has been custom created as the composition of several othermodules (either simple orClassorg.springframework.xd.moduleSpring XDjavadoc
ConfigCommandsDefines several shell commands in order to configure the shell itself.Classorg.springframework.xd.shell.commandSpring XDjavadoc
ConfigLocationsStatic constants for configuration locations.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
ConfigurationEncapsulates various configuration properties for the shell such as Targetand the configurable TimeZone.Classorg.springframework.xd.shellSpring XDjavadoc
ConfigurationAwareUtility base class for components monitoring Configuration changes in order to update state.Classorg.springframework.xd.shell.hadoopSpring XDjavadoc
ConfigurationCommandsCommand for configuring the global Hadoop Configuration object used by other components.Classorg.springframework.xd.shell.hadoopSpring XDjavadoc
ConfigurationModifiedEventNotification event that a Configuration object (attached) has been modified.Classorg.springframework.xd.shell.hadoopSpring XDjavadoc
ConfigUtilTools to create and read configuration files for an environment deployed on EC2.Classorg.springframework.xd.integration.utilSpring XDjavadoc
ConnectionFactorySettingsConfigures the connection factory used by the rabbit message bus.Classorg.springframework.xd.dirt.integration.rabbitSpring XDjavadoc
ConsoleUserInputUserInput that uses Standard in and out.Classorg.springframework.xd.shell.commandSpring XDjavadoc
ContainerDomain object for an XD container.Classorg.springframework.xd.dirt.clusterSpring XDjavadoc
ContainerAttributesMetadata for a Container instance.Classorg.springframework.xd.dirt.clusterSpring XDjavadoc
ContainerBootstrapContextPackage private class to bootstrap the Container process.Classorg.springframework.xd.dirt.server.containerSpring XDjavadoc
ContainerConfigurationContainer Application ContextAuthor:David Turanski, Ilayaperumal Gopinathan, Marius BogoeviciClassorg.springframework.xd.dirt.server.containerSpring XDjavadoc
ContainerFilterA filter interface that applies filter for the given containers and returnseligible containers for deployment.Interfaceorg.springframework.xd.dirt.clusterSpring XDjavadoc
ContainerInfoPluginA plugin that exposes information about the container to the Environment.Classorg.springframework.xd.dirt.pluginsSpring XDjavadoc
ContainerListenerListener implementation that is invoked when containers are added/removed/modified.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ContainerMatcherModuleDescriptor to.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
ContainerMatchingModuleRedeployerThe ModuleRedeployer that deploys the unallocated stream/job modules.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ContainerOptionsHolds configuration options that are valid for the Container node, when using distributed mode.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
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 XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ContainerRepositoryRepository for persisting Container entities.Interfaceorg.springframework.xd.dirt.container.storeSpring XDjavadoc
ContainerResolverResolve runtime hosts for modules.Classorg.springframework.xd.integration.fixturesSpring XDjavadoc
ContainersControllerHandles interaction with the runtime containers/and its modules.Classorg.springframework.xd.dirt.restSpring XDjavadoc
ContainerServerApplicationThe boot application class for a Container server.Classorg.springframework.xd.dirt.server.containerSpring XDjavadoc
ContainerShutdownExceptionException thrown when shutting down the containerAuthor:Ilayaperumal GopinathanSee Also:Serialized FormClassorg.springframework.xd.dirt.clusterSpring XDjavadoc
ControlFileClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
ControlFileFactoryBeanClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
ConversionExceptionException thrown when an error is encountered during message conversion.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
CounterRepresents the data stored in a valueer of a single value.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
CounterCommandsCommands for interacting with Counter analytics.Classorg.springframework.xd.shell.commandSpring XDjavadoc
CounterOperationsInterface defining operations available when dealing with Counters.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
CounterRepositoryInterface for repositories that now how to deal with Counters.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
CounterResourceThe REST representation of a Counter.Classorg.springframework.xd.rest.domain.metricsSpring XDjavadoc
CountersControllerExposes representations of Counters.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
CounterSinkFixture class for an "simple" counter.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
CounterTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
CronExpressionThe annotated element must be a valid Spring cron expression (6 fields).Classorg.springframework.xd.module.options.validationSpring XDjavadoc
CronValidationClassorg.springframework.xd.rest.domain.validationSpring XDjavadoc
CustomLoggerConverterClassorg.springframework.xd.dirt.util.loggingSpring XDjavadoc
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 XDjavadoc
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 XDjavadoc
DatabaseVendorFriendlyNameFactoryBeanA factory bean that returns a friendly string name from database metadata.Classorg.springframework.xd.dirt.jdbc.utilSpring XDjavadoc
DatasetDefinitionFactoryBeanFactoryBean that creates a default DatasetDefinitionAuthor:Thomas RisbergClassorg.springframework.xd.hadoop.fsSpring XDjavadoc
DatasetOutboundChannelAdapterParserParser for the 'dataset-outbound-channel-adapter' element.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
DatasetWriterClassorg.springframework.xd.hadoop.fsSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

DatasetWriterFactoryClassorg.springframework.xd.hadoop.fsSpring XDjavadoc
DatasetWritingMessageHandlerFactoryBeanFactory bean used to create HdfsWritingMessageHandlerAuthor:Thomas RisbergClassorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
DateFormatThe annotated must be a valid SimpleDateFormat pattern.Classorg.springframework.xd.module.options.validationSpring XDjavadoc
DateFormatMixinProvides a dateFormat module option, meant to hold a pattern that conforms to SimpleDateFormat.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
DateTriggerA Trigger implementation that enables execution on a series of Dates.Classorg.springframework.xd.module.supportSpring XDjavadoc
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 XDjavadoc
DeepAggregateCountResourceAssemblerKnows how to construct AggregateCountsResource out of AggregateCount.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
DeepCounterResourceAssemblerKnows how to assemble CounterResources out of Counters.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
DeepFieldValueCounterResourceAssemblerKnows how to create rich representations of FieldValueCounter.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
DefaultDeploymentStateRecalculatorStream/Job deployment state re-calculator upon leadership election.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DefaultDeploymentUnitStateCalculatorDefault DeploymentUnitStateCalculatorIf all expected modules are deployed, the state is consideredClassorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DefaultDistributedTestSupportClassorg.springframework.xd.distributed.utilSpring XDjavadoc
DefaultGreenplumLoadClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
DefaultLoadServiceClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
DefaultModuleDeploymentPropertiesProviderDefault implementation that retrieves the ModuleDeploymentProperties for the givenAuthor:Ilayaperumal GopinathanClassorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DefaultModuleOptionsMetadataCollectorClassorg.springframework.xd.module.optionsSpring XDjavadoc
DefaultModuleOptionsMetadataResolverThe default implementation of ModuleOptionsMetadataResolver that deals with simple modules and reads thecompanion .Classorg.springframework.xd.module.optionsSpring XDjavadoc
DefaultSimpleModuleInformationResolverDefault implementation of ModuleInformationResolver that supportsSimpleModuleDefinitions and that reads Strings fromClassorg.springframework.xd.module.infoSpring XDjavadoc
DefaultSparkStreamingModuleOptionsMetadataDefault module options for SparkStreamingSupport.Classorg.springframework.xd.spark.streamingSpring XDjavadoc
DefaultTupleDefault implementation of Tuple interfaceAuthor:Mark Pollack, David Turanski, Michael MinellaClassorg.springframework.xd.tupleSpring XDjavadoc
DefaultTupleConversionServiceBase ConversionService implementation suitable for use with TupleAuthor:David TuranskiClassorg.springframework.xd.tupleSpring XDjavadoc
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 XDjavadoc
DefinitionAlreadyExistsExceptionException which is raised when a resource definition with the same name already exists.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
DelegatingModuleInformationResolverA composite resolver that will try delegates until one returns a non null result.Classorg.springframework.xd.module.infoSpring XDjavadoc
DelegatingModuleOptionsMetadataResolverA ModuleOptionsMetadataResolver that will invoke several other ModuleOptionsMetadataResolverinstances in turn and merge their results (flattening them).Classorg.springframework.xd.module.optionsSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

DelegatingModuleRegistryA ModuleRegistry that delegates to several ModuleRegistries, in order.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
DelimitedStringToMapPropertyEditorConverts a String of comma delimited name-value pairs to a Map.Classorg.springframework.xd.extension.processSpring XDjavadoc
DepartedContainerModuleRedeployerThe ModuleRedeployer that re-deploys the stream/job modules that weredeployed into the departing container.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DependencyExceptionThrown when performing an action cannot be carried over because some dependency would be broken.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
DeployableResourceAbstract base class for resources that represent deployable units.Classorg.springframework.xd.rest.domainSpring XDjavadoc
DeploymentActionenum DeploymentActionEnum class for the supported deployment actions.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentConfigurationConfiguration class that holds the beans required for deployment management.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DeploymentExceptionException thrown when DeploymentHandler encounters problemwhen deploying/un-deploying stream/job.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentHandlerDeployment handler that is responsible for deploying/un-deploying theDeploymentUnit (Stream/Job) to/from the container.Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentLoaderUtility for loading streams and jobs for the purpose of deployment.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DeploymentMessageThe message that wraps the details of a deployment request.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentMessageConsumerConsumer for DeploymentMessagewhich delegates to the corresponding @ResourceDeployerClassorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DeploymentMessagePublisherPublisher that defines the contract to publish the DeploymentMessage.Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentOptionKeysUsed to factor out names of the options that are shared by all deploy commands.Classorg.springframework.xd.shell.commandSpring XDjavadoc
DeploymentPropertiesFormatProvides utility methods for formatting and parsing deployment properties.Classorg.springframework.xd.rest.domain.supportSpring XDjavadoc
DeploymentPropertiesUtilityClass that provides utility methods to handle module deployment properties.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
DeploymentQueueThis class controls the lifecycle operations of the ZK distributed queue thatholds the DeploymentMessages.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DeploymentStatusRepositoryInterface definition for repositories that support the reportingof deployment unit state.Interfaceorg.springframework.xd.dirt.coreSpring XDjavadoc
DeploymentSupervisorProcess that watches ZooKeeper for Container arrivals and departures fromthe XD cluster.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
DeploymentUnitDeploymentUnit is a collection of modules that are intended to bedeployed as a single unit.Interfaceorg.springframework.xd.dirt.coreSpring XDjavadoc
DeploymentUnitStateCalculatorCalculates the overall status for a deployment unit (stream or job).Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentUnitStatusStatus for a DeploymentUnit.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
DeploymentUnitTypeenum DeploymentUnitTypeEnum class that defines the deployment unit type.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
DeploymentValidatorThis interface defines validation methods that verify a stream or jobcan be saved, deployed, undeployed, or deleted.Interfaceorg.springframework.xd.dirt.streamSpring XDjavadoc
DetailedContainerDomain object for an XD container with detailed info (deployed modules, messageRates etc.Classorg.springframework.xd.dirt.container.storeSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

DetailedContainerResourceRepresents container info model.Classorg.springframework.xd.rest.domainSpring XDjavadoc
DetailedJobInfoA job info for batch jobs that provides more details than the base JobInfoAuthor:Andrew Eisenberg, Ilayaperumal GopinathanClassorg.springframework.xd.dirt.jobSpring XDjavadoc
DetailedJobInfoResourceRepresents Expanded Batch job info that has more details on batch jobs.Classorg.springframework.xd.rest.domainSpring XDjavadoc
DetailedJobInfoResourceAssemblerKnows how to build a REST resource out of our domain model DetailedJobInfo.Classorg.springframework.xd.dirt.restSpring XDjavadoc
DetailedModuleDefinitionResourceClassorg.springframework.xd.rest.domainSpring XDjavadoc
DetailedModuleDefinitionResourceAssemblerKnows how to build DetailedModuleDefinitionResource out of a ModuleDefinition.Classorg.springframework.xd.dirt.restSpring XDjavadoc
DirtExceptionRoot of the hierarchy of exceptions for DIRT (Distributed Integration RunTime).Classorg.springframework.xd.dirtSpring XDjavadoc
DisposableTo be implemented by fixtures that need special cleanup when a test is done.Interfaceorg.springframework.xd.test.fixturesSpring XDjavadoc
DisposableFileSupportBase class for stream elements that deal with file locations.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
DisposableMailSupportBase class for fixtures that interact with a mail server.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
DistributedJobLocatorto work with batch jobs in a distributed environment.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
DistributedJobServiceSimpleJobService in distributed modeAuthor:Ilayaperumal Gopinathan, Andrew Eisenberg, Gunnar HillertClassorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
DistributedTestSupportProvides support methods for building distributed system tests.Interfaceorg.springframework.xd.distributed.utilSpring XDjavadoc
DocumentParseResultRepresents the result of parsing a multiline document, made of several definitions.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
DocumentParseResultResourceRepresents the result of parsing a multiline definition document.Classorg.springframework.xd.rest.domainSpring XDjavadoc
DocumentParseResultResourceAssemblerThis class is responsible for creating a REST representation of a DocumentParseResult.Classorg.springframework.xd.dirt.restSpring XDjavadoc
DomainRepositoryInterfaceorg.springframework.xd.storeSpring XDjavadoc
EmbeddedHeadersMessageConverterEncodes requested headers into payload with format0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] .Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
EmbeddedZooKeeperHelper class to start an embedded instance of standalone (non clustered) ZooKeeper.Classorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
EmbeddedZookeeperA port of kafka.Classorg.springframework.xd.test.kafkaSpring XDjavadoc
EmptyStartYieldsModulesRecoveryStrategyClassorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
EncoderDecoderMixinsProvides mixins for encoder/decoder options.Classorg.springframework.xd.tcp.encdecSpring XDjavadoc
EnvironmentAwareModuleOptionsMetadataResolverA decorator around another ModuleOptionsMetadataResolver that will provide default values for module optionsusing the environment.Classorg.springframework.xd.module.optionsSpring XDjavadoc
EventuallyMatcherA matcher that will evaluate another matcher repeatedly until it matches, or fail after some number of attempts.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
ExclusivesUtility class for assisting in checking that mutually exclusive options are correctly set.Classorg.springframework.xd.module.options.validationSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ExecutionContextJacksonMixInJackson MixIn for the JSON serialization of the ExecutionContext class, which is used by theStepExecution class.Classorg.springframework.xd.dirt.plugins.job.supportSpring XDjavadoc
ExecutionContextJacksonMixInJackson MixIn for ExecutionContext de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
ExistingXDEntityConverterA no-op converter from String to String, but that helps with completion in names of already existing entities.Classorg.springframework.xd.shell.converterSpring XDjavadoc
ExpandedJobParametersConverterMore flexible implementation of the JobParametersConverter.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
ExpandOneDashToTwoDashesRecoveryStrategyProvides completion when the user has typed in the first dash to a module option.Classorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
ExpressionOrScriptMixinA standard mixin for modules that do some transformation based on either a script or a SpEL expression.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
ExtendedResourceA wrapper around a Resource that adds capabilities lacking in the original interface.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
FieldSetConverterA converter that maps from the batch FieldSet world to Mongo's DBObject.Classorg.springframework.xd.mongodbSpring XDjavadoc
FieldSetSqlParameterSourceProviderAn ItemSqlParameterSourceProvider that will derive parameters from a FieldSet.Classorg.springframework.xd.batch.item.jdbcSpring XDjavadoc
FieldSetTypeEnum used to provide typing information when reading from a file.Classorg.springframework.xd.tuple.batchSpring XDjavadoc
FieldValueCounterRepresents the data stored in a Counter for multiple field-value pairs.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
FieldValueCounterCommandsCommands for interacting with field value counter analytics.Classorg.springframework.xd.shell.commandSpring XDjavadoc
FieldValueCounterHandlerCounts the occurrence of values for a set of JavaBean properties or Tuple fields using a FieldValueCounterRepository.Classorg.springframework.xd.analytics.metrics.integrationSpring XDjavadoc
FieldValueCounterOperationsInterface defining operations available when dealing with Field Value Counters.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
FieldValueCounterRepositoryA repository to save, delete and find FieldValueCounter instances.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
FieldValueCounterResourceClassorg.springframework.xd.rest.domain.metricsSpring XDjavadoc
FieldValueCountersControllerController that exposes FieldValueCounter related representations.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
FieldValueCounterSinkOptionsMetadataCaptures options for the field-value-counter sink module.Classorg.springframework.xd.analytics.metrics.metadataSpring XDjavadoc
FieldValueCounterTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
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 XDjavadoc
FileAuthenticationConfigurationA security configuration that conditionally sets up in-memory users from a file.Classorg.springframework.xd.dirt.server.securitySpring XDjavadoc
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 XDjavadoc
FileJdbcJobClassorg.springframework.xd.test.fixturesSpring XDjavadoc
FileJdbcJobOptionsMetadataCaptures options for the filejdbc job.Classorg.springframework.xd.jdbcSpring XDjavadoc
FileLoggerClassorg.springframework.xd.spark.streaming.examples.javaSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

FileLoggerModuleOptionsMetadataClassorg.springframework.xd.spark.streaming.examples.javaSpring XDjavadoc
FilePollHdfsJobTest fixture that creates a File Poll Hdfs Job.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
FilePollHdfsJobOptionsMetadataDescribes the options for the filepollhdfs job.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
FileReadingModeenum FileReadingModeDefines the supported modes of reading and processing files for theClassorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
FileSinkSupport class to capture output of a sink in a File.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
FileSinkOptionsMetadataHolds options to the 'file' sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
FileSourceSupport class that represents the file source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
FileSourceOptionsMetadataHolds module options metadata about the file source.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
FixtureUtilsUtility to support common tasks done by fixtures.Classorg.springframework.xd.test.fixtures.utilSpring XDjavadoc
FlattenedCompositeModuleOptionsMetadataA composite ModuleOptionsMetadata made of several ModuleOptionsMetadata that will appear "flattened".Classorg.springframework.xd.module.optionsSpring XDjavadoc
FlowThe AST node representing a flow.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
FormatClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
FromMongoDbOptionMixinAn option class to mix-in when reading from MongoDB.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
FromStringCharsetMixinA standard mixin for modules that do conversion from String to bytes.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
FsShellCommandsClassorg.springframework.xd.shell.hadoopSpring XDjavadoc
FtpConnectionMixinA mixin that can be used anytime a connection to an FTP server is needed.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
FtpHdfsJobTest fixture that creates a Ftp Hdfs Job.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
FtpHdfsJobOptionsMetadataDescribes the options for the ftphdfs job.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
FtpSinkA fixture that helps testing the ftp sink.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
FtpSinkOptionsMetadataModule options for the FTP sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
FtpSourceA fixture that helps testing the ftp source.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
FtpSourceOptionsMetadataModule options for FTP source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
GaugeRepresents the data stored in a Gauge which can be set to any integral value.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
GaugeCommandsCommands for interacting with Gauge analytics.Classorg.springframework.xd.shell.commandSpring XDjavadoc
GaugeHandlerClassorg.springframework.xd.analytics.metrics.integrationSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

GaugeOperationsInterface defining operations available when dealing with Gauge.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
GaugeRepositoryA marker interface for Gauge repositories.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
GaugeResourceThe REST representation of a Gauge.Classorg.springframework.xd.rest.domain.metricsSpring XDjavadoc
GaugesControllerExposes representations of Gauges.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc
GaugeTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
GemFireCQSourceCreate a gemfire CQ (continuous query) source.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
GemfireCQSourceOptionsMetadataDescribes options to the gemfire-cq source module.Classorg.springframework.xd.gemfireSpring XDjavadoc
GemfireHostPortMixinClassorg.springframework.xd.gemfireSpring XDjavadoc
GemFireServerSinkCreate a gemfire-server or gemfire-json-server sink.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
GemfireServerSinkModuleOptionsMetadataCaptures module options for the "gemfire-server" and "gemfire-json-server" sink modules.Classorg.springframework.xd.gemfireSpring XDjavadoc
GemFireSourceCreate a gemfire sourceAuthor:David TuranskiClassorg.springframework.xd.test.fixturesSpring XDjavadoc
GemfireSourceOptionsMetadataDescribes options to the gemfire source module.Classorg.springframework.xd.gemfireSpring XDjavadoc
GeneratorExceptionCore exception for generators.Classorg.springframework.xd.test.generatorSpring XDjavadoc
GPFDistCodecClassorg.springframework.xd.greenplum.gpfdistSpring XDjavadoc
GPFDistMessageHandlerClassorg.springframework.xd.greenplum.gpfdistSpring XDjavadoc
GPFDistServerClassorg.springframework.xd.greenplum.gpfdistSpring XDjavadoc
GPFDistSinkOptionsMetadataConfig options for gpfdist sink.Classorg.springframework.xd.greenplum.configSpring XDjavadoc
GploadEnvironmentProviderClassorg.springframework.xd.gploadSpring XDjavadoc
GploadOptionsMetadataModule options for Gpload batch job module.Classorg.springframework.xd.gploadSpring XDjavadoc
GploadTaskletTasklet used for running gpload tool.Classorg.springframework.xd.gploadSpring XDjavadoc
GraphRepresents a Graph that Flo will display.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
GreenplumDataSourceFactoryBeanFactory bean for configuring a DataSource.Classorg.springframework.xd.greenplum.supportSpring XDjavadoc
HadoopConfigurationMixinFactors out common configuration options for Hadoop.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
HadoopNamespaceHandlerNamespace handler for Spring Integration's 'hadoop' namespace.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
HadoopUtilsClassorg.springframework.xd.integration.utilSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

HdfsDataStoreMessageHandlerSpring Integration MessageHandler handling Message writing into hdfs using DataStoreWriter.Classorg.springframework.xd.integration.hadoop.outboundSpring XDjavadoc
HdfsJdbcJobClassorg.springframework.xd.test.fixturesSpring XDjavadoc
HdfsMongoDbJobClassorg.springframework.xd.test.fixturesSpring XDjavadoc
HdfsMongodbJobOptionsMetadataOptions for Hdfs to Mongodb export job module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
HdfsOutboundChannelAdapterParserParser for the 'hdfs-outbound-channel-adapter' element.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
HdfsPartitionDataStoreMessageHandlerSpring Integration MessageHandler handling Message writing into hdfs using PartitionDataStoreWriter.Classorg.springframework.xd.integration.hadoop.outboundSpring XDjavadoc
HdfsSinkA test fixture that allows testing of the 'hdfs' sink module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
HdfsStoreMessageHandlerBase implementation of Spring Integration MessageHandler handling Message.Classorg.springframework.xd.integration.hadoop.outboundSpring XDjavadoc
HdfsStoreMessageHandlerFactoryBeanA message handler factory bean which differentiates whether HdfsStoreMessageHandlershould be based on either HdfsPartitionDataStoreMessageHandler or HdfsDataStoreMessageHandler.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
HdfsTextFileWriterClassorg.springframework.xd.hadoop.fsSpring XDjavadoc
HdfsTextFileWriterFactoryClassorg.springframework.xd.hadoop.fsSpring XDjavadoc
HdfsTextItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XDjavadoc
HdfsWriterInterfaceorg.springframework.xd.hadoop.fsSpring XDjavadoc
HdfsWritingMessageHandlerSpring Integration MessageHandler handling Message writing into hdfs using HdfsWriter.Classorg.springframework.xd.integration.hadoop.outboundSpring XDjavadoc
HdfsWritingMessageHandlerFactoryBeanClassorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
HierarchicalCompositeModuleOptionsMetadataA composite ModuleOptionsMetadata made of several ModuleOptionsMetadata, each assigned to a name,that will appear in a hierarchy.Classorg.springframework.xd.module.optionsSpring XDjavadoc
HostNotWindowsRuleClassorg.springframework.xd.testSpring XDjavadoc
HsqlDatasourceConfigurationDatasource configuration for HSQL database.Classorg.springframework.xd.batch.hsqldb.serverSpring XDjavadoc
HsqlServerApplicationSpring Application to operate life-cycle methods on HSQLServerBean.Classorg.springframework.xd.batch.hsqldb.serverSpring XDjavadoc
HSQLServerBeanClassorg.springframework.xd.batch.hsqldb.serverSpring XDjavadoc
HttpClientProcessorOptionsMetadataCaptures options for the http-client processor module.Classorg.springframework.xd.httpSpring XDjavadoc
HttpCommandsClassorg.springframework.xd.shell.commandSpring XDjavadoc
HttpGeneratorGenerate a single http request from a string or file payload.Interfaceorg.springframework.xd.test.generatorSpring XDjavadoc
HttpSourceOptionsMetadataDescribes options to the http source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
IncrementalColumnRangePartitionerProvides the ability to partition a job and append additional conditions to supportincremental imports.Classorg.springframework.batch.integration.xSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

IncrementalJdbcHdfsJobA test fixture that represents the JdbcHdfs JobAuthor:Glenn Renfro, Michael MinellaClassorg.springframework.xd.test.fixturesSpring XDjavadoc
InitialOffsetsFactoryBeanParses the list of initial offsets and creates a map to initialize the OffsetManagerAuthor:Marius Bogoevici, Ilayaperumal GopinathanClassorg.springframework.integration.x.kafkaSpring XDjavadoc
InMemoryAggregateCounterRepositoryIn-memory aggregate counter with minute resolution.Classorg.springframework.xd.analytics.metrics.memorySpring XDjavadoc
InMemoryCounterRepositoryMemory backed implementation of Counter repository that uses a ConcurrentMap.Classorg.springframework.xd.analytics.metrics.memorySpring XDjavadoc
InMemoryFieldValueCounterRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XDjavadoc
InMemoryGaugeRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XDjavadoc
InMemoryMetricRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XDjavadoc
InMemoryRichGaugeRepositoryClassorg.springframework.xd.analytics.metrics.memorySpring XDjavadoc
InputMapperAn InputMapper maps a given domain input I to an appropriate model input MI for the givenAuthor:Thomas DarimontInterfaceorg.springframework.xd.analytics.mlSpring XDjavadoc
IntegerEncoderDecoderA Kafka encoder / decoder used to serialize a single int, used as the kafka partition key.Classorg.springframework.xd.dirt.integration.kafkaSpring XDjavadoc
IntegrationHadoopNamespaceUtilsUtility methods for namespace.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
IntegrationHadoopSystemConstantsVarious constants throughout the spring integration hadoop libraries.Classorg.springframework.xd.integration.hadoopSpring XDjavadoc
IntoMongoDbOptionMixinAn option class to mix-in when writing to MongoDB.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
InvalidResultExceptionClassorg.springframework.xd.integration.utilSpring XDjavadoc
ISO8601DateFormatWithMilliSecondsImproved version of the ISO8601DateFormat that also serializes milliseconds.Classorg.springframework.xd.rest.domain.utilSpring XDjavadoc
JavaConfiguredModuleA SimpleModule configured by an @Configuration class.Classorg.springframework.xd.module.coreSpring XDjavadoc
JavaMailPropertiesFactoryBeanPropertiesFactoryBean thatreads comma separated (ex: key1=value1,key2=value2) values and make them as properties.Classorg.springframework.xd.mailSpring XDjavadoc
JavaToSerializedMessageConverterto convert from a POJO to byte[] with Java.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
JdbcCommandsUtility class helping to execute jdbc operations within a load session.Classorg.springframework.xd.greenplum.supportSpring XDjavadoc
JdbcConnectionMixinBasic JDBC module/job options.Classorg.springframework.xd.jdbcSpring XDjavadoc
JdbcConnectionPoolMixinBasic JDBC module/job connection pool options.Classorg.springframework.xd.jdbcSpring XDjavadoc
JdbcHdfsJobClassorg.springframework.xd.test.fixturesSpring XDjavadoc
JdbcHdfsOptionsMetadataCaptures options for the jdbchdfs job.Classorg.springframework.xd.jdbcSpring XDjavadoc
JdbcMessagePayloadTransformerTransforms a payload to a Map representation based on provided column names.Classorg.springframework.xd.jdbcSpring XDjavadoc
JdbcSinkRepresents the jdbc sink module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

JdbcSinkModuleOptionsMetadataCaptures module options for the "jdbc" sink module.Classorg.springframework.xd.jdbcSpring XDjavadoc
JdbcSourceRepresents the jdbc source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
JdbcSourceModuleOptionsMetadataCaptures options for the jdbc source module.Classorg.springframework.xd.jdbcSpring XDjavadoc
JmsSourceA test fixture that allows testing of the 'jms' source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
JmsSourceModuleOptionsMetadataCaptures options for the jms source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
JMXChannelResultThe Module/Channel that is returned when a JMX Query is exected against XD.Classorg.springframework.xd.integration.util.jmxresultSpring XDjavadoc
JMXRequestThe request to retrieve the Module MBean.Classorg.springframework.xd.integration.util.jmxresultSpring XDjavadoc
JMXResultThe Object that is returned when a JMX Query is exected against XD.Classorg.springframework.xd.integration.util.jmxresultSpring XDjavadoc
JMXValueThe JMXValue returned from JMX Request.Classorg.springframework.xd.integration.util.jmxresultSpring XDjavadoc
JobDomain model for Job runtime module.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
JobCaptures runtime information about a deployed JobDefinition.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
JobCommandsClassorg.springframework.xd.shell.commandSpring XDjavadoc
JobCommandsUtilsProvides helper methods for the JobCommands class, e.Classorg.springframework.xd.shell.command.supportSpring XDjavadoc
JobDefinitionRepresents an inlined job definition in a job specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobDefinitionRepresents a job in the system.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
JobDefinitionRepositoryA repository for persisting JobDefinitions.Interfaceorg.springframework.xd.dirt.streamSpring XDjavadoc
JobDefinitionResourceRepresents a Job Definition.Classorg.springframework.xd.rest.domainSpring XDjavadoc
JobDefinitionResourceAssemblerKnows how to build a REST resource out of our domain model JobDefinition.Classorg.springframework.xd.dirt.restSpring XDjavadoc
JobDeployerClassorg.springframework.xd.dirt.streamSpring XDjavadoc
JobDeploymentsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
JobDescriptorCommon AST base class for nodes representing job definitions or job references.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobDSLMessageContains all the messages that can be produced during Spring XD Job DSL parsing.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobEventsListenerPluginPlugin to enable the registration of out of the box job listeners.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
JobExceptionRoot of the hierarchy of exceptions for Job processing in DIRT.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobExecutionAlreadyRunningExceptionException that is raised when JobExecutionAuthor:Gunnar HillertSee Also:Serialized FormClassorg.springframework.xd.dirt.jobSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

JobExecutionInfoRepresents Batch job execution info.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobExecutionInfoResourceRepresents job execution info resource.Classorg.springframework.xd.rest.domainSpring XDjavadoc
JobExecutionInfoResourceAssemblerKnows how to build a REST resource out of our domain model JobExecutionInfo.Classorg.springframework.xd.dirt.restSpring XDjavadoc
JobExecutionJacksonMixInJackson MixIn for JobExecution de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
JobExecutionNotRunningExceptionException for the job execution that is not running.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobFactoryFactory class that builds Job instances.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobInfoRepresents Batch job info.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobInfoResourceRepresents Batch job info.Classorg.springframework.xd.rest.domainSpring XDjavadoc
JobInfoResourceAssemblerKnows how to build a REST resource out of our domain model JobInfo.Classorg.springframework.xd.dirt.restSpring XDjavadoc
JobInstanceAlreadyCompleteExceptionException thrown when the JobInstance is already complete.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobInstanceInfoRepresents Batch job instance info.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobInstanceInfoResourceRepresents JobInstance info resource.Classorg.springframework.xd.rest.domainSpring XDjavadoc
JobInstanceInfoResourceAssemblerResource assembler that builds the REST resource JobInstanceInfoResource out of domain modelAuthor:Ilayaperumal GopinathanClassorg.springframework.xd.dirt.restSpring XDjavadoc
JobInstanceJacksonMixInJackson MixIn for JobInstance de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
JobLaunchingJobRepositoryThis JobRepository implementationprovides the same functionality as Spring Batch'sClassorg.springframework.xd.dirt.plugins.job.supportSpring XDjavadoc
JobLaunchingJobRepositoryFactoryBeanA FactoryBean for creating an instance ofJobLaunchingJobRepositoryClassorg.springframework.xd.dirt.plugins.job.supportSpring XDjavadoc
JobLaunchingTaskletA Tasklet implementation that uses the Spring XD MessageBus to launchjobs deployed within the same Spring XD cluster.Classorg.springframework.xd.dirt.batch.taskletSpring XDjavadoc
JobLaunchRequestTransformerExecutes all jobs defined within a given stream once the context has been started.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
JobNodeAST node base type for all elements in an AST parsed from a job specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobOperationsInterface defining operations available against jobs.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
JobParameterJacksonDeserializerJackson Deserializer for JobParameter de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
JobParameterJacksonMixInJackson MixIn for JobParameter de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
JobParametersBeanPrepares the JobParameters for the Spring Bach Jobs.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
JobParametersInvalidExceptionException thrown when the job parameters are invalid.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobParametersJacksonMixInJackson MixIn for JobParameters de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

JobParserParse a Batch DSL Job specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobPartitionerPluginPlugin to enable job partitioning.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
JobPluginPlugin to enable the registration of jobs in a central registry.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
JobPluginMetadataResolverA ModuleOptionsMetadataResolver that will dynamically add the module options (such as makeUnique)supported by job modules.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
JobReferenceRepresents a simple job reference.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobRepositoryA repository for persisting Job instances.Interfaceorg.springframework.xd.dirt.streamSpring XDjavadoc
JobRestartExceptionException thrown where the batch job is not restartable.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
JobsA factory that provides fully instantiated job fixtures using default values.Classorg.springframework.xd.integration.fixturesSpring XDjavadoc
JobsControllerHandles all Job related interactions.Classorg.springframework.xd.dirt.restSpring XDjavadoc
JobSeriesCommon AST base class for nodes representing splits or flows.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobSpecificationThe root AST node for any AST parsed from a job specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobSpecificationExceptionRoot exception for Job Flow DSL parsing related exceptions.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobSpecificationVisitorvery basic visitor pattern for a JobSpecVisitor.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
JobTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
JsonBytesToTupleConverterClassorg.springframework.xd.tupleSpring XDjavadoc
JsonNodeToTupleConverterClassorg.springframework.xd.tupleSpring XDjavadoc
JsonStringToObjectTransformerClassorg.springframework.integration.x.gemfireSpring XDjavadoc
JsonStringToTupleConverterClassorg.springframework.xd.tupleSpring XDjavadoc
JsonToPojoMessageConverterClassorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
JsonToTupleMessageConverterto convert from a JSON (byte[] or String) to a Tuple.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
JsonToTupleTransformerConverts from a json string into a tuple data structure.Classorg.springframework.xd.tuple.integrationSpring XDjavadoc
JsonUtilSome JSON helper utilities.Classorg.springframework.xd.shell.utilSpring XDjavadoc
KafkaConsumerOptionsMixinModule options for Kafka consumer configuration.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
KafkaMessageBusA message bus that uses Kafka as the underlying middleware.Classorg.springframework.xd.dirt.integration.kafkaSpring XDjavadoc
KafkaMessageTransformerA transformer that transforms the Kafka messages into Map of partition and payload.Classorg.springframework.integration.x.kafkaSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

KafkaOffsetTopicOptionsMixinClassorg.springframework.integration.x.kafkaSpring XDjavadoc
KafkaPartitionAllocatorIs responsible for managing the partition allocation between multiple instances of a Kafka source moduledeployed in a stream.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
KafkaProducerOptionsMixinModule options for Kafka Producer configuration.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
KafkaSinkClassorg.springframework.xd.test.fixturesSpring XDjavadoc
KafkaSinkModuleOptionsMetadataModule options for Kafka sink module.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
KafkaSourceClassorg.springframework.xd.test.fixturesSpring XDjavadoc
KafkaSourceModuleOptionsMetadataModule options for Kafka source module.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
KafkaTestSupportJUnit Rule that starts an embedded Kafka server (with an associated Zookeeper)Since:1.Classorg.springframework.xd.test.kafkaSpring XDjavadoc
KafkaUtilsUtility methods for working with Kafka.Classorg.springframework.xd.test.fixtures.utilSpring XDjavadoc
KafkaZKOptionMixinKafka module options mixin for ZK configuration.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
LabelNodeRepresents a label attached to a module.Classorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
LdapAuthenticationConfigurationClassorg.springframework.xd.dirt.server.securitySpring XDjavadoc
LinkRepresents a link in a Graph object that Flo will display as a block.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
LoadConfigurationClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
LoadConfigurationFactoryBeanClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
LoadFactoryBeanFactoryBean for easy creation and configuration of GreenplumLoadAuthor:Janne ValkealahtiClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
LoadServiceInterfaceorg.springframework.xd.greenplum.supportSpring XDjavadoc
LocaleAwareStringToNumberConverterFactoryConverts from a String any JDK-standard Number implementation.Classorg.springframework.xd.tupleSpring XDjavadoc
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 XDjavadoc
LocalMessageBusA simple implementation of MessageBus for in-process use.Classorg.springframework.xd.dirt.integration.bus.localSpring XDjavadoc
LoggerAbbreviatorClassorg.springframework.xd.dirt.util.loggingSpring XDjavadoc
LoggingCacheListenerA simple cache listener that will log events.Classorg.springframework.xd.gemfire.serverSpring XDjavadoc
LoggingRecoveryCallbackClassorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
LoginControllerController responsible for handling web-logins as well as basic redirects forAuthor:Gunnar HillertClassorg.springframework.xd.dirt.web.controllerSpring XDjavadoc
LogSinkClassorg.springframework.xd.test.fixturesSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

LogSinkOptionsMetadataCaptures options for the log sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
MailProtocolThe list of supported mail protocols.Classorg.springframework.xd.mailSpring XDjavadoc
MailServerMixinTypical options for configuring connection to a mail server.Classorg.springframework.xd.mailSpring XDjavadoc
MailSinkA fixture to help test the mail sink module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
MailSinkOptionsMetadataCaptures options for the mail sink module.Classorg.springframework.xd.mailSpring XDjavadoc
MailSourceOptionsMetadataCaptures options for the mail source module.Classorg.springframework.xd.mailSpring XDjavadoc
MappedAnalyticAn Analytic that supports the mapping of input and outputto and from internal representations by applying the given InputMapperClassorg.springframework.xd.analytics.mlSpring XDjavadoc
MappedRequestHeadersMixinBase class for mixins that add the mappedRequestHeaders option.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
MappedResponseHeadersMixinBase class for mixins that add the mappedResponseHeaders option.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
MapreduceConfigurationMixinFactors out common configuration options for Hadoop MapReduce.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
MapToTupleTransformerConverts from a Map to the Tuple data structure.Classorg.springframework.xd.tuple.integrationSpring XDjavadoc
MaxMessagesDefaultOneMixinMixin for polled sources where the default is 1 message per poll.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
MaxMessagesDefaultUnlimitedMixinMixin for polled sources where the default is unlimited messages per poll.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
MBeanExportingPluginExports MBeans from a module using a unique domain name xd.Classorg.springframework.xd.dirt.pluginsSpring XDjavadoc
MD5StalenessCheckA StalenessCheck that expects to find a .Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
MediaTypeConverterKnows how to parse String representations of MediaType.Classorg.springframework.xd.shell.converterSpring XDjavadoc
MessageBusA strategy interface used to bind a MessageChannel to a logical name.Interfaceorg.springframework.xd.dirt.integration.busSpring XDjavadoc
MessageBusAwareChannelResolverA DestinationResolver implementation that first checks for any channelwhose name begins with a colon in the MessageBus.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
MessageBusAwareRouterBeanPostProcessorA BeanPostProcessor that sets a MessageBusAwareChannelResolver on any bean of typeAbstractMappingMessageRouter within the context.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
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 XDjavadoc
MessageBusExceptionException thrown to indicate a message bus error (mostlikely a configuration error).Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
MessageBusExtensionsConfigurationConfiguration class for Codec and possibly other MessageBus extensionsSince:1.Classorg.springframework.xd.dirt.serverSpring XDjavadoc
MessageBusSupportClassorg.springframework.xd.dirt.integration.busSpring XDjavadoc
MessageConverterUtilsMessage conversion utility methods.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
MessageCounterHandlerCounts the number of non-null messages using an underlying CounterRepository.Classorg.springframework.xd.analytics.metrics.integrationSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

MessageExpressionMethodsHelper class to work with a spel expressions resolving valuesfrom a Message.Classorg.springframework.xd.integration.hadoop.expressionSpring XDjavadoc
MessagePartitionKeyMethodResolverA Message specific MethodResolver.Classorg.springframework.xd.integration.hadoop.expressionSpring XDjavadoc
MessagePartitionKeyPropertyAccessorA PropertyAccessor reading values from a backing Message used by apartition key.Classorg.springframework.xd.integration.hadoop.expressionSpring XDjavadoc
MessagePartitionStrategyA PartitionStrategy which is used to provide a generic partitioning support using Spring SpEL.Classorg.springframework.xd.integration.hadoop.partitionSpring XDjavadoc
MessageValuesA mutable type for allowing MessageBus implementations to transform and enrich message content moreAuthor:David TuranskiClassorg.springframework.xd.dirt.integration.busSpring XDjavadoc
MetricSuper interface for all metrics.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
MetricHasSimpleValueMatcherA matcher that will assert that the display xxx shell command displays the expected value.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
MetricNameMixinAdds a name option, intended to capture the name of the metric.Classorg.springframework.xd.analytics.metrics.metadataSpring XDjavadoc
MetricRepositoryA repository to save, delete and find Metric instances.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
MetricResourceBase class for resources that adhere to the Metric interface.Classorg.springframework.xd.rest.domain.metricsSpring XDjavadoc
MetricUtilsUtility class, primarily to avoid exposing mutable objects beyond the core package.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
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 XDjavadoc
ModeClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
ModuleRepresents an XD Module that is returned from a JMX Query.Classorg.springframework.xd.integration.util.jmxresultSpring XDjavadoc
ModuleInterfaceorg.springframework.xd.module.coreSpring XDjavadoc
ModuleAlreadyExistsExceptionThrown when trying to create a new module with the given name and type, but one already exists.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
ModuleCommandsCommands for working with modules.Classorg.springframework.xd.shell.commandSpring XDjavadoc
ModuleConfigurationExceptionThrown when something is wrong with options passed to a module.Classorg.springframework.xd.dirt.pluginsSpring XDjavadoc
ModuleDefinitionAn instance of ModuleDefinition reflects the fact that a given module (identified by its type and name) is'available', i.Classorg.springframework.xd.moduleSpring XDjavadoc
ModuleDefinitionRepositoryUtilsClassorg.springframework.xd.dirt.module.supportSpring XDjavadoc
ModuleDefinitionResourceRepresents a Module Definition.Classorg.springframework.xd.rest.domainSpring XDjavadoc
ModuleDefinitionResourceAssemblerKnows how to build a REST resource out of our domain model ModuleDefinition.Classorg.springframework.xd.dirt.restSpring XDjavadoc
ModuleDefinitionsFactory class to create ModuleDefinitions.Classorg.springframework.xd.moduleSpring XDjavadoc
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 XDjavadoc
ModuleDependencyRepositoryUsed to track usage of modules from streams and composed modules.Interfaceorg.springframework.xd.dirt.moduleSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ModuleDeployedEventClassorg.springframework.xd.dirt.eventSpring XDjavadoc
ModuleDeployerHandles the creation, deployment, and un-deployment of modules.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
ModuleDeploymentPropertiesDeployment properties for a module.Classorg.springframework.xd.moduleSpring XDjavadoc
ModuleDeploymentPropertiesProviderCallback interface to obtain ModuleDeploymentPropertiesfor a ModuleDescriptor.Interfaceorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
ModuleDeploymentRequestsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
ModuleDeploymentsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
ModuleDeploymentStatusStatus of a module deployment for a container.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
ModuleDeploymentWriterUtility class to write module deployment requests under /xd/deployments/modules.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ModuleDescriptorRepresentation of a module in the context of a defined stream or job.Classorg.springframework.xd.moduleSpring XDjavadoc
ModuleEnvironmentA dedicated Environment for a module, which restricts the values exposed to thePropertySourcesPlaceholderConfigurer living in the module context.Classorg.springframework.xd.module.coreSpring XDjavadoc
ModuleExceptionRoot of the hierarchy of exceptions for Module processing in DIRT.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
ModuleExecutorInvokes the process method of a Processorand handles the output DStream if present.Classorg.springframework.xd.spark.streaming.javaSpring XDjavadoc
ModuleFactoryDetermines the type of Module to create from the Module's metadata and creates a module instance.Classorg.springframework.xd.module.coreSpring XDjavadoc
ModuleFixtureEstablishes the base behavior for Acceptance Test Module Factories.Classorg.springframework.xd.integration.fixturesSpring XDjavadoc
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 XDjavadoc
ModuleInformationHolder object for various bits of information about a module, such as description, etc.Classorg.springframework.xd.module.infoSpring XDjavadoc
ModuleInformationResolverInterfaceorg.springframework.xd.module.infoSpring XDjavadoc
ModuleJobLauncherExecutes all jobs defined within a given stream once the context has been started.Classorg.springframework.xd.dirt.plugins.jobSpring XDjavadoc
ModuleMessageRateNotFoundExceptionException thrown when getting message rate forAuthor:Ilayaperumal GopinathanSee Also:Serialized FormClassorg.springframework.xd.dirt.clusterSpring XDjavadoc
ModuleMetadataMetadata class for modules at runtime.Classorg.springframework.xd.dirt.module.storeSpring XDjavadoc
ModuleMetadataRepositoryRepository for persisting ModuleMetadataAuthor:Ilayaperumal GopinathanInterfaceorg.springframework.xd.dirt.module.storeSpring XDjavadoc
ModuleMetadataResourceRepresents a runtime module.Classorg.springframework.xd.rest.domainSpring XDjavadoc
ModuleMetadataResourceAssemblerKnows how to assemble ModuleMetadataResources out of ModuleMetadatas.Classorg.springframework.xd.dirt.restSpring XDjavadoc
ModuleNodeClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
ModuleNotDeployedExceptionException thrown when a module doesn't exist in the container.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ModuleObjectNamingStrategyObject naming strategy for XD module.Classorg.springframework.xd.dirt.module.jmxSpring XDjavadoc
ModuleOperationsInterface defining operations available against Module.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
ModuleOptionProvides information about an option that a user can set to customize the behavior of a module.Classorg.springframework.xd.module.optionsSpring XDjavadoc
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 XDjavadoc
ModuleOptionsRepresents runtime information about a module once user provided values are known.Classorg.springframework.xd.module.optionsSpring XDjavadoc
ModuleOptionsMetadataEncapsulates metadata about the accepted options for a module.Interfaceorg.springframework.xd.module.optionsSpring XDjavadoc
ModuleOptionsMetadataResolverNote that basic metadata derived from a module may be enriched by collaborators.Interfaceorg.springframework.xd.module.optionsSpring XDjavadoc
ModuleOptionsReferenceDocA class that generates asciidoc snippets for each module's options.Classorg.springframework.xd.documentationSpring XDjavadoc
ModulePlaceholdersDefines constants for well known XD keys that are available at runtime for a module.Classorg.springframework.xd.module.options.spiSpring XDjavadoc
ModuleRedeployerAbstract ModuleRedeployer that deploy/re-deploys the unallocated/orphaned modules.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ModuleRegistryA module registry is used to lookup modules by name and/or type.Interfaceorg.springframework.xd.dirt.moduleSpring XDjavadoc
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 XDjavadoc
ModulesControllerHandles all Module related interactions.Classorg.springframework.xd.dirt.restSpring XDjavadoc
ModulesMetadataControllerController that handles the interaction with the deployed modules.Classorg.springframework.xd.dirt.restSpring XDjavadoc
ModuleTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
ModuleTypeEnumeration of different module typesEnum Constant SummaryClassorg.springframework.xd.integration.fixturesSpring XDjavadoc
ModuleTypeRepresents the kind of modules that make up a stream or job.Classorg.springframework.xd.moduleSpring XDjavadoc
ModuleTypeConversionPluginA Plugin for processing module message conversion parameters (inputType and outputType).Classorg.springframework.xd.dirt.plugins.streamSpring XDjavadoc
ModuleTypeConversionPluginMetadataResolverA ModuleOptionsMetadataResolver that will dynamically add inputType and outputType options toevery module, according to their type.Classorg.springframework.xd.dirt.plugins.streamSpring XDjavadoc
ModuleTypeConversionSupportSupport class that configures the message converters for the module input/output channel.Classorg.springframework.xd.dirt.plugins.streamSpring XDjavadoc
ModuleUndeployedEventClassorg.springframework.xd.dirt.eventSpring XDjavadoc
ModuleUtilsContains utility methods for accessing a module's properties and dealing with ClassLoaders.Classorg.springframework.xd.module.optionsSpring XDjavadoc
MongoDbConnectionMixinA mixin to add anytime a connection to MongoDB is required.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
MqttConnectionMixinFactors out common options about configuring a connection to an MQTT broker.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
MqttSinkTest fixture that creates a mqtt sink.Classorg.springframework.xd.test.fixturesSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

MqttSinkOptionsMetadataDescribes options to the mqtt sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
MqttSourceA test fixture that allows testing of the mqtt source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
MqttSourceOptionsMetadataDescribes options to the mqtt source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
MqttTestSupportClassorg.springframework.xd.test.mqttSpring XDjavadoc
MultipleBroadcasterMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to a Stream based on a partitionExpression.Classorg.springframework.xd.reactorSpring XDjavadoc
MultipleSubjectMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to an Observable based on a partitionExpression.Classorg.springframework.xd.rxjavaSpring XDjavadoc
NamedChannelSinkA Sink bound to a named channel.Interfaceorg.springframework.xd.dirt.test.sinkSpring XDjavadoc
NamedChannelSourceA Source that binds to a named channel.Interfaceorg.springframework.xd.dirt.test.sourceSpring XDjavadoc
NamedColumnJdbcBatchItemWriterJdbcBatchItemWriter which is customized for use with the XDSets the SQL insert property based on the column names and table nameClassorg.springframework.xd.jdbcSpring XDjavadoc
NamedColumnJdbcItemReaderReader which reads a row from a database as a delimited string from apredefined list of column names.Classorg.springframework.xd.jdbcSpring XDjavadoc
NamedColumnJdbcItemReaderFactoryFactory for configuring a NamedColumnJdbcItemReader.Classorg.springframework.xd.jdbcSpring XDjavadoc
NamedResourceAbstract base class for all resources that have a name.Classorg.springframework.xd.rest.domainSpring XDjavadoc
NamespaceDelegatingMetadataStoreWraps a delegate MetadataStore and adds a prefix to all the handled keys.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
NamingStrategyParserParser for the 'naming-strategy' element.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
NestedArchiveResourceRepresents a resource as resolved inside a boot Archive.Classorg.springframework.xd.module.supportSpring XDjavadoc
NettyHttpInboundChannelAdapterClassorg.springframework.integration.x.httpSpring XDjavadoc
NettyInboundMessageConverterMessage converter (inbound only) to convert a Netty Http MessageEvent toa Message.Classorg.springframework.integration.x.httpSpring XDjavadoc
NetworkUtilsVarious network utilities.Classorg.springframework.xd.greenplum.supportSpring XDjavadoc
NewJsonPathUtilsSimilar to org.Classorg.springframework.xd.dirt.integration.jsonSpring XDjavadoc
NoContainerExceptionException thrown when there are no containers availablefor module deployment.Classorg.springframework.xd.dirt.clusterSpring XDjavadoc
NodeRepresents a node in a Graph object that Flo will display as a block.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
NonBindingResourceConfiguredModuleA module type that chooses not to bind to the MessageBus.Classorg.springframework.xd.module.coreSpring XDjavadoc
NonPollingImapSourceRepresents the imap source module, that does not use polling.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
NoSuchBatchJobExceptionException thrown when there is no such batch job with the given name.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
NoSuchBatchJobInstanceExceptionException thrown when there is no such batch job instance with the given instanceId.Classorg.springframework.xd.dirt.jobSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

NoSuchContainerExceptionException thrown when the container in search could not be found.Classorg.springframework.xd.dirt.clusterSpring XDjavadoc
NoSuchDefinitionExceptionException which is raised when a named resource definition cannot be found.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
NoSuchJobExecutionExceptionThrown when attempting to refer to JobExecution that does not exist.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
NoSuchMetricExceptionThrown when trying to access a named metric that does not exist.Classorg.springframework.xd.dirt.analyticsSpring XDjavadoc
NoSuchModuleExceptionThrown when attempting to refer to a module that does not exist.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
NoSuchStepExecutionExceptionThrown when attempting to refer to StepExecution that does not exist.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
NotDeployedExceptionThrown when a definition was assumed to be deployed when it actually was not.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
NothingToDeleteExceptionThrown when a delete operation has nothing to delete.Classorg.springframework.xd.dirt.integration.bus.rabbitSpring XDjavadoc
NullClassLoaderA ClassLoader that can't find or load anything.Classorg.springframework.xd.module.supportSpring XDjavadoc
NumberFormatConverterKnows how to convert from a String to a new NumberFormat instance.Classorg.springframework.xd.shell.converterSpring XDjavadoc
OptionNameAfterDashDashRecoveryStrategyProvides completion proposals when the user has typed the two dashes that precede a module option name.Classorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
OrderedContextInitializerAllows any necessary changes to the Target Context.Interfaceorg.springframework.xd.dirt.container.initializerSpring XDjavadoc
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 XDjavadoc
PackageSuiteRunnerA Suite to run all concrete classes ending in Tests in the same package.Classorg.springframework.xd.testSpring XDjavadoc
PageNotFoundExceptionException thrown when a Pageable requests a page that does not exist.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
PagingUtilityUtility class for paging support in repository accessor methods.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
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 XDjavadoc
ParentLastURLClassLoaderExtension for URLClassLoader that uses a parent-last (or child first) delegation.Classorg.springframework.xd.module.supportSpring XDjavadoc
ParsingContextCaptures the context in which a parse operation is made.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
PartitionedJdbcHdfsJobA test fixture that represents a partitioned JdbcHdfs JobAuthor:Glenn Renfro, Thomas RisbergClassorg.springframework.xd.test.fixturesSpring XDjavadoc
PartitionKeyExtractorStrategyStrategy for extracting a partition key from a Message.Interfaceorg.springframework.xd.dirt.integration.busSpring XDjavadoc
PartitionSelectorStrategyStrategy for determining the partition to which a message should be sent.Interfaceorg.springframework.xd.dirt.integration.busSpring XDjavadoc
PassthruModuleOptionsMetadataClassorg.springframework.xd.module.optionsSpring XDjavadoc
PasswordThis module option type represents a password.Classorg.springframework.xd.module.options.typesSpring XDjavadoc
PasswordUtilsProvides common utility methods for JobDefinitions andStreamDefinitions (BaseDefinition), e.Classorg.springframework.xd.dirt.restSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

PathsCommon paths and path utilities for XD components.Classorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
PeriodicTriggerMixinMixin for options that include a periodic fixed-delay trigger.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
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 XDjavadoc
PluginTo be implemented by classes that want to alter how a Module works.Interfaceorg.springframework.xd.module.coreSpring XDjavadoc
PluginContextComponentScanningExtensionsInitializerAn OrderedContextInitializer to scan for annotation configured beans in xd.Classorg.springframework.xd.dirt.container.initializerSpring XDjavadoc
PluginContextResourceExtensionsInitializerAn OrderedContextInitializer to scan resource locations xd.Classorg.springframework.xd.dirt.container.initializerSpring XDjavadoc
PluginsInitializerAn OrderedContextInitializer to load out-of-the-box XD Plugins.Classorg.springframework.xd.dirt.container.initializerSpring XDjavadoc
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 XDjavadoc
PojoToJsonMessageConverterto convert a Java object to a JSON StringAuthor:David Turanski, David LiuClassorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
PojoToStringMessageConverterto convert a Java object to a String using toString()Author:David TuranskiClassorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
PollingMailSourceFixture that represents the mail source module, which uses polling (here forced to 1s).Classorg.springframework.xd.test.fixturesSpring XDjavadoc
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 XDjavadoc
ProcessorContract for performing stream processing using Reactor within an XD processor moduleAuthor:Mark Pollack, Stephane MaldiniInterfaceorg.springframework.xd.reactorSpring XDjavadoc
ProcessorInterfaceorg.springframework.xd.rxjavaSpring XDjavadoc
ProcessorInterface for the Java based modules using the Spark Streaming API to process messages from the Message Bus.Interfaceorg.springframework.xd.spark.streaming.javaSpring XDjavadoc
ProcessorsA factory that provides fully instantiated processor fixtures.Classorg.springframework.xd.integration.fixturesSpring XDjavadoc
ProfileNamesProviderTo be implemented by classes that instruct the framework to activate some named profiles.Interfaceorg.springframework.xd.module.options.spiSpring XDjavadoc
QualifiedModuleNameConverterKnows how to build and query ModuleCommands.Classorg.springframework.xd.shell.converterSpring XDjavadoc
RabbitAdminExceptionExceptions thrown while interfacing with the RabbitMQ admin plugin.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
RabbitAdminTestSupportJUnit Rule that detects the fact that RabbitMQ is available on localhost withthe management plugin enabled.Classorg.springframework.xd.test.rabbitSpring XDjavadoc
RabbitBusCleanerClassorg.springframework.xd.dirt.integration.bus.rabbitSpring XDjavadoc
RabbitConnectionMixinFactors out options for the typical connection setup to RabbitMQ.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
RabbitManagementUtilsClassorg.springframework.xd.dirt.integration.busSpring XDjavadoc
RabbitMessageBusA MessageBus implementation backed by RabbitMQ.Classorg.springframework.xd.dirt.integration.rabbitSpring XDjavadoc
RabbitSinkA test fixture that allows testing of the rabbit sink module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

RabbitSinkOptionsMetadataCaptures options to the rabbit sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
RabbitSourceA test fixture that allows testing of the rabbit source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
RabbitSourceOptionsMetadataDescribes options to the rabbit source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
RabbitTestSupportJUnit Rule that detects the fact that RabbitMQ is available on localhost.Classorg.springframework.xd.test.rabbitSpring XDjavadoc
RandomConfigurationSupportSupport class to have random configuration for tests.Classorg.springframework.xd.testSpring XDjavadoc
RangeCapableRepositoryTo be implemented by repositories that know how to return a slice of their data.Interfaceorg.springframework.xd.storeSpring XDjavadoc
ReactorNamespaceHandlerClassorg.springframework.xd.integration.reactor.configSpring XDjavadoc
ReactorNetSourceOptionsMetadataProvides metadata about the configuration options of a ReactorPeer in Spring XD.Classorg.springframework.xd.integration.reactor.netSpring XDjavadoc
ReactorPeerFactoryBeanClassorg.springframework.xd.integration.reactor.netSpring XDjavadoc
ReactorPeerInboundChannelAdapterInbound ChannelAdapter that uses ReactorPeer abstraction to provide high-speed TCP or UDP ingest.Classorg.springframework.xd.integration.reactor.netSpring XDjavadoc
ReactorPeerInboundChannelAdapterConfigurationClassorg.springframework.xd.integration.reactor.netSpring XDjavadoc
ReactorReflectionUtilsUtility class for working with the reflection API for Reactor based processors.Classorg.springframework.xd.reactorSpring XDjavadoc
ReadableTableSettings for readable external table.Classorg.springframework.xd.greenplum.supportSpring XDjavadoc
ReadableTableFactoryBeanClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
RedisAggregateCounterRepositoryRedis implementation of AggregateCounterRepository.Classorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
RedisConnectionMixinMixin for Redis connection options.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
RedisCounterRepositoryClassorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
RedisFieldValueCounterRepositoryClassorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
RedisGaugeRepositoryRedis backed implementation that uses Redis keys to store and update the value.Classorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
RedisMessageBusA MessageBus implementation backed by Redis.Classorg.springframework.xd.dirt.integration.redisSpring XDjavadoc
RedisRetryTemplateClassorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
RedisRichGaugeRepositoryRepository for rich-gauges backed by Redis.Classorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
RedisSinkConfigurationClassorg.springframework.xd.redisSpring XDjavadoc
RedisSinkOptionsMetadataOptions metadata for Redis sink module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
RedisTestSupportJUnit Rule that detects the fact that a Redis server is running on localhost.Classorg.springframework.xd.test.redisSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

RemoteFilePartitionerTakes the result of an (S)FTP Gateway LS (list of FileInfo) and creates a StepExecution for each file.Classorg.springframework.batch.integration.xSpring XDjavadoc
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 XDjavadoc
RepositoryConnectionListenerZooKeeper connection listener that ensures path creation fornodes required by the various repository implementations thatClassorg.springframework.xd.dirt.stream.zookeeperSpring XDjavadoc
ResourceConfiguredModuleA SimpleModule configured using a bean definition resource (XML orAuthor:David Turanski, Eric BottardClassorg.springframework.xd.module.coreSpring XDjavadoc
ResourceDefinitionExceptionThrown when a problem is detected with the (DSL) definition of an XD resource.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
ResourceDeployerInterface for XD Resource Services.Interfaceorg.springframework.xd.dirt.coreSpring XDjavadoc
ResourceModuleRegistryResource based implementation of ModuleRegistry.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
ResourceOperationsOperations common to resources like Stream and Job.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
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 XDjavadoc
ResourcePatternScanningOptionHandlersHolds definitions of ResourcePatternScanningOptionHandlers used in Spring XD.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
ResourcesIntoJdbcJobModuleOptionsMetadataTypical class for metadata about jobs that slurp delimited resources into jdbc.Classorg.springframework.xd.jdbcSpring XDjavadoc
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 XDjavadoc
RestConfigurationTakes care of infrastructure setup for the web/rest layer.Classorg.springframework.xd.dirt.restSpring XDjavadoc
RestControllerAdviceCentral class for behavior common to all REST controllers.Classorg.springframework.xd.dirt.restSpring XDjavadoc
RESTDeploymentStateenum RESTDeploymentStateREST domain representation of org.Classorg.springframework.xd.rest.domainSpring XDjavadoc
RestLogoutSuccessHandlerstatus code of 200.Classorg.springframework.xd.dirt.web.controller.supportSpring XDjavadoc
RESTModuleTypeSibling of org.Classorg.springframework.xd.rest.domainSpring XDjavadoc
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 XDjavadoc
RichGaugeA gauge which stores the maximum, minimum and average in addition to the current value.Classorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
RichGaugeCommandsCommands for interacting with RichGauge analytics.Classorg.springframework.xd.shell.commandSpring XDjavadoc
RichGaugeHandlerClassorg.springframework.xd.analytics.metrics.integrationSpring XDjavadoc
RichGaugeOperationsInterface defining operations available when dealing with Rich Gauge.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
RichGaugeRepositoryA service for managing RichGauge instances.Interfaceorg.springframework.xd.analytics.metrics.coreSpring XDjavadoc
RichGaugeResourceThe REST representation of a RichGauge.Classorg.springframework.xd.rest.domain.metricsSpring XDjavadoc
RichGaugesControllerExposes representations of Gauges.Classorg.springframework.xd.dirt.rest.metricsSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

RichGaugeSinkOptionsMetadataCaptures options for the rich-gauge sink module.Classorg.springframework.xd.analytics.metrics.metadataSpring XDjavadoc
RichGaugeTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
RolloverStrategyParserParser for the 'rollover-policy' element.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
RuntimeBatchConfigurerSpring XD runtime specific BatchConfigurer.Classorg.springframework.xd.dirt.batchSpring XDjavadoc
RuntimeCommandsCommands to interact with cluster for containers/modules.Classorg.springframework.xd.shell.commandSpring XDjavadoc
RuntimeContainerResourceAssemblerKnows how to assemble DetailedContainerResources out of DetailedContainer instances.Classorg.springframework.xd.dirt.restSpring XDjavadoc
RuntimeContextRuntime context for load operations.Classorg.springframework.xd.greenplum.supportSpring XDjavadoc
RuntimeIOExceptionThrown when something goes wrong during some IO operation.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
RuntimeModuleDeploymentPropertiesRuntime ModuleDeploymentProperties for a module.Classorg.springframework.xd.moduleSpring XDjavadoc
RuntimeModuleDeploymentPropertiesProviderDefault implementation of ModuleDeploymentPropertiesProviderfor type RuntimeModuleDeploymentProperties.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
RuntimeOperationsInterface defining operations available against runtime container/modules.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
RuntimeTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
RuntimeTimeoutExceptionException thrown when a blocking operation times out.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
RuntimeUtilsUtilities for obtaining runtime information for the running process.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
ScriptMixinA standard mixin for modules that do some transformation based on a script.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
ScriptModulePropertiesFactoryBeanClassorg.springframework.xd.extension.scriptSpring XDjavadoc
SecurityConfigurationSetup Spring Security for the http endpoints of the application.Classorg.springframework.xd.dirt.web.configSpring XDjavadoc
SecurityControllerProvides security-related meta information.Classorg.springframework.xd.dirt.rest.securitySpring XDjavadoc
SecurityInfoResourceProvides security related meta-information.Classorg.springframework.xd.rest.domain.securitySpring XDjavadoc
SegmentRejectTypeenum SegmentRejectTypeEnum Constant SummaryClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
SerializationExceptionThrown when something goes wrong with inter-module communication.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
SerializedToJavaMessageConverterto deserialize Serializable Java objects.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
ServerProcessUtilsCollection of utilities for starting external processes requiredfor a distributed XD system.Classorg.springframework.xd.distributed.utilSpring XDjavadoc
ServerTcpConnectionFactoryOptionsMetadataMixinMixin for options metadata that configure a server tcp connection factory.Classorg.springframework.xd.tcpSpring XDjavadoc
SftpSourceOptionsMetadataModule options for SFTP source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

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 XDjavadoc
SharedServerContextConfigurationBeans defined and imported here are shared by the XD Admin Server and Container Server.Classorg.springframework.xd.dirt.serverSpring XDjavadoc
ShellCommandProcessorCreates a process to run a shell command and communicate with it using String payloads over stdin and stdout.Classorg.springframework.xd.extension.processSpring XDjavadoc
ShellModuleOptionsMetadataOptions Metadata for shell processor and sink modules.Classorg.springframework.xd.extension.processSpring XDjavadoc
SimpleAbstractHdfsItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XDjavadoc
SimpleCounterSinkUsed to generate the counter sink portion of a stream.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
SimpleFileSinkUsed to generate the file sink portion of a stream.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
SimpleFileSourceA FileSource for integration tests.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
SimpleHdfsTextItemWriterClassorg.springframework.xd.batch.item.hadoopSpring XDjavadoc
SimpleHttpGeneratorUsed to generate basic http posts for string and file contentsAuthor:Glenn Renfro, Mark PollackClassorg.springframework.xd.test.generatorSpring XDjavadoc
SimpleHttpSourceAn HTTP source that default to using localhost:9000Author:Glenn Renfro, Mark PollackClassorg.springframework.xd.test.fixturesSpring XDjavadoc
SimpleModuleA Module implementation backed by a Spring ApplicationContext.Classorg.springframework.xd.module.coreSpring XDjavadoc
SimpleModuleDefinitionA module definition for a "simple", single module whose code and supporting resourcescan be located somewhere.Classorg.springframework.xd.moduleSpring XDjavadoc
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 XDjavadoc
SimpleTailSourceA tail source for integration tests.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
SimpleXdChunkListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
SimpleXdItemListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
SimpleXdJobExecutionListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
SimpleXdSkipListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
SimpleXdStepExecutionListenerClassorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
SingleNodeApplicationSingle Node XD Runtime.Classorg.springframework.xd.dirt.server.singlenodeSpring XDjavadoc
SingleNodeIntegrationTestSupportA helper class that provides methods used for testing streams with SingleNodeApplication.Classorg.springframework.xd.dirt.testSpring XDjavadoc
SingleNodeNamedChannelSinkFactoryA factory for creating NamedChannelSinks.Classorg.springframework.xd.dirt.test.sinkSpring XDjavadoc
SingleNodeNamedChannelSourceFactoryA factory for creating NamedChannelSources.Classorg.springframework.xd.dirt.test.sourceSpring XDjavadoc
SingleNodeNamedQueueSinkA NamedChannelSink implementation that binds to a Queue Channel.Classorg.springframework.xd.dirt.test.sinkSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

SingleNodeNamedQueueSourceA NamedChannelSource implementation that binds to a Queue Channel.Classorg.springframework.xd.dirt.test.sourceSpring XDjavadoc
SingleNodeNamedTopicSinkA NamedChannelSink implementation that binds to a PubSub Channel.Classorg.springframework.xd.dirt.test.sinkSpring XDjavadoc
SingleNodeNamedTopicSourceA NamedChannelSource implementation that binds to a PubSub Channel.Classorg.springframework.xd.dirt.test.sourceSpring XDjavadoc
SingleNodeOptionsHolds options that can be used in single-node mode.Classorg.springframework.xd.dirt.server.optionsSpring XDjavadoc
SingleNodeProcessingChainCreates a stream to test a processing chain p1 p2 .Classorg.springframework.xd.dirt.test.processSpring XDjavadoc
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 XDjavadoc
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 XDjavadoc
SingleNodeProcessingChainSupportA helper class to easily create AbstractSingleNodeProcessingChains using static methods.Classorg.springframework.xd.dirt.test.processSpring XDjavadoc
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 XDjavadoc
SingletonModuleRegistryAn implementation of ModuleRegistry suitable to lookup a module that is atthe root of the classpath.Classorg.springframework.xd.dirt.testSpring XDjavadoc
SinkChannelNodeClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
SinksA factory that provides fully instantiated sink fixtures based on the environment selected at test startup.Classorg.springframework.xd.integration.fixturesSpring XDjavadoc
SourceChannelNodeClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
SourcesA convenience class for creating instances of sources to be used for integration testing.Classorg.springframework.xd.integration.fixturesSpring XDjavadoc
SparkAppJobClassorg.springframework.xd.test.fixturesSpring XDjavadoc
SparkAppOptionsMetadataModule options for Spark application module.Classorg.springframework.xd.sparkSpring XDjavadoc
SparkMessageSenderAbstract class that defines abstract methods to support sending the computed messages out of Spark clusterto XD MessageBus etc.Classorg.springframework.xd.spark.streamingSpring XDjavadoc
SparkPiSparkPi Sample Code that utilizes spark master calls to generate a rough estimate of pi.ClasssparkSpring XDjavadoc
SparkStreamingChannelThe DirectChannel that provides support forspark streaming configurations.Classorg.springframework.xd.dirt.plugins.spark.streamingSpring XDjavadoc
SparkStreamingContainerFilterA ContainerFilter which filters out the containers that have a sparkstreaming module running.Classorg.springframework.xd.dirt.sparkSpring XDjavadoc
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 XDjavadoc
SparkStreamingPluginPlugin for Spark Streaming support.Classorg.springframework.xd.dirt.plugins.spark.streamingSpring XDjavadoc
SparkStreamingSupportBase interface for spring XD and spark streaming integration.Interfaceorg.springframework.xd.spark.streamingSpring XDjavadoc
SparkTaskletTasklet for running Spark application.Classorg.springframework.xd.spark.taskletSpring XDjavadoc
SplitThe AST node representing a split.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

SplitterProcessorOptionsMetadataCaptures options for the splitter processor module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
SplunkSinkOptionsMetadataCaptures options to the splunk sink module.Classorg.springframework.xd.splunkSpring XDjavadoc
SplunkTransformerMessage consumer that will push the payload to a splunk instance via a TCP-Port.Classorg.springframework.integration.x.splunkSpring XDjavadoc
SpringXDExceptionA Java exception that wraps the serialized VndErrors object.Classorg.springframework.xd.rest.client.implSpring XDjavadoc
SpringXDOperationsMain entry point for interacting with a running XD system.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
SpringXDTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
SqlUtilsClassorg.springframework.xd.greenplum.supportSpring XDjavadoc
SqoopEnvironmentProviderClassorg.springframework.xd.sqoopSpring XDjavadoc
SqoopOptionsMetadataModule options for Sqoop application module.Classorg.springframework.xd.sqoopSpring XDjavadoc
SqoopRunnerClass for running Sqoop tool.Classorg.springframework.xd.sqoopSpring XDjavadoc
SqoopTaskletTasklet used for running Sqoop tool.Classorg.springframework.xd.sqoopSpring XDjavadoc
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 XDjavadoc
StalenessCheckA strategy interface for deciding whether a target definition is stale compared to a source definition.Interfaceorg.springframework.xd.dirt.moduleSpring XDjavadoc
StandAloneUiAppStarts the Web UI without needing the full Spring XD setup.Classorg.springframework.xd.dirt.webSpring XDjavadoc
StepExecutionHistoryJacksonMixInJackson MixIn for StepExecutionHistory de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
StepExecutionInfoRepresents Batch step execution info.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
StepExecutionInfoResourceRepresents the step execution info resource.Classorg.springframework.xd.rest.domainSpring XDjavadoc
StepExecutionInfoResourceAssemblerKnows how to build a REST resource out of our domain model StepExecutionInfo.Classorg.springframework.xd.dirt.restSpring XDjavadoc
StepExecutionJacksonMixInJackson MixIn for StepExecution serialization.Classorg.springframework.xd.dirt.plugins.job.supportSpring XDjavadoc
StepExecutionJacksonMixInJackson MixIn for StepExecution de-serialization.Classorg.springframework.xd.rest.client.impl.supportSpring XDjavadoc
StepExecutionProgressInfoRepresents Batch job step execution progress info.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
StepExecutionProgressInfoResourceRepresents the step execution progress info resource.Classorg.springframework.xd.rest.domainSpring XDjavadoc
StepExecutionProgressInfoResourceAssemblerKnows how to build a REST resource out of our domain model StepExecutionProgressInfo.Classorg.springframework.xd.dirt.restSpring XDjavadoc
StepTypeThe types of Spring Batch Step implementations that are known to the system.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
StoreWriterFactoryBeanA FactoryBean creating a DataStoreWriter.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

StoreWriterParserParser for the 'storage' element.Classorg.springframework.xd.integration.hadoop.configSpring XDjavadoc
StreamDomain model for runtime Stream modules.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
StreamA runtime representation of a running stream.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamCommandsClassorg.springframework.xd.shell.commandSpring XDjavadoc
StreamConfigParserClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
StreamDefinitionRepresents a model for a data flow in the system.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamDefinitionExceptionRoot exception for DSL parsing related exceptions.Classorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
StreamDefinitionRepositoryA repository for persisting StreamDefinitions.Interfaceorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamDefinitionRepositoryUtilsClassorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamDefinitionResourceRepresents a stream definition, i.Classorg.springframework.xd.rest.domainSpring XDjavadoc
StreamDefinitionResourceAssemblerKnows how to build a REST resource out of our domain model StreamDefinition.Classorg.springframework.xd.dirt.restSpring XDjavadoc
StreamDeployerDefault implementation of StreamDeployer that uses providedStreamDefinitionRepository and StreamRepository toClassorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamDeploymentsPathBuilder object for paths under Paths.Classorg.springframework.xd.dirt.coreSpring XDjavadoc
StreamExceptionRoot of the hierarchy of exceptions for Module processing in DIRT.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamFactoryFactory class that builds Stream instances.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamLookupEnvironmentA lookup environment is used to resolve a stream.Interfaceorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
StreamNodeClassorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
StreamOperationsInterface defining operations available against streams.Interfaceorg.springframework.xd.rest.clientSpring XDjavadoc
StreamPluginClassorg.springframework.xd.dirt.plugins.streamSpring XDjavadoc
StreamRepositoryA repository for persisting Streams.Interfaceorg.springframework.xd.dirt.streamSpring XDjavadoc
StreamRuntimePropertiesProviderRuntimeModuleDeploymentPropertiesProvider that provides the stream partition/short circuitproperties for the given ModuleDescriptor.Classorg.springframework.xd.dirt.server.admin.deploymentSpring XDjavadoc
StreamsControllerHandles all Stream related interaction.Classorg.springframework.xd.dirt.restSpring XDjavadoc
StreamTemplateClassorg.springframework.xd.rest.client.implSpring XDjavadoc
StreamUtilsUtilities for creating and monitoring streams and the JMX hooks for those strings.Classorg.springframework.xd.integration.utilSpring XDjavadoc
StrictContentTypeResolverA StringConvertingContentTypeResolver that requires a the content-type to be present.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

StringConvertingContentTypeResolverA DefaultContentTypeResolver that can parse String values.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
StringRedisRetryTemplateString-focused extension of RedisRetryTemplate.Classorg.springframework.xd.analytics.metrics.redisSpring XDjavadoc
StringToByteArrayMessageConverterto convert a String to a byte[], applying the provided Charset inthe content-type header if any.Classorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
StringToDateConverterClassorg.springframework.xd.tupleSpring XDjavadoc
StringToEnumIgnoringCaseConverterFactoryCopied from org.Classorg.springframework.xd.module.options.supportSpring XDjavadoc
SubjectMessageHandlerAdapts the item at a time delivery of a MessageHandlerby delegating processing to a Observable.Classorg.springframework.xd.rxjavaSpring XDjavadoc
SupervisorElectedEventEvent that is fired after a admin leader is elected.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
SupervisorElectionListenerEvent listener for SupervisorElectedEvents.Interfaceorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
SynchronizingModuleRegistryA ModuleRegistry that is configured with two delegates: a remote (source) and a local (target) registry.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
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 XDjavadoc
SyslogInboundChannelAdapterConfigurationClassorg.springframework.xd.integration.reactor.syslogSpring XDjavadoc
SyslogInboundChannelAdapterParserClassorg.springframework.xd.integration.reactor.configSpring XDjavadoc
SyslogSourceOptionsMetadataCaptures options for the syslog-udp source module.Classorg.springframework.xd.syslogSpring XDjavadoc
SyslogTcpSourceA test fixture that allows testing of the syslog tcp source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
SyslogTcpSourceOptionsMetadataCaptures options for the syslog-tcp source module.Classorg.springframework.xd.syslogSpring XDjavadoc
SyslogUdpSourceA test fixture that allows testing of the syslog udp source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
TableProvide a basic concept of a table structure containing a map of column headers and a collection of rows.Classorg.springframework.xd.shell.utilSpring XDjavadoc
TableHeaderDefines table column headers used by Table.Classorg.springframework.xd.shell.utilSpring XDjavadoc
TableRowHolds the table rows used by Table.Classorg.springframework.xd.shell.utilSpring XDjavadoc
TailSourceSupport class that represents a tail source.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
TailSourceOptionsMetadataDescribes options to the tail source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
TapTest fixture that creates a tap.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
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 XDjavadoc
TaskletTypeTypes of Tasklet implementations known by Spring XD.Classorg.springframework.xd.dirt.jobSpring XDjavadoc
TcpClientSourceA test fixture that allows testing of the 'tcp-client' source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

TcpClientSourceOptionsMetadataCaptures options available to the tcp-client source module.Classorg.springframework.xd.tcpSpring XDjavadoc
TcpSinkTest fixture that creates a simple socket server, ready to accept connections from a 'tcp' sink module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
TcpSinkOptionsMetadataCaptures the options to the tcp sink module.Classorg.springframework.xd.tcpSpring XDjavadoc
TcpSourceA test fixture that allows testing of the 'tcp' source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
TcpSourceOptionsMetadataCaptures options for the tcp source module.Classorg.springframework.xd.tcpSpring XDjavadoc
TestModuleDefinitionsUtility class for creating ModuleDefinitions in the context of tests.Classorg.springframework.xd.moduleSpring XDjavadoc
ThreadContextClassLoaderSetterAdviceAn advice that will set the thread context ClassLoader to theenclosing ApplicationContext's class loader before invocation and resetClassorg.springframework.xd.dirt.module.supportSpring XDjavadoc
ThroughputSamplerMessageHandlerSamples throughput by counting messages over an elapsed time between receiving aMessage with the given startMessage and a endMessage andClassorg.springframework.xd.integration.throughputSpring XDjavadoc
ThroughputSamplerOptionsMetadataClassorg.springframework.xd.integration.throughputSpring XDjavadoc
TimeSourceOptionsMetadataDescribes options to the time source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
TimestampFileJobOptionsMetadataOptions for the timestampfile job module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
TimestampFileTaskletA Tasklet implementationthat writes the current timestamp to a file.Classorg.springframework.batch.integration.xSpring XDjavadoc
TimeUtilsProvides a commons set of time-related helper methods and also defines commonSince:1.Classorg.springframework.xd.rest.domain.utilSpring XDjavadoc
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 XDjavadoc
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 XDjavadoc
TokenKindEnumeration of all the token types that may be found in a Job DSL specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
TokenKindEnumeration of all the token types that may be found in a DSL definition stream.Classorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
TokensClass that converts an expression into a list of tokens.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
ToolsControllerA controller for integrating with frontend tools.Classorg.springframework.xd.dirt.restSpring XDjavadoc
ToStringCharsetMixinA standard mixin for modules that do conversion from bytes to String.Classorg.springframework.xd.module.options.mixinsSpring XDjavadoc
TransformTest fixture that creates a Transform.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
TransitionAn AST node representing a transition found in the parsed Job specification.Classorg.springframework.xd.dirt.job.dslSpring XDjavadoc
TriggerSourceOptionsMetadataDescribes options to the trigger source module.Classorg.springframework.xd.dirt.modules.metadataSpring XDjavadoc
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 XDjavadoc
TupleBuilderBuilder class to create Tuple instances.Classorg.springframework.xd.tupleSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

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 XDjavadoc
TupleFieldSetMapperA FieldSetMapper implementation intended to allow a user use a Tuple as the item.Classorg.springframework.xd.tuple.batchSpring XDjavadoc
TupleJsonMarshallerClassorg.springframework.xd.tupleSpring XDjavadoc
TupleKryoRegistrarused to register a Tuple serializer.Classorg.springframework.xd.tuple.serializer.kryoSpring XDjavadoc
TuplePropertyAccessorA PropertyAccessor implementation that enables reading of Tuple values using dot notation within SpELexpressions.Classorg.springframework.xd.tuple.spelSpring XDjavadoc
TupleRowMapperA RowMapper implementation to be used with the Tuple data structure.Classorg.springframework.xd.tuple.batchSpring XDjavadoc
TupleSqlParameterSourceClassorg.springframework.xd.tuple.batchSpring XDjavadoc
TupleSqlParameterSourceProviderA factory for TupleSqlParameterSourcesAuthor:Michael MinellaClassorg.springframework.xd.tuple.batchSpring XDjavadoc
TupleStringMarshallerClassorg.springframework.xd.tupleSpring XDjavadoc
TupleToJsonMessageConverterto convert a Tuple to a JSON StringAuthor:David TuranskiClassorg.springframework.xd.dirt.integration.bus.converterSpring XDjavadoc
TupleToJsonStringConverterConverts a Tuple to JSON representationAuthor:David Turanski, Gunnar HillertClassorg.springframework.xd.tupleSpring XDjavadoc
TupleWriteConverterClassorg.springframework.xd.mongodbSpring XDjavadoc
TwitterMixinOptions common to twitter source modulesAuthor:David TuranskiClassorg.springframework.integration.x.twitterSpring XDjavadoc
TwitterSearchChannelAdapterMessage producer which reads form Twitter's public search endpoints.Classorg.springframework.integration.x.twitterSpring XDjavadoc
TwitterSearchOptionsMetadataClassorg.springframework.integration.x.twitterSpring XDjavadoc
TwitterSearchSourceA test fixture that allows testing of the 'TwitterSearch' source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
TwitterStreamChannelAdapterMessage producer which reads form Twitter's public stream endpoints.Classorg.springframework.integration.x.twitterSpring XDjavadoc
TwitterStreamOptionsMetadataClassorg.springframework.integration.x.twitterSpring XDjavadoc
TwitterStreamSourceA test fixture that allows testing of the 'TwitterStream' source module.Classorg.springframework.xd.test.fixturesSpring XDjavadoc
UiUtilsContains utility methods for rendering data to a formatted console output.Classorg.springframework.xd.shell.utilSpring XDjavadoc
UnfinishedModuleNameRecoveryStrategyClassorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
UnfinishedOptionNameRecoveryStrategyClassorg.springframework.xd.dirt.stream.completionSpring XDjavadoc
UploadedModuleDefinitionA module definition that serves as a temporary vehicle for the payload of an uploaded module.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
UserInputAbstraction for a mechanism used to get user interactive user input.Interfaceorg.springframework.xd.shell.commandSpring XDjavadoc
ValidationControllerProvides server-validation services.Classorg.springframework.xd.dirt.rest.validationSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

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 XDjavadoc
VersionControllerController to retrieve version control information.Classorg.springframework.xd.dirt.rest.metaSpring XDjavadoc
VersionPatternConverterthat returns the "Implementation-Version" string obtained from themanifest of the jar that this class was loaded from.Classorg.springframework.xd.dirt.util.loggingSpring XDjavadoc
VersionPatternLayoutExtension of Log4j's EnhancedPatternLayoutwhich supports logging of the "Implementation-Version" stringClassorg.springframework.xd.dirt.util.loggingSpring XDjavadoc
VersionPatternParserExtension of Log4j's PatternParserthat recognizes the pattern %v which is used to log theClassorg.springframework.xd.dirt.util.loggingSpring XDjavadoc
VersionResourceProvides the version information for Spring XD.Classorg.springframework.xd.rest.domain.metaSpring XDjavadoc
VndErrorResponseErrorHandlerExtension of DefaultResponseErrorHandler that knows how to de-serialize a VndErrors.Classorg.springframework.xd.rest.client.implSpring XDjavadoc
WebConfigurationProvides Spring MVC configuration.Classorg.springframework.xd.dirt.webSpring XDjavadoc
WindowingOffsetManagerAn OffsetManager that aggregates writes over a time or count window, using an underlying delegate todo the actual operations.Classorg.springframework.integration.x.kafkaSpring XDjavadoc
WordCountClassorg.springframework.xd.spark.streaming.examples.javaSpring XDjavadoc
WritableModuleRegistryBase interface for registries that know how to create (and hence how to delete) new module definitions.Interfaceorg.springframework.xd.dirt.moduleSpring XDjavadoc
WritableResourceModuleRegistryWritable extension of ResourceModuleRegistry.Classorg.springframework.xd.dirt.moduleSpring XDjavadoc
XdAppmasterCustom application master handling XD containers grouping settingfor launch commands.Classorg.springframework.xd.yarnSpring XDjavadoc
XdBatchDatabaseInitializerA BatchDatabaseInitializer for XD batch datasource.Classorg.springframework.xd.batchSpring XDjavadoc
XdConfigLoggingInitializerInitializer that can print useful stuff about an XD context on startup.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
XDControllerBase Class for XD Controllers.Classorg.springframework.xd.dirt.restSpring XDjavadoc
XDDSLMessagesContains all the messages that can be produced during Spring XD DSL parsing.Classorg.springframework.xd.dirt.stream.dslSpring XDjavadoc
XdEc2ValidationValidates that all instances of the cluster is up and running.Classorg.springframework.xd.integration.utilSpring XDjavadoc
XdEnvironmentExtracts the host and port information for the XD Instances.Classorg.springframework.xd.integration.utilSpring XDjavadoc
XdErrorControllerErrorController that causes 404 errors to be redirected to the Admin-UI 404 page.Classorg.springframework.xd.dirt.restSpring XDjavadoc
XdHeadersSpring Integration message headers for XD.Classorg.springframework.xd.dirt.integration.busSpring XDjavadoc
XdJdbcSearchableJobExecutionDaoClassorg.springframework.xd.dirt.job.daoSpring XDjavadoc
XDJobListenerConstantsInterface holdings constants related to XD JobListeners.Interfaceorg.springframework.xd.dirt.plugins.job.support.listenerSpring XDjavadoc
XDParserParser to convert a DSL string for a deployable unit (i.Interfaceorg.springframework.xd.dirt.streamSpring XDjavadoc
XdProfilesStatic constants for XD server's spring profile names.Classorg.springframework.xd.dirt.utilSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

XDRuntimeRepresents information about the XD Runtime.Classorg.springframework.xd.rest.domainSpring XDjavadoc
XDShellClassorg.springframework.xd.shellSpring XDjavadoc
XDShellBannerProviderProvides the Spring XD specific BannerProvider.Classorg.springframework.xd.shellSpring XDjavadoc
XDShellPromptProviderA provider that sets the shell prompt to xd:>Since:1.Classorg.springframework.xd.shellSpring XDjavadoc
XDStreamParserParser to convert a DSL string for a stream into a list ofobjects that comprise the given stream.Classorg.springframework.xd.dirt.streamSpring XDjavadoc
XdUtilsProvides general utilities for Spring XD.Classorg.springframework.xd.dirt.utilSpring XDjavadoc
XdYarnAdminInfoCommandA custom command for listing the http ports used by admin servers.Classorg.springframework.xd.yarnSpring XDjavadoc
XdYarnClusterCreateCommandA custom YarnClusterCreateCommand adding option for defininga groups for XD's containers.Classorg.springframework.xd.yarnSpring XDjavadoc
ZKDeploymentHandlerAbstract class that has common implementations of ZK based deployments.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ZKDeploymentMessagePublisherZooKeeper based DeploymentMessagePublisher that publishesdeployment messages into a ZooKeeper/CuratorClassorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ZKJobDeploymentHandlerDeployment handler that is responsible for the deployment of a Job.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ZKStreamDeploymentHandlerDeployment handler that is responsible for deploying Stream.Classorg.springframework.xd.dirt.server.admin.deployment.zkSpring XDjavadoc
ZooKeeperAccessExceptionRuntime exception used to wrap native ZooKeeper checked exceptions thrown whileaccessing ZooKeeper nodes.Classorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
ZooKeeperAdminRepositoryZooKeeper backed repository for runtime info about Admins.Classorg.springframework.xd.dirt.container.storeSpring XDjavadoc
ZooKeeperComposedModuleDefinitionRegistryAn implementation of WriteableModuleRegistry dedicated to CompositeModuleDefinitions and that usesZooKeeper as storage mechanism.Classorg.springframework.xd.dirt.module.storeSpring XDjavadoc
ZooKeeperConnectionA wrapper for a CuratorFramework instance whose lifecycle is managed as a Spring bean.Classorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
ZooKeeperConnectionConfigurerA strategy interface for configuring ZooKeeperConnection at start up.Interfaceorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
ZooKeeperConnectionListenerListener for ZooKeeper connection and disconnection events.Interfaceorg.springframework.xd.dirt.zookeeperSpring XDjavadoc
ZookeeperConnectionPluginSupplies plugins with a reference to the Spring XD ZooKeeperConnectionAuthor:Marius BogoeviciClassorg.springframework.xd.dirt.pluginsSpring XDjavadoc
ZooKeeperContainerRepositoryZooKeeper backed repository for runtime info about Containers.Classorg.springframework.xd.dirt.container.storeSpring XDjavadoc
ZooKeeperJobDefinitionRepositoryA Zookeeper backed repository for persisting JobDefinitions.Classorg.springframework.xd.dirt.stream.zookeeperSpring XDjavadoc
ZooKeeperJobRepositoryJob instance repository.Classorg.springframework.xd.dirt.stream.zookeeperSpring XDjavadoc
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 XDjavadoc
ZooKeeperModuleMetadataRepositoryZooKeeper backed repository for runtime info about deployed modules.Classorg.springframework.xd.dirt.module.storeSpring XDjavadoc
ZooKeeperStreamDefinitionRepositoryClassorg.springframework.xd.dirt.stream.zookeeperSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ZooKeeperStreamRepositoryStream instance repository.Classorg.springframework.xd.dirt.stream.zookeeperSpring XDjavadoc
ZooKeeperUtilsUtility methods for ZooKeeper.Classorg.springframework.xd.dirt.zookeeperSpring XDjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner



comments powered by Disqus