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

A

AbstractContainerEvent - Class in org.springframework.xd.dirt.event
 
AbstractContainerEvent(Container) - Constructor for class org.springframework.xd.dirt.event.AbstractContainerEvent
 
AbstractContainerEventListener - Class in org.springframework.xd.dirt.listener
 
AbstractContainerEventListener() - Constructor for class org.springframework.xd.dirt.listener.AbstractContainerEventListener
 
AbstractEvent<S> - Class in org.springframework.xd.dirt.event
 
AbstractEvent(S) - Constructor for class org.springframework.xd.dirt.event.AbstractEvent
 
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
 
AbstractModule - Class in org.springframework.xd.module
 
AbstractModule(String, String) - Constructor for class org.springframework.xd.module.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
 
AbstractModuleRegistry() - Constructor for class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
addComponents(Resource) - Method in interface org.springframework.xd.module.Module
 
addComponents(Resource) - Method in class org.springframework.xd.module.SimpleModule
 
addDeployment(String, List<ModuleDeploymentRequest>) - Method in class org.springframework.xd.dirt.stream.DefaultStreamDeployer
 
addListener(ApplicationListener<?>) - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
addProperties(Properties) - Method in interface org.springframework.xd.module.Module
 
addProperties(Properties) - Method in class org.springframework.xd.module.SimpleModule
 
AdminMain - Class in org.springframework.xd.dirt.server
The main driver class for the admin.
AdminMain() - Constructor for class org.springframework.xd.dirt.server.AdminMain
 
AdminOptions - Class in org.springframework.xd.dirt.server
A class the defines the options that will be parsed on the command line
AdminOptions() - Constructor for class org.springframework.xd.dirt.server.AdminOptions
 
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
 
afterPropertiesSet() - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
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.batch.item.mongodb.MongoItemWriter
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.stream.StreamServer
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.stream.Tap
 
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
 
afterUpdate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener
 
apply(Statement, Description) - Method in class org.springframework.xd.test.redis.RedisAvailableRule
 
ArgumentNode - Class in org.springframework.xd.dirt.stream.dsl.ast
 
