Index (Spring XD 1.0.0.M5 API)

A B C D E F G H I J K L M N O P Q R S T U V W X Z

A

abandon(Long) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
ABSOLUTE_FILE_PATH - Static variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
AbstractCodec<T> - Class in org.springframework.integration.x.bus.serializer: Support class providing convenience methods for codecs.
AbstractCodec() - Constructor for class org.springframework.integration.x.bus.serializer.AbstractCodec
AbstractContainerEvent - Class in org.springframework.xd.dirt.container
AbstractContainerEvent(XDContainer) - Constructor for class org.springframework.xd.dirt.container.AbstractContainerEvent
AbstractContainerEventStoreListener - Class in org.springframework.xd.dirt.listener
AbstractContainerEventStoreListener() - Constructor for class org.springframework.xd.dirt.listener.AbstractContainerEventStoreListener
AbstractDeployer<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream: Abstract implementation of the @link ResourceDeployer interface.
AbstractDeployer(PagingAndSortingRepository<D, String>, DeploymentMessageSender, XDParser, String) - Constructor for class org.springframework.xd.dirt.stream.AbstractDeployer
AbstractEvent<S> - Class in org.springframework.xd.dirt.event
AbstractEvent(S) - Constructor for class org.springframework.xd.dirt.event.AbstractEvent
AbstractExternalResourceTestSupport<R> - Class in org.springframework.xd.test: Abstract base class for JUnit Rules that detect the presence of some external resource.
AbstractExternalResourceTestSupport(String) - Constructor for class org.springframework.xd.test.AbstractExternalResourceTestSupport
AbstractHdfsItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop
AbstractHdfsItemWriter() - Constructor for class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
AbstractHdfsWriter - Class in org.springframework.xd.hadoop.fs: Logic for writing to files of a specified size or other strategies go here as they are shared across implementations
AbstractHdfsWriter() - Constructor for class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
AbstractInMemoryRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Class in org.springframework.xd.store: Base implementation for an in-memory store, using a Map internally.
AbstractInMemoryRepository() - Constructor for class org.springframework.xd.store.AbstractInMemoryRepository
AbstractInstancePersistingDeployer<D extends BaseDefinition,I extends BaseInstance<D>> - Class in org.springframework.xd.dirt.stream: Base support class for deployers that know how to deal with instances of a definition.
AbstractInstancePersistingDeployer(PagingAndSortingRepository<D, String>, DomainRepository<I, String>, DeploymentMessageSender, XDParser, String) - Constructor for class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
AbstractJdbcModuleOptionsMetadata - Class in org.springframework.xd.jdbc: Factors out options that are common to modules/jobs that import into a db table.
AbstractJdbcModuleOptionsMetadata() - Constructor for class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
AbstractMetricsCommands - Class in org.springframework.xd.shell.command: Base class to factor out similar behavior for all related metrics commands.
AbstractMetricsCommands(String) - Constructor for class org.springframework.xd.shell.command.AbstractMetricsCommands
AbstractModule - Class in org.springframework.xd.module.core: Base support class for modules, wrapping ModuleDefinition and DeploymentMetadata.
AbstractModule(ModuleDefinition, DeploymentMetadata) - Constructor for class org.springframework.xd.module.core.AbstractModule
AbstractModuleEvent - Class in org.springframework.xd.dirt.event
AbstractModuleEvent(Module, String) - Constructor for class org.springframework.xd.dirt.event.AbstractModuleEvent
AbstractModuleRegistry - Class in org.springframework.xd.dirt.module: Provides common behavior for ModuleRegistry and knows how to handle custom classpath population for storages that support it.
AbstractModuleRegistry() - Constructor for class org.springframework.xd.dirt.module.AbstractModuleRegistry
AbstractPlugin - Class in org.springframework.xd.module.core
AbstractPlugin() - Constructor for class org.springframework.xd.module.core.AbstractPlugin
AbstractRabbitConnectionOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Factors out options for the typical connection setup to RabbitMQ.
AbstractRabbitConnectionOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
AbstractRedisDefinitionRepository<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream.redis: Helper class for repositories persisting BaseDefinitions, acknowledging the fact that the definition name is a String and using it as a key.
AbstractRedisDefinitionRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository
AbstractRedisInstanceRepository> - Class in org.springframework.xd.dirt.stream.redis: Helper class for repositories persisting BaseInstances, acknowledging the fact that the instance can use the definition name as a key.
AbstractRedisInstanceRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository
AbstractRedisRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Class in org.springframework.xd.store: Base implementation for a store, using Redis behind the scenes.
AbstractRedisRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.store.AbstractRedisRepository
AbstractRedisRuntimeModuleInfoRepository - Class in org.springframework.xd.dirt.module.store: Abstract class that has redis hashOperations to operate on RuntimeModuleInfoEntitys.
AbstractRedisRuntimeModuleInfoRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
AbstractRepository<T,ID extends java.io.Serializable> - Class in org.springframework.xd.store: Helper class for repositories, implementing some behavior in terms of unit methods.
AbstractRepository() - Constructor for class org.springframework.xd.store.AbstractRepository
AccessControlInterceptor - Class in org.springframework.xd.dirt.rest: An interceptor to handle basic CORS logic.
AccessControlInterceptor() - Constructor for class org.springframework.xd.dirt.rest.AccessControlInterceptor
add(ModuleOption) - Method in class org.springframework.xd.module.options.SimpleModuleOptionsMetadata
addAttribute(String, Object) - Method in class org.springframework.xd.module.DeploymentMetadata
addBeanDefinition(String, BeanDefinition) - Method in class org.springframework.xd.module.support.BeanDefinitionAddingPostProcessor: Allows you to add custom BeanDefinitions.
addBinding(Binding) - Method in class org.springframework.integration.x.bus.MessageBusSupport
addCodecInfoConstructorArgReference(Element, ParserContext, BeanDefinitionBuilder, String) - Static method in class org.springframework.xd.integration.hadoop.config.IntegrationHadoopNamespaceUtils: Adds the codec info constructor arg reference.
addComponents(Resource) - Method in class org.springframework.xd.module.core.CompositeModule
addComponents(Resource) - Method in interface org.springframework.xd.module.core.Module
addComponents(Resource) - Method in class org.springframework.xd.module.core.SimpleModule
addConverter(Class<?>, MediaType, Converter<?, ?>) - Method in interface org.springframework.integration.x.bus.converter.ContentTypeAwareConverterRegistry: Register a converter
addConverter(Class<?>, MediaType, Converter<?, ?>) - Method in class org.springframework.integration.x.bus.converter.DefaultContentTypeAwareConverterRegistry
addDelegate(ModuleRegistry) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
addDeployment(String, List<ModuleDeploymentRequest>) - Method in class org.springframework.xd.dirt.stream.DeploymentMessageSender
addHandler(MessageHandler) - Method in class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher
addHeader(Integer, TableHeader) - Method in class org.springframework.xd.shell.util.Table
addJob(String, boolean) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator: Store the job name & isIncrementable flag for the job when there is a registry update
addListener(ApplicationListener<?>) - Method in class org.springframework.xd.dirt.container.XDContainer
addOption(DetailedModuleDefinitionResource.Option) - Method in class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource
addPathConstructorArgReference(Element, ParserContext, BeanDefinitionBuilder, String, String) - Static method in class org.springframework.xd.integration.hadoop.config.IntegrationHadoopNamespaceUtils: Adds the path constructor arg reference.
addProperties(Properties) - Method in class org.springframework.xd.module.core.CompositeModule
addProperties(Properties) - Method in interface org.springframework.xd.module.core.Module
addProperties(Properties) - Method in class org.springframework.xd.module.core.SimpleModule
addRow(String...) - Method in class org.springframework.xd.shell.util.Table
addScript(Resource) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
addSource(Object) - Method in class org.springframework.xd.module.core.SimpleModule
addValue(Date, long) - Method in class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource: Add a data point to the set.
addValue(Integer, String) - Method in class org.springframework.xd.shell.util.TableRow: Add a value to the to the specified column within this row.
ADMIN_PROFILE - Static variable in class org.springframework.xd.dirt.server.AdminServerApplication
AdminController - Class in org.springframework.xd.dirt.rest
AdminController(EntityLinks) - Constructor for class org.springframework.xd.dirt.rest.AdminController
AdminOptions - Class in org.springframework.xd.dirt.server.options: Holds configuration options that are valid for the Admin server, when using distributed mode.
AdminOptions() - Constructor for class org.springframework.xd.dirt.server.options.AdminOptions
AdminServerApplication - Class in org.springframework.xd.dirt.server
AdminServerApplication() - Constructor for class org.springframework.xd.dirt.server.AdminServerApplication
AdminServerApplication.JmxConfiguration - Class in org.springframework.xd.dirt.server
AdminServerApplication.JmxConfiguration() - Constructor for class org.springframework.xd.dirt.server.AdminServerApplication.JmxConfiguration
afterChunk(ChunkContext) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
afterChunkError(ChunkContext) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
afterCreate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterDestroy(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterInvalidate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterJob(JobExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdJobExecutionListener
afterPropertiesSet() - Method in class org.springframework.integration.x.bus.LocalMessageBus
afterPropertiesSet() - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
afterPropertiesSet() - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
afterPropertiesSet() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
afterPropertiesSet() - Method in class org.springframework.xd.dirt.job.HSQLServerBean
afterPropertiesSet() - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean
afterPropertiesSet() - Method in class org.springframework.xd.dirt.post.HandlerMappingRegistrar
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcBatchItemWriter
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReader
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
afterPropertiesSet() - Method in class org.springframework.xd.mongodb.MongoItemWriter
afterPropertiesSet() - Method in class org.springframework.xd.shell.XDShell
afterRegionClear(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterRegionCreate(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterRegionDestroy(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterRegionInvalidate(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterRegionLive(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterReturningInvocation(ParseResult, Object) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
afterReturningInvocation(ParseResult, Object) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
afterSave(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer: Callback method that subclasses may override to get a chance to act on newly saved definitions.
afterStep(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdStepExecutionListener
afterThrowingInvocation(ParseResult, Throwable) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
afterThrowingInvocation(ParseResult, Throwable) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
afterUpdate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
afterWrite(List<? extends Object>) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener: In order to support serialization with Kryo, the list of items is copied into a new List as the passed in List is Unmodifiable.
aggrCounterOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
aggrCounterOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with Aggregate Counters.
AggregateCount - Class in org.springframework.xd.analytics.metrics.core: Represents the data returned from an aggregate count query.
AggregateCount(String, Interval, long[], AggregateCountResolution) - Constructor for class org.springframework.xd.analytics.metrics.core.AggregateCount
AggregateCounterCommands - Class in org.springframework.xd.shell.command: Commands for interacting with aggregate counter analytics.
AggregateCounterCommands() - Constructor for class org.springframework.xd.shell.command.AggregateCounterCommands
AggregateCounterHandler - Class in org.springframework.xd.analytics.metrics.integration
AggregateCounterHandler(AggregateCounterRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.AggregateCounterHandler
AggregateCounterOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available when dealing with Aggregate Counters.
AggregateCounterOperations.Resolution - Enum in org.springframework.xd.rest.client
AggregateCounterRepository - Interface in org.springframework.xd.analytics.metrics.core: A repository to interact with Aggregate Counters.
AggregateCountersController - Class in org.springframework.xd.dirt.rest.metrics: Exposes representations of AggregateCounts.
AggregateCountersController(AggregateCounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.AggregateCountersController
AggregateCounterTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the Aggregate Counter part of the metrics API.
AggregateCounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.AggregateCounterTemplate
AggregateCountResolution - Enum in org.springframework.xd.analytics.metrics.core: The resolution options available for querying an aggregate counter.
AggregateCountsResource - Class in org.springframework.xd.rest.client.domain.metrics: The REST representation of an Aggregate Count.
AggregateCountsResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource: No-arg constructor for serialization frameworks.
AggregateCountsResource(String) - Constructor for class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource
AlreadyDeployedException - Exception in org.springframework.xd.dirt.stream: Thrown when an attempt is made to deploy a definition that is already deployed.
AlreadyDeployedException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.AlreadyDeployedException: Create a new exception.
AlreadyDeployedException(String, String, Throwable) - Constructor for exception org.springframework.xd.dirt.stream.AlreadyDeployedException: Create a new exception.
apply(Statement, Description) - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport
ArgumentNode - Class in org.springframework.xd.dirt.stream.dsl: Represents an argument like "--name=value".
ArgumentNode(String, String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ArgumentNode
asPropertySource() - Method in class org.springframework.xd.module.options.ModuleOptions
Assertions - Class in org.springframework.xd.shell.util: Various utility methods when dealing with shell commands.
AstNode - Class in org.springframework.xd.dirt.stream.dsl: Common supertype for the ast nodes built during stream parsing.
AstNode(int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.AstNode
atMostOneOf(Object...) - Static method in class org.springframework.xd.shell.util.Assertions: Accepts 2*N arguments, even ones being names and odd ones being values for those names.
available() - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
available() - Method in class org.springframework.xd.shell.command.CounterCommands
available() - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
available() - Method in class org.springframework.xd.shell.command.GaugeCommands
available() - Method in class org.springframework.xd.shell.command.JobCommands
available() - Method in class org.springframework.xd.shell.command.ModuleCommands
available() - Method in class org.springframework.xd.shell.command.RichGaugeCommands
available() - Method in class org.springframework.xd.shell.command.RuntimeCommands
available() - Method in class org.springframework.xd.shell.command.StreamCommands
AvroOutboundChannelAdapterParser - Class in org.springframework.xd.integration.hadoop.config: Parser for the 'avro-outbound-channel-adapter' element.
AvroOutboundChannelAdapterParser() - Constructor for class org.springframework.xd.integration.hadoop.config.AvroOutboundChannelAdapterParser
AvroWriter - Class in org.springframework.xd.hadoop.fs
AvroWriter(DatasetOperations) - Constructor for class org.springframework.xd.hadoop.fs.AvroWriter
AvroWriterFactory - Class in org.springframework.xd.hadoop.fs
AvroWriterFactory(DatasetOperations) - Constructor for class org.springframework.xd.hadoop.fs.AvroWriterFactory
AvroWritingMessageHandlerFactoryBean - Class in org.springframework.xd.integration.hadoop.config
AvroWritingMessageHandlerFactoryBean(DatasetOperations) - Constructor for class org.springframework.xd.integration.hadoop.config.AvroWritingMessageHandlerFactoryBean

B

BannerUtils - Class in org.springframework.xd.dirt.util: Provides utilities for rendering graphical console output.
BaseDefinition - Class in org.springframework.xd.dirt.core: Represents the base model for a data flow in the system.
BaseDefinition() - Constructor for class org.springframework.xd.dirt.core.BaseDefinition
BaseDefinition(String, String) - Constructor for class org.springframework.xd.dirt.core.BaseDefinition
BaseInstance<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream: A runtime representation of a Definition.
BaseInstance(D) - Constructor for class org.springframework.xd.dirt.stream.BaseInstance: Create a new instance out of the given definition.
basicDeploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer: Provides basic deployment behavior, whereby running state of deployed definitions is not persisted.
basicUndeploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer: Provides basic un-deployment behavior, whereby state of deployed definitions is not dealt with.
BATCH_EXCEPTION - Static variable in class org.springframework.xd.dirt.plugins.job.BatchJobHeaders
BATCH_LISTENER_EVENT_TYPE - Static variable in class org.springframework.xd.dirt.plugins.job.BatchJobHeaders
BatchJobAlreadyExistsException - Exception in org.springframework.xd.dirt.job
BatchJobAlreadyExistsException(String) - Constructor for exception org.springframework.xd.dirt.job.BatchJobAlreadyExistsException
BatchJobExecutionsController - Class in org.springframework.xd.dirt.rest: Controller for batch job executions.
BatchJobExecutionsController(JobService) - Constructor for class org.springframework.xd.dirt.rest.BatchJobExecutionsController
BatchJobHeaders - Class in org.springframework.xd.dirt.plugins.job: Headers definitions used by the batch job plugin.
BatchJobLocator - Class in org.springframework.xd.dirt.plugins.job: Implementation of ListableJobLocator used by DistributedJobService
BatchJobLocator() - Constructor for class org.springframework.xd.dirt.plugins.job.BatchJobLocator
BatchJobRegistryBeanPostProcessor - Class in org.springframework.xd.dirt.plugins.job: JobRegistryBeanPostProcessor that processes Job bean with name JobPlugin.JOB_BEAN_ID
BatchJobRegistryBeanPostProcessor() - Constructor for class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
BatchJobsController - Class in org.springframework.xd.dirt.rest: Controller for batch jobs and job instances, job executions on a given batch job.
BatchJobsController(JobService) - Constructor for class org.springframework.xd.dirt.rest.BatchJobsController
BatchListenerEventType - Enum in org.springframework.xd.dirt.plugins.job.support.listener: Enumerations to help identify various Batch job events being issued.
BatchStepExecutionsController - Class in org.springframework.xd.dirt.rest: Controller for returning Batch StepExecutions.
BatchStepExecutionsController(JobService) - Constructor for class org.springframework.xd.dirt.rest.BatchStepExecutionsController
BeanDefinitionAddingPostProcessor - Class in org.springframework.xd.module.support: Implementation of BeanDefinitionRegistryPostProcessor that adds all beans defined in the specified Resources.
BeanDefinitionAddingPostProcessor(ConfigurableEnvironment, Resource...) - Constructor for class org.springframework.xd.module.support.BeanDefinitionAddingPostProcessor
BeanDefinitionAddingPostProcessor() - Constructor for class org.springframework.xd.module.support.BeanDefinitionAddingPostProcessor
BeanPropertiesPropertySource<T> - Class in org.springframework.xd.dirt.server.options: A PropertySource that exposes the javabeans properties of an object as properties.
BeanPropertiesPropertySource(String, T) - Constructor for class org.springframework.xd.dirt.server.options.BeanPropertiesPropertySource
beforeChunk(ChunkContext) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
beforeDelete(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer: Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.
beforeDelete(D) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
beforeInvocation(ParseResult) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
beforeInvocation(ParseResult) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
beforeInvocation(ParseResult) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
beforeShutdown(Module) - Method in interface org.springframework.xd.module.core.Plugin: Perform any cleanup necessary prior to module shutdown
beforeShutdown(Module) - Method in class org.springframework.xd.module.core.PluginAdapter
beforeStep(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdStepExecutionListener
bindConsumer(String, MessageChannel, Collection<MediaType>, boolean) - Method in class org.springframework.integration.x.bus.LocalMessageBus: Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance.
bindConsumer(String, MessageChannel, Collection<MediaType>, boolean) - Method in interface org.springframework.integration.x.bus.MessageBus: Bind a message consumer on a p2p channel
bindConsumer(String, MessageChannel, Collection<MediaType>, boolean) - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus
bindConsumer(String, MessageChannel, Collection<MediaType>, boolean) - Method in class org.springframework.integration.x.redis.RedisMessageBus
Binding - Class in org.springframework.integration.x.bus: Represents a binding between a module's channel and an adapter endpoint that connects to the MessageBus.
bindProducer(String, MessageChannel, boolean) - Method in class org.springframework.integration.x.bus.LocalMessageBus: Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.
bindProducer(String, MessageChannel, boolean) - Method in interface org.springframework.integration.x.bus.MessageBus: Bind a message producer on a p2p channel.
bindProducer(String, MessageChannel, boolean) - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus
bindProducer(String, MessageChannel, boolean) - Method in class org.springframework.integration.x.redis.RedisMessageBus
bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in class org.springframework.integration.x.bus.LocalMessageBus
bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in interface org.springframework.integration.x.bus.MessageBus: Bind a message consumer on a pub/sub channel
bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus
bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in class org.springframework.integration.x.redis.RedisMessageBus
bindPubSubProducer(String, MessageChannel) - Method in class org.springframework.integration.x.bus.LocalMessageBus
bindPubSubProducer(String, MessageChannel) - Method in interface org.springframework.integration.x.bus.MessageBus: Bind a message producer on a pub/sub channel.
bindPubSubProducer(String, MessageChannel) - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus
bindPubSubProducer(String, MessageChannel) - Method in class org.springframework.integration.x.redis.RedisMessageBus
bridge(MessageChannel, MessageChannel, String) - Method in class org.springframework.integration.x.bus.LocalMessageBus
bridge(MessageChannel, MessageChannel, String, Collection<MediaType>) - Method in class org.springframework.integration.x.bus.LocalMessageBus
build() - Method in class org.springframework.xd.tuple.TupleBuilder
buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.xd.integration.reactor.config.ReactorPublishSubscribeChannelParser
buildMap() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
buildUndeployRequests(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
ByteArrayToStringConverter - Class in org.springframework.integration.x.bus.converter: Converts a byte[] to String using the provided Charset (UTF-8 by default)
ByteArrayToStringConverter() - Constructor for class org.springframework.integration.x.bus.converter.ByteArrayToStringConverter
ByteArrayToStringConverter(String) - Constructor for class org.springframework.integration.x.bus.converter.ByteArrayToStringConverter: Constructor accepting a charset name

C

CacheServer - Class in org.springframework.xd.gemfire
CacheServer() - Constructor for class org.springframework.xd.gemfire.CacheServer
calculateColumnWidths() - Method in class org.springframework.xd.shell.util.Table
canRead(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
canWrite(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
cat(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
ChannelNode - Class in org.springframework.xd.dirt.stream.dsl
ChannelNode(ChannelType, int, int, List<String>, List<String>) - Constructor for class org.springframework.xd.dirt.stream.dsl.ChannelNode
ChannelType - Enum in org.springframework.xd.dirt.stream.dsl
chgrp(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
chmod(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
chown(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
ChunkContextInfo - Class in org.springframework.xd.dirt.plugins.job.support.listener
ChunkContextInfo() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
cleanupResource() - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport: Perform cleanup of the AbstractExternalResourceTestSupport.resource field, which is guaranteed to be non null.
cleanupResource() - Method in class org.springframework.xd.test.rabbit.RabbitTestSupport
cleanupResource() - Method in class org.springframework.xd.test.redis.RedisTestSupport
close() - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
close() - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
close() - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
close() - Method in class org.springframework.xd.gemfire.LoggingCacheListener
close() - Method in class org.springframework.xd.hadoop.fs.AvroWriter
close() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
close() - Method in interface org.springframework.xd.hadoop.fs.HdfsWriter
closeReader(Reader) - Static method in class org.springframework.xd.shell.util.CommonUtils
cloud() - Method in class org.springframework.xd.dirt.server.ParentConfiguration.CloudFoundryConfiguration
collectionToCommaDelimitedString(Collection<String>) - Static method in class org.springframework.xd.shell.util.CommonUtils: Convert a List of Strings to a comma delimited String.
COLUMN_1 - Static variable in class org.springframework.xd.shell.util.UiUtils
COLUMN_2 - Static variable in class org.springframework.xd.shell.util.UiUtils
COLUMN_3 - Static variable in class org.springframework.xd.shell.util.UiUtils
COLUMN_4 - Static variable in class org.springframework.xd.shell.util.UiUtils
COLUMN_5 - Static variable in class org.springframework.xd.shell.util.UiUtils
COLUMN_6 - Static variable in class org.springframework.xd.shell.util.UiUtils
CommandLinePropertySourceOverridingInitializer<T extends CommonOptions> - Class in org.springframework.xd.dirt.server.options: An initializer that will parse command line options and also replace the default boot commandline PropertySource with those values.
CommandLinePropertySourceOverridingInitializer(T) - Constructor for class org.springframework.xd.dirt.server.options.CommandLinePropertySourceOverridingInitializer
CommonDistributedOptions - Class in org.springframework.xd.dirt.server.options: Holds options that are common to both admin and container servers, when used in distributed mode.
CommonDistributedOptions() - Constructor for class org.springframework.xd.dirt.server.options.CommonDistributedOptions
CommonDistributedOptions.Analytics - Enum in org.springframework.xd.dirt.server.options
CommonDistributedOptions.ControlTransport - Enum in org.springframework.xd.dirt.server.options
CommonDistributedOptions.Store - Enum in org.springframework.xd.dirt.server.options
CommonOptions - Class in org.springframework.xd.dirt.server.options: Base class for command line options that are common to absolutely every setup (single and distributed).
CommonOptions() - Constructor for class org.springframework.xd.dirt.server.options.CommonOptions
CommonUtils - Class in org.springframework.xd.shell.util: Contains common non-ui related helper methods for rendering text to the console.
compareTo(BaseDefinition) - Method in class org.springframework.xd.dirt.core.BaseDefinition
compareTo(ModuleDeploymentRequest) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
componentPathsSelector(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
componentPathsSelector(Module) - Method in class org.springframework.xd.module.core.AbstractPlugin: Establish the configuration file path and names required to setup the context for the type of module you are deploying.
composeModule(String, String) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
composeModule(String, String) - Method in interface org.springframework.xd.rest.client.ModuleOperations: Compose a new virtual Module.
CompositeCodec - Class in org.springframework.integration.x.bus.serializer: A codec that can delegate to one out of many codecs, depending on the type of the object to serialize/deserialize.
CompositeCodec(Map<Class<?>, AbstractCodec>, MultiTypeCodec) - Constructor for class org.springframework.integration.x.bus.serializer.CompositeCodec
CompositeCodec(MultiTypeCodec) - Constructor for class org.springframework.integration.x.bus.serializer.CompositeCodec
CompositeModule - Class in org.springframework.xd.module.core
CompositeModule(String, ModuleType, List<SimpleModule>, DeploymentMetadata) - Constructor for class org.springframework.xd.module.core.CompositeModule
CompositeModuleDefinitionService - Class in org.springframework.xd.dirt.stream: Provides save, delete and dependency operations for managing a composite module definition.
CompositeModuleDefinitionService(ModuleDefinitionRepository, XDStreamParser) - Constructor for class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
CompositeModuleDeploymentRequest - Class in org.springframework.xd.dirt.module: A request to deploy a composite module.
CompositeModuleDeploymentRequest(ModuleDeploymentRequest, List<ModuleDeploymentRequest>) - Constructor for class org.springframework.xd.dirt.module.CompositeModuleDeploymentRequest
concatArrays(List<long[]>, int, int) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
configProperties - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
ConfigurationAware - Class in org.springframework.xd.shell.hadoop: Utility base class for components monitoring Configuration changes in order to update state.
ConfigurationAware() - Constructor for class org.springframework.xd.shell.hadoop.ConfigurationAware
configurationChanged() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware: Called before invoking a command in case the configuration changed.
configurationChanged() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
ConfigurationCommands - Class in org.springframework.xd.shell.hadoop: Command for configuring the global Hadoop Configuration object used by other components.
ConfigurationCommands() - Constructor for class org.springframework.xd.shell.hadoop.ConfigurationCommands
ConfigurationModifiedEvent - Class in org.springframework.xd.shell.hadoop: Notification event that a Configuration object (attached) has been modified.
ConfigurationModifiedEvent(Configuration) - Constructor for class org.springframework.xd.shell.hadoop.ConfigurationModifiedEvent
configureProperties(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
configureProperties(Module) - Method in class org.springframework.xd.module.core.AbstractPlugin: set the properties required for the module based on its type.
configurer() - Method in class org.springframework.xd.dirt.rest.RestConfiguration
ConsoleUserInput - Class in org.springframework.xd.shell.command: UserInput that uses Standard in and out.
ConsoleUserInput() - Constructor for class org.springframework.xd.shell.command.ConsoleUserInput
ContainerEventStoreListener - Class in org.springframework.xd.dirt.listener: Container event listener that stores the container info.
ContainerEventStoreListener(RuntimeContainerInfoRepository) - Constructor for class org.springframework.xd.dirt.listener.ContainerEventStoreListener
ContainerOptions - Class in org.springframework.xd.dirt.server.options: Holds configuration options that are valid for the Container node, when using distributed mode.
ContainerOptions() - Constructor for class org.springframework.xd.dirt.server.options.ContainerOptions
ContainerStartedEvent - Class in org.springframework.xd.dirt.container
ContainerStartedEvent(XDContainer) - Constructor for class org.springframework.xd.dirt.container.ContainerStartedEvent
ContainerStoppedEvent - Class in org.springframework.xd.dirt.container
ContainerStoppedEvent(XDContainer) - Constructor for class org.springframework.xd.dirt.container.ContainerStoppedEvent
ContentTypeAwareConverterRegistry - Interface in org.springframework.integration.x.bus.converter: Strategy interface for a implementing a registry of Converters mapped to MediaType Used by XD to resolve a Converter corresponding to a requested MediaType.
ContentTypeHeaderInterceptor - Class in org.springframework.integration.x.bus.converter
ContentTypeHeaderInterceptor(MediaType) - Constructor for class org.springframework.integration.x.bus.converter.ContentTypeHeaderInterceptor
ConversionException - Exception in org.springframework.integration.x.bus.converter
ConversionException(String) - Constructor for exception org.springframework.integration.x.bus.converter.ConversionException
ConversionException(String, Throwable) - Constructor for exception org.springframework.integration.x.bus.converter.ConversionException
convert(byte[]) - Method in class org.springframework.integration.x.bus.converter.ByteArrayToStringConverter
convert(Object) - Method in class org.springframework.integration.x.bus.converter.DefaultObjectToStringConverter
convert(Object) - Method in class org.springframework.integration.x.bus.converter.JavaSerializingConverter
convert(String) - Method in class org.springframework.integration.x.bus.converter.JsonToMapConverter
convert(String) - Method in class org.springframework.integration.x.bus.converter.JsonToTupleConverter
convert(Object) - Method in class org.springframework.integration.x.bus.converter.MappingJackson2Converter
convert(Tuple) - Method in class org.springframework.integration.x.bus.converter.TupleToJsonConverter
convert(FieldSet) - Method in class org.springframework.xd.mongodb.FieldSetConverter
convert(Tuple) - Method in class org.springframework.xd.mongodb.TupleWriteConverter
convert(byte[]) - Method in class org.springframework.xd.tuple.JsonBytesToTupleConverter
convert(JsonNode) - Method in class org.springframework.xd.tuple.JsonNodeToTupleConverter
convert(String) - Method in class org.springframework.xd.tuple.JsonStringToTupleConverter
convert(String) - Method in class org.springframework.xd.tuple.StringToDateConverter
convert(Tuple) - Method in class org.springframework.xd.tuple.TupleToJsonStringConverter
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.QualifiedModuleNameConverter
convertJsonToList(String) - Static method in class org.springframework.xd.shell.util.JsonUtil
convertJsonToMap(String) - Static method in class org.springframework.xd.shell.util.JsonUtil
convertToJson(Object) - Static method in class org.springframework.xd.shell.util.JsonUtil
copy(byte[], FSDataOutputStream) - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter: Simple not optimized copy
copy(byte[], FSDataOutputStream) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter: Simple not optimized copy
copyFromLocal(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
copyMergeToLocal(String, String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
copyOf(ArgumentNode[], boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode: Construct a copy of the module node but the supplied replacement arguments can adjust the argument set that the resultant copy will have, in three ways: - they can be used to fill in variables in parameters - they can override existing parameters with the same name - they can behave as additional parameters
copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
copyToLocal(String, String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
count() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
count() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
count() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
count(boolean, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
count() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
count() - Method in class org.springframework.xd.store.AbstractRedisRepository
Counter - Class in org.springframework.xd.analytics.metrics.core: Represents the data stored in a valueer of a single value.
Counter(String) - Constructor for class org.springframework.xd.analytics.metrics.core.Counter: Construct a new Counter given a name
Counter(String, long) - Constructor for class org.springframework.xd.analytics.metrics.core.Counter: Construct a new Counter given a name and a initial value of the value
CounterCommands - Class in org.springframework.xd.shell.command: Commands for interacting with Counter analytics.
CounterCommands() - Constructor for class org.springframework.xd.shell.command.CounterCommands
CounterOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available when dealing with Counters.
counterOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
counterOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with Counters.
CounterRepository - Interface in org.springframework.xd.analytics.metrics.core: Interface for repositories that now how to deal with Counters.
CounterResource - Class in org.springframework.xd.rest.client.domain.metrics: The REST representation of a Counter.
CounterResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.CounterResource: No-arg constructor for serialization frameworks.
CounterResource(String, long) - Constructor for class org.springframework.xd.rest.client.domain.metrics.CounterResource
CountersController - Class in org.springframework.xd.dirt.rest.metrics: Exposes representations of Counters.
CountersController(CounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.CountersController
CounterTemplate - Class in org.springframework.xd.rest.client.impl: Implements the CounterOperations part of the API.
CounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.CounterTemplate
cp(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
createBeanDefinitionBuilder(Class<?>, Element) - Static method in class org.springframework.xd.integration.reactor.config.ReactorNamespaceUtils: Create a BeanDefinitionBuilder that checks for an env attribute and uses that as the Environment bean reference.
createDefinition(String, String) - Method in class org.springframework.xd.dirt.rest.JobsController
createDefinition(String, String) - Method in class org.springframework.xd.dirt.rest.StreamsController
createDefinition(String, String) - Method in class org.springframework.xd.dirt.rest.XDController
createJob(String, String, String, String, boolean, boolean) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
createJob(String, String, String, String, boolean, boolean) - Method in interface org.springframework.xd.rest.client.JobOperations: Create a new Job, optionally deploying it.
createJob(String, String, boolean, String, String, boolean) - Method in class org.springframework.xd.shell.command.JobCommands
createModule(String, String) - Method in class org.springframework.xd.shell.command.ModuleCommands
createSharedChannel(String, Class<T>) - Method in class org.springframework.integration.x.bus.LocalMessageBus
createSqlParameterSource(FieldSet) - Method in class org.springframework.xd.batch.item.jdbc.FieldSetSqlParameterSourceProvider
createSqlParameterSource(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider
createStream(String, String, boolean) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
createStream(String, String, boolean) - Method in interface org.springframework.xd.rest.client.StreamOperations: Create a new Stream, optionally deploying it.
createStream(String, String, boolean) - Method in class org.springframework.xd.shell.command.StreamCommands
createWriter() - Method in class org.springframework.xd.hadoop.fs.AvroWriterFactory
createWriter() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
createWriter() - Method in interface org.springframework.xd.hadoop.fs.HdfsWriterFactory

D

DatabaseVendorFriendlyNameFactoryBean - Class in org.springframework.xd.dirt.jdbc.util: A factory bean that returns a friendly string name from database metadata.
DatabaseVendorFriendlyNameFactoryBean() - Constructor for class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
DatasetTemplateAllowingNulls - Class in org.springframework.data.hadoop.x.store.dataset: TODO: remove this class once we update to use spring-data-hadoop 2.0.0.M5 Temporary patch class to allow POJOs containing null values to be stored in Datasets
DatasetTemplateAllowingNulls() - Constructor for class org.springframework.data.hadoop.x.store.dataset.DatasetTemplateAllowingNulls
dataSource() - Method in class org.springframework.xd.dirt.server.ParentConfiguration.CloudFoundryConfiguration
DataTransport - Enum in org.springframework.xd.dirt.server.options
DateTrigger - Class in org.springframework.xd.module.support: A Trigger implementation that enables execution on a series of Dates.
DateTrigger() - Constructor for class org.springframework.xd.module.support.DateTrigger
DateTrigger(Date...) - Constructor for class org.springframework.xd.module.support.DateTrigger
decrement(long) - Method in class org.springframework.xd.analytics.metrics.core.Counter: Decrement this counter by a given amount.
decrement(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository: Decrement the given counter, creating it if it did not exist.
decrement(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository: Decrement the FieldValueCounter for a given field name by one, creating missing counters.
decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
decrement(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
decrement(String, String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
DeepAggregateCountResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics: Knows how to construct AggregateCountsResource out of AggregateCount.
DeepAggregateCountResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler
DeepCounterResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics: Knows how to assemble CounterResources out of Counters.
DeepCounterResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler
DeepFieldValueCounterResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics: Knows how to create rich representations of FieldValueCounter.
DeepFieldValueCounterResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler
DEFAULT - Static variable in class org.springframework.xd.shell.converter.NumberFormatConverter
DEFAULT_BASE_FILENAME - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
DEFAULT_BASE_PATH - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
DEFAULT_DATA_PATH - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants: Default writer path.
DEFAULT_FILE_SUFFIX - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
DEFAULT_HOST - Static variable in class org.springframework.xd.shell.Target
DEFAULT_ID_FILE_NAMING_STRATEGY - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants: Default bean id for file naming policy.
DEFAULT_ID_FILE_ROLLOVER_STRATEGY - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants: Default bean id for file rollover policy.
DEFAULT_ID_STORE_WRITER - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants: Default bean id for store writer.
DEFAULT_PORT - Static variable in class org.springframework.xd.shell.Target
DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
DEFAULT_SCHEME - Static variable in class org.springframework.xd.shell.Target
DEFAULT_TARGET - Static variable in class org.springframework.xd.shell.Target
DefaultContentTypeAwareConverterRegistry - Class in org.springframework.integration.x.bus.converter
DefaultContentTypeAwareConverterRegistry() - Constructor for class org.springframework.integration.x.bus.converter.DefaultContentTypeAwareConverterRegistry
DefaultMessageMediaTypeResolver - Class in org.springframework.integration.x.bus
DefaultMessageMediaTypeResolver() - Constructor for class org.springframework.integration.x.bus.DefaultMessageMediaTypeResolver
DefaultModuleOptionsMetadata - Class in org.springframework.xd.module.options: Implementation of ModuleOptionsMetadata used when no explicit information about a module has been authored.
DefaultModuleOptionsMetadata() - Constructor for class org.springframework.xd.module.options.DefaultModuleOptionsMetadata
DefaultModuleOptionsMetadataResolver - Class in org.springframework.xd.module.options: The default implementation of ModuleOptionsMetadataResolver that deals with simple modules and reads the companion .properties file sitting next to the module definition.
DefaultModuleOptionsMetadataResolver() - Constructor for class org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver
DefaultObjectToStringConverter - Class in org.springframework.integration.x.bus.converter
DefaultObjectToStringConverter() - Constructor for class org.springframework.integration.x.bus.converter.DefaultObjectToStringConverter
DefaultTuple - Class in org.springframework.xd.tuple: Default implementation of Tuple interface
DefaultTuple(List<String>, List<Object>, FormattingConversionService) - Constructor for class org.springframework.xd.tuple.DefaultTuple
DefaultTupleConversionService - Class in org.springframework.xd.tuple: Base ConversionService implementation suitable for use with Tuple
DefaultTupleConversionService() - Constructor for class org.springframework.xd.tuple.DefaultTupleConversionService
DefinitionAlreadyExistsException - Exception in org.springframework.xd.dirt.stream: Exception which is raised when a resource definition with the same name already exists.
DefinitionAlreadyExistsException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.DefinitionAlreadyExistsException: Create a new exception.
definitionKind - Variable in class org.springframework.xd.dirt.stream.AbstractDeployer: Lower-case, singular name of the kind of definition we're deploying.
DelegatingHandlerMapping - Class in org.springframework.xd.dirt.post
DelegatingHandlerMapping() - Constructor for class org.springframework.xd.dirt.post.DelegatingHandlerMapping
DelegatingModuleRegistry - Class in org.springframework.xd.dirt.module: A ModuleRegistry that delegates to several ModuleRegistries, in order.
DelegatingModuleRegistry(ModuleRegistry...) - Constructor for class org.springframework.xd.dirt.module.DelegatingModuleRegistry
delete(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
delete(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
delete(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
delete(M) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
delete(Iterable<? extends M>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
delete(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
delete(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
delete(FieldValueCounter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
delete(Iterable<? extends FieldValueCounter>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
delete(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer: Delete the Definition using the provided name.
delete(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
delete(String) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
delete(String, ModuleType, String) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDependencyRepository
delete(String, ModuleType, String) - Method in interface org.springframework.xd.dirt.module.ModuleDependencyRepository: Remove an atomic dependency from a module (composed or not) to some target (stream, or composed module).
delete(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
delete(String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
delete(String, ModuleType, String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDependencyRepository
delete(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
delete(ModuleType, String) - Method in class org.springframework.xd.dirt.rest.ModulesController: Delete a (composite) module.
delete(String) - Method in class org.springframework.xd.dirt.rest.XDController: Request removal of an existing module.
delete(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
delete(String, ModuleType) - Method in class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
delete(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository
delete(String) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository
delete(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository
delete(String) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository
delete(String) - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations: Delete the given named aggregate counter
delete(String) - Method in interface org.springframework.xd.rest.client.CounterOperations: Delete the counter with given name
delete(String) - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations: Delete the given named field value counter
delete(String) - Method in interface org.springframework.xd.rest.client.GaugeOperations: Delete the given named gauge.
delete(String) - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate
delete(String) - Method in class org.springframework.xd.rest.client.impl.CounterTemplate
delete(String) - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate
delete(String) - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate
delete(String) - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate
delete(String) - Method in interface org.springframework.xd.rest.client.RichGaugeOperations: Delete the given named rich gauge
delete(String) - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
delete(String) - Method in class org.springframework.xd.shell.command.CounterCommands
delete(String) - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
delete(String) - Method in class org.springframework.xd.shell.command.GaugeCommands
delete(String) - Method in class org.springframework.xd.shell.command.RichGaugeCommands
delete(ID) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
delete(T) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
delete(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
delete(Iterable<? extends T>) - Method in class org.springframework.xd.store.AbstractRedisRepository
delete(T) - Method in class org.springframework.xd.store.AbstractRedisRepository
delete(Iterable<? extends T>) - Method in class org.springframework.xd.store.AbstractRepository
deleteAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
deleteAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
deleteAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
deleteAll() - Method in interface org.springframework.xd.dirt.core.ResourceDeployer: Delete all the definitions
deleteAll() - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
deleteAll() - Method in class org.springframework.xd.dirt.rest.XDController: Request removal of all modules.
deleteAll() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
deleteAll() - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
deleteAll() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
deleteAll() - Method in class org.springframework.xd.store.AbstractRedisRepository
deleteBinding(String, MessageChannel) - Method in class org.springframework.integration.x.bus.MessageBusSupport
deleteBindings(String) - Method in class org.springframework.integration.x.bus.MessageBusSupport
deleteDependencies(ModuleDependencyRepository, ModuleDefinition, String) - Static method in class org.springframework.xd.dirt.module.support.ModuleDefinitionRepositoryUtils
deleteDependencies(ModuleDependencyRepository, StreamDefinition) - Static method in class org.springframework.xd.dirt.stream.StreamDefinitionRepositoryUtils: Delete the dependencies of each module to its containing stream.
deleteJobName(String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
deleteModule(String, RESTModuleType) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
deleteModule(String, RESTModuleType) - Method in interface org.springframework.xd.rest.client.ModuleOperations: Request deletion of module with given name and type.
DependencyException - Exception in org.springframework.xd.dirt.module: Thrown when performing an action cannot be carried over because some dependency would be broken.
DependencyException(String, String, ModuleType, Set<String>) - Constructor for exception org.springframework.xd.dirt.module.DependencyException
deploy(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
deploy(String) - Method in class org.springframework.xd.dirt.rest.XDController: Request deployment of an existing named module.
deploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
deploy(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
deploy(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
deploy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations: Deploy an already created resource.
DeployableResource - Class in org.springframework.xd.rest.client.domain: Abstract base class for resources that represent deployable things.
DeployableResource() - Constructor for class org.springframework.xd.rest.client.domain.DeployableResource: No arg constructor for serialization frameworks.
DeployableResource(String) - Constructor for class org.springframework.xd.rest.client.domain.DeployableResource
deployAll() - Method in interface org.springframework.xd.dirt.core.ResourceDeployer: deploy all available undeployed resource definitions.
deployAll() - Method in class org.springframework.xd.dirt.rest.XDController: Request deployment of all modules.
deployAll() - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
deployAll() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
deployAll() - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
deployAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations: Deploy all the resources known to the system.
deployAllJobs(boolean) - Method in class org.springframework.xd.shell.command.JobCommands
deployAllStreams(boolean) - Method in class org.springframework.xd.shell.command.StreamCommands
deployJob(String) - Method in class org.springframework.xd.shell.command.JobCommands
deploymentInfo(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer: Query deployment information about definitions whose ids range from first to last.
DeploymentMessageSender - Class in org.springframework.xd.dirt.stream
DeploymentMessageSender(MessageChannel, MessageChannel) - Constructor for class org.springframework.xd.dirt.stream.DeploymentMessageSender
DeploymentMetadata - Class in org.springframework.xd.module: Represents information about a particular module deployment.
DeploymentMetadata(String, int) - Constructor for class org.springframework.xd.module.DeploymentMetadata
DeploymentMetadata(String, int, String, String) - Constructor for class org.springframework.xd.module.DeploymentMetadata
deployStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands
deserialize(byte[]) - Method in class org.springframework.integration.x.bus.serializer.AbstractCodec: Deserialize a byte array.
deserialize(InputStream, Class<?>) - Method in class org.springframework.integration.x.bus.serializer.CompositeCodec
deserialize(byte[], Class<?>) - Method in class org.springframework.integration.x.bus.serializer.CompositeCodec
deserialize(InputStream, Class<? extends T>) - Method in interface org.springframework.integration.x.bus.serializer.MultiTypeCodec: Deserialize an object of a given type
deserialize(byte[], Class<? extends T>) - Method in interface org.springframework.integration.x.bus.serializer.MultiTypeCodec: Deserialize an object of a given type
deserialize(byte[]) - Method in class org.springframework.integration.x.redis.KryoMessageSerializer
deserialize(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.container.store.RedisRuntimeContainerInfoRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisJobDefinitionRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisJobRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository
deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamRepository
deserialize(JsonParser, DeserializationContext) - Method in class org.springframework.xd.rest.client.impl.support.JobParameterJacksonDeserializer
deserialize(ID, String) - Method in class org.springframework.xd.store.AbstractRedisRepository: Deserialize from the String representation to the domain object.
deserializeId(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
deserializeId(String) - Method in class org.springframework.xd.dirt.container.store.RedisRuntimeContainerInfoRepository
deserializeId(String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
deserializeId(String) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
deserializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository
deserializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository
deserializeId(String) - Method in class org.springframework.xd.store.AbstractRedisRepository: Deserialize an entity id from its String representation.
destroy() - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus
destroy() - Method in class org.springframework.integration.x.redis.RedisMessageBus
destroy() - Method in class org.springframework.xd.dirt.job.HSQLServerBean
destroy() - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
destroy() - Method in class org.springframework.xd.dirt.post.HandlerMappingRegistrar
destroy() - Method in class org.springframework.xd.module.core.CompositeModule
destroy() - Method in interface org.springframework.xd.module.core.Module: Destroy this module's application context.
destroy() - Method in class org.springframework.xd.module.core.SimpleModule
destroy(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
destroy(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
destroy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations: Destroy an existing resource.
destroyAll() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
destroyAll() - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
destroyAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations: Undeploy all the resources known to the system.
destroyAllJobs(boolean) - Method in class org.springframework.xd.shell.command.JobCommands
destroyAllStreams(boolean) - Method in class org.springframework.xd.shell.command.StreamCommands
destroyJob(String) - Method in class org.springframework.xd.shell.command.JobCommands
destroyModule(ModuleCommands.QualifiedModuleName) - Method in class org.springframework.xd.shell.command.ModuleCommands
destroyStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands
DetailedJobInfo - Class in org.springframework.xd.dirt.job: A job info for batch jobs that provides more details than the base JobInfo
DetailedJobInfo(String, int, boolean, boolean, JobExecutionInfo) - Constructor for class org.springframework.xd.dirt.job.DetailedJobInfo
DetailedJobInfoResource - Class in org.springframework.xd.rest.client.domain: Represents Expanded Batch job info that has more details on batch jobs.
DetailedJobInfoResource(String, int, boolean, boolean, JobExecutionInfoResource) - Constructor for class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
DetailedJobInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model DetailedJobInfo.
DetailedJobInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.DetailedJobInfoResourceAssembler
DetailedModuleDefinitionResource - Class in org.springframework.xd.rest.client.domain: Extends ModuleDefinitionResource with information about module options.
DetailedModuleDefinitionResource() - Constructor for class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource: Default constructor for serialization frameworks.
DetailedModuleDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource
DetailedModuleDefinitionResource.Option - Class in org.springframework.xd.rest.client.domain
DetailedModuleDefinitionResource.Option(String, String, String, String) - Constructor for class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource.Option
DetailedModuleDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain: Dedicated subclass to workaround type erasure.
DetailedModuleDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource.Page
DetailedModuleDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build DetailedModuleDefinitionResource out of a ModuleDefinition.
DetailedModuleDefinitionResourceAssembler(ModuleOptionsMetadataResolver) - Constructor for class org.springframework.xd.dirt.rest.DetailedModuleDefinitionResourceAssembler
dispatch(Message<?>) - Method in class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher
display(String, DateTime, DateTime, AggregateCountResolution) - Method in class org.springframework.xd.dirt.rest.metrics.AggregateCountersController: Retrieve counts for a given time interval, using some precision.
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.CountersController: Retrieve information about a specific counter.
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.GaugesController
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.RichGaugesController
display(String) - Method in class org.springframework.xd.dirt.rest.XDController: Retrieve information about a single ResourceSupport.
display(String, String, String, Integer, Integer, AggregateCounterOperations.Resolution, NumberFormat) - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.CounterCommands
display(String, NumberFormat, int) - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.GaugeCommands
display(long) - Method in class org.springframework.xd.shell.command.JobCommands
display(ModuleCommands.QualifiedModuleName) - Method in class org.springframework.xd.shell.command.ModuleCommands
display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.RichGaugeCommands
displayBanner(String, String) - Static method in class org.springframework.xd.dirt.util.BannerUtils
displayJobExecution(long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
displayJobExecution(long) - Method in interface org.springframework.xd.rest.client.JobOperations: Retrieve a specific Job Execution for the provided jobExecutionId.
displayMetrics(PagedResources<MetricResource>) - Method in class org.springframework.xd.shell.command.AbstractMetricsCommands: Render a table with information about a list of metrics
DistributedJobService - Class in org.springframework.xd.dirt.plugins.job: SimpleJobService in distributed mode
DistributedJobService(SearchableJobInstanceDao, SearchableJobExecutionDao, SearchableStepExecutionDao, JobRepository, JobLauncher, BatchJobLocator, ExecutionContextDao) - Constructor for class org.springframework.xd.dirt.plugins.job.DistributedJobService
doDeserialize(Kryo, Input) - Method in class org.springframework.integration.x.bus.serializer.kryo.FileCodec
doDeserialize(Kryo, Input, Class<? extends Object>) - Method in class org.springframework.integration.x.bus.serializer.kryo.PojoCodec
doDeserialize(Kryo, Input) - Method in class org.springframework.integration.x.bus.serializer.kryo.StringCodec
doDeserialize(Kryo, Input) - Method in class org.springframework.integration.x.bus.serializer.kryo.TupleCodec
DomainRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Interface in org.springframework.xd.store: Implemented by XD repositories, exists mainly as a mean to capture several interfaces into one.
doParse(Element, ParserContext, String) - Method in class org.springframework.xd.integration.reactor.config.SyslogInboundChannelAdapterParser
doSerialize(File, Kryo, Output) - Method in class org.springframework.integration.x.bus.serializer.kryo.FileCodec
doSerialize(Object, Kryo, Output) - Method in class org.springframework.integration.x.bus.serializer.kryo.PojoCodec
doSerialize(String, Kryo, Output) - Method in class org.springframework.integration.x.bus.serializer.kryo.StringCodec
doSerialize(Tuple, Kryo, Output) - Method in class org.springframework.integration.x.bus.serializer.kryo.TupleCodec
doStart() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
doStart() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
doStart() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler: Subclasses may override this method with the start behaviour.
doStart() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
doStop() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
doStop() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
doStop() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler: Subclasses may override this method with the stop behaviour.
doStop() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
downloadConfigurationFile(RESTModuleType, String) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
downloadConfigurationFile(RESTModuleType, String) - Method in interface org.springframework.xd.rest.client.ModuleOperations: Get the configuration file associated with the provided module information.
downloadDefinition(ModuleType, String) - Method in class org.springframework.xd.dirt.rest.ModulesController: Retrieve the configuration file for the provided module information.
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler: Writes a Message into a DataStoreWriter.
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
driverClass - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
du(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

E

endpos - Variable in class org.springframework.xd.dirt.stream.dsl.AstNode
environment - Variable in class org.springframework.xd.dirt.util.XdConfigLoggingInitializer
equals(Object) - Method in class org.springframework.xd.analytics.metrics.core.Counter
equals(Object) - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
equals(Object) - Method in class org.springframework.xd.analytics.metrics.core.Gauge
equals(Object) - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
equals(Object) - Method in class org.springframework.xd.dirt.core.BaseDefinition
equals(Object) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
equals(Object) - Method in class org.springframework.xd.shell.util.Table
equals(Object) - Method in class org.springframework.xd.shell.util.TableHeader
equals(Object) - Method in class org.springframework.xd.shell.util.TableRow
equals(Object) - Method in class org.springframework.xd.tuple.DefaultTuple
exactlyOneOf(Object...) - Static method in class org.springframework.xd.shell.util.Assertions: Accepts 2*N arguments, even ones being names and odd ones being values for those names.
executeBatchJob() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
ExecutionContextJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for ExecutionContext de-serialization.
ExecutionContextJacksonMixIn() - Constructor for class org.springframework.xd.rest.client.impl.support.ExecutionContextJacksonMixIn
executionsForJob(String, int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobsController: Return a paged collection of job executions for a given job.
ExistingXDEntityConverter - Class in org.springframework.xd.shell.converter: A no-op converter from String to String, but that helps with completion in names of already existing entities.
ExistingXDEntityConverter() - Constructor for class org.springframework.xd.shell.converter.ExistingXDEntityConverter
exists(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
exists(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
exists(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
exists(ID) - Method in class org.springframework.xd.store.AbstractRepository
ExitStatusJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for ExitStatus de-serialization.
ExpandedJobParametersConverter - Class in org.springframework.xd.dirt.plugins.job: More flexible implementation of the JobParametersConverter.
ExpandedJobParametersConverter() - Constructor for class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
expressionString - Variable in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
expunge() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
extract(JsonNode) - Method in class org.springframework.integration.x.json.JsonNodeFieldExtractor
extract(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleFieldExtractor

F

failedComponentName() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
failedComponentName() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
FieldSetConverter - Class in org.springframework.xd.mongodb: A converter that maps from the batch FieldSet world to Mongo's DBObject.
FieldSetConverter() - Constructor for class org.springframework.xd.mongodb.FieldSetConverter
FieldSetSqlParameterSourceProvider - Class in org.springframework.xd.batch.item.jdbc: An ItemSqlParameterSourceProvider that will derive parameters from a FieldSet.
FieldSetSqlParameterSourceProvider() - Constructor for class org.springframework.xd.batch.item.jdbc.FieldSetSqlParameterSourceProvider
FieldSetType - Enum in org.springframework.xd.tuple.batch: Enum used to provide typing information when reading from a file.
FieldValueCounter - Class in org.springframework.xd.analytics.metrics.core: Represents the data stored in a Counter for multiple field-value pairs.
FieldValueCounter(String) - Constructor for class org.springframework.xd.analytics.metrics.core.FieldValueCounter
FieldValueCounter(String, Map<String, Double>) - Constructor for class org.springframework.xd.analytics.metrics.core.FieldValueCounter
FieldValueCounterCommands - Class in org.springframework.xd.shell.command: Commands for interacting with field value counter analytics.
FieldValueCounterCommands() - Constructor for class org.springframework.xd.shell.command.FieldValueCounterCommands
FieldValueCounterHandler - Class in org.springframework.xd.analytics.metrics.integration: Counts the occurrence of values for a set of JavaBean properties or Tuple fields using a FieldValueCounterService.
FieldValueCounterHandler(FieldValueCounterRepository, String, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler
FieldValueCounterOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available when dealing with Field Value Counters.
FieldValueCounterRepository - Interface in org.springframework.xd.analytics.metrics.core: A repository to save, delete and find FieldValueCounter instances.
FieldValueCounterResource - Class in org.springframework.xd.rest.client.domain.metrics: A deep representation of a FieldValueCounter
FieldValueCounterResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.FieldValueCounterResource: No arg constructor for serialization frameworks.
FieldValueCounterResource(String, Map<String, Double>) - Constructor for class org.springframework.xd.rest.client.domain.metrics.FieldValueCounterResource
FieldValueCountersController - Class in org.springframework.xd.dirt.rest.metrics: Controller that exposes FieldValueCounter related representations.
FieldValueCountersController(FieldValueCounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController
FieldValueCounterTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the Field Value Counter part of the metrics API.
FieldValueCounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate
FileCodec - Class in org.springframework.integration.x.bus.serializer.kryo
FileCodec() - Constructor for class org.springframework.integration.x.bus.serializer.kryo.FileCodec
FileJdbcJobModuleOptionsMetadata - Class in org.springframework.xd.jdbc: Captures module options for the "filejdbc" job module.
FileJdbcJobModuleOptionsMetadata() - Constructor for class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
find(String, ModuleType) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDependencyRepository
find(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDependencyRepository: Return the set of things that depend on the given module.
find(String, ModuleType) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDependencyRepository
findAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
findAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
findAll(Iterable<String>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
findAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
findAll(Iterable<String>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
findAll() - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
findAll(Pageable) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer: Return a slice of all definitions.
findAll(Pageable) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
findAll(Pageable) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
findAll() - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
findAll(Pageable) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
findAll() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
findAll() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
findAll(Pageable) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
findAll(Sort) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
findAll() - Method in class org.springframework.xd.store.AbstractRedisRepository
findAll(Iterable<ID>) - Method in class org.springframework.xd.store.AbstractRedisRepository
findAll(Pageable) - Method in class org.springframework.xd.store.AbstractRedisRepository
findAll(Sort) - Method in class org.springframework.xd.store.AbstractRedisRepository
findAll(Iterable<ID>) - Method in class org.springframework.xd.store.AbstractRepository
findAllByContainerId(Pageable, String) - Method in class org.springframework.xd.dirt.module.store.InMemoryRuntimeContainerModuleInfoRepository
findAllByContainerId(Pageable, String) - Method in class org.springframework.xd.dirt.module.store.RedisRuntimeContainerModuleInfoRepository
findAllByContainerId(Pageable, String) - Method in interface org.springframework.xd.dirt.module.store.RuntimeContainerModuleInfoRepository
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
findAllInRange(ID, boolean, ID, boolean) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
findAllInRange(ID, boolean, ID, boolean) - Method in class org.springframework.xd.store.AbstractRedisRepository
findAllInRange(ID, boolean, ID, boolean) - Method in interface org.springframework.xd.store.RangeCapableRepository: Return entities whose ids range between from and to.
findByName(String) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
findByName(String) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
findByName(String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
findByNameAndType(String, ModuleType) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
findByNameAndType(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
findByNameAndType(String, ModuleType) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
findByType(Pageable, ModuleType) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
findByType(Pageable, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
findByType(Pageable, ModuleType) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
findDefinition(String, ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
findDefinition(String, ModuleType) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
findDefinition(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry: Lookup a module of the given type with the given name.
findDefinitions(String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
findDefinitions(ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
findDefinitions() - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
findDefinitions(String) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
findDefinitions(ModuleType) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
findDefinitions() - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
findDefinitions(String) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry: Searches the registry for the name specified and returns all module definitions that match the name regardless of module type.
findDefinitions(ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry: Searches the registry for the type specified and returns all module definitions that match the type.
findDefinitions() - Method in interface org.springframework.xd.dirt.module.ModuleRegistry: Returns all module definitions.
findDefinitions(ModuleType) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
findDefinitions() - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
findDependentModules(String, ModuleType) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
findDependentModules(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
findDependentModules(String, ModuleType) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
findOne(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
findOne(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
findOne(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
findOne(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer: Retrieves a single Definition or null if none is found.
findOne(String) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
findOne(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
findOne(ID) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
findOne(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
forConsumer(AbstractEndpoint, MessageChannel) - Static method in class org.springframework.integration.x.bus.Binding
formatMessage(int, Object...) - Method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages: Produce a complete message including the prefix, the position (if known) and with the inserts applied to the message.
forProducer(MessageChannel, AbstractEndpoint) - Static method in class org.springframework.integration.x.bus.Binding
fromBindException(String, ModuleType, BindException) - Static method in exception org.springframework.xd.dirt.plugins.ModuleConfigurationException: Construct an exception following a configuration exception on a particular module.
fromBytes(byte[]) - Method in class org.springframework.integration.x.json.TypedJsonMapper
fromBytes(byte[], String) - Method in class org.springframework.integration.x.json.TypedJsonMapper: UnMarshall to a requested class
fromString(String) - Static method in class org.springframework.xd.tuple.TupleBuilder
fromTuple(Tuple) - Method in class org.springframework.xd.tuple.TupleStringMarshaller
FsShellCommands - Class in org.springframework.xd.shell.hadoop: HDFS shell commands
FsShellCommands() - Constructor for class org.springframework.xd.shell.hadoop.FsShellCommands
fvcOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
fvcOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with Field Value Counters.

G

Gauge - Class in org.springframework.xd.analytics.metrics.core: Represents the data stored in a Gauge which can be set to any integral value.
Gauge(String) - Constructor for class org.springframework.xd.analytics.metrics.core.Gauge: Construct a new Gauge given a name
Gauge(String, long) - Constructor for class org.springframework.xd.analytics.metrics.core.Gauge: Construct a new Gauge given a name and a initial value of the value
GaugeCommands - Class in org.springframework.xd.shell.command: Commands for interacting with Gauge analytics.
GaugeCommands() - Constructor for class org.springframework.xd.shell.command.GaugeCommands
GaugeHandler - Class in org.springframework.xd.analytics.metrics.integration
GaugeHandler(GaugeRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.GaugeHandler
GaugeOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available when dealing with Gauge.
gaugeOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
gaugeOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with Gauge.
GaugeRepository - Interface in org.springframework.xd.analytics.metrics.core: A marker interface for Gauge repositories.
GaugeResource - Class in org.springframework.xd.rest.client.domain.metrics: The REST representation of a Gauge.
GaugeResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.GaugeResource: No-arg constructor for serialization frameworks.
GaugeResource(String, long) - Constructor for class org.springframework.xd.rest.client.domain.metrics.GaugeResource
GaugesController - Class in org.springframework.xd.dirt.rest.metrics: Exposes representations of Gauges.
GaugesController(GaugeRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.GaugesController
GaugeTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the Gauge part of the metrics API.
GaugeTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.GaugeTemplate
GemfireCQSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the gemfire-cq source module.
GemfireCQSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
GemfireServerSinkModuleOptionsMetadata - Class in org.springframework.xd.gemfire: Captures module options for the "gemfire-server" and "gemfire-json-server" sink modules.
GemfireServerSinkModuleOptionsMetadata() - Constructor for class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
GemfireSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the gemfire source module.
GemfireSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.GemfireSourceOptionsMetadata
generateSplunkEvent(Object) - Method in class org.springframework.integration.x.splunk.SplunkTransformer
get(String, String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
getAdminContext() - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.QualifiedModuleNameConverter
getAlpha() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
getAlpha() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource
getApplicationContext() - Method in class org.springframework.xd.dirt.container.XDContainer
getApplicationContext() - Method in class org.springframework.xd.module.core.SimpleModule
getArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
getArgumentsAsProperties() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
getAttribute(String, Class<T>) - Method in class org.springframework.xd.module.DeploymentMetadata
getAttributes() - Method in class org.springframework.xd.dirt.event.AbstractEvent
getAttributes() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
getAverage() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge: Either an exponential weighted moving average or a simple mean, respectively, depending on whether the weight 'alpha' has been set for this gauge.
getAverage() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource: Return the average value for the gauge.
getBanner() - Method in class org.springframework.xd.shell.XDShellBannerProvider
getBaseFilename() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getBaseFilename() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getBaseFilename() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getBaseFilename() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
getBasePath() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getBasePath() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getBasePath() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getBasePath() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
getBean(String, Class<T>) - Method in class org.springframework.integration.x.bus.LocalMessageBus
getBigDecimal(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getBigDecimal(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getBigDecimal(String, BigDecimal) - Method in class org.springframework.xd.tuple.DefaultTuple
getBigDecimal(int, BigDecimal) - Method in class org.springframework.xd.tuple.DefaultTuple
getBigDecimal(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'BigDecimal' value at index 'index'.
getBigDecimal(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'BigDecimal' value from column with given 'name'.
getBigDecimal(int, BigDecimal) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'BigDecimal' value at index 'index'.
getBigDecimal(String, BigDecimal) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'BigDecimal' value from column with given 'name'.
getBoolean(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getBoolean(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getBoolean(int, String) - Method in class org.springframework.xd.tuple.DefaultTuple
getBoolean(String, String) - Method in class org.springframework.xd.tuple.DefaultTuple
getBoolean(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'boolean' value at index 'index'.
getBoolean(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'boolean' value from field with given 'name'.
getBoolean(int, String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'boolean' value at index 'index'.
getBoolean(String, String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'boolean' value from column with given 'name'.
getByte(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getByte(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getByte(String, byte) - Method in class org.springframework.xd.tuple.DefaultTuple
getByte(int, byte) - Method in class org.springframework.xd.tuple.DefaultTuple
getByte(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'byte' value at index 'index'.
getByte(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'byte' value from column with given 'name'.
getByte(int, byte) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'byte' value at index 'index'.
getByte(String, byte) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'byte' value from column with given 'name'.
getBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getBytesWritten() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getCacheEventExpression() - Method in class org.springframework.xd.dirt.modules.metadata.GemfireSourceOptionsMetadata
getChannel() - Method in class org.springframework.integration.x.bus.Binding
getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
getChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
getChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
getChannelType() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
getChannelType() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
getChar(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getChar(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getChar(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'char' value at index 'index'.
getChar(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'char' value from field with given 'name'.
getChildren() - Method in class org.springframework.xd.dirt.module.CompositeModuleDeploymentRequest
getClasspath() - Method in interface org.springframework.xd.dirt.stream.redis.ModuleDefinitionMixin
getClasspath() - Method in class org.springframework.xd.module.ModuleDefinition
getClientId() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
getCollectionName() - Method in class org.springframework.xd.mongodb.MongoItemWriter
getColumns() - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer
getColumns() - Method in class org.springframework.xd.jdbc.JdbcSinkModuleOptionsMetadata
getComponent(Class<T>) - Method in class org.springframework.xd.module.core.CompositeModule
getComponent(String, Class<T>) - Method in class org.springframework.xd.module.core.CompositeModule
getComponent(Class<T>) - Method in interface org.springframework.xd.module.core.Module
getComponent(String, Class<T>) - Method in interface org.springframework.xd.module.core.Module
getComponent(Class<T>) - Method in class org.springframework.xd.module.core.SimpleModule
getComponent(String, Class<T>) - Method in class org.springframework.xd.module.core.SimpleModule
getComponentType() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
getComponentType() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
getComposedModuleDefinitions() - Method in class org.springframework.xd.module.ModuleDefinition
getConfigProperties() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getConfiguration() - Method in class org.springframework.xd.shell.hadoop.ConfigurationModifiedEvent
getContainerContext() - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
getContainerId() - Method in class org.springframework.xd.dirt.event.AbstractModuleEvent
getContainerId() - Method in class org.springframework.xd.dirt.module.store.RuntimeModuleInfoEntity
getContainerId() - Method in class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource
getContainerId() - Method in class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
getContext() - Method in class org.springframework.xd.dirt.server.AdminServerApplication
getContext() - Method in class org.springframework.xd.dirt.server.LauncherApplication
getConverter(Class<T>) - Method in class org.springframework.xd.tuple.LocaleAwareStringToNumberConverterFactory
getConverters(MediaType) - Method in interface org.springframework.integration.x.bus.converter.ContentTypeAwareConverterRegistry: return all registered converters for a given content type.
getConverters(MediaType) - Method in class org.springframework.integration.x.bus.converter.DefaultContentTypeAwareConverterRegistry
getCount() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
getCount() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource
getCounter() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getCounter() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getCounter() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getCounterFromName(String) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getCounterFromName(String) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getCounterFromName(String) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getCounts() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
getCounts(String, int, AggregateCountResolution) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository: Query function which returns the last 'n' points for a particular resolution.
getCounts(String, Interval, AggregateCountResolution) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository: Query function to allow the counts for a specific interval to be retrieved.
getCounts(String, int, DateTime, AggregateCountResolution) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository: Queries by requesting a number of points, ending on the given date (inclusive).
getCounts(String, int, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
getCounts(String, Interval, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
getCounts(String, int, DateTime, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
getCounts(String, int, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
getCounts(String, int, DateTime, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
getCounts(String, Interval, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository: For each query, we need to convert the interval into two variations.
getCron() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
getDate(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getDate(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getDate(String, Date) - Method in class org.springframework.xd.tuple.DefaultTuple
getDate(int, Date) - Method in class org.springframework.xd.tuple.DefaultTuple
getDate(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in default format at designated column index.
getDate(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in default format at designated column with given name.
getDate(int, Date) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in default format at designated column index using the supplied defaultValue if the field value is a zero length string or null.
getDate(String, Date) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in default format at designated column with given name.
getDateWithPattern(int, String) - Method in class org.springframework.xd.tuple.DefaultTuple
getDateWithPattern(String, String) - Method in class org.springframework.xd.tuple.DefaultTuple
getDateWithPattern(int, String, Date) - Method in class org.springframework.xd.tuple.DefaultTuple
getDateWithPattern(String, String, Date) - Method in class org.springframework.xd.tuple.DefaultTuple
getDateWithPattern(int, String) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in default format at designated column index.
getDateWithPattern(String, String) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in given format from column with given name.
getDateWithPattern(int, String, Date) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in default format at designated column index.
getDateWithPattern(String, String, Date) - Method in interface org.springframework.xd.tuple.Tuple: Read the java.util.Date value in given format from column with given name.
getDefaultValue() - Method in class org.springframework.xd.module.options.ModuleOption
getDefaultValue() - Method in class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource.Option
getDefinition() - Method in class org.springframework.xd.dirt.core.BaseDefinition: Returns a String representation of the desired data flow, expressed in the XD DSL.
getDefinition() - Method in class org.springframework.xd.dirt.stream.BaseInstance: Return the underlying definition.
getDefinition() - Method in class org.springframework.xd.module.core.AbstractModule
getDefinition() - Method in class org.springframework.xd.module.ModuleDefinition
getDefinition() - Method in class org.springframework.xd.rest.client.domain.JobDefinitionResource
getDefinition() - Method in class org.springframework.xd.rest.client.domain.StreamDefinitionResource
getDefinitionRepository() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
getDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
getDependents() - Method in exception org.springframework.xd.dirt.module.DependencyException
getDeployedModules() - Method in class org.springframework.xd.dirt.module.ModuleDeployer
getDeployer() - Method in class org.springframework.xd.dirt.rest.XDController
getDeploymentMetadata() - Method in class org.springframework.xd.module.core.AbstractModule
getDeploymentMetadata() - Method in interface org.springframework.xd.module.core.Module
getDescription() - Method in class org.springframework.xd.module.options.ModuleOption
getDescription() - Method in class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource.Option
getDispatcher() - Method in class org.springframework.xd.integration.reactor.channel.ReactorPublishSubscribeChannel
getDouble(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getDouble(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getDouble(String, double) - Method in class org.springframework.xd.tuple.DefaultTuple
getDouble(int, double) - Method in class org.springframework.xd.tuple.DefaultTuple
getDouble(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'double' value at index 'index'.
getDouble(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'double' value from column with given 'name'.
getDouble(int, double) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'double' value at index 'index'.
getDouble(String, double) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'double' value from column with given 'name'.
getDriverClass() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getDuration() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getDuration() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getDuration() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getDuration() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
getDuration() - Method in class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
getDuration() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getDuration() - Method in class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
getDurationMillis() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getEndpoint() - Method in class org.springframework.integration.x.bus.Binding
getEndPos() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode
getEstimatedPercentComplete() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
getEstimatedPercentCompleteMessage() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
getExchange() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
getExecutionCount() - Method in class org.springframework.xd.dirt.job.JobInfo
getExecutionCount() - Method in class org.springframework.xd.rest.client.domain.JobInfoResource
getExecutionId() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getExecutionId() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getExitCode() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getExitStatus() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getExitStatus() - Method in class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
getExpressionString() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
getFieldCount() - Method in class org.springframework.xd.tuple.DefaultTuple
getFieldCount() - Method in interface org.springframework.xd.tuple.Tuple: Return the number of fields in this tuple.
getFieldNames() - Method in class org.springframework.xd.tuple.DefaultTuple: Return the values for all the fields in this tuple
getFieldNames() - Method in interface org.springframework.xd.tuple.Tuple: Return the fields names that can reference elements by name in this tuple
getFieldTypes() - Method in class org.springframework.xd.tuple.DefaultTuple
getFieldTypes() - Method in interface org.springframework.xd.tuple.Tuple: Return the Java types of the fields in this tuple.
getFieldValueCount() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
getFieldValueCounts() - Method in class org.springframework.xd.rest.client.domain.metrics.FieldValueCounterResource
getFileDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
getFileName() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getFileName() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getFileName() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getFileSuffix() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getFileSuffix() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getFileSuffix() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getFileSuffix() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
getFileSystem() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getFileSystem() - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
getFileSystem() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getFileSystem() - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
getFileSystem() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getFileSystem() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
getFinished() - Method in class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
getFixedDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
getFixedDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
getFloat(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getFloat(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getFloat(String, float) - Method in class org.springframework.xd.tuple.DefaultTuple
getFloat(int, float) - Method in class org.springframework.xd.tuple.DefaultTuple
getFloat(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'float' value at index 'index'.
getFloat(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'float' value from column with given 'name'.
getFloat(int, float) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'float' value at index 'index'.
getFloat(String, float) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'float' value from column with given 'name'.
getFormat() - Method in class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
getFromEnd() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
getGroup() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getGroup() - Method in class org.springframework.xd.dirt.module.store.RuntimeModuleInfoEntity
getGroup() - Method in class org.springframework.xd.module.DeploymentMetadata
getGroup() - Method in class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
getHADOOP_DISTRO() - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
getHADOOP_DISTRO() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
getHadoopConfiguration() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware: Gets the hadoop configuration.
getHashOperations() - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
getHeaderBorder(Map<Integer, TableHeader>) - Static method in class org.springframework.xd.shell.util.UiUtils: Renders the Table header border, based on the map of provided headers.
getHeaders() - Method in class org.springframework.xd.shell.util.Table
getHost() - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
getHost() - Method in class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
getHost() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
getHostName() - Method in class org.springframework.xd.dirt.container.store.RuntimeContainerInfoEntity
getHostName() - Method in class org.springframework.xd.dirt.container.XDContainer
getHostName() - Method in class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource
getHttp(String) - Method in class org.springframework.xd.shell.command.HttpCommands
getId() - Method in class org.springframework.xd.dirt.container.store.RuntimeContainerInfoEntity
getId() - Method in class org.springframework.xd.dirt.container.XDContainer
getId() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getId() - Method in class org.springframework.xd.dirt.module.store.RuntimeModuleInfoEntity
getId() - Method in class org.springframework.xd.tuple.DefaultTuple
getId() - Method in interface org.springframework.xd.tuple.Tuple: Get the unique Id of this tuple, not included in comparisons for equality.
getIndex() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getIndex() - Method in class org.springframework.xd.dirt.module.store.RuntimeModuleInfoEntity
getIndex() - Method in class org.springframework.xd.module.DeploymentMetadata
getIndex() - Method in class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
getIndexingComponents() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
getIndexOfLabelOrModuleName(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getInitializeDatabase() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getInitializerScript() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getInlinedStream() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getInputChannelName() - Method in class org.springframework.xd.module.DeploymentMetadata
getInputType() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
getInputType() - Method in class org.springframework.xd.jdbc.JdbcSinkModuleOptionsMetadata
getInputType() - Method in class org.springframework.xd.module.options.spi.ProcessortModuleOptionsMetadataSupport
getInputType() - Method in class org.springframework.xd.module.options.spi.SinkModuleOptionsMetadataSupport
getInserts() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
getInt(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getInt(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getInt(String, int) - Method in class org.springframework.xd.tuple.DefaultTuple
getInt(int, int) - Method in class org.springframework.xd.tuple.DefaultTuple
getInt(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'int' value at index 'index'.
getInt(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'int' value from column with given 'name'.
getInt(int, int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'int' value at index 'index'.
getInt(String, int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'int' value from column with given 'name'.
getInterval() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
getIpAddress() - Method in class org.springframework.xd.dirt.container.store.RuntimeContainerInfoEntity
getIpAddress() - Method in class org.springframework.xd.dirt.container.XDContainer
getIpAddress() - Method in class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource
getJavaTypeForContentType(MediaType, ClassLoader) - Method in class org.springframework.integration.x.bus.converter.DefaultContentTypeAwareConverterRegistry: For a given MediaType determine the corresponding Java type assumed by the registry
getJdbcTemplate() - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
getJmxPort() - Method in class org.springframework.xd.dirt.container.XDContainer
getJob(String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
getJobExecution() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getJobExecution() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getJobExecutionId() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getJobExecutionId() - Method in class org.springframework.xd.rest.client.domain.StepExecutionInfoResource
getJobExecutionInfo(Long) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController
getJobId() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getJobId() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getJobInstanceId() - Method in class org.springframework.xd.dirt.job.JobInfo
getJobInstanceId() - Method in class org.springframework.xd.rest.client.domain.JobInfoResource
getJobName() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getJobNames() - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
getJobParameters() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getJobParameters() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getJobParameters(Properties) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: If ExpandedJobParametersConverter.makeParametersUnique is true the JobParameter with key ExpandedJobParametersConverter.UNIQUE_JOB_PARAMETER_KEY will be added with a random number value.
getJobParameters() - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean: Please ensure that JobParametersBean.afterPropertiesSet() is called before obtaining the JobParameters.
getJobParameters() - Method in class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
getJobParameters() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getJobParametersForFile(File) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Return JobParameters for the passed-in File.
getJobParametersForJsonString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Converts a String-based JSON map to JobParameters.
getJobParametersForMap(Map<?, ?>) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Will convert the provided Map into JobParameters.
getJobParametersString() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getJobParametersString() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getJvmName() - Method in class org.springframework.xd.dirt.container.store.RuntimeContainerInfoEntity
getJvmName() - Method in class org.springframework.xd.dirt.container.XDContainer
getJvmName() - Method in class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource
getKeyExpression() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
getKind() - Method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages
getKryoInstance() - Method in class org.springframework.integration.x.bus.serializer.kryo.FileCodec
getKryoInstance() - Method in class org.springframework.integration.x.bus.serializer.kryo.PojoCodec
getKryoInstance() - Method in class org.springframework.integration.x.bus.serializer.kryo.TupleCodec
getLabelName() - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode
getLabelNames() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
getLastExecutionInfo() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getLengthOfPrefixPlusNameComponents() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
getLong(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getLong(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getLong(String, long) - Method in class org.springframework.xd.tuple.DefaultTuple
getLong(int, long) - Method in class org.springframework.xd.tuple.DefaultTuple
getLong(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'long' value at index 'index'.
getLong(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'int' value from column with given 'name'.
getLong(int, long) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'long' value at index 'index'.
getLong(String, long) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'long' value from column with given 'name'.
getMax() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
getMax() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource
getMaxWidth() - Method in class org.springframework.xd.shell.util.TableHeader
getMessage() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
getMessage() - Method in exception org.springframework.xd.rest.client.impl.SpringXDException
getMessageCode() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
getMetricKey(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository: Provides the key for a named metric.
getMin() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
getMin() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource
getModule() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getModule(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode: Find the first reference to the named module in the stream.
getModuleDefinitionRepository() - Method in class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
getModuleDefinitions() - Method in class org.springframework.xd.dirt.core.BaseDefinition
getModuleId() - Method in class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
getModuleName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
getModuleNodes() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getModuleOptionsMetadata() - Method in interface org.springframework.xd.dirt.stream.redis.ModuleDefinitionMixin
getName() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
getName() - Method in class org.springframework.xd.analytics.metrics.core.Counter
getName() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
getName() - Method in class org.springframework.xd.analytics.metrics.core.Gauge
getName() - Method in interface org.springframework.xd.analytics.metrics.core.Metric: Return the name of the metric.
getName() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
getName() - Method in class org.springframework.xd.dirt.core.BaseDefinition: Returns a unique name given to that stream definition.
getName() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getName() - Method in class org.springframework.xd.dirt.job.JobInfo
getName() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getName() - Method in exception org.springframework.xd.dirt.module.DependencyException
getName() - Method in exception org.springframework.xd.dirt.module.ModuleAlreadyExistsException
getName() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
getName() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode
getName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
getName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getName() - Method in class org.springframework.xd.module.core.AbstractModule
getName() - Method in interface org.springframework.xd.module.core.Module
getName() - Method in class org.springframework.xd.module.ModuleDefinition
getName() - Method in class org.springframework.xd.module.options.ModuleOption
getName() - Method in class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource.Option
getName() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getName() - Method in class org.springframework.xd.rest.client.domain.JobInfoResource
getName() - Method in class org.springframework.xd.rest.client.domain.ModuleDefinitionResource
getName() - Method in class org.springframework.xd.rest.client.domain.NamedResource: Return the name of the represented entity.
getName() - Method in class org.springframework.xd.shell.util.TableHeader
getNameComponents() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
getNames() - Method in class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
getNativeOptions() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
getObject() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
getObject() - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean: Return the Job for the corresponding JobFactoryBean.jobName.
getObject() - Method in class org.springframework.xd.integration.hadoop.config.AvroWritingMessageHandlerFactoryBean
getObject() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
getObjectType() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
getObjectType() - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean
getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.AvroWritingMessageHandlerFactoryBean
getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
getOffendingName() - Method in exception org.springframework.xd.dirt.analytics.NoSuchMetricException: Return the name that was not found.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.AlreadyDeployedException: Return the name of the already deployed definition.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.DefinitionAlreadyExistsException: Return the definition name that was in conflict.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.NoSuchDefinitionException: Return the name of the definition that could not be found.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.NotDeployedException: Return the name of the definition that could not be found.
getOptions() - Method in class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
getOutputChannelName() - Method in class org.springframework.xd.module.DeploymentMetadata
getOutputType() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
getOutputType() - Method in class org.springframework.xd.module.options.spi.ProcessortModuleOptionsMetadataSupport
getOutputType() - Method in class org.springframework.xd.module.options.spi.SourceModuleOptionsMetadataSupport
getParameters() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getPassword() - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
getPassword() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
getPassword() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getPayload() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
getPercentageComplete() - Method in class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
getPhase() - Method in class org.springframework.xd.dirt.container.XDContainer
getPhase() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
getPhase() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
getPort() - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
getPort() - Method in class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
getPORT() - Method in class org.springframework.xd.dirt.server.options.AdminOptions
getPORT() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
getPort() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
getPosition() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
getPrefix() - Method in class org.springframework.xd.store.AbstractRedisRepository
getPrompt() - Method in class org.springframework.xd.shell.XDShellPromptProvider
getProperties() - Method in class org.springframework.xd.dirt.module.store.RuntimeModuleInfoEntity
getProperties() - Method in class org.springframework.xd.module.core.CompositeModule
getProperties() - Method in interface org.springframework.xd.module.core.Module
getProperties() - Method in class org.springframework.xd.module.core.SimpleModule
getProperties() - Method in class org.springframework.xd.module.ModuleDefinition
getProperties() - Method in class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
getProperty(String) - Method in class org.springframework.xd.dirt.server.options.BeanPropertiesPropertySource
getProperty(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
getPropertyNames() - Method in class org.springframework.xd.dirt.server.options.BeanPropertiesPropertySource
getPropertyValue(String) - Method in class org.springframework.xd.dirt.container.XDContainer
getProviderName() - Method in class org.springframework.xd.shell.XDShellBannerProvider
getProviderName() - Method in class org.springframework.xd.shell.XDShellPromptProvider
getQuery() - Method in class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
getQueues() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
getRawString(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getRawString(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getRawString(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the String value at index 'index' including trailing whitespace (don't trim).
getRawString(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the String value from column with given 'name' including trailing whitespace (don't trim).
getRegionName() - Method in class org.springframework.xd.dirt.modules.metadata.GemfireSourceOptionsMetadata
getRegionName() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
getReOpen() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
getResolution() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
getResource() - Method in interface org.springframework.xd.dirt.stream.redis.ModuleDefinitionMixin
getResource() - Method in class org.springframework.xd.module.ModuleDefinition
getResource(String) - Method in class org.springframework.xd.module.support.ParentLastURLClassLoader
getResource() - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport
getResources() - Method in class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
getResources(String) - Method in class org.springframework.xd.module.support.ParentLastURLClassLoader
getRestartable() - Method in class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
getRolloverThresholdInBytes() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
getRolloverThresholdInBytes() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
getRolloverThresholdInBytes() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
getRolloverThresholdInBytes() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
getRoutingKey() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
getRows() - Method in class org.springframework.xd.shell.util.Table
getServerProperties() - Method in class org.springframework.xd.dirt.job.HSQLServerBean
getShort(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getShort(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getShort(String, short) - Method in class org.springframework.xd.tuple.DefaultTuple
getShort(int, short) - Method in class org.springframework.xd.tuple.DefaultTuple
getShort(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'short' value at index 'index'.
getShort(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'short' value from column with given 'name'.
getShort(int, short) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'short' value at index 'index'.
getShort(String, short) - Method in interface org.springframework.xd.tuple.Tuple: Read the 'short' value from column with given 'name'.
getSinkChannelName() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getSinkChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getSource() - Method in class org.springframework.xd.dirt.event.AbstractEvent
getSourceChannelName() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getSourceChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getSpecificTargetClasses() - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
getSpringXDOperations() - Method in class org.springframework.xd.shell.XDShell
getStartDate() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getStartDate() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getStartDate() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getStartDate() - Method in class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
getStartDate() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getStartedAt() - Method in class org.springframework.xd.dirt.stream.BaseInstance
getStartPos() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode
getStartTime() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getStartTime() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getStartTime() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getStartTime() - Method in class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
getStartTime() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getStatus() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getStatus() - Method in class org.springframework.xd.shell.Target: Return the target status, which is either Success or Error.
getStepExecution() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
getStepExecution() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
getStepExecution() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
getStepExecution() - Method in class org.springframework.xd.rest.client.domain.StepExecutionInfoResource
getStepExecution() - Method in class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
getStepExecutionCount() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
getStepExecutionCount() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getStepExecutionCount() - Method in class org.springframework.xd.rest.client.domain.DetailedJobInfoResource
getStepExecutionCount() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getStepExecutionHistory() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
getStepExecutionHistory() - Method in class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
getStepExecutionId() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
getStreamData() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getStreamText() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
getString(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getString(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getString(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the String value given the field 'name'.
getString(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the String value given the index position
getStringRepresentation() - Method in enum org.springframework.xd.dirt.stream.dsl.ChannelType
getTableName() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getTarget() - Method in class org.springframework.xd.shell.XDShell: Return the Target which encapsulates not only the Target URI but also success/error messages + status.
getTargetException() - Method in class org.springframework.xd.shell.Target: If during targeting an error occurred, the resulting Exception is made available for further introspection.
getTargetResultMessage() - Method in class org.springframework.xd.shell.Target: Provides a result message indicating whether the provide Target.getTargetUri() was successfully targeted or not.
getTargetUri() - Method in class org.springframework.xd.shell.Target
getTargetUriAsString() - Method in class org.springframework.xd.shell.Target: Returns the target URI as a String.
getTimestamp() - Method in class org.springframework.xd.tuple.DefaultTuple
getTimestamp() - Method in interface org.springframework.xd.tuple.Tuple: Get the creation timestamp of this tuple, not included in comparisons for equality
getTimeZone() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
getTimeZone() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
getTopics() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
getTotal() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
getTuple(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getTuple(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getTuple(String) - Method in interface org.springframework.xd.tuple.Tuple: Read the Tuple value given the field 'name'.
getTuple(int) - Method in interface org.springframework.xd.tuple.Tuple: Read the Tuple value given the index position
getType() - Method in class org.springframework.xd.dirt.event.AbstractEvent
getType() - Method in exception org.springframework.xd.dirt.module.DependencyException
getType() - Method in exception org.springframework.xd.dirt.module.ModuleAlreadyExistsException
getType() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
getType() - Method in class org.springframework.xd.module.core.AbstractModule
getType() - Method in interface org.springframework.xd.module.core.Module
getType() - Method in class org.springframework.xd.module.ModuleDefinition
getType() - Method in class org.springframework.xd.module.options.ModuleOption
getType() - Method in class org.springframework.xd.rest.client.domain.DetailedModuleDefinitionResource.Option
getType() - Method in class org.springframework.xd.rest.client.domain.ModuleDefinitionResource
getUrl() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
getUrl() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getUsername() - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
getUsername() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
getUsername() - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
getUtcTime(Date) - Static method in class org.springframework.xd.shell.util.CommonUtils: Return a date/time/UTC formatted String for the provided Date.
getValue() - Method in class org.springframework.xd.analytics.metrics.core.Counter
getValue() - Method in class org.springframework.xd.analytics.metrics.core.Gauge
getValue() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
getValue() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode
getValue() - Method in class org.springframework.xd.rest.client.domain.metrics.CounterResource: Return the value for the counter.
getValue() - Method in class org.springframework.xd.rest.client.domain.metrics.GaugeResource: Return the value for the gauge.
getValue() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource: Return the value for the gauge.
getValue(Integer) - Method in class org.springframework.xd.shell.util.TableRow: Return a value from this row.
getValue(String) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSource
getValue(String) - Method in class org.springframework.xd.tuple.DefaultTuple
getValue(int) - Method in class org.springframework.xd.tuple.DefaultTuple
getValue(String, Class<T>) - Method in class org.springframework.xd.tuple.DefaultTuple
getValue(int, Class<T>) - Method in class org.springframework.xd.tuple.DefaultTuple
getValue(String) - Method in interface org.springframework.xd.tuple.Tuple: Return the value of the field given the name
getValue(int) - Method in interface org.springframework.xd.tuple.Tuple: Return the value of the field given the index position
getValue(String, Class<T>) - Method in interface org.springframework.xd.tuple.Tuple: Return the value of the field given the name
getValue(int, Class<T>) - Method in interface org.springframework.xd.tuple.Tuple: Return the value of the field given the index position
getValues() - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer
getValues() - Method in class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource: Returns a date-sorted view of counts.
getValues() - Method in class org.springframework.xd.tuple.DefaultTuple: Return the values for all the fields in this tuple
getValues() - Method in interface org.springframework.xd.tuple.Tuple: Return the values for all the fields in this tuple
getVersion() - Static method in class org.springframework.xd.dirt.util.BannerUtils
getVersion() - Method in class org.springframework.xd.shell.XDShellBannerProvider: Returns the version information as found in the manifest file (set during release).
getVhost() - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
getWelcomeMessage() - Method in class org.springframework.xd.shell.XDShellBannerProvider
getWidth() - Method in class org.springframework.xd.shell.util.TableHeader
getXD_ANALYTICS() - Method in class org.springframework.xd.dirt.server.options.CommonDistributedOptions
getXD_ANALYTICS() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
getXD_CONTROL_TRANSPORT() - Method in class org.springframework.xd.dirt.server.options.AdminOptions
getXD_CONTROL_TRANSPORT() - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
getXD_CONTROL_TRANSPORT() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
getXD_STORE() - Method in class org.springframework.xd.dirt.server.options.CommonDistributedOptions
getXD_STORE() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
getXD_TRANSPORT() - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
getXD_TRANSPORT() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
getZSetData(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

H

HadoopDistro - Enum in org.springframework.xd.dirt.server.options
HadoopNamespaceHandler - Class in org.springframework.xd.integration.hadoop.config: Namespace handler for Spring Integration's 'hadoop' namespace.
HadoopNamespaceHandler() - Constructor for class org.springframework.xd.integration.hadoop.config.HadoopNamespaceHandler
handleError(ClientHttpResponse) - Method in class org.springframework.xd.rest.client.impl.VndErrorResponseErrorHandler
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
HandlerMappingRegistrar - Class in org.springframework.xd.dirt.post
HandlerMappingRegistrar(DelegatingHandlerMapping, String, Object) - Constructor for class org.springframework.xd.dirt.post.HandlerMappingRegistrar
hasArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
hasFieldName(String) - Method in class org.springframework.xd.tuple.DefaultTuple
hasFieldName(String) - Method in interface org.springframework.xd.tuple.Tuple: Return true if the tuple contains a field of the given name
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.Counter
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.Gauge
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
hashCode() - Method in class org.springframework.xd.dirt.core.BaseDefinition
hashCode() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
hashCode() - Method in class org.springframework.xd.shell.util.Table
hashCode() - Method in class org.springframework.xd.shell.util.TableHeader
hashCode() - Method in class org.springframework.xd.shell.util.TableRow
hashCode() - Method in class org.springframework.xd.tuple.DefaultTuple
hashOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
hasValue(String) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSource
HdfsOutboundChannelAdapterParser - Class in org.springframework.xd.integration.hadoop.config: Parser for the 'hdfs-outbound-channel-adapter' element.
HdfsOutboundChannelAdapterParser() - Constructor for class org.springframework.xd.integration.hadoop.config.HdfsOutboundChannelAdapterParser
HdfsStoreMessageHandler - Class in org.springframework.xd.integration.hadoop.outbound: Spring Integration MessageHandler handling Message writing into hdfs using DataStoreWriter.
HdfsStoreMessageHandler() - Constructor for class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
HdfsTextFileWriter - Class in org.springframework.xd.hadoop.fs
HdfsTextFileWriter(FileSystem) - Constructor for class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
HdfsTextFileWriterFactory - Class in org.springframework.xd.hadoop.fs
HdfsTextFileWriterFactory(FileSystem) - Constructor for class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
HdfsTextItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop
HdfsTextItemWriter(FileSystem) - Constructor for class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
HdfsWriter - Interface in org.springframework.xd.hadoop.fs
HdfsWriterFactory - Interface in org.springframework.xd.hadoop.fs
HdfsWritingMessageHandler - Class in org.springframework.xd.integration.hadoop.outbound
HdfsWritingMessageHandler(HdfsWriterFactory) - Constructor for class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
HdfsWritingMessageHandlerFactoryBean - Class in org.springframework.xd.integration.hadoop.config
HdfsWritingMessageHandlerFactoryBean(FileSystem) - Constructor for class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
HORIZONTAL_LINE - Static variable in class org.springframework.xd.shell.util.UiUtils
HSQL_PROFILE - Static variable in class org.springframework.xd.dirt.server.AdminServerApplication
HSQLServerBean - Class in org.springframework.xd.dirt.job: HSQL server mode
HSQLServerBean() - Constructor for class org.springframework.xd.dirt.job.HSQLServerBean
HttpCommands - Class in org.springframework.xd.shell.command: Http commands.
HttpCommands() - Constructor for class org.springframework.xd.shell.command.HttpCommands
httpPutFormContentFilter() - Method in class org.springframework.xd.dirt.server.AdminServerApplication

I

idFromRedisKey(String) - Method in class org.springframework.xd.store.AbstractRedisRepository
increment(String, long, DateTime) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository: Increments the named counter by a specific amount for the given instant.
increment(long) - Method in class org.springframework.xd.analytics.metrics.core.Counter: Increment this counter by a given amount.
increment(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository: Increment the given counter by one, creating it if it did not exist.
increment(String, long) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository: Increment the given counter by the specified amount, creating it if it did not exist.
increment(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository: Increment the FieldValueCounter for a given field name by one, creating missing counters.
increment(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
increment(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
increment(String, long, DateTime) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
increment(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
increment(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
increment(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
increment(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
increment(String, long, DateTime) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
increment(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
increment(String, long) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
increment(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
increment(String, String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
incrementBytesWritten(long) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
incrementBytesWritten(long) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
incrementBytesWritten(long) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
incrementCounter() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
incrementCounter() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
incrementCounter() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
indexOf(String) - Method in class org.springframework.xd.tuple.DefaultTuple: Find the index in the names collection for the given name.
inferModuleName(Resource) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry: Recover the name of the module, given its resource location.
inferModuleName(Resource) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
inferModuleName(Resource) - Method in class org.springframework.xd.dirt.module.ResourceModuleRegistry
info() - Method in class org.springframework.xd.dirt.rest.AdminController
info(ModuleType, String) - Method in class org.springframework.xd.dirt.rest.ModulesController: Retrieve detailed module definition about a particular module.
info(String, RESTModuleType) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
info(String, RESTModuleType) - Method in interface org.springframework.xd.rest.client.ModuleOperations: Retrieve information about a particular module.
info() - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
info() - Method in class org.springframework.xd.shell.XDShell
init() - Method in class org.springframework.xd.integration.hadoop.config.HadoopNamespaceHandler
init() - Method in class org.springframework.xd.integration.reactor.config.ReactorNamespaceHandler
init() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
initialize(SpringApplication, String[]) - Method in class org.springframework.xd.dirt.server.options.CommandLinePropertySourceOverridingInitializer
initialize(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.server.options.CommandLinePropertySourceOverridingInitializer
initialize() - Method in class org.springframework.xd.module.core.CompositeModule
initialize() - Method in interface org.springframework.xd.module.core.Module
initialize() - Method in class org.springframework.xd.module.core.SimpleModule
initializeCounterIfNecessary() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
initializeCounterIfNecessary() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
initializeCounterIfNecessary() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
initializeDatabase - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
initializerScript - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
InMemoryAggregateCounterRepository - Class in org.springframework.xd.analytics.metrics.memory: In-memory aggregate counter with minute resolution.
InMemoryAggregateCounterRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
InMemoryCounterRepository - Class in org.springframework.xd.analytics.metrics.memory: Memory backed implementation of Counter repository that uses a ConcurrentMap.
InMemoryCounterRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
InMemoryFieldValueCounterRepository - Class in org.springframework.xd.analytics.metrics.memory: Memory backed implementation of FieldValueCounterRepository that uses a ConcurrentMap
InMemoryFieldValueCounterRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
InMemoryGaugeRepository - Class in org.springframework.xd.analytics.metrics.memory: Memory backed Gauge repository that uses a ConcurrentMap
InMemoryGaugeRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
InMemoryJobDefinitionRepository - Class in org.springframework.xd.dirt.stream.memory
InMemoryJobDefinitionRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryJobDefinitionRepository
InMemoryJobRepository - Class in org.springframework.xd.dirt.stream.memory: In memory implementation of JobRepository.
InMemoryJobRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryJobRepository
InMemoryMetricRepository<M extends Metric> - Class in org.springframework.xd.analytics.metrics.memory: Memory backed implementation of MetricRepository that uses a ConcurrentMap
InMemoryMetricRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
InMemoryModuleDefinitionRepository - Class in org.springframework.xd.dirt.module.memory: An in memory store of ModuleDefinitions.
InMemoryModuleDefinitionRepository(ModuleRegistry, ModuleDependencyRepository) - Constructor for class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
InMemoryModuleDependencyRepository - Class in org.springframework.xd.dirt.module.memory: In memory implementation of ModuleDependencyRepository.
InMemoryModuleDependencyRepository() - Constructor for class org.springframework.xd.dirt.module.memory.InMemoryModuleDependencyRepository
InMemoryRichGaugeRepository - Class in org.springframework.xd.analytics.metrics.memory: Memory backed implementation of GaugeRepository that uses a ConcurrentMap
InMemoryRichGaugeRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
InMemoryRuntimeContainerInfoRepository - Class in org.springframework.xd.dirt.container.store: InMemory extension for the runtime container info repository.
InMemoryRuntimeContainerInfoRepository() - Constructor for class org.springframework.xd.dirt.container.store.InMemoryRuntimeContainerInfoRepository
InMemoryRuntimeContainerModuleInfoRepository - Class in org.springframework.xd.dirt.module.store: InMemory extension for the runtime module info repository with the modules mapped under their containers.
InMemoryRuntimeContainerModuleInfoRepository() - Constructor for class org.springframework.xd.dirt.module.store.InMemoryRuntimeContainerModuleInfoRepository
InMemoryRuntimeModuleInfoRepository - Class in org.springframework.xd.dirt.module.store: InMemory extension for the runtime module info repository.
InMemoryRuntimeModuleInfoRepository() - Constructor for class org.springframework.xd.dirt.module.store.InMemoryRuntimeModuleInfoRepository
InMemoryStreamDefinitionRepository - Class in org.springframework.xd.dirt.stream.memory: An in memory store of StreamDefinitions.
InMemoryStreamDefinitionRepository(ModuleDependencyRepository) - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository
InMemoryStreamRepository - Class in org.springframework.xd.dirt.stream.memory: In memory implementation of StreamRepository.
InMemoryStreamRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryStreamRepository
installMessageConverters(List<HttpMessageConverter<?>>) - Static method in class org.springframework.xd.rest.client.util.RestTemplateMessageConverterUtil: Install message converters we're interested in, with json coming before xml.
instanceRepository - Variable in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
instancesForJob(String, int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobsController: Return a paged collection of job instances for a given job.
instantiateResource(DetailedJobInfo) - Method in class org.springframework.xd.dirt.rest.DetailedJobInfoResourceAssembler
instantiateResource(ModuleDefinition) - Method in class org.springframework.xd.dirt.rest.DetailedModuleDefinitionResourceAssembler
instantiateResource(JobDefinition) - Method in class org.springframework.xd.dirt.rest.JobDefinitionResourceAssembler
instantiateResource(JobExecutionInfo) - Method in class org.springframework.xd.dirt.rest.JobExecutionInfoResourceAssembler
instantiateResource(JobInfo) - Method in class org.springframework.xd.dirt.rest.JobInfoResourceAssembler
instantiateResource(AggregateCount) - Method in class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler
instantiateResource(Counter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler
instantiateResource(FieldValueCounter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler
instantiateResource(M) - Method in class org.springframework.xd.dirt.rest.metrics.ShallowMetricResourceAssembler
instantiateResource(ModuleDefinition) - Method in class org.springframework.xd.dirt.rest.ModuleDefinitionResourceAssembler
instantiateResource(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.rest.RuntimeContainerInfoResourceAssembler
instantiateResource(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.rest.RuntimeModuleInfoResourceAssembler
instantiateResource(StepExecutionInfo) - Method in class org.springframework.xd.dirt.rest.StepExecutionInfoResourceAssembler
instantiateResource(StepExecutionProgressInfo) - Method in class org.springframework.xd.dirt.rest.StepExecutionProgressInfoResourceAssembler
instantiateResource(StreamDefinition) - Method in class org.springframework.xd.dirt.rest.StreamDefinitionResourceAssembler
IntegrationHadoopNamespaceUtils - Class in org.springframework.xd.integration.hadoop.config: Utility methods for namespace.
IntegrationHadoopSystemConstants - Class in org.springframework.xd.integration.hadoop: Various constants throughout the spring integration hadoop libraries.
integrationMBeanExporter() - Method in class org.springframework.xd.dirt.server.AdminServerApplication.JmxConfiguration
integrationMBeanExporter() - Method in class org.springframework.xd.dirt.server.LauncherApplication.JmxConfiguration
integrationMBeanExporter() - Method in class org.springframework.xd.dirt.server.ParentConfiguration.JmxConfiguration
interpolate(Map<String, String>) - Method in class org.springframework.xd.module.options.DefaultModuleOptionsMetadata
interpolate(Map<String, String>) - Method in interface org.springframework.xd.module.options.ModuleOptionsMetadata
interpolate(Map<String, String>) - Method in class org.springframework.xd.module.options.PojoModuleOptionsMetadata
interpolate(Map<String, String>) - Method in class org.springframework.xd.module.options.SimpleModuleOptionsMetadata
invoke(MethodInvocation) - Method in class org.springframework.xd.dirt.module.support.ThreadContextClassLoaderSetterAdvice
isAbandonable() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
isAbandonable() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
isAliasedInput() - Method in class org.springframework.xd.module.DeploymentMetadata: Return whether the source end is using an aliased name.
isAliasedOutput() - Method in class org.springframework.xd.module.DeploymentMetadata: Return whether the output end is using an aliased name.
isAutoStartup() - Method in class org.springframework.xd.dirt.container.XDContainer
isAutoStartup() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
isAutoStartup() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
isComplete() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
isComposed() - Method in interface org.springframework.xd.dirt.stream.redis.ModuleDefinitionMixin
isComposed() - Method in class org.springframework.xd.module.ModuleDefinition: Determine if this a composed module
isDeployed() - Method in class org.springframework.xd.rest.client.domain.DeployableResource: Return deployment status of the underlying thing, or null if unknown.
isDeployments() - Method in class org.springframework.xd.dirt.rest.XDController.QueryOptions: Whether to also return deployment status when listing definitions.
isFinished() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
isIncrementable() - Method in class org.springframework.xd.dirt.job.JobInfo
isIncrementable(String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
isIncrementable(String) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
isIncrementable() - Method in class org.springframework.xd.rest.client.domain.JobInfoResource
isJmxEnabled() - Method in class org.springframework.xd.dirt.container.XDContainer
isLaunch() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
isLaunchable() - Method in class org.springframework.xd.dirt.job.JobInfo
isLaunchable() - Method in class org.springframework.xd.rest.client.domain.JobInfoResource
isRemove() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
isRestartable() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
isRestartable() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
isRunning() - Method in class org.springframework.integration.x.bus.Binding
isRunning() - Method in class org.springframework.xd.dirt.container.XDContainer
isRunning() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
isRunning() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
isRunning() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
isRunning() - Method in class org.springframework.xd.module.core.CompositeModule
isRunning() - Method in class org.springframework.xd.module.core.SimpleModule
isShowHelp() - Method in class org.springframework.xd.dirt.server.options.CommonOptions
isSingleton() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
isSingleton() - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean
isSingleton() - Method in class org.springframework.xd.integration.hadoop.config.AvroWritingMessageHandlerFactoryBean
isSingleton() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
isStoppable() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
isStoppable() - Method in class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
isTap() - Method in enum org.springframework.xd.dirt.stream.dsl.ChannelType
isUseLocator() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
isValidEmail(String) - Static method in class org.springframework.xd.shell.util.CommonUtils
isXD_JMX_ENABLED() - Method in class org.springframework.xd.dirt.server.options.CommonOptions
iterator() - Method in class org.springframework.xd.module.options.DefaultModuleOptionsMetadata
iterator() - Method in class org.springframework.xd.module.options.PojoModuleOptionsMetadata
iterator() - Method in class org.springframework.xd.module.options.SimpleModuleOptionsMetadata

J

JavaSerializingConverter - Class in org.springframework.integration.x.bus.converter
JavaSerializingConverter() - Constructor for class org.springframework.integration.x.bus.converter.JavaSerializingConverter
JdbcMessagePayloadTransformer - Class in org.springframework.xd.jdbc: Transforms a payload to a Map representation based on provided column names.
JdbcMessagePayloadTransformer() - Constructor for class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer
JdbcSinkModuleOptionsMetadata - Class in org.springframework.xd.jdbc: Captures module options for the "jdbc" sink module.
JdbcSinkModuleOptionsMetadata() - Constructor for class org.springframework.xd.jdbc.JdbcSinkModuleOptionsMetadata
Job - Class in org.springframework.xd.dirt.stream: Captures runtime information about a deployed JobDefinition.
Job(JobDefinition) - Constructor for class org.springframework.xd.dirt.stream.Job: Create a new Job instance out of the given JobDefinition.
JOB_BEAN_ID - Static variable in class org.springframework.xd.dirt.plugins.job.JobPlugin
JOB_NAME_DELIMITER - Static variable in class org.springframework.xd.dirt.plugins.job.JobPlugin
JOB_PARAMETERS_KEY - Static variable in class org.springframework.xd.dirt.plugins.job.JobPlugin
JobCommands - Class in org.springframework.xd.shell.command: Job commands.
JobCommands() - Constructor for class org.springframework.xd.shell.command.JobCommands
JobDefinition - Class in org.springframework.xd.dirt.stream: Represents a job in the system.
JobDefinition(String, String) - Constructor for class org.springframework.xd.dirt.stream.JobDefinition: Create a new JobDefinition.
JobDefinitionRepository - Interface in org.springframework.xd.dirt.stream: A repository for persisting JobDefinitions.
JobDefinitionResource - Class in org.springframework.xd.rest.client.domain: Represents a Job Definition.
JobDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.JobDefinitionResource
JobDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain: Dedicated subclass to workaround type erasure.
JobDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.JobDefinitionResource.Page
JobDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model StreamDefinition.
JobDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.JobDefinitionResourceAssembler
JobDeployer - Class in org.springframework.xd.dirt.stream
JobDeployer(DeploymentMessageSender, JobDefinitionRepository, JobRepository, XDParser) - Constructor for class org.springframework.xd.dirt.stream.JobDeployer
JobExecutionInfo - Class in org.springframework.xd.dirt.job: Represents Batch job execution info.
JobExecutionInfo(JobExecution, TimeZone) - Constructor for class org.springframework.xd.dirt.job.JobExecutionInfo
JobExecutionInfoResource - Class in org.springframework.xd.rest.client.domain: Represents job execution info resource.
JobExecutionInfoResource() - Constructor for class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
JobExecutionInfoResource(JobExecution, TimeZone) - Constructor for class org.springframework.xd.rest.client.domain.JobExecutionInfoResource
JobExecutionInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model JobExecutionInfo.
JobExecutionInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.JobExecutionInfoResourceAssembler
JobExecutionJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for JobExecution de-serialization.
JobExecutionNotRunningException - Exception in org.springframework.xd.dirt.job: Exception for the job execution that is not running.
JobExecutionNotRunningException(Long) - Constructor for exception org.springframework.xd.dirt.job.JobExecutionNotRunningException
JobFactoryBean - Class in org.springframework.xd.dirt.plugins.job
JobFactoryBean() - Constructor for class org.springframework.xd.dirt.plugins.job.JobFactoryBean
JobInfo - Class in org.springframework.xd.dirt.job: Represents Batch job info.
JobInfo(String, int) - Constructor for class org.springframework.xd.dirt.job.JobInfo
JobInfo(String, int, boolean) - Constructor for class org.springframework.xd.dirt.job.JobInfo
JobInfo(String, int, boolean, boolean) - Constructor for class org.springframework.xd.dirt.job.JobInfo
JobInfo(String, int, Long, boolean, boolean) - Constructor for class org.springframework.xd.dirt.job.JobInfo
jobinfo(String) - Method in class org.springframework.xd.dirt.rest.BatchJobsController
JobInfoResource - Class in org.springframework.xd.rest.client.domain: Represents Batch job info.
JobInfoResource() - Constructor for class org.springframework.xd.rest.client.domain.JobInfoResource: Default constructor for serialization frameworks.
JobInfoResource(String, int, Long, boolean, boolean) - Constructor for class org.springframework.xd.rest.client.domain.JobInfoResource
JobInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model JobInfo.
JobInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.JobInfoResourceAssembler
JobInstanceJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for JobInstance de-serialization.
JobLaunchRequestTransformer - Class in org.springframework.xd.dirt.plugins.job: Executes all jobs defined within a given stream once the context has been started.
JobLaunchRequestTransformer(Job) - Constructor for class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer
jobOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
JobOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available against jobs.
jobOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with Jobs.
JobParameterJacksonDeserializer - Class in org.springframework.xd.rest.client.impl.support: Jackson Deserializer for JobParameter de-serialization.
JobParameterJacksonDeserializer() - Constructor for class org.springframework.xd.rest.client.impl.support.JobParameterJacksonDeserializer
JobParameterJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for JobParameter de-serialization.
JobParameterJacksonMixIn() - Constructor for class org.springframework.xd.rest.client.impl.support.JobParameterJacksonMixIn
JobParametersBean - Class in org.springframework.xd.dirt.plugins.job: Prepares the JobParameters for the Spring Bach Jobs.
JobParametersBean(String) - Constructor for class org.springframework.xd.dirt.plugins.job.JobParametersBean: Initializes the JobParametersBean.
JobParametersJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for JobParameters de-serialization.
JobParametersJacksonMixIn() - Constructor for class org.springframework.xd.rest.client.impl.support.JobParametersJacksonMixIn
JobPlugin - Class in org.springframework.xd.dirt.plugins.job: Plugin to enable the registration of jobs in a central registry.
JobPlugin() - Constructor for class org.springframework.xd.dirt.plugins.job.JobPlugin
JobRepository - Interface in org.springframework.xd.dirt.stream: A repoository for persisting Job instances.
jobs(int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobsController: Get a list of JobInfo, in a given range.
JobsController - Class in org.springframework.xd.dirt.rest: Handles all Job related interactions.
JobsController(JobDeployer, JobDefinitionRepository) - Constructor for class org.springframework.xd.dirt.rest.JobsController
JobTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the Job-related part of the API.
JsonBytesToTupleConverter - Class in org.springframework.xd.tuple
JsonBytesToTupleConverter() - Constructor for class org.springframework.xd.tuple.JsonBytesToTupleConverter
JsonNodeFieldExtractor - Class in org.springframework.integration.x.json: Extract a field value from a JsonNode
JsonNodeFieldExtractor(String) - Constructor for class org.springframework.integration.x.json.JsonNodeFieldExtractor
JsonNodeToTupleConverter - Class in org.springframework.xd.tuple
JsonNodeToTupleConverter() - Constructor for class org.springframework.xd.tuple.JsonNodeToTupleConverter
JsonStringToObjectTransformer - Class in org.springframework.integration.x.gemfire
JsonStringToObjectTransformer() - Constructor for class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer
JsonStringToTupleConverter - Class in org.springframework.xd.tuple
JsonStringToTupleConverter() - Constructor for class org.springframework.xd.tuple.JsonStringToTupleConverter
JsonToMapConverter - Class in org.springframework.integration.x.bus.converter
JsonToMapConverter() - Constructor for class org.springframework.integration.x.bus.converter.JsonToMapConverter
JsonToTupleConverter - Class in org.springframework.integration.x.bus.converter
JsonToTupleConverter() - Constructor for class org.springframework.integration.x.bus.converter.JsonToTupleConverter
JsonToTupleTransformer - Class in org.springframework.xd.tuple.integration: Converts from a json string into a tuple data structure.
JsonToTupleTransformer() - Constructor for class org.springframework.xd.tuple.integration.JsonToTupleTransformer
JsonUtil - Class in org.springframework.xd.shell.util: Some JSON helper utilities.

K

keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
keyFor(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.container.store.InMemoryRuntimeContainerInfoRepository
keyFor(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.container.store.RedisRuntimeContainerInfoRepository
keyFor(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
keyFor(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
keyFor(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
keyFor(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.InMemoryRuntimeContainerModuleInfoRepository
keyFor(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.InMemoryRuntimeModuleInfoRepository
keyFor(JobDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryJobDefinitionRepository
keyFor(Job) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryJobRepository
keyFor(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository
keyFor(Stream) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamRepository
keyFor(D) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository
keyFor(I) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository
keyFor(T) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
keyFor(T) - Method in class org.springframework.xd.store.AbstractRedisRepository: Return the entity id for the given domain object.
keyForEntity(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
keyForEntity(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.RedisRuntimeContainerModuleInfoRepository
keyForEntity(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.RedisRuntimeModuleInfoRepository
KryoMessageHeadersSerializer - Class in org.springframework.integration.x.redis: Implementation of Kryo Serializer to handle MessageHeaders which is immutable.
KryoMessageHeadersSerializer() - Constructor for class org.springframework.integration.x.redis.KryoMessageHeadersSerializer
KryoMessageSerializer - Class in org.springframework.integration.x.redis: A Redis Serializer that uses Kryo serialization
KryoMessageSerializer() - Constructor for class org.springframework.integration.x.redis.KryoMessageSerializer

L

LabelNode - Class in org.springframework.xd.dirt.stream.dsl: Represents a label attached to a module.
LabelNode(String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.LabelNode
labelOrModuleNameOccursMultipleTimesInStream(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
launch(String, JobParameters) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
launch(Module, Map<String, String>) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
launch(String, String) - Method in class org.springframework.xd.dirt.stream.JobDeployer
LauncherApplication - Class in org.springframework.xd.dirt.server
LauncherApplication() - Constructor for class org.springframework.xd.dirt.server.LauncherApplication
LauncherApplication.JmxConfiguration - Class in org.springframework.xd.dirt.server
LauncherApplication.JmxConfiguration() - Constructor for class org.springframework.xd.dirt.server.LauncherApplication.JmxConfiguration
launchJob(String, String) - Method in class org.springframework.xd.dirt.rest.JobsController: Send the request to launch Job.
launchJob(String, String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
launchJob(String, String) - Method in interface org.springframework.xd.rest.client.JobOperations: Launch a job that is already deployed.
launchJob(String, String) - Method in class org.springframework.xd.shell.command.JobCommands
lifecycleMonitor - Variable in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
list(int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController: List all job executions in a given range.
list(long) - Method in class org.springframework.xd.dirt.rest.BatchStepExecutionsController: List all step executions.
list(Pageable, XDController.QueryOptions, PagedResourcesAssembler<JobDefinition>) - Method in class org.springframework.xd.dirt.rest.JobsController: List job definitions.
list(Pageable, PagedResourcesAssembler<Counter>) - Method in class org.springframework.xd.dirt.rest.metrics.AggregateCountersController: List AggregateCounts that match the given criteria.
list(Pageable, PagedResourcesAssembler<Counter>) - Method in class org.springframework.xd.dirt.rest.metrics.CountersController: List Counters that match the given criteria.
list(Pageable, PagedResourcesAssembler<FieldValueCounter>) - Method in class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController: List FieldValueCounters that match the given criteria.
list(Pageable, PagedResourcesAssembler<Gauge>) - Method in class org.springframework.xd.dirt.rest.metrics.GaugesController
list(Pageable, PagedResourcesAssembler<RichGauge>) - Method in class org.springframework.xd.dirt.rest.metrics.RichGaugesController
list(Pageable, PagedResourcesAssembler<ModuleDefinition>, ModuleType) - Method in class org.springframework.xd.dirt.rest.ModulesController: List Module definitions.
list(Pageable, PagedResourcesAssembler<RuntimeContainerInfoEntity>) - Method in class org.springframework.xd.dirt.rest.RuntimeContainersController: List all the available containers
list(Pageable, PagedResourcesAssembler<RuntimeModuleInfoEntity>, String) - Method in class org.springframework.xd.dirt.rest.RuntimeModulesController: List all the available modules
list(Pageable, XDController.QueryOptions, PagedResourcesAssembler<StreamDefinition>) - Method in class org.springframework.xd.dirt.rest.StreamsController: List stream definitions.
list() - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations: List the names of the available aggregate counters
list() - Method in interface org.springframework.xd.rest.client.CounterOperations: Retrieve basic information (i.e.
list() - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations: Retrieve basic information (i.e.
list() - Method in interface org.springframework.xd.rest.client.GaugeOperations: List the names of the available gauges.
list() - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate
list() - Method in class org.springframework.xd.rest.client.impl.CounterTemplate
list() - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate
list() - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate
list() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
list(RESTModuleType) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
list() - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate
list() - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
list() - Method in interface org.springframework.xd.rest.client.JobOperations: List jobs known to the system.
list(RESTModuleType) - Method in interface org.springframework.xd.rest.client.ModuleOperations: List modules known to the system.
list() - Method in interface org.springframework.xd.rest.client.RichGaugeOperations: List the names of the available richgauges
list() - Method in interface org.springframework.xd.rest.client.StreamOperations: List streams known to the system.
list() - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
list() - Method in class org.springframework.xd.shell.command.CounterCommands
list() - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
list() - Method in class org.springframework.xd.shell.command.GaugeCommands
list() - Method in class org.springframework.xd.shell.command.RichGaugeCommands
listContainers() - Method in class org.springframework.xd.shell.command.RuntimeCommands
listDeployedModules(String) - Method in class org.springframework.xd.shell.command.RuntimeCommands
listJobExecutions(int, int) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
listJobExecutions() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
listJobExecutions() - Method in interface org.springframework.xd.rest.client.JobOperations: List all Job Executions.
listJobExecutions() - Method in class org.springframework.xd.shell.command.JobCommands
listJobs() - Method in class org.springframework.xd.shell.command.JobCommands
listModules(RESTModuleType) - Method in class org.springframework.xd.shell.command.ModuleCommands
listProps() - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
listRuntimeContainers() - Method in class org.springframework.xd.rest.client.impl.RuntimeTemplate
listRuntimeContainers() - Method in interface org.springframework.xd.rest.client.RuntimeOperations
listRuntimeModules() - Method in class org.springframework.xd.rest.client.impl.RuntimeTemplate
listRuntimeModules() - Method in interface org.springframework.xd.rest.client.RuntimeOperations
listRuntimeModulesByContainer(String) - Method in class org.springframework.xd.rest.client.impl.RuntimeTemplate
listRuntimeModulesByContainer(String) - Method in interface org.springframework.xd.rest.client.RuntimeOperations
listStepExecutions(long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
listStepExecutions(long) - Method in interface org.springframework.xd.rest.client.JobOperations: Retrieve a List of StepExecutionInfoResources for the provided jobExecutionId.
listStepExecutions(long) - Method in class org.springframework.xd.shell.command.JobCommands
listStreams() - Method in class org.springframework.xd.shell.command.StreamCommands
listValues(Pageable, XDController.QueryOptions, PagedResourcesAssembler<D>) - Method in class org.springframework.xd.dirt.rest.XDController: List module definitions.
loadClass(String, boolean) - Method in class org.springframework.xd.module.support.ParentLastURLClassLoader
loadConfiguration(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
LocaleAwareStringToNumberConverterFactory - Class in org.springframework.xd.tuple: Converts from a String any JDK-standard Number implementation.
LocaleAwareStringToNumberConverterFactory(NumberFormat) - Constructor for class org.springframework.xd.tuple.LocaleAwareStringToNumberConverterFactory
LocalMessageBus - Class in org.springframework.integration.x.bus: A simple implementation of MessageBus for in-process use.
LocalMessageBus() - Constructor for class org.springframework.integration.x.bus.LocalMessageBus
locateApplicationContext(String, ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry: Return a resource pointing to an ApplicationContext XML definition file.
locateApplicationContext(String, ModuleType) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
locateApplicationContext(String, ModuleType) - Method in class org.springframework.xd.dirt.module.ResourceModuleRegistry
locateApplicationContexts(ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry: Return a list of resources pointing to ApplicationContext XML definition files.
locateApplicationContexts(ModuleType) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
locateApplicationContexts(ModuleType) - Method in class org.springframework.xd.dirt.module.ResourceModuleRegistry
LOG - Variable in class org.springframework.xd.shell.hadoop.ConfigurationAware
logger - Variable in class org.springframework.integration.x.bus.MessageBusSupport
logger - Variable in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
logger - Variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
logger - Variable in class org.springframework.xd.dirt.plugins.job.JobFactoryBean
logger - Variable in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer
logger - Variable in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
logger - Variable in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
logger - Variable in class org.springframework.xd.module.core.AbstractPlugin
logger - Variable in class org.springframework.xd.test.AbstractExternalResourceTestSupport
LoggingCacheListener<K,V> - Class in org.springframework.xd.gemfire
LoggingCacheListener() - Constructor for class org.springframework.xd.gemfire.LoggingCacheListener
LoggingCacheListener(String) - Constructor for class org.springframework.xd.gemfire.LoggingCacheListener
logUpdateError(Exception) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
longOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
lookupChannelForLabelOrModule(String, String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
lookupChannelForLabelOrModule(String, String) - Method in interface org.springframework.xd.dirt.stream.dsl.StreamLookupEnvironment: Look up an existing label or module name.
lookupHandler(String, HttpServletRequest) - Method in class org.springframework.xd.dirt.post.DelegatingHandlerMapping
lookupStream(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
lookupStream(String) - Method in interface org.springframework.xd.dirt.stream.dsl.StreamLookupEnvironment: Look up a previously defined stream by name, returns the parsed AST for it.
ls(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

M

main(String[]) - Static method in class org.springframework.xd.dirt.server.AdminServerApplication
main(String[]) - Static method in class org.springframework.xd.dirt.server.LauncherApplication
main(String[]) - Static method in class org.springframework.xd.dirt.server.SingleNodeApplication
main(String[]) - Static method in class org.springframework.xd.gemfire.CacheServer
makeInstance(D) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer: Create an running instance out of the given definition;
makeInstance(JobDefinition) - Method in class org.springframework.xd.dirt.stream.JobDeployer
makeInstance(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.StreamDeployer
mapFieldSet(FieldSet) - Method in class org.springframework.xd.tuple.batch.TupleFieldSetMapper
MappingJackson2Converter - Class in org.springframework.integration.x.bus.converter
MappingJackson2Converter() - Constructor for class org.springframework.integration.x.bus.converter.MappingJackson2Converter
mapRow(ResultSet, int) - Method in class org.springframework.xd.tuple.batch.TupleRowMapper
MapToTupleTransformer - Class in org.springframework.xd.tuple.integration: Converts from a Map to the Tuple data structure.
MapToTupleTransformer() - Constructor for class org.springframework.xd.tuple.integration.MapToTupleTransformer
maskPassword(String) - Static method in class org.springframework.xd.shell.util.CommonUtils: Simple method to replace characters in a String with asterisks to mask the password.
maybeEatStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
maybeLocateClasspath(Resource, String, ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry: Return an array of jar files locations or null if the module is a plain xml file.
maybeLocateClasspath(Resource, String, ModuleType) - Method in class org.springframework.xd.dirt.module.ResourceModuleRegistry
MBeanExportingPlugin - Class in org.springframework.xd.dirt.plugins: Exports MBeans from a module using a unique domain name xd.[group].[module]
MBeanExportingPlugin() - Constructor for class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
MediaTypeConverter - Class in org.springframework.xd.shell.converter: Knows how to parse String representations of MediaType.
MediaTypeConverter() - Constructor for class org.springframework.xd.shell.converter.MediaTypeConverter
MessageBus - Interface in org.springframework.integration.x.bus: A strategy interface used to bind a MessageChannel to a logical name.
MessageBusAwareChannelResolver - Class in org.springframework.integration.x.bus: A org.springframework.integration.support.channel.ChannelResolver implementation that first checks for any channel whose name begins with a colon in the MessageBus.
MessageBusAwareChannelResolver() - Constructor for class org.springframework.integration.x.bus.MessageBusAwareChannelResolver
MessageBusAwareRouterBeanPostProcessor - Class in org.springframework.integration.x.bus: A BeanPostProcessor that sets a MessageBusAwareChannelResolver on any bean of type AbstractMappingMessageRouter within the context.
MessageBusAwareRouterBeanPostProcessor() - Constructor for class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor
MessageBusSupport - Class in org.springframework.integration.x.bus
MessageBusSupport() - Constructor for class org.springframework.integration.x.bus.MessageBusSupport
MessageCounterHandler - Class in org.springframework.xd.analytics.metrics.integration: Counts the number of non-null messages using an underlying CounterRepository.
MessageCounterHandler(CounterRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.MessageCounterHandler
MessageMediaTypeResolver - Interface in org.springframework.integration.x.bus
Metric - Interface in org.springframework.xd.analytics.metrics.core: Super interface for all metrics.
MetricRepository<M extends Metric> - Interface in org.springframework.xd.analytics.metrics.core: A repository to save, delete and find Metric instances.
MetricResource - Class in org.springframework.xd.rest.client.domain.metrics: Base class for resources that adhere to the Metric interface.
MetricResource(String) - Constructor for class org.springframework.xd.rest.client.domain.metrics.MetricResource: Construct a new resource.
MetricResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.MetricResource: No arg constructor for serialization frameworks.
MetricResource.Page - Class in org.springframework.xd.rest.client.domain.metrics: Dedicated subclass to workaround type erasure.
MetricResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.metrics.MetricResource.Page
MetricUtils - Class in org.springframework.xd.analytics.metrics.core: Utility class, primarily to avoid exposing mutable objects beyond the core package.
MetricUtils() - Constructor for class org.springframework.xd.analytics.metrics.core.MetricUtils
minus(DateTime, int) - Method in enum org.springframework.xd.analytics.metrics.core.AggregateCountResolution: Subtracts this resolution a given number of times from a supplied date.
mkdir(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
Module - Interface in org.springframework.xd.module.core
ModuleAlreadyExistsException - Exception in org.springframework.xd.dirt.module: Thrown when trying to create a new module with the given name and type, but one already exists.
ModuleAlreadyExistsException(String, ModuleType) - Constructor for exception org.springframework.xd.dirt.module.ModuleAlreadyExistsException
ModuleCommands - Class in org.springframework.xd.shell.command: Commands for working with modules.
ModuleCommands() - Constructor for class org.springframework.xd.shell.command.ModuleCommands
ModuleCommands.QualifiedModuleName - Class in org.springframework.xd.shell.command
ModuleCommands.QualifiedModuleName(String, RESTModuleType) - Constructor for class org.springframework.xd.shell.command.ModuleCommands.QualifiedModuleName
ModuleConfigurationException - Exception in org.springframework.xd.dirt.plugins: Thrown when something is wrong with options passed to a module.
ModuleConfigurationException(String) - Constructor for exception org.springframework.xd.dirt.plugins.ModuleConfigurationException
ModuleConfigurationException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.plugins.ModuleConfigurationException
ModuleDefinition - Class in org.springframework.xd.module: Defines a module.
ModuleDefinition(String, ModuleType) - Constructor for class org.springframework.xd.module.ModuleDefinition
ModuleDefinition(String, ModuleType, Resource) - Constructor for class org.springframework.xd.module.ModuleDefinition
ModuleDefinition(String, ModuleType, Resource, URL[]) - Constructor for class org.springframework.xd.module.ModuleDefinition
ModuleDefinitionMixin - Interface in org.springframework.xd.dirt.stream.redis: Mixin for Jackson that will ignore the Resource, Classpath, Composed and ModuleOptionMetadata properties of a ModuleDefinition.
ModuleDefinitionRepository - Interface in org.springframework.xd.dirt.module
ModuleDefinitionRepositoryUtils - Class in org.springframework.xd.dirt.module.support: Encapsulate shared functionality between implementations of ModuleDefinitionRepository that can't be done using inheritance
ModuleDefinitionRepositoryUtils() - Constructor for class org.springframework.xd.dirt.module.support.ModuleDefinitionRepositoryUtils
ModuleDefinitionResource - Class in org.springframework.xd.rest.client.domain: Represents a Module Definition.
ModuleDefinitionResource() - Constructor for class org.springframework.xd.rest.client.domain.ModuleDefinitionResource: Default constructor for serialization frameworks.
ModuleDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.ModuleDefinitionResource
ModuleDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain: Dedicated subclass to workaround type erasure.
ModuleDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.ModuleDefinitionResource.Page
ModuleDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model ModuleDefinition.
ModuleDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.ModuleDefinitionResourceAssembler
ModuleDependencyRepository - Interface in org.springframework.xd.dirt.module: Used to track usage of modules from streams and composed modules.
ModuleDeployedEvent - Class in org.springframework.xd.dirt.event
ModuleDeployedEvent(Module, String) - Constructor for class org.springframework.xd.dirt.event.ModuleDeployedEvent
ModuleDeployer - Class in org.springframework.xd.dirt.module: Listens for deployment request messages and instantiates Modules accordingly, applying Plugin logic to them.
ModuleDeployer(ModuleDefinitionRepository, ModuleOptionsMetadataResolver) - Constructor for class org.springframework.xd.dirt.module.ModuleDeployer
ModuleDeploymentRequest - Class in org.springframework.xd.dirt.module
ModuleDeploymentRequest() - Constructor for class org.springframework.xd.dirt.module.ModuleDeploymentRequest
ModuleEventStoreListener - Class in org.springframework.xd.dirt.listener: Module event listener that stores the module info.
ModuleEventStoreListener(RuntimeModuleInfoRepository, RuntimeContainerModuleInfoRepository) - Constructor for class org.springframework.xd.dirt.listener.ModuleEventStoreListener
moduleInfo(ModuleCommands.QualifiedModuleName) - Method in class org.springframework.xd.shell.command.ModuleCommands
ModuleJobLauncher - Class in org.springframework.xd.dirt.plugins.job: Executes all jobs defined within a given stream once the context has been started.
ModuleJobLauncher(JobLauncher, JobRegistry, boolean, JobParametersBean) - Constructor for class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
ModuleNode - Class in org.springframework.xd.dirt.stream.dsl
ModuleNode(List<LabelNode>, String, int, int, ArgumentNode[]) - Constructor for class org.springframework.xd.dirt.stream.dsl.ModuleNode
ModuleNotDeployedException - Exception in org.springframework.xd.dirt.module: Thrown when a module is not deployed but the deployment request expects the module is deployed.
ModuleNotDeployedException(String) - Constructor for exception org.springframework.xd.dirt.module.ModuleNotDeployedException
moduleOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
ModuleOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available against Module.
moduleOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with Modules' definitions.
ModuleOption - Class in org.springframework.xd.module.options: Provides information about an option that a user can set to customize the behavior of a module.
ModuleOption(String, String) - Constructor for class org.springframework.xd.module.options.ModuleOption
ModuleOption - Annotation Type in org.springframework.xd.module.options.spi: Used to annotate the setter methods of a POJO Module Options class to provide the framework with additional option information.
ModuleOptions - Class in org.springframework.xd.module.options: Represents runtime information about a module once user provided values are known.
ModuleOptions() - Constructor for class org.springframework.xd.module.options.ModuleOptions
ModuleOptionsMetadata - Interface in org.springframework.xd.module.options: Encapsulates metadata about the accepted options for a module.
ModuleOptionsMetadataResolver - Interface in org.springframework.xd.module.options: Implementations are able to derive ModuleOptionsMetadata for a given module.
ModuleReferenceNode - Class in org.springframework.xd.dirt.stream.dsl
ModuleReferenceNode(String, String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
ModuleRegistry - Interface in org.springframework.xd.dirt.module
ModulesController - Class in org.springframework.xd.dirt.rest: Handles all Module related interactions.
ModulesController(CompositeModuleDefinitionService, DetailedModuleDefinitionResourceAssembler) - Constructor for class org.springframework.xd.dirt.rest.ModulesController
ModuleTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the Module-related part of the API.
ModuleType - Enum in org.springframework.xd.module: Represents the kind of modules that make up a stream.
ModuleTypeConversionPlugin - Class in org.springframework.xd.dirt.plugins.stream: A Plugin for processing module message conversion parameters (inputType and outputType)
ModuleTypeConversionPlugin() - Constructor for class org.springframework.xd.dirt.plugins.stream.ModuleTypeConversionPlugin
ModuleUndeployedEvent - Class in org.springframework.xd.dirt.event
ModuleUndeployedEvent(Module, String) - Constructor for class org.springframework.xd.dirt.event.ModuleUndeployedEvent
MongoItemWriter - Class in org.springframework.xd.mongodb
MongoItemWriter(MongoOperations) - Constructor for class org.springframework.xd.mongodb.MongoItemWriter
moveFromLocal(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
MqttSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the mqtt source module.
MqttSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
MultiTypeCodec<T> - Interface in org.springframework.integration.x.bus.serializer: Interface for classes that perform both serialization and deserialization.
mv(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

N

name - Variable in class org.springframework.xd.shell.command.ModuleCommands.QualifiedModuleName
NamedColumnJdbcBatchItemWriter<T> - Class in org.springframework.xd.jdbc: JdbcBatchItemWriter which is customized for use with the XD JDBC import job.
NamedColumnJdbcBatchItemWriter() - Constructor for class org.springframework.xd.jdbc.NamedColumnJdbcBatchItemWriter
NamedColumnJdbcItemReader - Class in org.springframework.xd.jdbc: Reader which reads a row from a database as a delimited string from a predefined list of column names.
NamedColumnJdbcItemReader() - Constructor for class org.springframework.xd.jdbc.NamedColumnJdbcItemReader
NamedResource - Class in org.springframework.xd.rest.client.domain: Abstract base class for all resources that have a name.
NamedResource() - Constructor for class org.springframework.xd.rest.client.domain.NamedResource: No arg constructor for serialization frameworks.
NamedResource(String) - Constructor for class org.springframework.xd.rest.client.domain.NamedResource
NamingStrategyParser - Class in org.springframework.xd.integration.hadoop.config: Parser for the 'naming-policy' element.
NamingStrategyParser() - Constructor for class org.springframework.xd.integration.hadoop.config.NamingStrategyParser
NettyHttpInboundChannelAdapter - Class in org.springframework.integration.x.http
NettyHttpInboundChannelAdapter(int) - Constructor for class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
newRow() - Method in class org.springframework.xd.shell.util.Table: Add a new empty row to the table.
newTuple(List<String>, List<Object>) - Method in class org.springframework.xd.tuple.TupleBuilder
nextExecutionTime(TriggerContext) - Method in class org.springframework.xd.module.support.DateTrigger
NO_DEFAULT - Static variable in annotation type org.springframework.xd.module.options.spi.ModuleOption
NO_PROFILES - Static variable in interface org.springframework.xd.module.options.spi.ProfileNamesProvider
NODE_PROFILE - Static variable in class org.springframework.xd.dirt.server.LauncherApplication
NONE - Static variable in class org.springframework.xd.dirt.rest.XDController.QueryOptions
NoSuchBatchJobException - Exception in org.springframework.xd.dirt.job
NoSuchBatchJobException(String) - Constructor for exception org.springframework.xd.dirt.job.NoSuchBatchJobException
NoSuchDefinitionException - Exception in org.springframework.xd.dirt.stream: Exception which is raised when a named resource definition cannot be found.
NoSuchDefinitionException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.NoSuchDefinitionException: Create a new exception.
NoSuchJobExecutionException - Exception in org.springframework.xd.dirt.job: Thrown when attempting to refer to JobExecution that does not exist.
NoSuchJobExecutionException(long) - Constructor for exception org.springframework.xd.dirt.job.NoSuchJobExecutionException: Create a new exception.
NoSuchMetricException - Exception in org.springframework.xd.dirt.analytics: Thrown when trying to access a named metric that does not exist.
NoSuchMetricException(String, String) - Constructor for exception org.springframework.xd.dirt.analytics.NoSuchMetricException: Construct a new exception.
NoSuchModuleException - Exception in org.springframework.xd.dirt.module: Thrown when attempting to refer to a module that does not exist.
NoSuchModuleException(String) - Constructor for exception org.springframework.xd.dirt.module.NoSuchModuleException: Create a new exception.
NoSuchModuleException(String, ModuleType) - Constructor for exception org.springframework.xd.dirt.module.NoSuchModuleException: Create a new exception.
NoSuchStepExecutionException - Exception in org.springframework.xd.dirt.job: Thrown when attempting to refer to StepExecution that does not exist.
NoSuchStepExecutionException(long) - Constructor for exception org.springframework.xd.dirt.job.NoSuchStepExecutionException: Create a new exception.
NotDeployedException - Exception in org.springframework.xd.dirt.stream: Thrown when a definition was assumed to be deployed when it actually was not.
NotDeployedException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.NotDeployedException: Create a new exception.
NumberFormatConverter - Class in org.springframework.xd.shell.converter: Knows how to convert from a String to a new NumberFormat instance.
NumberFormatConverter() - Constructor for class org.springframework.xd.shell.converter.NumberFormatConverter

O

OAuth2AuthenticatingTwitterTemplate - Class in org.springframework.integration.x.twitter: An extension of TwitterTemplate which can be configured with a consumerKey and consumerSecret and will use those as the clientId and secret to obtain an OAuth2 bearer token.
OAuth2AuthenticatingTwitterTemplate(String, String) - Constructor for class org.springframework.integration.x.twitter.OAuth2AuthenticatingTwitterTemplate
obtainResource() - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport: Try to obtain and validate a resource.
obtainResource() - Method in class org.springframework.xd.test.rabbit.RabbitTestSupport
obtainResource() - Method in class org.springframework.xd.test.redis.RedisTestSupport
of(String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder
of(String, Object, String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder
of(String, Object, String, Object, String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder
of(String, Object, String, Object, String, Object, String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder
ofNamesAndValues(List<String>, List<Object>) - Method in class org.springframework.xd.tuple.TupleBuilder
onAlreadyDeployedException(AlreadyDeployedException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the case where client tried to deploy something that is already deployed.
onApplicationEvent(AbstractContainerEvent) - Method in class org.springframework.xd.dirt.listener.AbstractContainerEventStoreListener
onApplicationEvent(AbstractModuleEvent) - Method in class org.springframework.xd.dirt.listener.ModuleEventStoreListener
onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.xd.dirt.util.XdConfigLoggingInitializer
onApplicationEvent(ConfigurationModifiedEvent) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
onDefinitionAlreadyExistsException(DefinitionAlreadyExistsException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the case where client referenced an entity that already exists.
onException(Exception) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the general error case.
onInit() - Method in class org.springframework.xd.dirt.module.ModuleDeployer
onInit() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
onInit() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
onInvalidDefintion(StreamDefinitionException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the case where client tried to deploy something that is has an invalid definition.
onJobExecutionNotRunningException(JobExecutionNotRunningException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice
onMissingServletRequestParameterException(MissingServletRequestParameterException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the case where client submitted an ill valued request (missing parameter).
onModuleAlreadyExistsException(ModuleAlreadyExistsException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice
onNoSuchDefinitionException(NoSuchDefinitionException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the case where client referenced an unknown entity.
onNoSuchJobExecutionException(NoSuchJobExecutionException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice
onNoSuchMetricException(NoSuchMetricException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice
onNoSuchModuleException(NoSuchModuleException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice
onNoSuchStepExecutionException(NoSuchStepExecutionException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice
onNotDeployedException(NotDeployedException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice: Handles the case where client tried to un-deploy something that is not currently deployed.
onProcessError(Object, Exception) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
onReadError(Exception) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
onSkipInProcess(Object, Throwable) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdSkipListener
onSkipInRead(Throwable) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdSkipListener
onSkipInWrite(Object, Throwable) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdSkipListener
onWriteError(Exception, List<? extends Object>) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
org.springframework.data.hadoop.x.store.dataset - package org.springframework.data.hadoop.x.store.dataset
org.springframework.integration.x.bus - package org.springframework.integration.x.bus
org.springframework.integration.x.bus.converter - package org.springframework.integration.x.bus.converter
org.springframework.integration.x.bus.serializer - package org.springframework.integration.x.bus.serializer
org.springframework.integration.x.bus.serializer.kryo - package org.springframework.integration.x.bus.serializer.kryo
org.springframework.integration.x.gemfire - package org.springframework.integration.x.gemfire
org.springframework.integration.x.http - package org.springframework.integration.x.http
org.springframework.integration.x.json - package org.springframework.integration.x.json
org.springframework.integration.x.rabbit - package org.springframework.integration.x.rabbit
org.springframework.integration.x.redis - package org.springframework.integration.x.redis
org.springframework.integration.x.splunk - package org.springframework.integration.x.splunk
org.springframework.integration.x.twitter - package org.springframework.integration.x.twitter
org.springframework.xd.analytics.metrics.core - package org.springframework.xd.analytics.metrics.core
org.springframework.xd.analytics.metrics.integration - package org.springframework.xd.analytics.metrics.integration
org.springframework.xd.analytics.metrics.memory - package org.springframework.xd.analytics.metrics.memory
org.springframework.xd.analytics.metrics.redis - package org.springframework.xd.analytics.metrics.redis
org.springframework.xd.batch.item.hadoop - package org.springframework.xd.batch.item.hadoop
org.springframework.xd.batch.item.jdbc - package org.springframework.xd.batch.item.jdbc
org.springframework.xd.dirt.analytics - package org.springframework.xd.dirt.analytics
org.springframework.xd.dirt.container - package org.springframework.xd.dirt.container
org.springframework.xd.dirt.container.store - package org.springframework.xd.dirt.container.store: Package for container info store.
org.springframework.xd.dirt.core - package org.springframework.xd.dirt.core
org.springframework.xd.dirt.event - package org.springframework.xd.dirt.event
org.springframework.xd.dirt.jdbc.util - package org.springframework.xd.dirt.jdbc.util
org.springframework.xd.dirt.job - package org.springframework.xd.dirt.job: Provides classes for the Spring Batch Admin Support
org.springframework.xd.dirt.listener - package org.springframework.xd.dirt.listener
org.springframework.xd.dirt.module - package org.springframework.xd.dirt.module
org.springframework.xd.dirt.module.memory - package org.springframework.xd.dirt.module.memory
org.springframework.xd.dirt.module.redis - package org.springframework.xd.dirt.module.redis
org.springframework.xd.dirt.module.store - package org.springframework.xd.dirt.module.store: Package for DIRT module store.
org.springframework.xd.dirt.module.support - package org.springframework.xd.dirt.module.support
org.springframework.xd.dirt.modules.metadata - package org.springframework.xd.dirt.modules.metadata
org.springframework.xd.dirt.plugins - package org.springframework.xd.dirt.plugins: Base Package for Spring XD plugins
org.springframework.xd.dirt.plugins.job - package org.springframework.xd.dirt.plugins.job: Provides classes for the Spring Batch Support
org.springframework.xd.dirt.plugins.job.support - package org.springframework.xd.dirt.plugins.job.support: Contains classes for improved Spring Batch support.
org.springframework.xd.dirt.plugins.job.support.listener - package org.springframework.xd.dirt.plugins.job.support.listener
org.springframework.xd.dirt.plugins.stream - package org.springframework.xd.dirt.plugins.stream
org.springframework.xd.dirt.post - package org.springframework.xd.dirt.post
org.springframework.xd.dirt.rest - package org.springframework.xd.dirt.rest: Provides a REST-style API for interacting with the XD runtime.
org.springframework.xd.dirt.rest.metrics - package org.springframework.xd.dirt.rest.metrics
org.springframework.xd.dirt.server - package org.springframework.xd.dirt.server
org.springframework.xd.dirt.server.options - package org.springframework.xd.dirt.server.options
org.springframework.xd.dirt.stream - package org.springframework.xd.dirt.stream
org.springframework.xd.dirt.stream.dsl - package org.springframework.xd.dirt.stream.dsl
org.springframework.xd.dirt.stream.memory - package org.springframework.xd.dirt.stream.memory
org.springframework.xd.dirt.stream.redis - package org.springframework.xd.dirt.stream.redis
org.springframework.xd.dirt.util - package org.springframework.xd.dirt.util
org.springframework.xd.gemfire - package org.springframework.xd.gemfire
org.springframework.xd.hadoop.fs - package org.springframework.xd.hadoop.fs
org.springframework.xd.integration.hadoop - package org.springframework.xd.integration.hadoop
org.springframework.xd.integration.hadoop.config - package org.springframework.xd.integration.hadoop.config
org.springframework.xd.integration.hadoop.outbound - package org.springframework.xd.integration.hadoop.outbound
org.springframework.xd.integration.reactor.channel - package org.springframework.xd.integration.reactor.channel
org.springframework.xd.integration.reactor.config - package org.springframework.xd.integration.reactor.config
org.springframework.xd.integration.reactor.dispatcher - package org.springframework.xd.integration.reactor.dispatcher
org.springframework.xd.integration.reactor.syslog - package org.springframework.xd.integration.reactor.syslog
org.springframework.xd.jdbc - package org.springframework.xd.jdbc
org.springframework.xd.module - package org.springframework.xd.module: Root package of the Module support.
org.springframework.xd.module.core - package org.springframework.xd.module.core: Contains the Module core classes.
org.springframework.xd.module.options - package org.springframework.xd.module.options: Contains the ModuleOption related classes.
org.springframework.xd.module.options.spi - package org.springframework.xd.module.options.spi
org.springframework.xd.module.support - package org.springframework.xd.module.support: Contains support classes for the Module support
org.springframework.xd.mongodb - package org.springframework.xd.mongodb
org.springframework.xd.rest.client - package org.springframework.xd.rest.client: Defines the various REST client operation interfaces.
org.springframework.xd.rest.client.domain - package org.springframework.xd.rest.client.domain: Contains the resources managed by the REST API.
org.springframework.xd.rest.client.domain.metrics - package org.springframework.xd.rest.client.domain.metrics
org.springframework.xd.rest.client.impl - package org.springframework.xd.rest.client.impl: Contains REST client operation implementations.
org.springframework.xd.rest.client.impl.support - package org.springframework.xd.rest.client.impl.support: Contains support classes for the Rest client, e.g.
org.springframework.xd.rest.client.util - package org.springframework.xd.rest.client.util
org.springframework.xd.shell - package org.springframework.xd.shell: Contains core Spring XD Shell classes.
org.springframework.xd.shell.command - package org.springframework.xd.shell.command: Defines the various Spring XD Shell commands.
org.springframework.xd.shell.converter - package org.springframework.xd.shell.converter
org.springframework.xd.shell.hadoop - package org.springframework.xd.shell.hadoop
org.springframework.xd.shell.util - package org.springframework.xd.shell.util: Contains utilities for rendering textual contents (E.g.
org.springframework.xd.store - package org.springframework.xd.store
org.springframework.xd.test - package org.springframework.xd.test
org.springframework.xd.test.rabbit - package org.springframework.xd.test.rabbit
org.springframework.xd.test.redis - package org.springframework.xd.test.redis
org.springframework.xd.tuple - package org.springframework.xd.tuple
org.springframework.xd.tuple.batch - package org.springframework.xd.tuple.batch
org.springframework.xd.tuple.integration - package org.springframework.xd.tuple.integration
org.springframework.xd.tuple.processor - package org.springframework.xd.tuple.processor
org.springframework.xd.tuple.spel - package org.springframework.xd.tuple.spel
ORIGINAL_CONTENT_TYPE_HEADER - Static variable in class org.springframework.integration.x.bus.MessageBusSupport

P

padRight(String, int, char) - Static method in class org.springframework.xd.shell.util.CommonUtils: Right-pad a String with a configurable padding character.
padRight(String, int) - Static method in class org.springframework.xd.shell.util.CommonUtils: Right-pad the provided String with empty spaces.
ParentConfiguration - Class in org.springframework.xd.dirt.server
ParentConfiguration() - Constructor for class org.springframework.xd.dirt.server.ParentConfiguration
ParentConfiguration.CloudFoundryConfiguration - Class in org.springframework.xd.dirt.server
ParentConfiguration.CloudFoundryConfiguration() - Constructor for class org.springframework.xd.dirt.server.ParentConfiguration.CloudFoundryConfiguration
ParentConfiguration.JmxConfiguration - Class in org.springframework.xd.dirt.server
ParentConfiguration.JmxConfiguration() - Constructor for class org.springframework.xd.dirt.server.ParentConfiguration.JmxConfiguration
ParentLastURLClassLoader - Class in org.springframework.xd.module.support: Extension for URLClassLoader that uses a parent-last (or child first) delegation.
ParentLastURLClassLoader(URL[], ClassLoader) - Constructor for class org.springframework.xd.module.support.ParentLastURLClassLoader
parse(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
parse(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser: Parse a stream definition without supplying the stream name up front.
parse(String, String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser: Parse a stream definition.
parse(String, String) - Method in interface org.springframework.xd.dirt.stream.XDParser
parse(String, String) - Method in class org.springframework.xd.dirt.stream.XDStreamParser
parseConsumer(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.AvroOutboundChannelAdapterParser
parseConsumer(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.HdfsOutboundChannelAdapterParser
parseInternal(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.NamingStrategyParser
parseInternal(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.RolloverStrategyParser
parseInternal(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterParser
password - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
Plugin - Interface in org.springframework.xd.module.core: To be implemented by classes that want to alter how a Module works.
PluginAdapter - Class in org.springframework.xd.module.core
PluginAdapter() - Constructor for class org.springframework.xd.module.core.PluginAdapter
PojoCodec - Class in org.springframework.integration.x.bus.serializer.kryo: Kryo Serializer that can handle arbitrary types
PojoCodec() - Constructor for class org.springframework.integration.x.bus.serializer.kryo.PojoCodec
PojoModuleOptionsMetadata - Class in org.springframework.xd.module.options: An implementation of ModuleOptionsMetadata that derives its information from a plain old java object: public setters are reported as valid options the type of the option is derived from the accepted type by the setter ModuleOptions for such a POJO will work as follows: an instance of the class will be created reflectively and injected with user provided values, reported properties are computed from all the getters, the POJO may bear JSR303 validation annotations, which will be used to validate the interpolated options, if the POJO implements ProfileNamesProvider, profile names will be gathered from a reflective call to ProfileNamesProvider.profilesToActivate()
PojoModuleOptionsMetadata(Class<?>) - Constructor for class org.springframework.xd.module.options.PojoModuleOptionsMetadata
PojoModuleOptionsMetadata(Class<?>, ResourceLoader, Environment) - Constructor for class org.springframework.xd.module.options.PojoModuleOptionsMetadata
portAvailable(int) - Static method in class org.springframework.xd.gemfire.CacheServer
position - Variable in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
postHttp(String, String, File, MediaType) - Method in class org.springframework.xd.shell.command.HttpCommands
postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor
postProcessAfterInitialization(Object, String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
postProcessBeanDefinitionRegistry(BeanDefinitionRegistry) - Method in class org.springframework.xd.module.support.BeanDefinitionAddingPostProcessor
postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.xd.module.support.BeanDefinitionAddingPostProcessor
postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor
postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.ModuleTypeConversionPlugin
postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
postProcessModule(Module) - Method in interface org.springframework.xd.module.core.Plugin: Apply changes to the module after it is initialized i.e. after its context is refreshed, but before it is started.
postProcessModule(Module) - Method in class org.springframework.xd.module.core.PluginAdapter
postProcessModuleInternal(Module) - Method in class org.springframework.xd.module.core.AbstractPlugin: Perform any plugin-specific post-refresh initialization.
preHandle(HttpServletRequest, HttpServletResponse, Object) - Method in class org.springframework.xd.dirt.rest.AccessControlInterceptor
preProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
preProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
preProcessModule(Module) - Method in class org.springframework.xd.module.core.AbstractPlugin: Process the Module and add the Application Context resources necessary to setup the Batch Job.
preProcessModule(Module) - Method in interface org.springframework.xd.module.core.Plugin: Apply changes to the module before it is initialized i.e. before its context is refreshed.
preProcessModule(Module) - Method in class org.springframework.xd.module.core.PluginAdapter
preProcessModuleInternal(Module) - Method in class org.springframework.xd.module.core.AbstractPlugin: Perform any plugin-specific pre-refresh initialization.
preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.module.core.AbstractPlugin
preProcessSharedContext(ConfigurableApplicationContext) - Method in interface org.springframework.xd.module.core.Plugin: Invoked when this plugin is discovered, allows to make any necessary changes to the context which will be used as the parent of all modules.
preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.module.core.PluginAdapter
preSend(Message<?>, MessageChannel) - Method in class org.springframework.integration.x.bus.converter.ContentTypeHeaderInterceptor
process(Message<?>, String) - Method in class org.springframework.xd.analytics.metrics.integration.AggregateCounterHandler
process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler
process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.GaugeHandler
process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.MessageCounterHandler
process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.RichGaugeHandler
process(Tuple) - Method in interface org.springframework.xd.tuple.processor.TupleProcessor
ProcessortModuleOptionsMetadataSupport - Class in org.springframework.xd.module.options.spi: Provides info about the inputType and outputType options.
ProcessortModuleOptionsMetadataSupport() - Constructor for class org.springframework.xd.module.options.spi.ProcessortModuleOptionsMetadataSupport
processValue(String, Object) - Method in class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler
ProfileNamesProvider - Interface in org.springframework.xd.module.options.spi: To be implemented by classes that instruct the framework to activate some named profiles.
profilesToActivate() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
profilesToActivate() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
profilesToActivate() - Method in class org.springframework.xd.module.options.ModuleOptions
profilesToActivate() - Method in interface org.springframework.xd.module.options.spi.ProfileNamesProvider
progress(long, long) - Method in class org.springframework.xd.dirt.rest.BatchStepExecutionsController: Get the step execution progress for the given jobExecutions step.
prompt(String, String, String...) - Method in class org.springframework.xd.shell.command.ConsoleUserInput: Loops until one of the options is provided.
prompt(String, String, String...) - Method in interface org.springframework.xd.shell.command.UserInput: Display a prompt text to the user and expect one of options in return.
publishContainerStarted(ConfigurableApplicationContext) - Static method in class org.springframework.xd.dirt.server.LauncherApplication
put(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
put(String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder

Q

QualifiedModuleNameConverter - Class in org.springframework.xd.shell.converter: Knows how to build and query ModuleCommands.QualifiedModuleNames.
QualifiedModuleNameConverter() - Constructor for class org.springframework.xd.shell.converter.QualifiedModuleNameConverter

R

rabbitConnectionFactory() - Method in class org.springframework.xd.dirt.server.ParentConfiguration.CloudFoundryConfiguration
RabbitMessageBus - Class in org.springframework.integration.x.rabbit: A MessageBus implementation backed by RabbitMQ.
RabbitMessageBus(ConnectionFactory, MultiTypeCodec<Object>) - Constructor for class org.springframework.integration.x.rabbit.RabbitMessageBus
RabbitSinkOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Captures options to the rabbit sink module.
RabbitSinkOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
RabbitSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the rabbit source module.
RabbitSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
RabbitTestSupport - Class in org.springframework.xd.test.rabbit: JUnit Rule that detects the fact that RabbitMQ is available on localhost.
RabbitTestSupport() - Constructor for class org.springframework.xd.test.rabbit.RabbitTestSupport
RangeCapableRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Interface in org.springframework.xd.store: To be implemented by repositories that know how to return a slice of their data.
REACTOR_ENV_BEAN - Static variable in class org.springframework.xd.integration.reactor.config.ReactorNamespaceUtils
ReactorNamespaceHandler - Class in org.springframework.xd.integration.reactor.config
ReactorNamespaceHandler() - Constructor for class org.springframework.xd.integration.reactor.config.ReactorNamespaceHandler
ReactorNamespaceUtils - Class in org.springframework.xd.integration.reactor.config: Namespace parser helper for creating BeanDefinitionBuilder instances that have a reference to a Reactor Environment as their first constructor parameter.
ReactorNamespaceUtils() - Constructor for class org.springframework.xd.integration.reactor.config.ReactorNamespaceUtils
ReactorProcessorMessageDispatcher - Class in org.springframework.xd.integration.reactor.dispatcher
ReactorProcessorMessageDispatcher() - Constructor for class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher
ReactorProcessorMessageDispatcher(boolean) - Constructor for class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher
ReactorPublishSubscribeChannel - Class in org.springframework.xd.integration.reactor.channel
ReactorPublishSubscribeChannel(MessageDispatcher) - Constructor for class org.springframework.xd.integration.reactor.channel.ReactorPublishSubscribeChannel
ReactorPublishSubscribeChannelParser - Class in org.springframework.xd.integration.reactor.config
ReactorPublishSubscribeChannelParser() - Constructor for class org.springframework.xd.integration.reactor.config.ReactorPublishSubscribeChannelParser
read(Kryo, Input, Class<MessageHeaders>) - Method in class org.springframework.integration.x.redis.KryoMessageHeadersSerializer
read(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
RedisAggregateCounterRepository - Class in org.springframework.xd.analytics.metrics.redis: Redis implementation of AggregateCounterRepository.
RedisAggregateCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
RedisCounterRepository - Class in org.springframework.xd.analytics.metrics.redis
RedisCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
RedisCounterRepository(String, RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
RedisFieldValueCounterRepository - Class in org.springframework.xd.analytics.metrics.redis
RedisFieldValueCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
RedisFieldValueCounterRepository(RedisConnectionFactory, String) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
RedisGaugeRepository - Class in org.springframework.xd.analytics.metrics.redis: Redis backed implementation that uses Redis keys to store and update the value.
RedisGaugeRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository
RedisGaugeRepository(RedisConnectionFactory, String) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository
redisHashKeyFromEntity(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
RedisJobDefinitionRepository - Class in org.springframework.xd.dirt.stream.redis: An implementation of JobDefinitionRepository that persists @{link JobDefinition} in Redis.
RedisJobDefinitionRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisJobDefinitionRepository
RedisJobRepository - Class in org.springframework.xd.dirt.stream.redis: Redis implementation of JobRepository, uses a RedisJobDefinitionRepository in turn.
RedisJobRepository(RedisOperations<String, String>, RedisJobDefinitionRepository) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisJobRepository
redisKeyFromId(String) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
redisKeyFromId(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
RedisMessageBus - Class in org.springframework.integration.x.redis: A MessageBus implementation backed by Redis.
RedisMessageBus(RedisConnectionFactory, MultiTypeCodec<Object>) - Constructor for class org.springframework.integration.x.redis.RedisMessageBus
RedisModuleDefinitionRepository - Class in org.springframework.xd.dirt.module.redis: An Redis-based store of ModuleDefinitions.
RedisModuleDefinitionRepository(String, RedisOperations<String, String>, ModuleRegistry, ModuleDependencyRepository) - Constructor for class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
RedisModuleDependencyRepository - Class in org.springframework.xd.dirt.module.redis: Redis implementation of ModuleDependencyRepository.
RedisModuleDependencyRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.module.redis.RedisModuleDependencyRepository
RedisModuleRegistry - Class in org.springframework.xd.dirt.module: A ModuleRegistry that stores module definitions in various redis hashes.
RedisModuleRegistry(RedisConnectionFactory) - Constructor for class org.springframework.xd.dirt.module.RedisModuleRegistry
redisOperations - Variable in class org.springframework.xd.store.AbstractRedisRepository
RedisRichGaugeRepository - Class in org.springframework.xd.analytics.metrics.redis
RedisRichGaugeRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
RedisRuntimeContainerInfoRepository - Class in org.springframework.xd.dirt.container.store: Redis specific implementation for the runtime container info repository.
RedisRuntimeContainerInfoRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.container.store.RedisRuntimeContainerInfoRepository
RedisRuntimeContainerModuleInfoRepository - Class in org.springframework.xd.dirt.module.store: Redis specific implementation for runtime modules repository where modules mapped to their containers.
RedisRuntimeContainerModuleInfoRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.module.store.RedisRuntimeContainerModuleInfoRepository
RedisRuntimeModuleInfoRepository - Class in org.springframework.xd.dirt.module.store: Redis specific implementation for runtime modules info repository.
RedisRuntimeModuleInfoRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.module.store.RedisRuntimeModuleInfoRepository
RedisStreamDefinitionRepository - Class in org.springframework.xd.dirt.stream.redis: An implementation of StreamDefinitionRepository that persists StreamDefinition in Redis.
RedisStreamDefinitionRepository(RedisOperations<String, String>, ModuleDependencyRepository) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository
RedisStreamRepository - Class in org.springframework.xd.dirt.stream.redis: Redis implementation of StreamRepository, uses a RedisStreamDefinitionRepository in turn.
RedisStreamRepository(RedisOperations<String, String>, RedisStreamDefinitionRepository) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisStreamRepository
RedisTestSupport - Class in org.springframework.xd.test.redis: JUnit Rule that detects the fact that a Redis server is running on localhost.
RedisTestSupport() - Constructor for class org.springframework.xd.test.redis.RedisTestSupport
register(Object, String) - Method in class org.springframework.xd.dirt.post.DelegatingHandlerMapping
removeAttribute(String) - Method in class org.springframework.xd.module.DeploymentMetadata
removeContainerEntity(String) - Method in class org.springframework.xd.dirt.listener.AbstractContainerEventStoreListener
removeContainerEntity(String) - Method in class org.springframework.xd.dirt.listener.ContainerEventStoreListener
removeDeployment(String) - Method in class org.springframework.xd.dirt.stream.DeploymentMessageSender
removeHandler(MessageHandler) - Method in class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher
removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
removeModule(Module) - Method in interface org.springframework.xd.module.core.Plugin: Take any actions necessary to remove a module from the system.
removeModule(Module) - Method in class org.springframework.xd.module.core.PluginAdapter
renderMapDataAsTable(List<Map<String, Object>>, List<String>) - Static method in class org.springframework.xd.shell.util.UiUtils: Renders a textual representation of the list of provided Map data
renderParameterInfoDataAsTable(Map<String, String>, boolean, int) - Static method in class org.springframework.xd.shell.util.UiUtils
renderParameterInfoDataAsTable(Map<String, String>) - Static method in class org.springframework.xd.shell.util.UiUtils: Renders a textual representation of provided parameter map.
renderTextTable(Table) - Static method in class org.springframework.xd.shell.util.UiUtils
renderTextTable(Table, boolean) - Static method in class org.springframework.xd.shell.util.UiUtils: Renders a textual representation of the provided Table
repoPrefix - Variable in class org.springframework.xd.store.AbstractRedisRepository
reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository: Reset the given counter to zero.
reset(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository: Reset the FieldValueCounter to zero for the given field name, creating missing counters.
reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.GaugeRepository: Reset the gauge to zero
reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeRepository: Reset the gauge to zero and reset any accumulated average, max and min values
reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
reset(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
reset(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
reset() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
resetBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
resetBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
resetBytesWritten() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
resetRichGauge(RichGauge) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
resolve(ModuleDefinition) - Method in class org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver
resolve(ModuleDefinition) - Method in interface org.springframework.xd.module.options.ModuleOptionsMetadataResolver: Return metadata about a module, as identified by the given moduleDefinition.
resolveDestination(String) - Method in class org.springframework.integration.x.bus.MessageBusAwareChannelResolver
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.NamingStrategyParser
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.RolloverStrategyParser
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterParser
resolveMediaType(Message<?>) - Method in class org.springframework.integration.x.bus.DefaultMessageMediaTypeResolver
resolveMediaType(Message<?>) - Method in interface org.springframework.integration.x.bus.MessageMediaTypeResolver
resolveModuleNodes(StreamLookupEnvironment, List<ModuleNode>) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode: Does the lookup of module nodes to see if any previously defined and if so replaces them in this stream.
resource - Variable in class org.springframework.xd.test.AbstractExternalResourceTestSupport
ResourceDefinitionException - Exception in org.springframework.xd.dirt.module: Thrown when a problem is detected with the (DSL) definition of an XD resource.
ResourceDefinitionException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.module.ResourceDefinitionException
ResourceDefinitionException(String) - Constructor for exception org.springframework.xd.dirt.module.ResourceDefinitionException
ResourceDeployer<R extends BaseDefinition> - Interface in org.springframework.xd.dirt.core: Interface for XD Resource Services.
ResourceModuleRegistry - Class in org.springframework.xd.dirt.module: Resource based implementation of ModuleRegistry that supports two kinds of modules: the "simple" case is a sole xml file, located in a "directory" named after the module type, e.g. source/time.xml the "enhanced" case is made up of a directory, where the application context file lives in a config sub-directory e.g. source/time/config/time.xml and extra classpath is loaded from jars in a lib subdirectory e.g. source/time/lib/*.jar
ResourceModuleRegistry(String) - Constructor for class org.springframework.xd.dirt.module.ResourceModuleRegistry
ResourceOperations - Interface in org.springframework.xd.rest.client: Operations common to resources like Stream and Job.
restart(Long) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
RestConfiguration - Class in org.springframework.xd.dirt.rest: Takes care of infrastructure setup for the web/rest layer.
RestConfiguration() - Constructor for class org.springframework.xd.dirt.rest.RestConfiguration
RestControllerAdvice - Class in org.springframework.xd.dirt.rest: Central class for behavior common to all REST controllers.
RestControllerAdvice() - Constructor for class org.springframework.xd.dirt.rest.RestControllerAdvice
RESTModuleType - Enum in org.springframework.xd.rest.client.domain: Sibling of org.springframework.xd.module.ModuleType, but we don't want to drag that into client dependencies.
RestTemplateMessageConverterUtil - Class in org.springframework.xd.rest.client.util: Utility class that does two things: Resets a RestTemplate's message converters list to have json support come before xml. Force injects JAXBContexts that know about our particular classes
retrieve(String, Date, Date, AggregateCounterOperations.Resolution) - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations: Retrieve the information for the given named AggregateCounter
retrieve(String) - Method in interface org.springframework.xd.rest.client.CounterOperations: Retrieve information about the given named counter.
retrieve(String) - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations: Retrieve information about the given named field value counter.
retrieve(String) - Method in interface org.springframework.xd.rest.client.GaugeOperations: Retrieve information about the given named gauge.
retrieve(String, Date, Date, AggregateCounterOperations.Resolution) - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate
retrieve(String) - Method in class org.springframework.xd.rest.client.impl.CounterTemplate
retrieve(String) - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate
retrieve(String) - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate
retrieve(String) - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate
retrieve(String) - Method in interface org.springframework.xd.rest.client.RichGaugeOperations: Display the value of the named Rich Gauge
RichGauge - Class in org.springframework.xd.analytics.metrics.core: A gauge which stores the maximum, minimum and average in addition to the current value.
RichGauge(String) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge: Creates an "empty" gauge.
RichGauge(String, double) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge
RichGauge(String, double, double, double, double, double, long) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge
RichGaugeCommands - Class in org.springframework.xd.shell.command: Commands for interacting with RichGauge analytics.
RichGaugeCommands() - Constructor for class org.springframework.xd.shell.command.RichGaugeCommands
RichGaugeHandler - Class in org.springframework.xd.analytics.metrics.integration
RichGaugeHandler(RichGaugeRepository, String, double) - Constructor for class org.springframework.xd.analytics.metrics.integration.RichGaugeHandler
richGaugeOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
RichGaugeOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available when dealing with Rich Gauge.
richGaugeOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with RichGauge.
RichGaugeRepository - Interface in org.springframework.xd.analytics.metrics.core: A service for managing RichGauge instances.
RichGaugeResource - Class in org.springframework.xd.rest.client.domain.metrics: The REST representation of a RichGauge.
RichGaugeResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource: No-arg constructor for serialization frameworks.
RichGaugeResource(String, double, double, double, double, double, long) - Constructor for class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource
RichGaugesController - Class in org.springframework.xd.dirt.rest.metrics: Exposes representations of Gauges.
RichGaugesController(RichGaugeRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.RichGaugesController
RichGaugeTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the RichGauge part of the metrics API.
RichGaugeTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.RichGaugeTemplate
rm(String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
RolloverStrategyParser - Class in org.springframework.xd.integration.hadoop.config: Parser for the 'rollover-policy' element.
RolloverStrategyParser() - Constructor for class org.springframework.xd.integration.hadoop.config.RolloverStrategyParser
run(String...) - Method in class org.springframework.xd.dirt.server.AdminServerApplication
run(String...) - Method in class org.springframework.xd.dirt.server.LauncherApplication
run(String...) - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
RuntimeCommands - Class in org.springframework.xd.shell.command: Commands to interact with runtime containers/modules.
RuntimeCommands() - Constructor for class org.springframework.xd.shell.command.RuntimeCommands
RuntimeContainerInfoEntity - Class in org.springframework.xd.dirt.container.store: Represents Container info model.
RuntimeContainerInfoEntity(String, String, String, String) - Constructor for class org.springframework.xd.dirt.container.store.RuntimeContainerInfoEntity
RuntimeContainerInfoRepository - Interface in org.springframework.xd.dirt.container.store: Repository for persisting Container entities
RuntimeContainerInfoResource - Class in org.springframework.xd.rest.client.domain: Represents runtime container info model.
RuntimeContainerInfoResource(String, String, String, String) - Constructor for class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource
RuntimeContainerInfoResource.Page - Class in org.springframework.xd.rest.client.domain: Dedicated subclass to workaround type erasure.
RuntimeContainerInfoResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource.Page
RuntimeContainerInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to assemble RuntimeContainerInfoResources out of RuntimeContainerInfoEntitys.
RuntimeContainerInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.RuntimeContainerInfoResourceAssembler
RuntimeContainerModuleInfoRepository - Interface in org.springframework.xd.dirt.module.store: Repository for persisting runtime modules mapped to their containers.
RuntimeContainersController - Class in org.springframework.xd.dirt.rest: Handles interaction with the runtime containers/and its modules.
RuntimeContainersController(RuntimeContainerInfoRepository) - Constructor for class org.springframework.xd.dirt.rest.RuntimeContainersController
RuntimeIOException - Exception in org.springframework.xd.dirt.core: Thrown when something goes wrong during some IO operation.
RuntimeIOException(String, IOException) - Constructor for exception org.springframework.xd.dirt.core.RuntimeIOException
RuntimeModuleInfoEntity - Class in org.springframework.xd.dirt.module.store: Represents runtime module model info.
RuntimeModuleInfoEntity(String, String, String, String) - Constructor for class org.springframework.xd.dirt.module.store.RuntimeModuleInfoEntity
RuntimeModuleInfoRepository - Interface in org.springframework.xd.dirt.module.store: Repository for persisting runtime modules.
RuntimeModuleInfoResource - Class in org.springframework.xd.rest.client.domain: Represents a runtime module.
RuntimeModuleInfoResource(String, String, String, String) - Constructor for class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
RuntimeModuleInfoResource.Page - Class in org.springframework.xd.rest.client.domain: Dedicated subclass to workaround type erasure.
RuntimeModuleInfoResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource.Page
RuntimeModuleInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to assemble RuntimeModuleInfoResources out of RuntimeModuleInfoEntitys.
RuntimeModuleInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.RuntimeModuleInfoResourceAssembler
RuntimeModulesController - Class in org.springframework.xd.dirt.rest: Controller that handles the interaction with the deployed modules.
RuntimeModulesController(RuntimeModuleInfoRepository, RuntimeContainerModuleInfoRepository) - Constructor for class org.springframework.xd.dirt.rest.RuntimeModulesController
runtimeOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
RuntimeOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available against runtime container/modules.
runtimeOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interaction with runtime containers/modules.
RuntimeTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the runtime containers/modules related part of the API.

S

save(S) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
save(S) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
save(Iterable<S>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
save(S) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
save(Iterable<S>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
save(R) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
save(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository
save(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
save(S) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
save(String, String) - Method in class org.springframework.xd.dirt.rest.ModulesController: Create a new composite Module.
save(String, String, boolean) - Method in class org.springframework.xd.dirt.rest.XDController: Create a new domain object.
save(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
save(String, String) - Method in class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
save(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository
save(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository
save(S) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
save(S) - Method in class org.springframework.xd.store.AbstractRedisRepository
save(Iterable<S>) - Method in class org.springframework.xd.store.AbstractRedisRepository
save(Iterable<S>) - Method in class org.springframework.xd.store.AbstractRepository
saveDependencies(ModuleDependencyRepository, ModuleDefinition, String) - Static method in class org.springframework.xd.dirt.module.support.ModuleDefinitionRepositoryUtils
saveDependencies(ModuleDependencyRepository, StreamDefinition) - Static method in class org.springframework.xd.dirt.stream.StreamDefinitionRepositoryUtils: Save the dependencies of each module to its containing stream.
select(String) - Method in class org.springframework.xd.tuple.DefaultTuple
select(String) - Method in interface org.springframework.xd.tuple.Tuple: Use SpEL expression to return a subset of the tuple that matches the expression
sendDeploymentRequests(String, List<ModuleDeploymentRequest>) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
sendDeploymentRequests(String, List<ModuleDeploymentRequest>) - Method in class org.springframework.xd.dirt.stream.DeploymentMessageSender
SerializationException - Exception in org.springframework.integration.x.bus.serializer: Thrown when something goes wrong with inter-module communication.
SerializationException(String) - Constructor for exception org.springframework.integration.x.bus.serializer.SerializationException
SerializationException(String, Throwable) - Constructor for exception org.springframework.integration.x.bus.serializer.SerializationException
serialize(Object, OutputStream) - Method in class org.springframework.integration.x.bus.serializer.CompositeCodec
serialize(Message<?>) - Method in class org.springframework.integration.x.redis.KryoMessageSerializer
serialize(Counter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
serialize(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.container.store.RedisRuntimeContainerInfoRepository
serialize(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
serialize(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
serialize(JobDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisJobDefinitionRepository
serialize(Job) - Method in class org.springframework.xd.dirt.stream.redis.RedisJobRepository
serialize(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository
serialize(Stream) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamRepository
serialize(T) - Method in class org.springframework.xd.store.AbstractRedisRepository: Provide a String representation of the domain entity.
serializeId(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
serializeId(String) - Method in class org.springframework.xd.dirt.container.store.RedisRuntimeContainerInfoRepository
serializeId(String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository
serializeId(String) - Method in class org.springframework.xd.dirt.module.store.AbstractRedisRuntimeModuleInfoRepository
serializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository
serializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository
serializeId(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository: Return a String representation of the domain ID.
setAlpha(double) - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
setAlpha(String, double) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeRepository: Sets the "smoothing constant", "alpha" for use in calculating an exponential moving average for the gauge.
setAlpha(String, double) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
setAlpha(String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
setApplicationContext(ApplicationContext) - Method in class org.springframework.integration.x.bus.LocalMessageBus
setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
setAttribute(String, String) - Method in class org.springframework.xd.dirt.event.AbstractEvent
setAutoStartup(boolean) - Method in class org.springframework.xd.integration.hadoop.config.AvroWritingMessageHandlerFactoryBean
setAutoStartup(boolean) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
setAutoStartup(boolean) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler: Sets the auto startup.
setAutoStartup(boolean) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
setBaseFilename(String) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
setBaseFilename(String) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
setBaseFilename(String) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
setBaseFilename(String) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
setBaseFilename(String) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
setBasePath(String) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
setBasePath(String) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
setBasePath(String) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
setBasePath(String) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
setBasePath(String) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
setBeanClassLoader(ClassLoader) - Method in class org.springframework.integration.x.json.TypedJsonMapper
setBeanClassLoader(ClassLoader) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
setBeanClassLoader(ClassLoader) - Method in class org.springframework.xd.dirt.module.support.ThreadContextClassLoaderSetterAdvice
setBeanFactory(BeanFactory) - Method in class org.springframework.integration.x.bus.MessageBusAwareChannelResolver
setBeanFactory(BeanFactory) - Method in class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor
setCacheEventExpression(String) - Method in class org.springframework.xd.dirt.modules.metadata.GemfireSourceOptionsMetadata
setClientId(String) - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
setCodec(MultiTypeCodec<Object>) - Method in class org.springframework.integration.x.bus.LocalMessageBus
setCodec(MultiTypeCodec<Object>) - Method in class org.springframework.integration.x.bus.MessageBusSupport
setCollectionName(String) - Method in class org.springframework.xd.mongodb.MongoItemWriter
setColumnNames(String) - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer
setColumnNames(String[]) - Method in class org.springframework.xd.jdbc.NamedColumnJdbcBatchItemWriter
setColumnNames(String) - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReader: The column names in the database, in the order in which they should be read and assembled into the returned string.
setColumnNames(String[]) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer: Sets the column names which will be used to create a DDL definition of the columns for the table.
setColumns(String) - Method in class org.springframework.xd.jdbc.JdbcSinkModuleOptionsMetadata
setComplete(boolean) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
setComposedModuleDefinitions(List<ModuleDefinition>) - Method in class org.springframework.xd.module.ModuleDefinition: Set the list of composed modules if this is a composite module, can not be null
setConfigProperties(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setConnectTimeout(int) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: The connection timeout for making a connection to Twitter.
setContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.container.XDContainer
setConvertWithinTransport(boolean) - Method in class org.springframework.integration.x.bus.LocalMessageBus: Determines whether any conversion logic is applied within the local transport.
setCounter(long) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
setCounter(long) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
setCounter(long) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
setCron(String) - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
setData(Map<Integer, String>) - Method in class org.springframework.xd.shell.util.TableRow
setDatasetRepositoryFactory(DatasetRepositoryFactory) - Method in class org.springframework.data.hadoop.x.store.dataset.DatasetTemplateAllowingNulls: The DatasetRepositoryFactory to use for this template.
setDataSource(DataSource) - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
setDateFormat(DateFormat) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Will set the DateFormat on the underlying DefaultJobParametersConverter.
setDateFormat(DateFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer: Will set the DateFormat on the underlying DefaultJobParametersConverter.
setDateFormat(DateFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean: Will set the DateFormat on the underlying DefaultJobParametersConverter.
setDateFormat(DateFormat) - Method in class org.springframework.xd.tuple.batch.TupleFieldSetMapper: The DateFormat used by the resulting Tuple instance returned when converting strings to Dates.
setDateFormat(DateFormat) - Method in class org.springframework.xd.tuple.TupleBuilder
setDateFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Allows for setting the DateFormat using a String.
setDateFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer
setDateFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean
setDefinition(String) - Method in class org.springframework.xd.module.ModuleDefinition
setDelay(long) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setDelimited(boolean) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: Whether "delimited=length" shoud be added to the query.
setDeployed(Boolean) - Method in class org.springframework.xd.rest.client.domain.DeployableResource
setDeployments(boolean) - Method in class org.springframework.xd.dirt.rest.XDController.QueryOptions
setDriverClass(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setEnvironment(Environment) - Method in class org.springframework.xd.dirt.server.options.CommandLinePropertySourceOverridingInitializer
setEnvironment(Environment) - Method in class org.springframework.xd.dirt.util.XdConfigLoggingInitializer
setEnvironment(Environment) - Method in class org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver
setExchange(String) - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
setExecutor(Executor) - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
setFileDelay(long) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setFileSuffix(String) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
setFileSuffix(String) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
setFileSuffix(String) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
setFileSuffix(String) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
setFileSuffix(String) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
setFilterLevel(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: One of "none", "low" or "medium"
setFixedDelay(int) - Method in class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
setFixedDelay(Integer) - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
setFollow(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: Restrict the stream to a user or users.
setFormat(String) - Method in class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
setFormattingConversionService(FormattingConversionService) - Method in class org.springframework.xd.tuple.TupleBuilder
setFromEnd(boolean) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setFs(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
setGaugeValue(Gauge, long) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
setGroup(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setGroupName(String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
setGroupName(String) - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
setHADOOP_DISTRO(HadoopDistro) - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
setHADOOP_DISTRO(HadoopDistro) - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
setHost(String) - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
setHost(String) - Method in class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
setHost(String) - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
setHost(String) - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
setIdField(String) - Method in class org.springframework.xd.mongodb.TupleWriteConverter: Set the tuple field name which will be used as the Mongo _id.
setIndex(int) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setInitializeDatabase(Boolean) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setInitializerScript(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setInputType(MediaType) - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
setInputType(MediaType) - Method in class org.springframework.xd.jdbc.JdbcSinkModuleOptionsMetadata
setInputType(MediaType) - Method in class org.springframework.xd.module.options.spi.ProcessortModuleOptionsMetadataSupport
setInputType(MediaType) - Method in class org.springframework.xd.module.options.spi.SinkModuleOptionsMetadataSupport
setJdbcTemplate(JdbcOperations) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobLocator
setJobLocator(BatchJobLocator) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
setJobName(String) - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean
setJobRegistry(JobRegistry) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
setJobSuffix(String) - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean
setJt(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
setKeyExpression(String) - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
setLanguage(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: Filter tweets by language or languages.
setLaunch(boolean) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setLauncherContext(ApplicationContext) - Method in class org.springframework.xd.dirt.container.XDContainer
setLineAggregator(LineAggregator<T>) - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter: Public setter for the LineAggregator.
setLineAggregator(LineAggregator<T>) - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter: Public setter for the LineAggregator.
setLines(int) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setLocations(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: Bound the returned tweets by location(s).
setMakeParametersUnique(boolean) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: If not set, this property defaults to true.
setMakeParametersUnique(boolean) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer: If not set, this property defaults to true.
setMakeParametersUnique(boolean) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean: If not set, this property defaults to true.
setMappings(Map<String, String>) - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
setMaxWidth(int) - Method in class org.springframework.xd.shell.util.TableHeader: Defaults to -1 indicating to ignore the property.
setModule(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setModuleDefinitions(List<ModuleDefinition>) - Method in class org.springframework.xd.dirt.core.BaseDefinition
setName(String) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setName(String) - Method in class org.springframework.xd.shell.util.TableHeader
setNames(String) - Method in class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
setNames(List<String>) - Method in class org.springframework.xd.tuple.batch.TupleFieldExtractor: An ordered list of field names to be extracted from each item.
setNativeOptions(String) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setNotificationsChannel(MessageChannel) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
setNotificationsChannel(MessageChannel) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
setNotificationsChannel(MessageChannel) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdJobExecutionListener
setNotificationsChannel(MessageChannel) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdSkipListener
setNotificationsChannel(MessageChannel) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdStepExecutionListener
setNumberFormat(NumberFormat) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Setter for the NumberFormat which is set on the underlying DefaultJobParametersConverter.
setNumberFormat(NumberFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer: Setter for the NumberFormat which is set on the underlying DefaultJobParametersConverter.
setNumberFormat(NumberFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean: Setter for the NumberFormat which is set on the underlying DefaultJobParametersConverter.
setNumberFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter: Allows for setting the NumberFormat using a String.
setNumberFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer
setNumberFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean
setNumberFormatFromLocale(Locale) - Method in class org.springframework.xd.tuple.TupleBuilder
setOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
setOutputType(MediaType) - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
setOutputType(MediaType) - Method in class org.springframework.xd.module.options.spi.ProcessortModuleOptionsMetadataSupport
setOutputType(MediaType) - Method in class org.springframework.xd.module.options.spi.SourceModuleOptionsMetadataSupport
setOverride(String) - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
setParameter(String, String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setParentContext(ApplicationContext) - Method in class org.springframework.xd.module.core.CompositeModule
setParentContext(ApplicationContext) - Method in interface org.springframework.xd.module.core.Module
setParentContext(ApplicationContext) - Method in class org.springframework.xd.module.core.SimpleModule
setPassword(String) - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
setPassword(String) - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
setPassword(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setPayload(String) - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
setPhase(int) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler: Sets the phase.
setPhase(int) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
setPoller(PollerMetadata) - Method in class org.springframework.integration.x.bus.LocalMessageBus: Set the poller to use when QueueChannels are used.
setPort(int) - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
setPort(int) - Method in class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
setPORT(int) - Method in class org.springframework.xd.dirt.server.options.AdminOptions
setPORT(int) - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
setPort(int) - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
setPort(int) - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
setPostProcessContextPaths(String...) - Method in class org.springframework.xd.module.core.AbstractPlugin
setPrefix(String) - Method in class org.springframework.xd.store.AbstractRedisRepository: Change the prefix after creation.
setProperties(Properties) - Method in class org.springframework.xd.module.ModuleDefinition
setProperty(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
setQuery(String) - Method in class org.springframework.xd.dirt.modules.metadata.GemfireCQSourceOptionsMetadata
setQueues(String) - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
setQueueSize(int) - Method in class org.springframework.integration.x.bus.LocalMessageBus: Set the size of the queue when using QueueChannels.
setReadTimeout(int) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: The read timeout for the underlying URLConnection to the twitter stream.
setRegionName(String) - Method in class org.springframework.xd.dirt.modules.metadata.GemfireSourceOptionsMetadata
setRegionName(String) - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
setRegistry(JobRegistry) - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean
setRemove(boolean) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setReOpen(boolean) - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
setrep(String, int, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
setResourceLoader(ResourceLoader) - Method in class org.springframework.xd.dirt.module.ResourceModuleRegistry
setResourceLoader(ResourceLoader) - Method in class org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver
setResources(String) - Method in class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
setRestartable(Boolean) - Method in class org.springframework.xd.jdbc.FileJdbcJobModuleOptionsMetadata
setRichGaugeAlpha(RichGauge, double) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
setRichGaugeValue(RichGauge, double) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
setRoutingKey(String) - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
setRows(List<TableRow>) - Method in class org.springframework.xd.shell.util.Table
setScripts(Resource[]) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
setServerProperties(Properties) - Method in class org.springframework.xd.dirt.job.HSQLServerBean
setSinkChannelName(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setSourceChannelName(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setStallWarnings(boolean) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: Whether "stall_warnings=true" should be added to the query.
setStartedAt(Date) - Method in class org.springframework.xd.dirt.stream.BaseInstance: Returns the date when this instance was started.
setStepExecution(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
setStoreWriter(DataStoreWriter<String>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler: Sets the store writer.
setTableName(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setTableName(String) - Method in class org.springframework.xd.jdbc.NamedColumnJdbcBatchItemWriter
setTableName(String) - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReader: The table to read from.
setTableName(String) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
setTargetException(Exception) - Method in class org.springframework.xd.shell.Target: Sets the exception in case an error occurred during targeting.
setTargetResultMessage(String) - Method in class org.springframework.xd.shell.Target: Set the result messages indicating the success or failure while targeting the Spring XD Admin Server.
setTimeFormat(String) - Method in class org.springframework.xd.analytics.metrics.integration.AggregateCounterHandler
setTimeZone(TimeZone) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController
setTimeZone(TimeZone) - Method in class org.springframework.xd.dirt.rest.BatchJobsController
setTimeZone(TimeZone) - Method in class org.springframework.xd.dirt.rest.BatchStepExecutionsController
setTopics(String) - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
setTrack(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter: Filter tweets by words or phrases.
setTupleToStringConverter(Converter<Tuple, String>) - Method in class org.springframework.xd.tuple.DefaultTuple
setType(ModuleType) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
setTypes(Map<String, FieldSetType>) - Method in class org.springframework.xd.tuple.batch.TupleFieldSetMapper: A map of FieldSet field names to FieldSetType.
setUrl(String) - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
setUrl(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setUseLocator(boolean) - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
setUsername(String) - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
setUsername(String) - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
setUsername(String) - Method in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
setValue(String, long) - Method in interface org.springframework.xd.analytics.metrics.core.GaugeRepository: Set the value of the gauge
setValue(String, double) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeRepository: Sets the current value of the gauge.
setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository
setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
setVhost(String) - Method in class org.springframework.xd.dirt.modules.metadata.AbstractRabbitConnectionOptionsMetadata
setWidth(int) - Method in class org.springframework.xd.shell.util.TableHeader
setXD_ANALYTICS(CommonDistributedOptions.Analytics) - Method in class org.springframework.xd.dirt.server.options.CommonDistributedOptions
setXD_ANALYTICS(SingleNodeOptions.Analytics) - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
setXD_CONTROL_TRANSPORT(CommonDistributedOptions.ControlTransport) - Method in class org.springframework.xd.dirt.server.options.AdminOptions
setXD_CONTROL_TRANSPORT(CommonDistributedOptions.ControlTransport) - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
setXD_CONTROL_TRANSPORT(SingleNodeOptions.ControlTransport) - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
setXD_JMX_ENABLED(boolean) - Method in class org.springframework.xd.dirt.server.options.CommonOptions
setXD_STORE(CommonDistributedOptions.Store) - Method in class org.springframework.xd.dirt.server.options.CommonDistributedOptions
setXD_STORE(CommonDistributedOptions.Store) - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
setXD_TRANSPORT(DataTransport) - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
setXD_TRANSPORT(DataTransport) - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
ShallowMetricResourceAssembler<M extends Metric> - Class in org.springframework.xd.dirt.rest.metrics: Base class for a ResourceAssembler that builds shallow resources for metrics (exposing only their names, and hence their "self" rel).
ShallowMetricResourceAssembler(Class<?>) - Constructor for class org.springframework.xd.dirt.rest.metrics.ShallowMetricResourceAssembler
SimpleAbstractHdfsItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop
SimpleAbstractHdfsItemWriter() - Constructor for class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
SimpleHdfsTextItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop
SimpleHdfsTextItemWriter(FileSystem) - Constructor for class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
SimpleModule - Class in org.springframework.xd.module.core: A Module implementation backed by a Spring ApplicationContext.
SimpleModule(ModuleDefinition, DeploymentMetadata) - Constructor for class org.springframework.xd.module.core.SimpleModule
SimpleModule(ModuleDefinition, DeploymentMetadata, ClassLoader, ModuleOptions) - Constructor for class org.springframework.xd.module.core.SimpleModule
SimpleModuleOptionsMetadata - Class in org.springframework.xd.module.options: An implementation of ModuleOptionsMetadata that only knows how to list options and does not support advanced facilities such as derived options, profile activation or validation.
SimpleModuleOptionsMetadata() - Constructor for class org.springframework.xd.module.options.SimpleModuleOptionsMetadata
SimpleXdChunkListener - Class in org.springframework.xd.dirt.plugins.job.support.listener
SimpleXdChunkListener() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
SimpleXdItemListener - Class in org.springframework.xd.dirt.plugins.job.support.listener
SimpleXdItemListener() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
SimpleXdJobExecutionListener - Class in org.springframework.xd.dirt.plugins.job.support.listener
SimpleXdJobExecutionListener() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdJobExecutionListener
SimpleXdSkipListener - Class in org.springframework.xd.dirt.plugins.job.support.listener
SimpleXdSkipListener() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdSkipListener
SimpleXdStepExecutionListener - Class in org.springframework.xd.dirt.plugins.job.support.listener
SimpleXdStepExecutionListener() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdStepExecutionListener
SINGLE_PROFILE - Static variable in class org.springframework.xd.dirt.server.SingleNodeApplication
SingleNodeApplication - Class in org.springframework.xd.dirt.server: Single Node XD Runtime.
SingleNodeApplication() - Constructor for class org.springframework.xd.dirt.server.SingleNodeApplication
SingleNodeOptions - Class in org.springframework.xd.dirt.server.options: Holds options that can be used in single-node mode.
SingleNodeOptions() - Constructor for class org.springframework.xd.dirt.server.options.SingleNodeOptions
SingleNodeOptions.Analytics - Enum in org.springframework.xd.dirt.server.options
SingleNodeOptions.ControlTransport - Enum in org.springframework.xd.dirt.server.options
SingleTableDatabaseInitializer - Class in org.springframework.xd.jdbc: Class that's intended for initializing a single table and the script used can use a placeholder #table for the table name.
SingleTableDatabaseInitializer() - Constructor for class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
SinkChannelNode - Class in org.springframework.xd.dirt.stream.dsl
SinkChannelNode(ChannelNode, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
SinkModuleOptionsMetadataSupport - Class in org.springframework.xd.module.options.spi: Provides info about the inputType option.
SinkModuleOptionsMetadataSupport() - Constructor for class org.springframework.xd.module.options.spi.SinkModuleOptionsMetadataSupport
size() - Method in class org.springframework.xd.tuple.DefaultTuple
size() - Method in interface org.springframework.xd.tuple.Tuple: Return the number of elements in this tuple.
slice(List<ModuleDefinition>, Pageable) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDefinitionRepository: Post-process the list to only return elements matching the page request.
slice(List<ModuleDefinition>, Pageable) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDefinitionRepository: Post-process the list to only return elements matching the page request.
slice(List<T>, Pageable) - Method in class org.springframework.xd.store.AbstractInMemoryRepository: Post-process the list to only return elements matching the page request.
SourceChannelNode - Class in org.springframework.xd.dirt.stream.dsl
SourceChannelNode(ChannelNode, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
SourceModuleOptionsMetadataSupport - Class in org.springframework.xd.module.options.spi: Provides info about the outputType option.
SourceModuleOptionsMetadataSupport() - Constructor for class org.springframework.xd.module.options.spi.SourceModuleOptionsMetadataSupport
SplunkTransformer - Class in org.springframework.integration.x.splunk: Message consumer that will push the payload to a splunk instance via a TCP-Port.
SplunkTransformer() - Constructor for class org.springframework.integration.x.splunk.SplunkTransformer
SpringXDException - Exception in org.springframework.xd.rest.client.impl: A Java exception that wraps the serialized VndErrors object.
SpringXDException(VndErrors) - Constructor for exception org.springframework.xd.rest.client.impl.SpringXDException
SpringXDOperations - Interface in org.springframework.xd.rest.client: Main entry point for interacting with a running XD system.
SpringXDTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the entry point to the API.
SpringXDTemplate(ClientHttpRequestFactory, URI) - Constructor for class org.springframework.xd.rest.client.impl.SpringXDTemplate
SpringXDTemplate(URI) - Constructor for class org.springframework.xd.rest.client.impl.SpringXDTemplate
start() - Method in class org.springframework.integration.x.bus.Binding
start() - Method in class org.springframework.xd.dirt.container.XDContainer
start() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
start() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
start() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
start() - Method in class org.springframework.xd.module.core.CompositeModule
start() - Method in class org.springframework.xd.module.core.SimpleModule
startpos - Variable in class org.springframework.xd.dirt.stream.dsl.AstNode
StepExecutionHistoryJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for StepExecutionHistory de-serialization.
StepExecutionInfo - Class in org.springframework.xd.dirt.job: Represents Batch step execution info.
StepExecutionInfo(String, Long, String, TimeZone) - Constructor for class org.springframework.xd.dirt.job.StepExecutionInfo
StepExecutionInfo(StepExecution, TimeZone) - Constructor for class org.springframework.xd.dirt.job.StepExecutionInfo
StepExecutionInfoResource - Class in org.springframework.xd.rest.client.domain: Represents the step execution info resource.
StepExecutionInfoResource(Long, StepExecution) - Constructor for class org.springframework.xd.rest.client.domain.StepExecutionInfoResource
StepExecutionInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model StepExecutionInfo.
StepExecutionInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.StepExecutionInfoResourceAssembler
StepExecutionJacksonMixIn - Class in org.springframework.xd.dirt.plugins.job.support: Jackson MixIn for StepExecution serialization.
StepExecutionJacksonMixIn() - Constructor for class org.springframework.xd.dirt.plugins.job.support.StepExecutionJacksonMixIn
StepExecutionJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support: Jackson MixIn for StepExecution de-serialization.
stepExecutionProgress(long, long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
stepExecutionProgress(long, long) - Method in interface org.springframework.xd.rest.client.JobOperations: Retrieve step execution progress with the given jobExecutionId and stepExecutionId.
stepExecutionProgress(long, long) - Method in class org.springframework.xd.shell.command.JobCommands
StepExecutionProgressInfo - Class in org.springframework.xd.dirt.job: Represents Batch job step execution progress info.
StepExecutionProgressInfo(StepExecution, StepExecutionHistory) - Constructor for class org.springframework.xd.dirt.job.StepExecutionProgressInfo
StepExecutionProgressInfoResource - Class in org.springframework.xd.rest.client.domain: Represents the step execution progress info resource.
StepExecutionProgressInfoResource() - Constructor for class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
StepExecutionProgressInfoResource(StepExecution, StepExecutionHistory, double, boolean, double) - Constructor for class org.springframework.xd.rest.client.domain.StepExecutionProgressInfoResource
StepExecutionProgressInfoResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model StepExecutionProgressInfo.
StepExecutionProgressInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.StepExecutionProgressInfoResourceAssembler
stop() - Method in class org.springframework.integration.x.bus.Binding
stop() - Method in class org.springframework.xd.dirt.container.XDContainer
stop(Runnable) - Method in class org.springframework.xd.dirt.container.XDContainer
stop() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
stop() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
stop(Runnable) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
stop() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
stop(Runnable) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
stop() - Method in class org.springframework.xd.module.core.CompositeModule
stop() - Method in class org.springframework.xd.module.core.SimpleModule
stopAll() - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController: Stop all job executions.
stopAllJobExecutions() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
stopAllJobExecutions() - Method in interface org.springframework.xd.rest.client.JobOperations: Stop all job executions.
stopAllJobExecutions(boolean) - Method in class org.springframework.xd.shell.command.JobCommands
stopBindings() - Method in class org.springframework.integration.x.bus.MessageBusSupport
stopJobExecution(Long) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController: Stop Job Execution by the given executionId.
stopJobExecution(long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
stopJobExecution(long) - Method in interface org.springframework.xd.rest.client.JobOperations: Stop job execution that is running.
stopJobExecution(long) - Method in class org.springframework.xd.shell.command.JobCommands
store(String, ModuleType, String) - Method in class org.springframework.xd.dirt.module.memory.InMemoryModuleDependencyRepository
store(String, ModuleType, String) - Method in interface org.springframework.xd.dirt.module.ModuleDependencyRepository: Store one atomic dependency from a module (composed or not) to some target (stream, or composed module).
store(String, ModuleType, String) - Method in class org.springframework.xd.dirt.module.redis.RedisModuleDependencyRepository
storeContainerEntity(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.listener.AbstractContainerEventStoreListener
storeContainerEntity(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.listener.ContainerEventStoreListener
StoreWriterParser - Class in org.springframework.xd.integration.hadoop.config: Parser for the 'storage' element.
StoreWriterParser() - Constructor for class org.springframework.xd.integration.hadoop.config.StoreWriterParser
Stream - Class in org.springframework.xd.dirt.stream: A runtime representation of a running stream.
Stream(StreamDefinition) - Constructor for class org.springframework.xd.dirt.stream.Stream: Create a new stream out of the given StreamDefinition.
StreamCommands - Class in org.springframework.xd.shell.command
StreamCommands() - Constructor for class org.springframework.xd.shell.command.StreamCommands
StreamConfigParser - Class in org.springframework.xd.dirt.stream.dsl
StreamConfigParser(CrudRepository<? extends BaseDefinition, String>) - Constructor for class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
StreamDefinition - Class in org.springframework.xd.dirt.stream: Represents a model for a data flow in the system.
StreamDefinition(String, String) - Constructor for class org.springframework.xd.dirt.stream.StreamDefinition: Create a new StreamDefinition
StreamDefinitionException - Exception in org.springframework.xd.dirt.stream.dsl: Root exception for DSL parsing related exceptions.
StreamDefinitionException(String, int, XDDSLMessages, Object...) - Constructor for exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
StreamDefinitionRepository - Interface in org.springframework.xd.dirt.stream: A repository for persisting StreamDefinitions.
StreamDefinitionRepositoryUtils - Class in org.springframework.xd.dirt.stream: Encapsulate shared functionality between implementations of StreamDefinitionRepository that can't be done using inheritance
StreamDefinitionRepositoryUtils() - Constructor for class org.springframework.xd.dirt.stream.StreamDefinitionRepositoryUtils
StreamDefinitionResource - Class in org.springframework.xd.rest.client.domain: Represents a stream definition, i.e. a flow of data in the system.
StreamDefinitionResource() - Constructor for class org.springframework.xd.rest.client.domain.StreamDefinitionResource: Default constructor for serialization frameworks.
StreamDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.StreamDefinitionResource
StreamDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain: Dedicated subclass to workaround type erasure.
StreamDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.StreamDefinitionResource.Page
StreamDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest: Knows how to build a REST resource out of our domain model StreamDefinition.
StreamDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.StreamDefinitionResourceAssembler
StreamDeployer - Class in org.springframework.xd.dirt.stream: Default implementation of StreamDeployer that emits deployment request messages on a bus and relies on StreamDefinitionRepository and StreamRepository for persistence.
StreamDeployer(StreamDefinitionRepository, DeploymentMessageSender, StreamRepository, XDParser) - Constructor for class org.springframework.xd.dirt.stream.StreamDeployer
StreamLookupEnvironment - Interface in org.springframework.xd.dirt.stream.dsl: A lookup environment is used to resolve a stream.
StreamNode - Class in org.springframework.xd.dirt.stream.dsl
StreamNode(String, String, List<ModuleNode>, SourceChannelNode, SinkChannelNode) - Constructor for class org.springframework.xd.dirt.stream.dsl.StreamNode
streamOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
streamOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations: Returns the portion of the API for interacting with Streams.
StreamOperations - Interface in org.springframework.xd.rest.client: Interface defining operations available against streams.
streamParser - Variable in class org.springframework.xd.dirt.stream.AbstractDeployer
StreamPlugin - Class in org.springframework.xd.dirt.plugins.stream
StreamPlugin() - Constructor for class org.springframework.xd.dirt.plugins.stream.StreamPlugin
StreamRepository - Interface in org.springframework.xd.dirt.stream: A repository for persisting Streams.
StreamsController - Class in org.springframework.xd.dirt.rest: Handles all Stream related interaction.
StreamsController(StreamDeployer, StreamDefinitionRepository) - Constructor for class org.springframework.xd.dirt.rest.StreamsController
StreamTemplate - Class in org.springframework.xd.rest.client.impl: Implementation of the Stream-related part of the API.
StringCodec - Class in org.springframework.integration.x.bus.serializer.kryo
StringCodec() - Constructor for class org.springframework.integration.x.bus.serializer.kryo.StringCodec
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.AstNode
stringify() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
StringToDateConverter - Class in org.springframework.xd.tuple: Converter for Strings to Date that can take into account date patterns
StringToDateConverter() - Constructor for class org.springframework.xd.tuple.StringToDateConverter
StringToDateConverter(String) - Constructor for class org.springframework.xd.tuple.StringToDateConverter
StringToDateConverter(DateFormat) - Constructor for class org.springframework.xd.tuple.StringToDateConverter
StringToJsonNodeTransformer - Class in org.springframework.integration.x.json: Transforms a String to a JsonNode.
StringToJsonNodeTransformer() - Constructor for class org.springframework.integration.x.json.StringToJsonNodeTransformer
sum(long[]) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
supports(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
supports(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin
supports(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
supports(Module) - Method in interface org.springframework.xd.module.core.Plugin: Check if the module is supported by the plugin.
supports(Module) - Method in class org.springframework.xd.module.core.PluginAdapter
supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter
supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter
supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter
supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.QualifiedModuleNameConverter
SyslogInboundChannelAdapter - Class in org.springframework.xd.integration.reactor.syslog: InboundChannelAdapter implementation that uses the Reactor TCP support to read in syslog messages and transform them to a Map for use in downstream modules.
SyslogInboundChannelAdapter(Environment) - Constructor for class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
SyslogInboundChannelAdapterParser - Class in org.springframework.xd.integration.reactor.config
SyslogInboundChannelAdapterParser() - Constructor for class org.springframework.xd.integration.reactor.config.SyslogInboundChannelAdapterParser

T

Table - Class in org.springframework.xd.shell.util: Provide a basic concept of a table structure containing a map of column headers and a collection of rows.
Table() - Constructor for class org.springframework.xd.shell.util.Table
TableHeader - Class in org.springframework.xd.shell.util: Defines table column headers used by Table.
TableHeader(String, int) - Constructor for class org.springframework.xd.shell.util.TableHeader: Constructor that initializes the table header with the provided header name and the with of the table header.
TableHeader(String) - Constructor for class org.springframework.xd.shell.util.TableHeader: Constructor that initializes the table header with the provided header name.
tableName - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
TableRow - Class in org.springframework.xd.shell.util: Holds the table rows used by Table.
TableRow() - Constructor for class org.springframework.xd.shell.util.TableRow
tail(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
TailSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the tail source module.
TailSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
tapSource() - Method in enum org.springframework.xd.dirt.stream.dsl.ChannelType
Target - Class in org.springframework.xd.shell: Encapsulates various data points related to the Admin Server Target, such as target URI, success/error state, exception messages that may have occurred.
Target(String) - Constructor for class org.springframework.xd.shell.Target: Construct a new Target.
target(String) - Method in class org.springframework.xd.shell.XDShell
Target.TargetStatus - Enum in org.springframework.xd.shell
text(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
ThreadContextClassLoaderSetterAdvice - Class in org.springframework.xd.dirt.module.support: An advice that will set the thread context ClassLoader to the enclosing ApplicationContext's class loader before invocation and reset it afterwards.
ThreadContextClassLoaderSetterAdvice() - Constructor for class org.springframework.xd.dirt.module.support.ThreadContextClassLoaderSetterAdvice
throwAlreadyDeployedException(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
throwDefinitionAlreadyExistsException(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
throwDefinitionNotDeployable(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
throwNoSuchDefinitionException(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
throwNoSuchDefinitionException(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
throwNotDeployedException(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
TimeSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the time source module.
TimeSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
toBytes(Object) - Method in class org.springframework.integration.x.json.TypedJsonMapper
toJobLaunchRequest(Message<?>) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer
toObject(String) - Method in class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer
toResource(DetailedJobInfo) - Method in class org.springframework.xd.dirt.rest.DetailedJobInfoResourceAssembler
toResource(ModuleDefinition) - Method in class org.springframework.xd.dirt.rest.DetailedModuleDefinitionResourceAssembler
toResource(JobDefinition) - Method in class org.springframework.xd.dirt.rest.JobDefinitionResourceAssembler
toResource(JobExecutionInfo) - Method in class org.springframework.xd.dirt.rest.JobExecutionInfoResourceAssembler
toResource(JobInfo) - Method in class org.springframework.xd.dirt.rest.JobInfoResourceAssembler
toResource(AggregateCount) - Method in class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler
toResource(Counter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler
toResource(FieldValueCounter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler
toResource(M) - Method in class org.springframework.xd.dirt.rest.metrics.ShallowMetricResourceAssembler
toResource(ModuleDefinition) - Method in class org.springframework.xd.dirt.rest.ModuleDefinitionResourceAssembler
toResource(RuntimeContainerInfoEntity) - Method in class org.springframework.xd.dirt.rest.RuntimeContainerInfoResourceAssembler
toResource(RuntimeModuleInfoEntity) - Method in class org.springframework.xd.dirt.rest.RuntimeModuleInfoResourceAssembler
toResource(StepExecutionInfo) - Method in class org.springframework.xd.dirt.rest.StepExecutionInfoResourceAssembler
toResource(StepExecutionProgressInfo) - Method in class org.springframework.xd.dirt.rest.StepExecutionProgressInfoResourceAssembler
toResource(StreamDefinition) - Method in class org.springframework.xd.dirt.rest.StreamDefinitionResourceAssembler
toString() - Method in class org.springframework.integration.x.bus.Binding
toString(Object) - Method in class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer
toString() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
toString() - Method in class org.springframework.xd.analytics.metrics.core.Counter
toString() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
toString() - Method in class org.springframework.xd.analytics.metrics.core.Gauge
toString() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
toString() - Method in class org.springframework.xd.dirt.container.AbstractContainerEvent
toString() - Method in class org.springframework.xd.dirt.core.BaseDefinition
toString() - Method in class org.springframework.xd.dirt.event.AbstractEvent
toString() - Method in class org.springframework.xd.dirt.event.AbstractModuleEvent
toString() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
toString() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
toString() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode
toString() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode
toString() - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode
toString() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
toString() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode
toString() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
toString() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
toString(Token) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
toString() - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
toString() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
toString() - Method in class org.springframework.xd.module.core.AbstractModule
toString() - Method in class org.springframework.xd.module.ModuleDefinition
toString() - Method in class org.springframework.xd.module.options.ModuleOption
toString() - Method in class org.springframework.xd.module.support.ParentLastURLClassLoader
toString() - Method in class org.springframework.xd.rest.client.domain.RuntimeContainerInfoResource
toString() - Method in class org.springframework.xd.rest.client.domain.RuntimeModuleInfoResource
toString() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
toString() - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
toString() - Method in class org.springframework.xd.shell.util.Table
toString() - Method in class org.springframework.xd.tuple.DefaultTuple
toTuple(String) - Method in class org.springframework.xd.tuple.TupleStringMarshaller
touchz(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
trackMembership(String) - Method in class org.springframework.xd.store.AbstractRedisRepository: Perform bookkeeping of entities managed by this repository.
transform(Object) - Method in class org.springframework.integration.x.json.StringToJsonNodeTransformer
transformPayload(String) - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer
transformPayload(String) - Method in class org.springframework.xd.tuple.integration.JsonToTupleTransformer
transformPayload(Map<Object, Object>) - Method in class org.springframework.xd.tuple.integration.MapToTupleTransformer
transformPayloadForConsumerIfNecessary(Message<?>, Collection<MediaType>) - Method in class org.springframework.integration.x.bus.MessageBusSupport
transformPayloadForProducerIfNecessary(Message<?>, MediaType) - Method in class org.springframework.integration.x.bus.MessageBusSupport
TriggerSourceOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata: Describes options to the trigger source module.
TriggerSourceOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
Tuple - Interface in org.springframework.xd.tuple: Data structure that stores a fixed number of ordered key-value pairs and adds convenience methods to access values in a type-safe manner.
tuple() - Static method in class org.springframework.xd.tuple.TupleBuilder
TupleBuilder - Class in org.springframework.xd.tuple: Builder class to create Tuple instances.
TupleBuilder() - Constructor for class org.springframework.xd.tuple.TupleBuilder
TupleCodec - Class in org.springframework.integration.x.bus.serializer.kryo: Kryo serializer for Tuple
TupleCodec() - Constructor for class org.springframework.integration.x.bus.serializer.kryo.TupleCodec
TupleFieldExtractor - Class in org.springframework.xd.tuple.batch: Implementation of the FieldExtractor that extracts fields from a Tuple.
TupleFieldExtractor() - Constructor for class org.springframework.xd.tuple.batch.TupleFieldExtractor
TupleFieldSetMapper - Class in org.springframework.xd.tuple.batch: A FieldSetMapper implementation intended to allow a user use a Tuple as the item.
TupleFieldSetMapper() - Constructor for class org.springframework.xd.tuple.batch.TupleFieldSetMapper
TupleJsonMarshaller - Class in org.springframework.xd.tuple
TupleJsonMarshaller() - Constructor for class org.springframework.xd.tuple.TupleJsonMarshaller
TupleProcessor - Interface in org.springframework.xd.tuple.processor: Simple type-safe process callback method that returns another Tuple
TuplePropertyAccessor - Class in org.springframework.xd.tuple.spel: A PropertyAccessor implementation that enables reading of Tuple values using dot notation within SpEL expressions.
TuplePropertyAccessor() - Constructor for class org.springframework.xd.tuple.spel.TuplePropertyAccessor
TupleRowMapper - Class in org.springframework.xd.tuple.batch: A RowMapper implementation to be used with the Tuple data structure.
TupleRowMapper() - Constructor for class org.springframework.xd.tuple.batch.TupleRowMapper
TupleSqlParameterSource - Class in org.springframework.xd.tuple.batch: Implementation of a SqlParameterSource that translates a Tuple into SQL parameters.
TupleSqlParameterSource(Tuple) - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSource
TupleSqlParameterSourceProvider - Class in org.springframework.xd.tuple.batch: A factory for TupleSqlParameterSources
TupleSqlParameterSourceProvider() - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider
TupleStringMarshaller - Class in org.springframework.xd.tuple
TupleStringMarshaller(Converter<Tuple, String>, Converter<String, Tuple>) - Constructor for class org.springframework.xd.tuple.TupleStringMarshaller
TupleToJsonConverter - Class in org.springframework.integration.x.bus.converter
TupleToJsonConverter() - Constructor for class org.springframework.integration.x.bus.converter.TupleToJsonConverter
TupleToJsonStringConverter - Class in org.springframework.xd.tuple
TupleToJsonStringConverter() - Constructor for class org.springframework.xd.tuple.TupleToJsonStringConverter
TupleWriteConverter - Class in org.springframework.xd.mongodb
TupleWriteConverter() - Constructor for class org.springframework.xd.mongodb.TupleWriteConverter
TwitterStreamChannelAdapter - Class in org.springframework.integration.x.twitter: Message producer which reads form Twitter's public stream endpoints.
TwitterStreamChannelAdapter(TwitterTemplate) - Constructor for class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
type - Variable in class org.springframework.xd.shell.command.ModuleCommands.QualifiedModuleName
TypedJsonMapper - Class in org.springframework.integration.x.json: A class that maps objects to JSON.
TypedJsonMapper() - Constructor for class org.springframework.integration.x.json.TypedJsonMapper
TypedJsonMapper.SmartJsonConversionException - Exception in org.springframework.integration.x.json
TypedJsonMapper.SmartJsonConversionException(String, Throwable) - Constructor for exception org.springframework.integration.x.json.TypedJsonMapper.SmartJsonConversionException
TypedJsonMapper.SmartJsonConversionException(String) - Constructor for exception org.springframework.integration.x.json.TypedJsonMapper.SmartJsonConversionException

U

UiUtils - Class in org.springframework.xd.shell.util: Contains utility methods for rendering data to a formatted console output.
unbindConsumer(String, MessageChannel) - Method in interface org.springframework.integration.x.bus.MessageBus: Unbind a specific p2p or pub/sub message consumer
unbindConsumer(String, MessageChannel) - Method in class org.springframework.integration.x.bus.MessageBusSupport
unbindConsumers(String) - Method in interface org.springframework.integration.x.bus.MessageBus: Unbind an inbound inter-module channel and stop any active components that use the channel.
unbindConsumers(String) - Method in class org.springframework.integration.x.bus.MessageBusSupport
unbindProducer(String, MessageChannel) - Method in interface org.springframework.integration.x.bus.MessageBus: Unbind a specific p2p or pub/sub message producer
unbindProducer(String, MessageChannel) - Method in class org.springframework.integration.x.bus.MessageBusSupport
unbindProducers(String) - Method in interface org.springframework.integration.x.bus.MessageBus: Unbind an outbound inter-module channel and stop any active components that use the channel.
unbindProducers(String) - Method in class org.springframework.integration.x.bus.MessageBusSupport
undeploy(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
undeploy(String) - Method in class org.springframework.xd.dirt.rest.XDController: Request un-deployment of an existing named module.
undeploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
undeploy(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
undeploy(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
undeploy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations: Undeploy a deployed resource, retaining its definition.
undeployAll() - Method in interface org.springframework.xd.dirt.core.ResourceDeployer: Undeploy all the deployed resources.
undeployAll() - Method in class org.springframework.xd.dirt.rest.XDController: Request un-deployment of all modules.
undeployAll() - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
undeployAll() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
undeployAll() - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
undeployAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations: Undeploy all the resources known to the system.
undeployAllJobs(boolean) - Method in class org.springframework.xd.shell.command.JobCommands
undeployAllStreams(boolean) - Method in class org.springframework.xd.shell.command.StreamCommands
undeployJob(String) - Method in class org.springframework.xd.shell.command.JobCommands
undeployStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands
UNIQUE_JOB_PARAMETER_KEY - Static variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
unitPeriod - Variable in enum org.springframework.xd.analytics.metrics.core.AggregateCountResolution
unregister(String) - Method in class org.springframework.xd.dirt.post.DelegatingHandlerMapping
updateWidth(int) - Method in class org.springframework.xd.shell.util.TableHeader: Updated the width for this particular column, but only if the value of the passed-in width is higher than the value of the pre-existing width.
url - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata
UserInput - Interface in org.springframework.xd.shell.command: Abstraction for a mechanism used to get user interactive user input.
username - Variable in class org.springframework.xd.jdbc.AbstractJdbcModuleOptionsMetadata

V

validate() - Method in class org.springframework.xd.module.options.ModuleOptions
valueOf(String) - Static method in enum org.springframework.xd.analytics.metrics.core.AggregateCountResolution: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.plugins.job.support.listener.BatchListenerEventType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.CommonDistributedOptions.Analytics: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.CommonDistributedOptions.ControlTransport: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.CommonDistributedOptions.Store: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.DataTransport: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.HadoopDistro: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.SingleNodeOptions.Analytics: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.SingleNodeOptions.ControlTransport: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.stream.dsl.ChannelType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages.Kind: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.module.ModuleType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.rest.client.AggregateCounterOperations.Resolution: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.rest.client.domain.RESTModuleType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.shell.Target.TargetStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.xd.tuple.batch.FieldSetType: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.xd.analytics.metrics.core.AggregateCountResolution: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.plugins.job.support.listener.BatchListenerEventType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.CommonDistributedOptions.Analytics: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.CommonDistributedOptions.ControlTransport: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.CommonDistributedOptions.Store: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.DataTransport: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.HadoopDistro: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.SingleNodeOptions.Analytics: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.server.options.SingleNodeOptions.ControlTransport: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.stream.dsl.ChannelType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages.Kind: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.module.ModuleType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.rest.client.AggregateCounterOperations.Resolution: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.rest.client.domain.RESTModuleType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.shell.Target.TargetStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.xd.tuple.batch.FieldSetType: Returns an array containing the constants of this enum type, in the order they are declared.
VndErrorResponseErrorHandler - Class in org.springframework.xd.rest.client.impl: Extension of DefaultResponseErrorHandler that knows how to de-serialize a VndErrors.VndError structure.
VndErrorResponseErrorHandler(List<HttpMessageConverter<?>>) - Constructor for class org.springframework.xd.rest.client.impl.VndErrorResponseErrorHandler

W

withDefaultValue(Object) - Method in class org.springframework.xd.module.options.ModuleOption
withReplacedVariables(Map<String, ModuleNode.ConsumableArgumentNode>) - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode
withType(Class<?>) - Method in class org.springframework.xd.module.options.ModuleOption
write(Collection<?>) - Method in class org.springframework.data.hadoop.x.store.dataset.DatasetTemplateAllowingNulls
write(Collection<?>, PartitionStrategy) - Method in class org.springframework.data.hadoop.x.store.dataset.DatasetTemplateAllowingNulls
write(Kryo, Output, MessageHeaders) - Method in class org.springframework.integration.x.redis.KryoMessageHeadersSerializer
write(List<? extends T>) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
write(List<? extends T>) - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
write(List<? extends T>) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
write(List<? extends T>) - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
write(Message<?>) - Method in class org.springframework.xd.hadoop.fs.AvroWriter
write(Message<?>) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
write(Message<?>) - Method in interface org.springframework.xd.hadoop.fs.HdfsWriter
write(List<? extends Object>) - Method in class org.springframework.xd.mongodb.MongoItemWriter
write(EvaluationContext, Object, String, Object) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor

X

X_JAVA_OBJECT - Static variable in interface org.springframework.integration.x.bus.converter.ContentTypeAwareConverterRegistry: A general MediaType for Java Types
X_JAVA_SERIALIZED_OBJECT - Static variable in interface org.springframework.integration.x.bus.converter.ContentTypeAwareConverterRegistry: A general MediaType for a Java serialized byte array
X_XD_TUPLE - Static variable in interface org.springframework.integration.x.bus.converter.ContentTypeAwareConverterRegistry: An XD MediaType specifying a Tuple
XD_ANALYTICS - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.XDContainer: Base location for XD config files.
XD_CONTROL_TRANSPORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_HADOOP_DISTRO - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_HOME - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_HTTP_PORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_INTERNAL_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.XDContainer: Where container related config files reside.
XD_JMX_ENABLED - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_JMX_PORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_STORE - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XD_TRANSPORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys
XdConfigLoggingInitializer - Class in org.springframework.xd.dirt.util: Initializer that can print useful stuff about an XD context on startup.
XdConfigLoggingInitializer(boolean) - Constructor for class org.springframework.xd.dirt.util.XdConfigLoggingInitializer
XDContainer - Class in org.springframework.xd.dirt.container
XDContainer(String) - Constructor for class org.springframework.xd.dirt.container.XDContainer: Creates a container with a given id
XDContainer() - Constructor for class org.springframework.xd.dirt.container.XDContainer: Default constructor generates a random id
XDController<D extends BaseDefinition,A extends org.springframework.hateoas.mvc.ResourceAssemblerSupport<D,R>,R extends NamedResource> - Class in org.springframework.xd.dirt.rest: Base Class for XD Controllers.
XDController(AbstractDeployer<D>, A) - Constructor for class org.springframework.xd.dirt.rest.XDController
XDController.QueryOptions - Class in org.springframework.xd.dirt.rest: Data holder class for controlling how the list methods should behave.
XDController.QueryOptions() - Constructor for class org.springframework.xd.dirt.rest.XDController.QueryOptions
XDDSLMessages - Enum in org.springframework.xd.dirt.stream.dsl: Contains all the messages that can be produced during Spring XD DSL parsing.
XDDSLMessages.Kind - Enum in org.springframework.xd.dirt.stream.dsl
xdInitializer(ApplicationContext) - Method in class org.springframework.xd.dirt.server.AdminServerApplication
xdInitializer(ApplicationContext) - Method in class org.springframework.xd.dirt.server.LauncherApplication
XDParser - Interface in org.springframework.xd.dirt.stream
XDPropertyKeys - Interface in org.springframework.xd.dirt.server.options: XD property keys.
XDRuntime - Class in org.springframework.xd.rest.client.domain: Represents information about the XD Runtime.
XDRuntime() - Constructor for class org.springframework.xd.rest.client.domain.XDRuntime
XDRuntimeException - Exception in org.springframework.xd.dirt.core: Base class for all XD-related exceptions.
XDRuntimeException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.core.XDRuntimeException
XDRuntimeException(String) - Constructor for exception org.springframework.xd.dirt.core.XDRuntimeException
XDShell - Class in org.springframework.xd.shell
XDShell() - Constructor for class org.springframework.xd.shell.XDShell
XDShellBannerProvider - Class in org.springframework.xd.shell: Provides the Spring XD specific BannerProvider.
XDShellBannerProvider() - Constructor for class org.springframework.xd.shell.XDShellBannerProvider
XDShellPromptProvider - Class in org.springframework.xd.shell: A provider that sets the shell prompt to xd:>
XDShellPromptProvider() - Constructor for class org.springframework.xd.shell.XDShellPromptProvider
XDStreamParser - Class in org.springframework.xd.dirt.stream
XDStreamParser(CrudRepository<? extends BaseDefinition, String>, ModuleDefinitionRepository, ModuleOptionsMetadataResolver) - Constructor for class org.springframework.xd.dirt.stream.XDStreamParser
XDStreamParser(ModuleDefinitionRepository, ModuleOptionsMetadataResolver) - Constructor for class org.springframework.xd.dirt.stream.XDStreamParser

Z

zSetOperations - Variable in class org.springframework.xd.store.AbstractRedisRepository

A B C D E F G H I J K L M N O P Q R S T U V W X Z