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

A factory for TupleSqlParameterSources

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