ArgumentNode(String, String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ast.ArgumentNode
 
AstNode - Class in org.springframework.xd.dirt.stream.dsl.ast
Common supertype for the ast nodes built during stream parsing.
AstNode(int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ast.AstNode
 

B

BannerUtils - Class in org.springframework.xd.dirt.listener.util
Provides utilities for rendering graphical console output.
bridge(SubscribableChannel, MessageChannel, String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
bridge(SubscribableChannel, MessageChannel, String, String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
build() - Method in class org.springframework.xd.tuple.TupleBuilder
 

C

CacheServer - Class in org.springframework.xd.gemfire
 
CacheServer() - Constructor for class org.springframework.xd.gemfire.CacheServer
 
ChannelExporter - Interface in org.springframework.integration.module.config
Strategy interface to expose module inputs and outputs
ChannelRegistry - Interface in org.springframework.integration.x.channel.registry
A strategy interface used to bind a MessageChannel to a logical name.
cleanAll(String) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry
Remove all subscriptions to inter-module channels for this module and stop any active components that use those channels.
cleanAll(String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
cleanAll(String) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry
 
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.gemfire.LoggingCacheListener
 
close() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
 
close() - Method in interface org.springframework.xd.hadoop.fs.HdfsWriter
 
Container - Interface in org.springframework.xd.dirt.core
 
ContainerLauncher - Interface in org.springframework.xd.dirt.launcher
 
ContainerMain - Class in org.springframework.xd.dirt.server
The main driver class for the container
ContainerMain() - Constructor for class org.springframework.xd.dirt.server.ContainerMain
 
ContainerOptions - Class in org.springframework.xd.dirt.server
A class the defines the options that will be parsed on the command line
ContainerOptions() - Constructor for class org.springframework.xd.dirt.server.ContainerOptions
 
ContainerStartedEvent - Class in org.springframework.xd.dirt.event
 
ContainerStartedEvent(Container) - Constructor for class org.springframework.xd.dirt.event.ContainerStartedEvent
 
ContainerStoppedEvent - Class in org.springframework.xd.dirt.event
 
ContainerStoppedEvent(Container) - Constructor for class org.springframework.xd.dirt.event.ContainerStoppedEvent
 
convert(FieldSet) - Method in class org.springframework.xd.batch.item.mongodb.FieldSetConverter
 
convert(String) - Method in class org.springframework.xd.tuple.StringToDateConverter
 
copy(byte[], FSDataOutputStream) - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
Simple not optimized copy
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
count() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
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
CounterRepository - Interface in org.springframework.xd.analytics.metrics.core
A marker interface for Counter repositories.
CounterService - Interface in org.springframework.xd.analytics.metrics.core
A Counter service that allows you to increment and decrement the count by one.
createSharedChannel(String, Class<T>) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
createSqlParameterSource(FieldSet) - Method in class org.springframework.xd.batch.item.jdbc.FieldSetSqlParameterSourceProvider
 
createSqlParameterSource(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider
 
createWriter() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
createWriter() - Method in interface org.springframework.xd.hadoop.fs.HdfsWriterFactory
 

D

decrement(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterService
Decrement the counter by one
decrement(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterService
Decrement the FieldValueCounter for a given field name by one
decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterService
 
decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterService
 
decrement(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
decrement(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterService
 
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
 
decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterService
 
decrementCounter(Counter) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
 
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_FILE_SUFFIX - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
DefaultChannelExporter - Class in org.springframework.integration.module.config
The Default ChannelExporter for Modules.
DefaultChannelExporter() - Constructor for class org.springframework.integration.module.config.DefaultChannelExporter
 
DefaultContainer - Class in org.springframework.xd.dirt.container
 
DefaultContainer(String) - Constructor for class org.springframework.xd.dirt.container.DefaultContainer
Creates a container with a given id
DefaultContainer() - Constructor for class org.springframework.xd.dirt.container.DefaultContainer
Default constructor generates a random id
DefaultContainerLauncher - Class in org.springframework.xd.dirt.launcher
 
DefaultContainerLauncher() - Constructor for class org.springframework.xd.dirt.launcher.DefaultContainerLauncher
 
DefaultStreamDeployer - Class in org.springframework.xd.dirt.stream
 
DefaultStreamDeployer(MessageChannel) - Constructor for class org.springframework.xd.dirt.stream.DefaultStreamDeployer
 
DefaultStreamParser - Class in org.springframework.xd.dirt.stream
 
DefaultStreamParser() - Constructor for class org.springframework.xd.dirt.stream.DefaultStreamParser
 
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
 
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
 
deleteAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
deployStream(String, String) - Method in class org.springframework.xd.dirt.stream.DefaultStreamDeployer
 
deployStream(String, String) - Method in interface org.springframework.xd.dirt.stream.StreamDeployer
 
destroy() - Method in class org.springframework.integration.x.redis.RedisChannelRegistry
 
doStart() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
 
doStart() - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter
 
doStop() - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter
 
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
DSLParseException - Exception in org.springframework.xd.dirt.stream.dsl
Root exception for DSL parsing related exceptions.
DSLParseException(String, int, XDDSLMessages, Object...) - Constructor for exception org.springframework.xd.dirt.stream.dsl.DSLParseException
 
DSLParseException(int, XDDSLMessages, Object...) - Constructor for exception org.springframework.xd.dirt.stream.dsl.DSLParseException
 
DSLParseException(int, Throwable, XDDSLMessages, Object...) - Constructor for exception org.springframework.xd.dirt.stream.dsl.DSLParseException
 

E

endpos - Variable in class org.springframework.xd.dirt.stream.dsl.ast.AstNode
 
EnhancedStreamParser - Class in org.springframework.xd.dirt.stream
 
EnhancedStreamParser() - Constructor for class org.springframework.xd.dirt.stream.EnhancedStreamParser
 
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.tuple.DefaultTuple
 
ExceptionWrappingLettuceConnectionFactory - Class in org.springframework.xd.dirt.redis
Temporary extension of LettuceConnectionFactory that addresses DATAREDIS-191 LettuceConnectionFactory should throw wrapped Exceptions on connection failure
ExceptionWrappingLettuceConnectionFactory() - Constructor for class org.springframework.xd.dirt.redis.ExceptionWrappingLettuceConnectionFactory
 
ExceptionWrappingLettuceConnectionFactory(String, int) - Constructor for class org.springframework.xd.dirt.redis.ExceptionWrappingLettuceConnectionFactory
 
exists(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
extract(JsonNode) - Method in class org.springframework.integration.x.json.JsonNodeFieldExtractor
 
extract(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleFieldExtractor
 

F

FieldSetConverter - Class in org.springframework.xd.batch.item.mongodb
 
FieldSetConverter() - Constructor for class org.springframework.xd.batch.item.mongodb.FieldSetConverter
 
FieldSetSqlParameterSourceProvider - Class in org.springframework.xd.batch.item.jdbc
 
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
 
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(FieldValueCounterService, String, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler
 
FieldValueCounterRepository - Interface in org.springframework.xd.analytics.metrics.core
A repository to save, delete and find FieldValueCounter instances.
FieldValueCounterService - Interface in org.springframework.xd.analytics.metrics.core
A Counter service that allows you to increment and decrement the count by one for a specific field.
FileModuleRegistry - Class in org.springframework.xd.dirt.module
 
FileModuleRegistry(String) - Constructor for class org.springframework.xd.dirt.module.FileModuleRegistry
 
findAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
findAll(Iterable<String>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
findOne(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
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.

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
GaugeHandler - Class in org.springframework.xd.analytics.metrics.integration
 
GaugeHandler(GaugeService, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.GaugeHandler
 
GaugeRepository - Interface in org.springframework.xd.analytics.metrics.core
A marker interface for Gauge repositories.
GaugeService - Interface in org.springframework.xd.analytics.metrics.core
A Gauge service that allows you to set the value of the gauge.
generateId() - Method in class org.springframework.xd.dirt.container.UUIDGenerator
 
getActiveProfiles() - Method in class org.springframework.integration.module.IntegrationModule
 
getApplicationContext() - Method in class org.springframework.xd.module.SimpleModule
 
getArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ast.ModuleNode
 
getArgumentsAsProperties() - Method in class org.springframework.xd.dirt.stream.dsl.ast.ModuleNode
 
getAttributes() - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
getBanner() - Static method in class org.springframework.xd.dirt.listener.util.BannerUtils
Retrieves the ASCII resource "banner.txt" from the classpath.
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
 
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
 
getCause() - Method in exception org.springframework.xd.dirt.stream.dsl.InternalParseException
 
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'.
getCollectionName() - Method in class org.springframework.xd.batch.item.mongodb.MongoItemWriter
 
getComponents(Class<T>) - Method in interface org.springframework.xd.module.Module
 
getComponents(Class<T>) - Method in class org.springframework.xd.module.SimpleModule
 
getContainerId() - Method in class org.springframework.xd.dirt.event.AbstractModuleEvent
 
getConverter(Class<T>) - Method in class org.springframework.xd.tuple.LocaleAwareStringToNumberConverterFactory
 
getCount() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
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
 
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.
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'.
getEndPos() - Method in class org.springframework.xd.dirt.stream.dsl.ast.AstNode
 
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
 
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
 
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'.
getGroup() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
getHttpPort() - Method in class org.springframework.xd.dirt.server.AdminOptions
 
getId() - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
getId() - Method in interface org.springframework.xd.dirt.core.Container
 
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
 
getInputChannel(Map<String, MessageChannel>) - Method in interface org.springframework.integration.module.config.ChannelExporter
 
getInputChannel(Map<String, MessageChannel>) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
getInputChannel() - Method in class org.springframework.integration.module.IntegrationModule
 
getInputChannelName() - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
getInserts() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLParseException
 
getInstanceId() - Method in class org.springframework.xd.module.AbstractModule
 
getInstanceId() - Method in interface org.springframework.xd.module.Module
 
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'.
getIntegrationModuleBasePath() - Method in class org.springframework.integration.module.IntegrationPlugin
 
getKind() - Method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages
 
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
 
getMean() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
getMessage() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLParseException
 
getMessageCode() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLParseException
 
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
 
getModule() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
getModule(String) - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamNode
Find the first reference to the named module in the stream.
getModule(String) - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
getModuleNodes() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamNode
 
getModuleNodes() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
getModules() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
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
 
getName() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
getName() - Method in class org.springframework.xd.dirt.stream.dsl.ast.ArgumentNode
 
getName() - Method in class org.springframework.xd.dirt.stream.dsl.ast.ModuleNode
 
getName() - Method in class org.springframework.xd.module.AbstractModule
 
getName() - Method in interface org.springframework.xd.module.Module
 
getObject() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
 
getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
 
getOrCreate(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterService
Returns an existing counter for the given name or creates a new counter set to zero
getOrCreate(String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterService
Returns an existing FieldValueCounter for the given name or creates a new FieldValueCounter with the counts of all fields set to zero
getOrCreate(String) - Method in interface org.springframework.xd.analytics.metrics.core.GaugeService
Returns an existing gauge for the given name or creates a new gauge set to zero
getOrCreate(String) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeService
Returns an existing gauge for the given name or creates a new gauge set to zero
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeService
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeService
 
getOutputChannelPrefix() - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
getOutputChannels(Map<String, MessageChannel>) - Method in interface org.springframework.integration.module.config.ChannelExporter
 
getOutputChannels(Map<String, MessageChannel>, Class<T>) - Method in interface org.springframework.integration.module.config.ChannelExporter
 
getOutputChannels(Map<String, MessageChannel>) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
getOutputChannels(Map<String, MessageChannel>, Class<T>) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
getOutputChannels() - Method in class org.springframework.integration.module.IntegrationModule
 
getParameters() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
getPhase() - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
getPhase() - Method in class org.springframework.xd.dirt.stream.StreamServer
 
getPhase() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
getProperties() - Method in interface org.springframework.xd.module.Module
 
getProperties() - Method in class org.springframework.xd.module.SimpleModule
 
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).
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
 
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'.
getSource() - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
getStartPos() - Method in class org.springframework.xd.dirt.stream.dsl.ast.AstNode
 
getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamNode
 
getStreamNodes() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
getStreams() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
getStreamsText() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
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
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
getTransport() - Method in class org.springframework.xd.dirt.server.AdminOptions
 
getTransport() - Method in class org.springframework.xd.dirt.server.ContainerOptions
 
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
getTweets() - Method in class org.springframework.integration.x.twitter.TwitterSearchMessageSource
 
getType() - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
getType() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
getType() - Method in class org.springframework.xd.module.AbstractModule
 
getType() - Method in interface org.springframework.xd.module.Module
 
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.ast.ArgumentNode
 
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.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.listener.util.BannerUtils
 
getXDHomeDir() - Method in class org.springframework.xd.dirt.server.AdminOptions
 
getXDHomeDir() - Method in class org.springframework.xd.dirt.server.ContainerOptions
 
getZSetData(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 

H

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
 
handleMessageInternal(Message<?>) - Method in class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter
 
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
hasArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ast.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.tuple.DefaultTuple
 
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
 
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
 

I

inbound(String, MessageChannel) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry
Register a message consumer
inbound(String, MessageChannel) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance.
inbound(String, MessageChannel) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry
 
increment(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterService
Increment the counter by one
increment(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterService
Increment the FieldValueCounter for a given field name by one
increment(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterService
 
increment(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterService
 
increment(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
increment(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterService
 
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
 
increment(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterService
 
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(Counter) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
 
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.
init() - Method in class org.springframework.xd.integration.hadoop.config.HadoopNamespaceHandler
 
initConnection() - Method in class org.springframework.xd.dirt.redis.ExceptionWrappingLettuceConnectionFactory
 
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
 
initializeModule() - Method in class org.springframework.integration.module.IntegrationModule
 
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
 
InMemoryCounterService - Class in org.springframework.xd.analytics.metrics.memory
An in memory based implementation.
InMemoryCounterService(InMemoryCounterRepository) - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryCounterService
 
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
 
InMemoryFieldValueCounterService - Class in org.springframework.xd.analytics.metrics.memory
An in memory based implementation of the FieldValueCounterService
InMemoryFieldValueCounterService(InMemoryFieldValueCounterRepository) - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterService
 
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
 
InMemoryGaugeService - Class in org.springframework.xd.analytics.metrics.memory
An in memory based implementation of the GaugeService
InMemoryGaugeService(InMemoryGaugeRepository) - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeService
 
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
 
InMemoryRichGaugeService - Class in org.springframework.xd.analytics.metrics.memory
An in memory based implementation of RichGaugeService.
InMemoryRichGaugeService(InMemoryRichGaugeRepository) - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeService
 
IntegrationModule - Class in org.springframework.integration.module
 
IntegrationModule(String) - Constructor for class org.springframework.integration.module.IntegrationModule
 
IntegrationModule(String, ChannelExporter) - Constructor for class org.springframework.integration.module.IntegrationModule
 
IntegrationPlugin - Class in org.springframework.integration.module
 
IntegrationPlugin(ChannelRegistry) - Constructor for class org.springframework.integration.module.IntegrationPlugin
 
InternalParseException - Exception in org.springframework.xd.dirt.stream.dsl
Wraps a real parse exception.
InternalParseException(DSLParseException) - Constructor for exception org.springframework.xd.dirt.stream.dsl.InternalParseException
 
isAutoStartup() - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
isAutoStartup() - Method in class org.springframework.xd.dirt.stream.StreamServer
 
isAutoStartup() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
isInputChannel(String, MessageChannel) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
Determine if a given bean is the input channel
isOutputChannel(String, MessageChannel) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
Determine if a given bean is an output channel
isRemove() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
isRunning() - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
isRunning() - Method in class org.springframework.xd.dirt.stream.StreamServer
 
isRunning() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
isRunning() - Method in class org.springframework.xd.module.SimpleModule
 
isShowHelp() - Method in class org.springframework.xd.dirt.server.AdminOptions
 
isShowHelp() - Method in class org.springframework.xd.dirt.server.ContainerOptions
 
isSingleton() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
 

J

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
 
JsonStringToObjectTransformer - Class in org.springframework.integration.x.gemfire
 
JsonStringToObjectTransformer() - Constructor for class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer
 
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
 

L

launch() - Method in interface org.springframework.xd.dirt.launcher.ContainerLauncher
 
launch() - Method in class org.springframework.xd.dirt.launcher.DefaultContainerLauncher
 
launch() - Method in class org.springframework.xd.dirt.launcher.RedisContainerLauncher
 
LAUNCHER_CONFIG_LOCATION - Static variable in interface org.springframework.xd.dirt.launcher.ContainerLauncher
 
launchStreamServer(String) - Static method in class org.springframework.xd.dirt.server.AdminMain
Launch stream server with the given home and transport
lifecycleMonitor - Variable in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
loadResource(String, String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
loadResource(String, String) - Method in class org.springframework.xd.dirt.module.FileModuleRegistry
 
loadResource(String, String) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
 
LocalChannelRegistry - Class in org.springframework.integration.x.channel.registry
A simple implementation of ChannelRegistry for in-process use.
LocalChannelRegistry() - Constructor for class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
LocalContainerEventListener - Class in org.springframework.xd.dirt.listener
 
LocalContainerEventListener() - Constructor for class org.springframework.xd.dirt.listener.LocalContainerEventListener
 
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
 
logger - Variable in class org.springframework.xd.dirt.stream.StreamServer
 
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
 
lookup(String, String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
lookup(String, String) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry
 
lookupOrCreateSharedChannel(String, Class<T>) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
lookupSharedChannel(String, Class<T>) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 

M

main(String[]) - Static method in class org.springframework.xd.dirt.launcher.DefaultContainerLauncher
 
main(String[]) - Static method in class org.springframework.xd.dirt.launcher.RedisContainerLauncher
 
main(String[]) - Static method in class org.springframework.xd.dirt.server.AdminMain
 
main(String[]) - Static method in class org.springframework.xd.dirt.server.ContainerMain
Start the RedisContainerLauncher
main(String[]) - Static method in class org.springframework.xd.gemfire.CacheServer
 
mapFieldSet(FieldSet) - Method in class org.springframework.xd.tuple.batch.TupleFieldSetMapper
 
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
 
MessageCounterHandler - Class in org.springframework.xd.analytics.metrics.integration
Counts the number of non-null messages using an underlying CounterService.
MessageCounterHandler(CounterService, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.MessageCounterHandler
 
Metric - Interface in org.springframework.xd.analytics.metrics.core
 
metricPrefix - Variable in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
MetricRepository<M extends Metric> - Interface in org.springframework.xd.analytics.metrics.core
A repository to save, delete and find Metric instances.
MetricsException - Exception in org.springframework.xd.analytics.metrics
 
MetricsException(String) - Constructor for exception org.springframework.xd.analytics.metrics.MetricsException
 
MetricsException(String, Throwable) - Constructor for exception org.springframework.xd.analytics.metrics.MetricsException
 
MetricUtils - Class in org.springframework.xd.analytics.metrics.core
Utility class to avoid exposing mutable Counters beyond the core package.
MetricUtils() - Constructor for class org.springframework.xd.analytics.metrics.core.MetricUtils
 
Module - Interface in org.springframework.xd.module
 
MODULE_TYPE - Static variable in class org.springframework.integration.module.IntegrationModule
 
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
 
ModuleDeployer(ModuleRegistry) - 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
 
ModuleNode - Class in org.springframework.xd.dirt.stream.dsl.ast
 
ModuleNode(String, int, int, ArgumentNode[]) - Constructor for class org.springframework.xd.dirt.stream.dsl.ast.ModuleNode
 
ModuleRegistry - Interface in org.springframework.xd.dirt.module
 
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.batch.item.mongodb
 
MongoItemWriter(MongoOperations) - Constructor for class org.springframework.xd.batch.item.mongodb.MongoItemWriter
 

N

NettyHttpInboundChannelAdapter - Class in org.springframework.integration.x.http
 
NettyHttpInboundChannelAdapter(int) - Constructor for class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
 
newTuple(List<String>, List<Object>) - Method in class org.springframework.xd.tuple.TupleBuilder
 

O

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
 
onApplicationEvent(AbstractContainerEvent) - Method in class org.springframework.xd.dirt.listener.AbstractContainerEventListener
 
onApplicationEvent(AbstractModuleEvent) - Method in class org.springframework.xd.dirt.listener.RedisModuleEventListener
 
onContainerStartedEvent(ContainerStartedEvent) - Method in class org.springframework.xd.dirt.listener.AbstractContainerEventListener
 
onContainerStartedEvent(ContainerStartedEvent) - Method in class org.springframework.xd.dirt.listener.LocalContainerEventListener
 
onContainerStartedEvent(ContainerStartedEvent) - Method in class org.springframework.xd.dirt.listener.RedisContainerEventListener
 
onContainerStoppedEvent(ContainerStoppedEvent) - Method in class org.springframework.xd.dirt.listener.AbstractContainerEventListener
 
onContainerStoppedEvent(ContainerStoppedEvent) - Method in class org.springframework.xd.dirt.listener.LocalContainerEventListener
 
onContainerStoppedEvent(ContainerStoppedEvent) - Method in class org.springframework.xd.dirt.listener.RedisContainerEventListener
 
onInit() - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter
 
org.springframework.integration.module - package org.springframework.integration.module
 
org.springframework.integration.module.config - package org.springframework.integration.module.config
 
org.springframework.integration.x.channel.registry - package org.springframework.integration.x.channel.registry
 
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.redis - package org.springframework.integration.x.redis
 
org.springframework.integration.x.twitter - package org.springframework.integration.x.twitter
 
org.springframework.xd.analytics.metrics - package org.springframework.xd.analytics.metrics
 
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.batch.item.mongodb - package org.springframework.xd.batch.item.mongodb
 
org.springframework.xd.dirt.container - package org.springframework.xd.dirt.container
 
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.launcher - package org.springframework.xd.dirt.launcher
 
org.springframework.xd.dirt.listener - package org.springframework.xd.dirt.listener
 
org.springframework.xd.dirt.listener.util - package org.springframework.xd.dirt.listener.util
Contains Utility Methods used by EventListeners.
org.springframework.xd.dirt.module - package org.springframework.xd.dirt.module
 
org.springframework.xd.dirt.plugins - package org.springframework.xd.dirt.plugins
 
org.springframework.xd.dirt.redis - package org.springframework.xd.dirt.redis
 
org.springframework.xd.dirt.server - package org.springframework.xd.dirt.server
Contains the Main classes for Admin and Container.
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.dsl.ast - package org.springframework.xd.dirt.stream.dsl.ast
 
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.config - package org.springframework.xd.integration.hadoop.config
 
org.springframework.xd.integration.hadoop.outbound - package org.springframework.xd.integration.hadoop.outbound
 
org.springframework.xd.module - package org.springframework.xd.module
 
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
 
outbound(String, MessageChannel) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry
Register a message producer
outbound(String, MessageChannel) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.
outbound(String, MessageChannel) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry
 

P

parse(String, String) - Method in class org.springframework.xd.dirt.stream.DefaultStreamParser
 
parse(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
 
parse(String, String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
 
parse(String, String) - Method in class org.springframework.xd.dirt.stream.EnhancedStreamParser
 
parse(String, String) - Method in interface org.springframework.xd.dirt.stream.StreamParser
 
parseConsumer(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.HdfsOutboundChannelAdapterParser
 
Plugin - Interface in org.springframework.xd.module
 
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
 
processModule(Module, String, int) - Method in class org.springframework.integration.module.IntegrationPlugin
 
processModule(Module, String, int) - Method in class org.springframework.xd.dirt.plugins.StreamPlugin
 
processModule(Module, String, int) - Method in interface org.springframework.xd.module.Plugin
 
processValue(String, Object) - Method in class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler
 
put(String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder
 

R

RedisAvailableRule - Class in org.springframework.xd.test.redis
 
RedisAvailableRule() - Constructor for class org.springframework.xd.test.redis.RedisAvailableRule
 
RedisChannelRegistry - Class in org.springframework.integration.x.redis
A ChannelRegistry implementation backed by Redis.
RedisChannelRegistry(RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisChannelRegistry
 
RedisContainerEventListener - Class in org.springframework.xd.dirt.listener
 
RedisContainerEventListener(RedisConnectionFactory) - Constructor for class org.springframework.xd.dirt.listener.RedisContainerEventListener
 
RedisContainerLauncher - Class in org.springframework.xd.dirt.launcher
 
RedisContainerLauncher(RedisConnectionFactory) - Constructor for class org.springframework.xd.dirt.launcher.RedisContainerLauncher
 
RedisCounterRepository - Class in org.springframework.xd.analytics.metrics.redis
Redis backed implementation that uses Redis keys to store and update the value.
RedisCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
RedisCounterRepository(RedisConnectionFactory, String) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
RedisCounterService - Class in org.springframework.xd.analytics.metrics.redis
A Redis backed implementation.
RedisCounterService(RedisCounterRepository) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterService
 
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
 
RedisFieldValueCounterService - Class in org.springframework.xd.analytics.metrics.redis
 
RedisFieldValueCounterService(RedisFieldValueCounterRepository) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterService
 
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
 
RedisGaugeService - Class in org.springframework.xd.analytics.metrics.redis
A Redis backed implementation.
RedisGaugeService(RedisGaugeRepository) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisGaugeService
 
RedisModuleEventListener - Class in org.springframework.xd.dirt.listener
 
RedisModuleEventListener(RedisConnectionFactory) - Constructor for class org.springframework.xd.dirt.listener.RedisModuleEventListener
 
RedisModuleRegistry - Class in org.springframework.xd.dirt.module
 
RedisModuleRegistry(RedisConnectionFactory) - Constructor for class org.springframework.xd.dirt.module.RedisModuleRegistry
 
RedisQueueInboundChannelAdapter - Class in org.springframework.integration.x.redis
 
RedisQueueInboundChannelAdapter(String, RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter
 
RedisQueueOutboundChannelAdapter - Class in org.springframework.integration.x.redis
 
RedisQueueOutboundChannelAdapter(String, RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter
 
RedisRichGaugeRepository - Class in org.springframework.xd.analytics.metrics.redis
 
RedisRichGaugeRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
 
RedisRichGaugeService - Class in org.springframework.xd.analytics.metrics.redis
A Redis backed implementation.
RedisRichGaugeService(RedisRichGaugeRepository) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeService
 
redisTemplate - Variable in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
removeDeployment(String) - Method in class org.springframework.xd.dirt.stream.DefaultStreamDeployer
 
removeModule(Module, String, int) - Method in class org.springframework.integration.module.IntegrationPlugin
 
removeModule(Module, String, int) - Method in class org.springframework.xd.dirt.plugins.StreamPlugin
 
removeModule(Module, String, int) - Method in interface org.springframework.xd.module.Plugin
 
reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterService
Reset the counter to zero
reset(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterService
Reset the FieldValueCounter to zero for the given field name
reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.GaugeService
Reset the gauge to zero
reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeService
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.InMemoryCounterService
 
reset(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterService
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeService
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeService
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterService
 
reset(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
reset(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterService
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeService
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
 
reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeService
 
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
 
resetCounter(Counter) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
 
resetRichGauge(RichGauge) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
 
RichGauge - Class in org.springframework.xd.analytics.metrics.core
A gauge which stores the maximum, minimum and simple mean 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, long) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge
 
RichGaugeHandler - Class in org.springframework.xd.analytics.metrics.integration
 
RichGaugeHandler(RichGaugeService, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.RichGaugeHandler
 
RichGaugeService - Interface in org.springframework.xd.analytics.metrics.core
A service for managing RichGauge instances.

S

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
 
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
setActiveProfiles(String[]) - Method in class org.springframework.integration.module.IntegrationModule
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
 
setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.dirt.launcher.DefaultContainerLauncher
 
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.dirt.launcher.RedisContainerLauncher
 
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
setAttribute(String, String) - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
setAutoStartup(boolean) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
 
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
 
setCollectionName(String) - Method in class org.springframework.xd.batch.item.mongodb.MongoItemWriter
 
setContextPath(String) - Method in class org.springframework.xd.dirt.stream.StreamServer
Set the contextPath
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
 
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
 
setExtractPayload(boolean) - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter
 
setExtractPayload(boolean) - Method in class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter
 
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
 
setFormattingConversionService(FormattingConversionService) - Method in class org.springframework.xd.tuple.TupleBuilder
 
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
 
setIndex(int) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
setInputChannelName(String) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
setInstanceId(String) - Method in class org.springframework.xd.module.AbstractModule
 
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.
setModule(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
setNames(List<String>) - Method in class org.springframework.xd.tuple.batch.TupleFieldExtractor
An ordered list of field names to be extracted from each item.
setNumberFormatFromLocale(Locale) - Method in class org.springframework.xd.tuple.TupleBuilder
 
setOutputChannel(MessageChannel) - Method in class org.springframework.xd.dirt.stream.Tap
 
setOutputChannelPrefix(String) - Method in class org.springframework.integration.module.config.DefaultChannelExporter
 
setParameter(String, String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
setParentContext(ApplicationContext) - Method in interface org.springframework.xd.module.Module
 
setParentContext(ApplicationContext) - Method in class org.springframework.xd.module.SimpleModule
 
setPhase(int) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
setRemove(boolean) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
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
 
setServletName(String) - Method in class org.springframework.xd.dirt.stream.StreamServer
Set the servletName.
setType(String) - 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.
setValue(String, long) - Method in interface org.springframework.xd.analytics.metrics.core.GaugeService
Set the value of the gauge
setValue(String, double) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeService
Sets the current value of the gauge.
setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeService
 
setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeService
 
setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository
 
setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeService
 
setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository
 
setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeService
 
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
 
SimpleModule(String, String) - Constructor for class org.springframework.xd.module.SimpleModule
 
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.
start() - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
start() - Method in class org.springframework.xd.dirt.stream.StreamServer
 
start() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
start() - Method in class org.springframework.xd.module.SimpleModule
 
startpos - Variable in class org.springframework.xd.dirt.stream.dsl.ast.AstNode
 
stop() - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
stop(Runnable) - Method in class org.springframework.xd.dirt.container.DefaultContainer
 
stop() - Method in class org.springframework.xd.dirt.stream.StreamServer
 
stop(Runnable) - Method in class org.springframework.xd.dirt.stream.StreamServer
 
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.SimpleModule
 
StreamConfigParser - Class in org.springframework.xd.dirt.stream.dsl
 
StreamConfigParser() - Constructor for class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
 
StreamDeployer - Interface in org.springframework.xd.dirt.stream
 
streamDeployer - Variable in class org.springframework.xd.dirt.stream.StreamServer
 
StreamNode - Class in org.springframework.xd.dirt.stream.dsl.ast
 
StreamNode(String, List<ModuleNode>) - Constructor for class org.springframework.xd.dirt.stream.dsl.ast.StreamNode
 
StreamParser - Interface in org.springframework.xd.dirt.stream
 
StreamPlugin - Class in org.springframework.xd.dirt.plugins
 
StreamPlugin(ChannelRegistry) - Constructor for class org.springframework.xd.dirt.plugins.StreamPlugin
 
StreamServer - Class in org.springframework.xd.dirt.stream
 
StreamServer(StreamDeployer) - Constructor for class org.springframework.xd.dirt.stream.StreamServer
 
StreamServer(StreamDeployer, int) - Constructor for class org.springframework.xd.dirt.stream.StreamServer
 
StreamsNode - Class in org.springframework.xd.dirt.stream.dsl.ast
 
StreamsNode(String, List<StreamNode>) - Constructor for class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
stringify() - Method in class org.springframework.xd.dirt.stream.dsl.ast.ArgumentNode
 
stringify() - Method in class org.springframework.xd.dirt.stream.dsl.ast.AstNode
 
stringify() - Method in class org.springframework.xd.dirt.stream.dsl.ast.ModuleNode
 
stringify() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamNode
 
stringify() - Method in class org.springframework.xd.dirt.stream.dsl.ast.StreamsNode
 
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
 

T

tap(String, String, MessageChannel) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry
Create a tap on an already registered inbound channel
tap(String, String, MessageChannel) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry
Looks up a wiretap for the inbound channel with the given name and creates a bridge from that wiretap's output channel to the provided channel instance.
tap(String, String, MessageChannel) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry
 
Tap - Class in org.springframework.xd.dirt.stream
 
Tap(String, String, ChannelRegistry) - Constructor for class org.springframework.xd.dirt.stream.Tap
 
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.event.AbstractEvent
 
toString() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest
 
toString(Token) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser
 
toString() - Method in class org.springframework.xd.module.AbstractModule
 
toString() - Method in class org.springframework.xd.tuple.DefaultTuple
 
transform(String) - Method in class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer
 
transform(Object) - Method in class org.springframework.integration.x.json.StringToJsonNodeTransformer
 
transformPayload(String) - Method in class org.springframework.xd.tuple.integration.JsonToTupleTransformer
 
transformPayload(Map) - Method in class org.springframework.xd.tuple.integration.MapToTupleTransformer
 
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
 
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
 
TupleProcessor - Interface in org.springframework.xd.tuple.processor
Simple type-safe process callback method that returns another Tuple
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
TupleSqlParameterSourceProvider() - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider
 
TwitterSearchMessageSource - Class in org.springframework.integration.x.twitter
Temporary implementation that bypasses Spring Integration to use the TwitterTemplate directly since the Twitter v1.0 API is being deprecated.
TwitterSearchMessageSource(String, OAuth2Template) - Constructor for class org.springframework.integration.x.twitter.TwitterSearchMessageSource
 
TwitterSearchMessageSource(String, TwitterTemplate) - Constructor for class org.springframework.integration.x.twitter.TwitterSearchMessageSource
 

U

undeploy(ModuleDeploymentRequest) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
undeployStream(String) - Method in class org.springframework.xd.dirt.stream.DefaultStreamDeployer
 
undeployStream(String) - Method in interface org.springframework.xd.dirt.stream.StreamDeployer
 
UUIDGenerator - Class in org.springframework.xd.dirt.container
 
UUIDGenerator() - Constructor for class org.springframework.xd.dirt.container.UUIDGenerator
 

V

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.tuple.batch.FieldSetType
Returns the enum constant of this type with the specified name.
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.tuple.batch.FieldSetType
Returns an array containing the constants of this enum type, in the order they are declared.

W

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(List<? extends Object>) - Method in class org.springframework.xd.batch.item.mongodb.MongoItemWriter
 
write(Message<?>) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
 
write(Message<?>) - Method in interface org.springframework.xd.hadoop.fs.HdfsWriter
 

X

XD_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.DefaultContainer
Base location for XD config files.
XD_INTERNAL_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.DefaultContainer
Where container related config files reside.
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
 
A B C D E F G H I J L M N O P R S T U V W X 
Spring XD