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

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

AbstractContainerLauncher - Class in org.springframework.xd.dirt.launcher

AbstractContainerLauncher() - Constructor for class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

AbstractDeployer<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream

Abstract implementation of the @link ResourceDeployer interface.

AbstractDeployer(PagingAndSortingRepository<D, String>, DeploymentMessageSender, XDParser, String) - Constructor for class org.springframework.xd.dirt.stream.AbstractDeployer

AbstractDeployer.ErrorMessage - Enum in org.springframework.xd.dirt.stream

AbstractEvent<S> - Class in org.springframework.xd.dirt.event

AbstractEvent(S) - Constructor for class org.springframework.xd.dirt.event.AbstractEvent

AbstractExternalServerAvailableRule - Class in org.springframework.xd.test

AbstractExternalServerAvailableRule() - Constructor for class org.springframework.xd.test.AbstractExternalServerAvailableRule

AbstractHdfsItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop

AbstractHdfsItemWriter() - Constructor for class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

AbstractHdfsWriter - Class in org.springframework.xd.hadoop.fs

Logic for writing to files of a specified size or other strategies go here as they are shared across implementations

AbstractHdfsWriter() - Constructor for class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

AbstractInMemoryRepository<T,ID extends java.io.Serializable> - Class in org.springframework.xd.store

Base implementation for an in-memory store, using a Map internally.

AbstractInMemoryRepository() - Constructor for class org.springframework.xd.store.AbstractInMemoryRepository

AbstractMetricsCommands - Class in org.springframework.xd.shell.command

Base class to factor out similar behavior for all related metrics commands.

AbstractMetricsCommands(String) - Constructor for class org.springframework.xd.shell.command.AbstractMetricsCommands

AbstractModule - Class in org.springframework.xd.module

AbstractModule(ModuleDefinition, DeploymentMetadata) - 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

AbstractOptions - Class in org.springframework.xd.dirt.server.options

Options shared by both the admin and the container server.

AbstractOptions() - Constructor for class org.springframework.xd.dirt.server.options.AbstractOptions

AbstractOptions.JmxDisabledHandler - Class in org.springframework.xd.dirt.server.options

AbstractOptions.JmxDisabledHandler(CmdLineParser, OptionDef, Setter<Boolean>) - Constructor for class org.springframework.xd.dirt.server.options.AbstractOptions.JmxDisabledHandler

AbstractOptions.PayloadTransformerHandler - Class in org.springframework.xd.dirt.server.options

AbstractOptions.PayloadTransformerHandler(CmdLineParser, OptionDef, Setter<String>) - Constructor for class org.springframework.xd.dirt.server.options.AbstractOptions.PayloadTransformerHandler

AbstractPlugin - Class in org.springframework.xd.module

AbstractPlugin() - Constructor for class org.springframework.xd.module.AbstractPlugin

AbstractRedisDefinitionRepository<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream.redis

Helper class for repositories persisting BaseDefinitions, acknowledging the fact that the definition name is a String and using it as a key.

AbstractRedisDefinitionRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository

AbstractRedisInstanceRepository<I extends BaseInstance<?>> - Class in org.springframework.xd.dirt.stream.redis

Helper class for repositories persisting BaseInstances, acknowledging the fact that the instance can use the definition name as a key.

AbstractRedisInstanceRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository

AbstractRedisRepository<T,ID extends java.io.Serializable> - Class in org.springframework.xd.store

Base implementation for a store, using Redis behind the scenes.

AbstractRedisRepository(String, RedisOperations<String, String>) - Constructor for class org.springframework.xd.store.AbstractRedisRepository

AbstractRepository<T,ID extends java.io.Serializable> - Class in org.springframework.xd.store

Helper class for repositories, implementing some behavior in terms of unit methods.

AbstractRepository() - Constructor for class org.springframework.xd.store.AbstractRepository

addAttribute(String, Object) - Method in class org.springframework.xd.module.DeploymentMetadata

addBeanDefinition(String, BeanDefinition) - Method in class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

Allows you to add custom BeanDefinitions.

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.DeploymentMessageSender

addHeader(Integer, TableHeader) - Method in class org.springframework.xd.shell.util.Table

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

addScript(Resource) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer

addValue(Date, long) - Method in class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource

Add a data point to the set.

addValue(Integer, String) - Method in class org.springframework.xd.shell.util.TableRow

Add a value to the to the specified column within this row.

AdminController - Class in org.springframework.xd.dirt.rest

AdminController(EntityLinks) - Constructor for class org.springframework.xd.dirt.rest.AdminController

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.options

A class the defines the options that will be parsed on the admin command line.

AdminOptions() - Constructor for class org.springframework.xd.dirt.server.options.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

afterPropertiesSet() - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer

afterPropertiesSet() - Method in class org.springframework.xd.shell.XDShell

afterRegionClear(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener

afterRegionCreate(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener

afterRegionDestroy(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener

afterRegionInvalidate(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener

afterRegionLive(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener

afterReturningInvocation(ParseResult, Object) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

afterReturningInvocation(ParseResult, Object) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

afterThrowingInvocation(ParseResult, Throwable) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

afterThrowingInvocation(ParseResult, Throwable) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

afterUpdate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.LoggingCacheListener

aggrCounterOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

aggrCounterOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Aggregate Counters.

AggregateCount - Class in org.springframework.xd.analytics.metrics.core

AggregateCount(String, Interval, long[], DateTimeField) - Constructor for class org.springframework.xd.analytics.metrics.core.AggregateCount

AggregateCounterCommands - Class in org.springframework.xd.shell.command

Commands for interacting with aggregate counter analytics.

AggregateCounterCommands() - Constructor for class org.springframework.xd.shell.command.AggregateCounterCommands

AggregateCounterHandler - Class in org.springframework.xd.analytics.metrics.integration

AggregateCounterHandler(AggregateCounterRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.AggregateCounterHandler

AggregateCounterOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available when dealing with Aggregate Counters.

AggregateCounterOperations.Resolution - Enum in org.springframework.xd.rest.client

AggregateCounterRepository - Interface in org.springframework.xd.analytics.metrics.core

A repository to interact with Aggregate Counters.

AggregateCountersController - Class in org.springframework.xd.dirt.rest.metrics

Exposes representations of AggregateCounts.

AggregateCountersController(AggregateCounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.AggregateCountersController

AggregateCountersController.Resolution - Enum in org.springframework.xd.dirt.rest.metrics

The resolution at which to collect data between two dates.

AggregateCounterTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Aggregate Counter part of the metrics API.

AggregateCounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.AggregateCounterTemplate

AggregateCountsResource - Class in org.springframework.xd.rest.client.domain.metrics

The REST representation of an Aggregate Count.

AggregateCountsResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource

No-arg constructor for serialization frameworks.

AggregateCountsResource(String) - Constructor for class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource

AlreadyDeployedException - Exception in org.springframework.xd.dirt.stream

Thrown when an attempt is made to deploy a definition that is already deployed.

AlreadyDeployedException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.AlreadyDeployedException

Create a new exception.

AlreadyDeployedException(String, String, Throwable) - Constructor for exception org.springframework.xd.dirt.stream.AlreadyDeployedException

Create a new exception.

Analytics - Enum in org.springframework.xd.dirt.server.options

The kind of persistence mechanism used to store analytics.

apply(Statement, Description) - Method in class org.springframework.xd.test.rabbit.RabbitAvailableRule

apply(Statement, Description) - Method in class org.springframework.xd.test.redis.RedisAvailableRule

ArgumentNode - Class in org.springframework.xd.dirt.stream.dsl

Represents an argument like "--name=value".

ArgumentNode(String, String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ArgumentNode

Assertions - Class in org.springframework.xd.shell.util

Various utility methods when dealing with shell commands.

AstNode - Class in org.springframework.xd.dirt.stream.dsl

Common supertype for the ast nodes built during stream parsing.

AstNode(int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.AstNode

atMostOneOf(Object...) - Static method in class org.springframework.xd.shell.util.Assertions

Accepts 2*N arguments, even ones being names and odd ones being values for those names.

available() - Method in class org.springframework.xd.shell.command.AggregateCounterCommands

available() - Method in class org.springframework.xd.shell.command.CounterCommands

available() - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands

available() - Method in class org.springframework.xd.shell.command.GaugeCommands

available() - Method in class org.springframework.xd.shell.command.JobCommands

available() - Method in class org.springframework.xd.shell.command.RichGaugeCommands

available() - Method in class org.springframework.xd.shell.command.StreamCommands

available() - Method in class org.springframework.xd.shell.command.TapCommands

available() - Method in class org.springframework.xd.shell.command.TriggerCommands

B

BannerUtils - Class in org.springframework.xd.dirt.server.util

Provides utilities for rendering graphical console output.

BaseDefinition - Class in org.springframework.xd.dirt.core

Represents the base model for a data flow in the system.

BaseDefinition(String, String) - Constructor for class org.springframework.xd.dirt.core.BaseDefinition

BaseInstance<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream

A runtime representation of a Definition.

BaseInstance(D) - Constructor for class org.springframework.xd.dirt.stream.BaseInstance

Create a new instance out of the given definition.

BEAN_NAME_PREFIX - Static variable in class org.springframework.xd.dirt.plugins.trigger.TriggerPlugin

BeanDefinitionAddingPostProcessor - Class in org.springframework.xd.module

Implementation of BeanDefinitionRegistryPostProcessor that adds all beans defined in the specified Resources.

BeanDefinitionAddingPostProcessor(Resource...) - Constructor for class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

BeanDefinitionAddingPostProcessor() - Constructor for class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

beforeInvocation(ParseResult) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

beforeInvocation(ParseResult) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

beforeInvocation(ParseResult) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

bridge(MessageChannel, MessageChannel, String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

bridge(MessageChannel, MessageChannel, String, String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

bridge(MessageChannel, MessageChannel, String, Collection<MediaType>) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

bridge(MessageChannel, MessageChannel, String, String, Collection<MediaType>) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

build() - Method in class org.springframework.xd.tuple.TupleBuilder

buildMap() - Method in class org.springframework.xd.store.AbstractInMemoryRepository

C

CacheServer - Class in org.springframework.xd.gemfire

CacheServer() - Constructor for class org.springframework.xd.gemfire.CacheServer

calculateColumnWidths() - Method in class org.springframework.xd.shell.util.Table

cat(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

ChannelExporter - Interface in org.springframework.integration.module.config

Strategy interface to expose module inputs and outputs

ChannelNode - Class in org.springframework.xd.dirt.stream.dsl

ChannelNode(String, String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ChannelNode

ChannelRegistry - Interface in org.springframework.integration.x.channel.registry

A strategy interface used to bind a MessageChannel to a logical name.

ChannelRegistrySupport - Class in org.springframework.integration.x.channel.registry

ChannelRegistrySupport() - Constructor for class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

chgrp(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

chmod(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

chown(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

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

closeReader(Reader) - Static method in class org.springframework.xd.shell.util.CommonUtils

collectionToCommaDelimitedString(Collection<String>) - Static method in class org.springframework.xd.shell.util.CommonUtils

Convert a List of Strings to a comma delimited String.

COLUMN_1 - Static variable in class org.springframework.xd.shell.util.UiUtils

COLUMN_2 - Static variable in class org.springframework.xd.shell.util.UiUtils

COLUMN_3 - Static variable in class org.springframework.xd.shell.util.UiUtils

COLUMN_4 - Static variable in class org.springframework.xd.shell.util.UiUtils

COLUMN_5 - Static variable in class org.springframework.xd.shell.util.UiUtils

COLUMN_6 - Static variable in class org.springframework.xd.shell.util.UiUtils

CommonUtils - Class in org.springframework.xd.shell.util

Contains common non-ui related helper methods for rendering text to the console.

compareTo(BaseDefinition) - Method in class org.springframework.xd.dirt.core.BaseDefinition

componentPathsSelector(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin

componentPathsSelector(Module) - Method in class org.springframework.xd.module.AbstractPlugin

Establish the configuration file path and names required to setup the context for the type of module you are deploying.

concatArrays(List<long[]>, int, int, int) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils

ConfigurationAware - Class in org.springframework.xd.shell.hadoop

Utility base class for components monitoring Configuration changes in order to update state.

ConfigurationAware() - Constructor for class org.springframework.xd.shell.hadoop.ConfigurationAware

configurationChanged() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

Called before invoking a command in case the configuration changed.

configurationChanged() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

ConfigurationCommands - Class in org.springframework.xd.shell.hadoop

Command for configuring the global Hadoop Configuration object used by other components.

ConfigurationCommands() - Constructor for class org.springframework.xd.shell.hadoop.ConfigurationCommands

ConfigurationModifiedEvent - Class in org.springframework.xd.shell.hadoop

Notification event that a Configuration object (attached) has been modified.

ConfigurationModifiedEvent(Configuration) - Constructor for class org.springframework.xd.shell.hadoop.ConfigurationModifiedEvent

configureProperties(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin

configureProperties(Module) - Method in class org.springframework.xd.module.AbstractPlugin

set the properties required for the module based on its type.

configurer() - Method in class org.springframework.xd.dirt.rest.RestConfiguration

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.options

A class the defines the options that will be parsed on the container command line.

ContainerOptions() - Constructor for class org.springframework.xd.dirt.server.options.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(byte[]) - Method in class org.springframework.xd.tuple.JsonBytesToTupleConverter

convert(JsonNode) - Method in class org.springframework.xd.tuple.JsonNodeToTupleConverter

convert(String) - Method in class org.springframework.xd.tuple.JsonStringToTupleConverter

convert(String) - Method in class org.springframework.xd.tuple.StringToDateConverter

convert(Tuple) - Method in class org.springframework.xd.tuple.TupleToJsonStringConverter

convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter

convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter

convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter

convertJsonToList(String) - Static method in class org.springframework.xd.shell.util.JsonUtil

convertJsonToMap(String) - Static method in class org.springframework.xd.shell.util.JsonUtil

convertToJson(Object) - Static method in class org.springframework.xd.shell.util.JsonUtil

copy(byte[], FSDataOutputStream) - Method in class org.springframework.xd.batch.item.hadoop.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

copyFromLocal(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

copyMergeToLocal(String, String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode

copyOf(ArgumentNode[], boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

Construct a copy of the module node but the supplied replacement arguments can adjust the argument set that the resultant copy will have, in three ways: - they can be used to fill in variables in parameters - they can override existing parameters with the same name - they can behave as additional parameters

copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

copyToLocal(String, String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

count() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

count() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

count() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

count(boolean, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

count() - Method in class org.springframework.xd.store.AbstractInMemoryRepository

count() - Method in class org.springframework.xd.store.AbstractRedisRepository

Counter - Class in org.springframework.xd.analytics.metrics.core

Represents the data stored in a valueer of a single value.

Counter(String) - Constructor for class org.springframework.xd.analytics.metrics.core.Counter

Construct a new Counter given a name

Counter(String, long) - Constructor for class org.springframework.xd.analytics.metrics.core.Counter

Construct a new Counter given a name and a initial value of the value

CounterCommands - Class in org.springframework.xd.shell.command

Commands for interacting with Counter analytics.

CounterCommands() - Constructor for class org.springframework.xd.shell.command.CounterCommands

CounterOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available when dealing with Counters.

counterOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

counterOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Counters.

CounterRepository - Interface in org.springframework.xd.analytics.metrics.core

A marker interface for Counter repositories.

CounterResource - Class in org.springframework.xd.rest.client.domain.metrics

The REST representation of a Counter.

CounterResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.CounterResource

No-arg constructor for serialization frameworks.

CounterResource(String, long) - Constructor for class org.springframework.xd.rest.client.domain.metrics.CounterResource

CountersController - Class in org.springframework.xd.dirt.rest.metrics

Exposes representations of Counters.

CountersController(CounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.CountersController

CounterTemplate - Class in org.springframework.xd.rest.client.impl

Implements the CounterOperations part of the API.

CounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.CounterTemplate

counts - Variable in class org.springframework.xd.analytics.metrics.core.AggregateCount

cp(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository

create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository

create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository

createInbound(String, MessageChannel, Collection<MediaType>, boolean) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry

Register a message consumer.

createInbound(String, MessageChannel, Collection<MediaType>, boolean) - 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.

createInbound(String, MessageChannel, Collection<MediaType>, boolean) - Method in class org.springframework.integration.x.rabbit.RabbitChannelRegistry

createInbound(String, MessageChannel, Collection<MediaType>, boolean) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry

createJob(String, String, Boolean) - Method in class org.springframework.xd.rest.client.impl.JobTemplate

createJob(String, String, Boolean) - Method in interface org.springframework.xd.rest.client.JobOperations

Create a new Job, optionally deploying it.

createJob(String, String, Boolean) - Method in class org.springframework.xd.shell.command.JobCommands

createOutbound(String, MessageChannel, boolean) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry

Register a message producer.

createOutbound(String, MessageChannel, boolean) - 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.

createOutbound(String, MessageChannel, boolean) - Method in class org.springframework.integration.x.rabbit.RabbitChannelRegistry

createOutbound(String, MessageChannel, boolean) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry

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

createStream(String, String, boolean) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate

createStream(String, String, boolean) - Method in interface org.springframework.xd.rest.client.StreamOperations

Create a new Stream, optionally deploying it.

createStream(String, String, boolean) - Method in class org.springframework.xd.shell.command.StreamCommands

createTap(String, String, boolean) - Method in class org.springframework.xd.rest.client.impl.TapTemplate

createTap(String, String, boolean) - Method in interface org.springframework.xd.rest.client.TapOperations

Create a new Tap.

createTap(String, String, boolean) - Method in class org.springframework.xd.shell.command.TapCommands

createTrigger(String, String) - Method in class org.springframework.xd.rest.client.impl.TriggerTemplate

createTrigger(String, String) - Method in interface org.springframework.xd.rest.client.TriggerOperations

Create a new Trigger.

createTrigger(String, String) - Method in class org.springframework.xd.shell.command.TriggerCommands

createWriter() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

createWriter() - Method in interface org.springframework.xd.hadoop.fs.HdfsWriterFactory

D

decrement(long) - Method in class org.springframework.xd.analytics.metrics.core.Counter

Decrement this counter by a given amount.

decrement(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository

Decrement the given counter, creating it if it did not exist.

decrement(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository

Decrement the FieldValueCounter for a given field name by one, creating missing counters.

decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository

decrement(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

decrement(String, String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

DeepAggregateCountResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics

Knows how to construct AggregateCountsResource out of AggregateCount.

DeepAggregateCountResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler

DeepCounterResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics

Knows how to assemble CounterResources out of Counters.

DeepCounterResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler

DeepFieldValueCounterResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics

Knows how to create rich representations of FieldValueCounter.

DeepFieldValueCounterResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler

DEFAULT - Static variable in class org.springframework.xd.shell.converter.NumberFormatConverter

DEFAULT_BASE_FILENAME - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

DEFAULT_BASE_PATH - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

DEFAULT_FILE_SUFFIX - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

DEFAULT_HOME - Static variable in class org.springframework.xd.dirt.server.options.AbstractOptions

DEFAULT_HOST - Static variable in class org.springframework.xd.shell.Target

DEFAULT_PORT - Static variable in class org.springframework.xd.shell.Target

DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

DEFAULT_SCHEME - Static variable in class org.springframework.xd.shell.Target

DEFAULT_TARGET - Static variable in class org.springframework.xd.shell.Target

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

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

DefaultTupleConversionService - Class in org.springframework.xd.tuple

Base ConversionService implementation suitable for use with Tuple

DefinitionAlreadyExistsException - Exception in org.springframework.xd.dirt.stream

Exception which is raised when a resource definition with the same name already exists.

DefinitionAlreadyExistsException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.DefinitionAlreadyExistsException

Create a new exception.

definitionFactory(String, String) - Method in class org.springframework.xd.dirt.rest.JobsController

definitionFactory(String, String) - Method in class org.springframework.xd.dirt.rest.StreamsController

definitionFactory(String, String) - Method in class org.springframework.xd.dirt.rest.TapsController

definitionFactory(String, String) - Method in class org.springframework.xd.dirt.rest.TriggersController

definitionFactory(String, String) - Method in class org.springframework.xd.dirt.rest.XDController

delete(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

delete(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

delete(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

delete(M) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

delete(Iterable<? extends M>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

delete(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

delete(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

delete(FieldValueCounter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

delete(Iterable<? extends FieldValueCounter>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

delete(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer

Delete the Definition using the provided name.

delete(String) - Method in class org.springframework.xd.dirt.rest.XDController

Request removal of an existing module.

delete(String) - Method in class org.springframework.xd.dirt.stream.JobDeployer

delete(String) - Method in class org.springframework.xd.dirt.stream.StreamDeployer

delete(String) - Method in class org.springframework.xd.dirt.stream.TapDeployer

delete(String) - Method in class org.springframework.xd.dirt.stream.TriggerDeployer

delete(String) - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations

Delete the given named aggregate counter

delete(String) - Method in interface org.springframework.xd.rest.client.CounterOperations

Delete the counter with given name

delete(String) - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations

Delete the given named field value counter

delete(String) - Method in interface org.springframework.xd.rest.client.GaugeOperations

Delete the given named gauge.

delete(String) - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate

delete(String) - Method in class org.springframework.xd.rest.client.impl.CounterTemplate

delete(String) - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate

delete(String) - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate

delete(String) - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate

delete(String) - Method in interface org.springframework.xd.rest.client.RichGaugeOperations

Delete the given named rich gauge

delete(String) - Method in class org.springframework.xd.shell.command.AggregateCounterCommands

delete(String) - Method in class org.springframework.xd.shell.command.CounterCommands

delete(String) - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands

delete(String) - Method in class org.springframework.xd.shell.command.GaugeCommands

delete(String) - Method in class org.springframework.xd.shell.command.RichGaugeCommands

delete(ID) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

delete(T) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

delete(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository

delete(Iterable<? extends T>) - Method in class org.springframework.xd.store.AbstractRedisRepository

delete(T) - Method in class org.springframework.xd.store.AbstractRedisRepository

delete(Iterable<? extends T>) - Method in class org.springframework.xd.store.AbstractRepository

deleteAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

deleteAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

deleteAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

deleteAll() - Method in class org.springframework.xd.store.AbstractInMemoryRepository

deleteAll() - Method in class org.springframework.xd.store.AbstractRedisRepository

deleteInbound(String) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry

Remove an inbound inter-module channel and stop any active components that use the channel.

deleteInbound(String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

deleteInbound(String) - Method in class org.springframework.integration.x.rabbit.RabbitChannelRegistry

deleteInbound(String) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry

deleteOutbound(String) - Method in interface org.springframework.integration.x.channel.registry.ChannelRegistry

Remove an outbound inter-module channel and stop any active components that use the channel.

deleteOutbound(String) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

deleteOutbound(String) - Method in class org.springframework.integration.x.rabbit.RabbitChannelRegistry

deleteOutbound(String) - Method in class org.springframework.integration.x.redis.RedisChannelRegistry

deleteTrigger(String) - Method in class org.springframework.xd.rest.client.impl.TriggerTemplate

deleteTrigger(String) - Method in interface org.springframework.xd.rest.client.TriggerOperations

deploy(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer

deploy(String) - Method in class org.springframework.xd.dirt.rest.XDController

Request deployment of an existing named module.

deploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

deploy(String) - Method in class org.springframework.xd.dirt.stream.JobDeployer

deploy(String) - Method in class org.springframework.xd.dirt.stream.StreamDeployer

deploy(String) - Method in class org.springframework.xd.dirt.stream.TapDeployer

deployJob(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate

deployJob(String) - Method in interface org.springframework.xd.rest.client.JobOperations

Deploy an already created stream.

deployJob(String) - Method in class org.springframework.xd.shell.command.JobCommands

DeploymentMessageSender - Class in org.springframework.xd.dirt.stream

DeploymentMessageSender(MessageChannel, MessageChannel) - Constructor for class org.springframework.xd.dirt.stream.DeploymentMessageSender

DeploymentMetadata - Class in org.springframework.xd.module

Represents information about a particular module deployment.

DeploymentMetadata(String, int) - Constructor for class org.springframework.xd.module.DeploymentMetadata

DeploymentMetadata(String, int, String, String) - Constructor for class org.springframework.xd.module.DeploymentMetadata

deployStream(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate

deployStream(String) - Method in interface org.springframework.xd.rest.client.StreamOperations

Deploy an already created stream.

deployStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands

deserialize(byte[]) - Method in class org.springframework.redis.x.NoOpRedisSerializer

deserialize(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisJobDefinitionRepository

deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository

deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamRepository

deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisTapDefinitionRepository

deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisTapInstanceRepository

deserialize(String, String) - Method in class org.springframework.xd.dirt.stream.redis.RedisTriggerDefinitionRepository

deserialize(ID, String) - Method in class org.springframework.xd.store.AbstractRedisRepository

Deserialize from the String representation to the domain object.

deserializeId(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

deserializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository

deserializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository

deserializeId(String) - Method in class org.springframework.xd.store.AbstractRedisRepository

Deserialize an entity id from its String representation.

destroy() - Method in class org.springframework.integration.x.rabbit.RabbitChannelRegistry

destroy() - Method in class org.springframework.integration.x.redis.RedisChannelRegistry

destroyJob(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate

destroyJob(String) - Method in interface org.springframework.xd.rest.client.JobOperations

Destroy an existing stream.

destroyJob(String) - Method in class org.springframework.xd.shell.command.JobCommands

destroyStream(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate

destroyStream(String) - Method in interface org.springframework.xd.rest.client.StreamOperations

Destroy an existing stream.

destroyStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands

destroyTap(String) - Method in class org.springframework.xd.rest.client.impl.TapTemplate

destroyTap(String) - Method in interface org.springframework.xd.rest.client.TapOperations

Destroy an existing tap

destroyTap(String) - Method in class org.springframework.xd.shell.command.TapCommands

destroyTrigger(String) - Method in class org.springframework.xd.shell.command.TriggerCommands

display(String, DateTime, DateTime, AggregateCountersController.Resolution) - Method in class org.springframework.xd.dirt.rest.metrics.AggregateCountersController

Retrieve counts for a given time interval, using some precision.

display(String) - Method in class org.springframework.xd.dirt.rest.metrics.CountersController

Retrieve information about a specific counter.

display(String) - Method in class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController

display(String) - Method in class org.springframework.xd.dirt.rest.metrics.GaugesController

display(String) - Method in class org.springframework.xd.dirt.rest.metrics.RichGaugesController

display(String) - Method in class org.springframework.xd.dirt.rest.XDController

Retrieve information about a single ResourceSupport.

display(String, String, String, Integer, Integer, AggregateCounterOperations.Resolution, NumberFormat) - Method in class org.springframework.xd.shell.command.AggregateCounterCommands

display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.CounterCommands

display(String, NumberFormat, int) - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands

display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.GaugeCommands

display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.RichGaugeCommands

displayBanner(String, String) - Static method in class org.springframework.xd.dirt.server.util.BannerUtils

displayMetrics(PagedResources<MetricResource>) - Method in class org.springframework.xd.shell.command.AbstractMetricsCommands

Render a table with information about a list of metrics

doStart() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter

doStart() - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

doStart() - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter

doStart() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

doStop() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter

doStop() - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

doStop() - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter

doStop() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler

DSLException - Exception in org.springframework.xd.dirt.stream.dsl

Root exception for DSL parsing related exceptions.

DSLException(String, int, XDDSLMessages, Object...) - Constructor for exception org.springframework.xd.dirt.stream.dsl.DSLException

du(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

E

eatPossiblyQualifiedLabelOrModuleReference() - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

endpos - Variable in class org.springframework.xd.dirt.stream.dsl.AstNode

EnhancedStreamParser - Class in org.springframework.xd.dirt.stream

EnhancedStreamParser(CrudRepository<? extends BaseDefinition, String>, ModuleRegistry) - Constructor for class org.springframework.xd.dirt.stream.EnhancedStreamParser

EnhancedStreamParser(ModuleRegistry) - 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.dirt.core.BaseDefinition

equals(Object) - Method in class org.springframework.xd.dirt.stream.TapDefinition

equals(String) - Method in enum org.springframework.xd.module.ModuleType

equals(Object) - Method in class org.springframework.xd.shell.util.TableRow

equals(Object) - Method in class org.springframework.xd.tuple.DefaultTuple

exactlyOneOf(Object...) - Static method in class org.springframework.xd.shell.util.Assertions

Accepts 2*N arguments, even ones being names and odd ones being values for those names.

executeBatchJob() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

ExistingXDEntityConverter - Class in org.springframework.xd.shell.converter

A no-op converter from String to String, but that helps with completion in names of already existing entities.

ExistingXDEntityConverter() - Constructor for class org.springframework.xd.shell.converter.ExistingXDEntityConverter

exists(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

exists(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

exists(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository

exists(ID) - Method in class org.springframework.xd.store.AbstractRepository

expressionString - Variable in exception org.springframework.xd.dirt.stream.dsl.DSLException

expunge() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

extract(JsonNode) - Method in class org.springframework.integration.x.json.JsonNodeFieldExtractor

extract(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleFieldExtractor

F

failedComponentName() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

failedComponentName() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

failOrSkipTests(String, Exception) - Method in class org.springframework.xd.test.AbstractExternalServerAvailableRule

FieldSetConverter - Class in org.springframework.xd.batch.item.mongodb

A converter that maps from the batch FieldSet world to Mongo's DBObject.

FieldSetConverter() - Constructor for class org.springframework.xd.batch.item.mongodb.FieldSetConverter

FieldSetSqlParameterSourceProvider - Class in org.springframework.xd.batch.item.jdbc

An ItemSqlParameterSourceProvider that will derive parameters from a FieldSet.

FieldSetSqlParameterSourceProvider() - Constructor for class org.springframework.xd.batch.item.jdbc.FieldSetSqlParameterSourceProvider

FieldSetType - Enum in org.springframework.xd.tuple.batch

Enum used to provide typing information when reading from a file.

FieldValueCounter - Class in org.springframework.xd.analytics.metrics.core

Represents the data stored in a Counter for multiple field-value pairs.

FieldValueCounter(String) - Constructor for class org.springframework.xd.analytics.metrics.core.FieldValueCounter

FieldValueCounter(String, Map<String, Double>) - Constructor for class org.springframework.xd.analytics.metrics.core.FieldValueCounter

FieldValueCounterCommands - Class in org.springframework.xd.shell.command

Commands for interacting with field value counter analytics.

FieldValueCounterCommands() - Constructor for class org.springframework.xd.shell.command.FieldValueCounterCommands

FieldValueCounterHandler - Class in org.springframework.xd.analytics.metrics.integration

Counts the occurrence of values for a set of JavaBean properties or Tuple fields using a FieldValueCounterService.

FieldValueCounterHandler(FieldValueCounterRepository, String, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler

FieldValueCounterOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available when dealing with Field Value Counters.

FieldValueCounterRepository - Interface in org.springframework.xd.analytics.metrics.core

A repository to save, delete and find FieldValueCounter instances.

FieldValueCounterResource - Class in org.springframework.xd.rest.client.domain.metrics

A deep representation of a FieldValueCounter

FieldValueCounterResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.FieldValueCounterResource

No arg constructor for serialization frameworks.

FieldValueCounterResource(String, Map<String, Double>) - Constructor for class org.springframework.xd.rest.client.domain.metrics.FieldValueCounterResource

FieldValueCountersController - Class in org.springframework.xd.dirt.rest.metrics

Controller that exposes FieldValueCounter related representations.

FieldValueCountersController(FieldValueCounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController

FieldValueCounterTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Field Value Counter part of the metrics API.

FieldValueCounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate

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.memory.InMemoryAggregateCounterRepository

findAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

findAll(Iterable<String>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

findAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

findAll(Iterable<String>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

findAll() - Method in interface org.springframework.xd.dirt.core.ResourceDeployer

Return all definitions ordered by BaseDefinition.getName() ascending.

findAll() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

findAll() - Method in class org.springframework.xd.store.AbstractInMemoryRepository

findAll(Pageable) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

findAll(Sort) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

findAll() - Method in class org.springframework.xd.store.AbstractRedisRepository

findAll(Iterable<ID>) - Method in class org.springframework.xd.store.AbstractRedisRepository

findAll(Pageable) - Method in class org.springframework.xd.store.AbstractRedisRepository

findAll(Sort) - Method in class org.springframework.xd.store.AbstractRedisRepository

findAll(Iterable<ID>) - Method in class org.springframework.xd.store.AbstractRepository

findDefinitions(String) - Method in class org.springframework.xd.dirt.module.FileModuleRegistry

findDefinitions(String) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry

Searches the registry for the name specified and returns all module definitions that match the name regardless of module type.

findDefinitions(String) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry

findOne(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

findOne(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

findOne(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

findOne(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer

Retrieves a single Definition or null if none is found.

findOne(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

findOne(ID) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

findOne(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository

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.

fromBytes(byte[]) - Method in class org.springframework.integration.x.json.TypedJsonMapper

fromBytes(byte[], String) - Method in class org.springframework.integration.x.json.TypedJsonMapper

UnMarshall to a requested class

fromString(String) - Static method in class org.springframework.xd.tuple.TupleBuilder

fromTuple(Tuple) - Method in class org.springframework.xd.tuple.TupleStringMarshaller

FsShellCommands - Class in org.springframework.xd.shell.hadoop

HDFS shell commands

FsShellCommands() - Constructor for class org.springframework.xd.shell.hadoop.FsShellCommands

fvcOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

fvcOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Field Value Counters.

G

Gauge - Class in org.springframework.xd.analytics.metrics.core

Represents the data stored in a Gauge which can be set to any integral value.

Gauge(String) - Constructor for class org.springframework.xd.analytics.metrics.core.Gauge

Construct a new Gauge given a name

Gauge(String, long) - Constructor for class org.springframework.xd.analytics.metrics.core.Gauge

Construct a new Gauge given a name and a initial value of the value

GaugeCommands - Class in org.springframework.xd.shell.command

Commands for interacting with Gauge analytics.

GaugeCommands() - Constructor for class org.springframework.xd.shell.command.GaugeCommands

GaugeHandler - Class in org.springframework.xd.analytics.metrics.integration

GaugeHandler(GaugeRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.GaugeHandler

GaugeOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available when dealing with Gauge.

gaugeOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

gaugeOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Gauge.

GaugeRepository - Interface in org.springframework.xd.analytics.metrics.core

A marker interface for Gauge repositories.

GaugeResource - Class in org.springframework.xd.rest.client.domain.metrics

The REST representation of a Gauge.

GaugeResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.GaugeResource

No-arg constructor for serialization frameworks.

GaugeResource(String, long) - Constructor for class org.springframework.xd.rest.client.domain.metrics.GaugeResource

GaugesController - Class in org.springframework.xd.dirt.rest.metrics

Exposes representations of Gauges.

GaugesController(GaugeRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.GaugesController

GaugeTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Gauge part of the metrics API.

GaugeTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.GaugeTemplate

generateId() - Method in class org.springframework.xd.dirt.container.UUIDGenerator

generateId() - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

generateId() - Method in class org.springframework.xd.dirt.launcher.RabbitContainerLauncher

generateId() - Method in class org.springframework.xd.dirt.launcher.RedisContainerLauncher

generateSplunkEvent(Object) - Method in class org.springframework.integration.x.splunk.SplunkTransformer

get(String, String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

getActiveProfiles() - Method in class org.springframework.integration.module.IntegrationModule

getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter

getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter

getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter

getAlpha() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

getAlpha() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

getAnalytics() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions

getApplicationContext() - Method in class org.springframework.xd.module.SimpleModule

getArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

getArgumentsAsProperties() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

getAttribute(String, Class<T>) - Method in class org.springframework.xd.module.DeploymentMetadata

getAttributes() - Method in class org.springframework.xd.dirt.event.AbstractEvent

getAverage() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

Either an exponential weighted moving average or a simple mean, respectively, depending on whether the weight 'alpha' has been set for this gauge.

getAverage() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

Return the average value for the gauge.

getBanner() - Method in class org.springframework.xd.shell.XDShellBannerProvider

getBaseFilename() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

getBaseFilename() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

getBaseFilename() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

getBaseFilename() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

getBasePath() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

getBasePath() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

getBasePath() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

getBasePath() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

getBean(String, Class<T>) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

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

getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode

getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode

getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

getChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode

getChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

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

getColumns() - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer

getComponent(Class<T>) - Method in interface org.springframework.xd.module.Module

getComponent(String, Class<T>) - Method in interface org.springframework.xd.module.Module

getComponent(Class<T>) - Method in class org.springframework.xd.module.SimpleModule

getComponent(String, Class<T>) - Method in class org.springframework.xd.module.SimpleModule

getComponentType() - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

getComponentType() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

getConfiguration() - Method in class org.springframework.xd.shell.hadoop.ConfigurationModifiedEvent

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

getCount() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

getCounter() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

getCounter() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

getCounter() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

getCounterFromName(String) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

getCounterFromName(String) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

getCounterFromName(String) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

getCounts(String, Interval, DateTimeField) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository

Query function to allow the counts for a specific interval to be retrieved.

getCounts(String, Interval, DateTimeField) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

getCounts(String, Interval, DateTimeField) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

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.

getDefaultMetaVariable() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions.JmxDisabledHandler

getDefaultMetaVariable() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions.PayloadTransformerHandler

getDefinition() - Method in class org.springframework.xd.dirt.core.BaseDefinition

Returns a String representation of the desired data flow, expressed in the XD DSL.

getDefinition() - Method in class org.springframework.xd.dirt.stream.BaseInstance

Return the underlying definition.

getDefinition() - Method in class org.springframework.xd.rest.client.domain.JobDefinitionResource

getDefinition() - Method in class org.springframework.xd.rest.client.domain.StreamDefinitionResource

getDefinition() - Method in class org.springframework.xd.rest.client.domain.TriggerDefinitionResource

getDeployer() - Method in class org.springframework.xd.dirt.rest.XDController

getDeploymentMetadata() - Method in class org.springframework.xd.module.AbstractModule

getDeploymentMetadata() - Method in interface org.springframework.xd.module.Module

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.AstNode

getExpressionString() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLException

getFieldCount() - Method in class org.springframework.xd.tuple.DefaultTuple

getFieldCount() - Method in interface org.springframework.xd.tuple.Tuple

Return the number of fields in this tuple.

getFieldNames() - Method in class org.springframework.xd.tuple.DefaultTuple

Return the values for all the fields in this tuple

getFieldNames() - Method in interface org.springframework.xd.tuple.Tuple

Return the fields names that can reference elements by name in this tuple

getFieldTypes() - Method in class org.springframework.xd.tuple.DefaultTuple

getFieldTypes() - Method in interface org.springframework.xd.tuple.Tuple

Return the Java types of the fields in this tuple.

getFieldValueCount() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter

getFieldValueCounts() - Method in class org.springframework.xd.rest.client.domain.metrics.FieldValueCounterResource

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

getGroup() - Method in class org.springframework.xd.module.DeploymentMetadata

getHadoopConfiguration() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

Gets the hadoop configuration.

getHeaderBorder(Map<Integer, TableHeader>) - Static method in class org.springframework.xd.shell.util.UiUtils

Renders the Table header border, based on the map of provided headers.

getHeaders() - Method in class org.springframework.xd.shell.util.Table

getHttpPort() - Method in class org.springframework.xd.dirt.server.options.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

getIndex() - Method in class org.springframework.xd.module.DeploymentMetadata

getIndexOfLabelOrModuleName(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

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

getInputChannelName() - Method in class org.springframework.xd.module.DeploymentMetadata

getInserts() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLException

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

getJmxPort() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions

getJmxPort() - Method in class org.springframework.xd.dirt.server.options.AdminOptions

getJmxPort() - Method in class org.springframework.xd.dirt.server.options.ContainerOptions

getJvmName() - Method in class org.springframework.xd.dirt.container.DefaultContainer

getJvmName() - Method in interface org.springframework.xd.dirt.core.Container

getKind() - Method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages

getLabelName() - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode

getLabelNames() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

getLocalPort() - Method in class org.springframework.xd.dirt.stream.StreamServer

Get the underlying HTTP port if a random port was requested, user port = 0.

getLong(String) - Method in class org.springframework.xd.tuple.DefaultTuple

getLong(int) - Method in class org.springframework.xd.tuple.DefaultTuple

getLong(String, long) - Method in class org.springframework.xd.tuple.DefaultTuple

getLong(int, long) - Method in class org.springframework.xd.tuple.DefaultTuple

getLong(int) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'long' value at index 'index'.

getLong(String) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'int' value from column with given 'name'.

getLong(int, long) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'long' value at index 'index'.

getLong(String, long) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'long' value from column with given 'name'.

getMax() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

getMax() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

getMaxWidth() - Method in class org.springframework.xd.shell.util.TableHeader

getMessage() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLException

getMessage() - Method in exception org.springframework.xd.rest.client.impl.SpringXDException

getMessageCode() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLException

getMetricKey(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

Provides the key for a named metric.

getMin() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

getMin() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

getModule() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

getModule(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

Find the first reference to the named module in the stream.

getModule(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

getModuleName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

getModuleNodes() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

getModuleNodes() - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

getModuleReferenceNode() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

getModules() - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

getModuleTypeByTypeName(String) - Static method in enum org.springframework.xd.module.ModuleType

getName() - Method in class org.springframework.xd.analytics.metrics.core.Counter

getName() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter

getName() - Method in class org.springframework.xd.analytics.metrics.core.Gauge

getName() - Method in interface org.springframework.xd.analytics.metrics.core.Metric

Return the name of the metric.

getName() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

getName() - Method in class org.springframework.xd.dirt.core.BaseDefinition

Returns a unique name given to that stream definition.

getName() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode

getName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

getName() - Method in class org.springframework.xd.module.AbstractModule

getName() - Method in interface org.springframework.xd.module.Module

getName() - Method in class org.springframework.xd.module.ModuleDefinition

getName() - Method in class org.springframework.xd.rest.client.domain.NamedResource

Return the name of the represented entity.

getName() - Method in class org.springframework.xd.shell.util.TableHeader

getObject() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean

getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean

getOffendingName() - Method in exception org.springframework.xd.dirt.analytics.NoSuchMetricException

Return the name that was not found.

getOffendingName() - Method in exception org.springframework.xd.dirt.stream.AlreadyDeployedException

Return the name of the already deployed definition.

getOffendingName() - Method in exception org.springframework.xd.dirt.stream.DefinitionAlreadyExistsException

Return the definition name that was in conflict.

getOffendingName() - Method in exception org.springframework.xd.dirt.stream.MissingRequiredDefinitionException

Return the name of the definition that could not be found.

getOffendingName() - Method in exception org.springframework.xd.dirt.stream.NoSuchDefinitionException

Return the name of the definition that could not be found.

getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository

getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository

getOutputChannelName() - Method in class org.springframework.xd.module.DeploymentMetadata

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

getPort() - Method in class org.springframework.xd.dirt.stream.StreamServer

getPosition() - Method in exception org.springframework.xd.dirt.stream.dsl.DSLException

getPrefix() - Method in class org.springframework.xd.store.AbstractRedisRepository

getPrompt() - Method in class org.springframework.xd.shell.XDShellPromptProvider

getProperties() - Method in interface org.springframework.xd.module.Module

getProperties() - Method in class org.springframework.xd.module.ModuleDefinition

getProperties() - Method in class org.springframework.xd.module.SimpleModule

getProperty(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

getProviderName() - Method in class org.springframework.xd.shell.XDShellBannerProvider

getProviderName() - Method in class org.springframework.xd.shell.XDShellPromptProvider

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).

getRepository() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

getResource() - Method in class org.springframework.xd.module.ModuleDefinition

getResourceAssemblerSupport() - Method in class org.springframework.xd.dirt.rest.XDController

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

getRows() - Method in class org.springframework.xd.shell.util.Table

getShort(String) - Method in class org.springframework.xd.tuple.DefaultTuple

getShort(int) - Method in class org.springframework.xd.tuple.DefaultTuple

getShort(String, short) - Method in class org.springframework.xd.tuple.DefaultTuple

getShort(int, short) - Method in class org.springframework.xd.tuple.DefaultTuple

getShort(int) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'short' value at index 'index'.

getShort(String) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'short' value from column with given 'name'.

getShort(int, short) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'short' value at index 'index'.

getShort(String, short) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'short' value from column with given 'name'.

getSinkChannelName() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

getSinkChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

getSize() - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

getSource() - Method in class org.springframework.xd.dirt.event.AbstractEvent

getSourceChannelName() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

getSourceChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

getSpringXDOperations() - Method in class org.springframework.xd.shell.XDShell

getStartedAt() - Method in class org.springframework.xd.dirt.stream.BaseInstance

getStartPos() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode

getStatus() - Method in class org.springframework.xd.shell.Target

Return the target status, which is either Success or Error.

getStore() - Method in class org.springframework.xd.dirt.server.options.AdminOptions

getStreamData() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode

getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

getStreamName(String, String) - Static method in class org.springframework.xd.dirt.stream.TapDefinition

getStreamName() - Method in class org.springframework.xd.dirt.stream.TapDefinition

getStreamName() - Method in class org.springframework.xd.rest.client.domain.TapDefinitionResource

getStreamNodes() - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

getStreams() - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

getStreamsText() - Method in class org.springframework.xd.dirt.stream.dsl.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

getTarget() - Method in class org.springframework.xd.shell.XDShell

Return the Target which encapsulates not only the Target URI but also success/error messages + status.

getTargetException() - Method in class org.springframework.xd.shell.Target

If during targeting an error occurred, the resulting Exception is made available for further introspection.

getTargetResultMessage() - Method in class org.springframework.xd.shell.Target

Provides a result message indicating whether the provide Target.getTargetUri() was successfully targeted or not.

getTargetUri() - Method in class org.springframework.xd.shell.Target

getTargetUriAsString() - Method in class org.springframework.xd.shell.Target

Returns the target URI as a String.

getTimestamp() - Method in class org.springframework.xd.tuple.DefaultTuple

getTimestamp() - Method in interface org.springframework.xd.tuple.Tuple

Get the creation timestamp of this tuple, not included in comparisons for equality

getTotal() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount

getTransformer() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions

getTransport() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions

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

getType() - Method in class org.springframework.xd.module.ModuleDefinition

getTypeName() - Method in enum org.springframework.xd.module.ModuleType

getValue() - Method in class org.springframework.xd.analytics.metrics.core.Counter

getValue() - Method in class org.springframework.xd.analytics.metrics.core.Gauge

getValue() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

getValue() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode

getValue() - Method in class org.springframework.xd.rest.client.domain.metrics.CounterResource

Return the value for the counter.

getValue() - Method in class org.springframework.xd.rest.client.domain.metrics.GaugeResource

Return the value for the gauge.

getValue() - Method in class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

Return the value for the gauge.

getValue(Integer) - Method in class org.springframework.xd.shell.util.TableRow

Return a value from this row.

getValue(String) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSource

getValue(String) - Method in class org.springframework.xd.tuple.DefaultTuple

getValue(int) - Method in class org.springframework.xd.tuple.DefaultTuple

getValue(String, Class<T>) - Method in class org.springframework.xd.tuple.DefaultTuple

getValue(int, Class<T>) - Method in class org.springframework.xd.tuple.DefaultTuple

getValue(String) - Method in interface org.springframework.xd.tuple.Tuple

Return the value of the field given the name

getValue(int) - Method in interface org.springframework.xd.tuple.Tuple

Return the value of the field given the index position

getValue(String, Class<T>) - Method in interface org.springframework.xd.tuple.Tuple

Return the value of the field given the name

getValue(int, Class<T>) - Method in interface org.springframework.xd.tuple.Tuple

Return the value of the field given the index position

getValues() - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer

getValues() - Method in class org.springframework.xd.rest.client.domain.metrics.AggregateCountsResource

Returns a date-sorted view of counts.

getValues() - Method in class org.springframework.xd.tuple.DefaultTuple

Return the values for all the fields in this tuple

getValues() - Method in interface org.springframework.xd.tuple.Tuple

Return the values for all the fields in this tuple

getVersion() - Static method in class org.springframework.xd.dirt.server.util.BannerUtils

getVersion() - Method in class org.springframework.xd.shell.XDShellBannerProvider

Returns the version information as found in the manifest file (set during release).

getWelcomeMessage() - Method in class org.springframework.xd.shell.XDShellBannerProvider

getWidth() - Method in class org.springframework.xd.shell.util.TableHeader

getXDHomeDir() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions

getXmlWebApplicationContext() - Method in class org.springframework.xd.dirt.stream.StreamServer

getZSetData(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

H

HadoopDistro - Enum in org.springframework.xd.dirt.server.options

The Hadoop distribution to use.

HadoopNamespaceHandler - Class in org.springframework.xd.integration.hadoop.config

Namespace handler for Spring Integration's 'hadoop' namespace.

HadoopNamespaceHandler() - Constructor for class org.springframework.xd.integration.hadoop.config.HadoopNamespaceHandler

handleError(ClientHttpResponse) - Method in class org.springframework.xd.rest.client.impl.VndErrorResponseErrorHandler

handleMessageInternal(Message<?>) - Method in class org.springframework.integration.x.redis.RedisPublishingMessageHandler

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.ModuleNode

hasFieldName(String) - Method in class org.springframework.xd.tuple.DefaultTuple

hasFieldName(String) - Method in interface org.springframework.xd.tuple.Tuple

Return true if the tuple contains a field of the given name

hashCode() - Method in class org.springframework.xd.analytics.metrics.core.Counter

hashCode() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter

hashCode() - Method in class org.springframework.xd.analytics.metrics.core.Gauge

hashCode() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

hashCode() - Method in class org.springframework.xd.dirt.core.BaseDefinition

hashCode() - Method in class org.springframework.xd.dirt.stream.TapDefinition

hashCode() - Method in class org.springframework.xd.shell.util.TableRow

hashCode() - Method in class org.springframework.xd.tuple.DefaultTuple

hashOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

hasValue(String) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSource

HdfsOutboundChannelAdapterParser - Class in org.springframework.xd.integration.hadoop.config

Parser for the 'hdfs-outbound-channel-adapter' element.

HdfsOutboundChannelAdapterParser() - Constructor for class org.springframework.xd.integration.hadoop.config.HdfsOutboundChannelAdapterParser

HdfsTextFileWriter - Class in org.springframework.xd.hadoop.fs

HdfsTextFileWriter(FileSystem) - Constructor for class org.springframework.xd.hadoop.fs.HdfsTextFileWriter

HdfsTextFileWriterFactory - Class in org.springframework.xd.hadoop.fs

HdfsTextFileWriterFactory(FileSystem) - Constructor for class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

HdfsTextItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop

HdfsTextItemWriter(FileSystem) - Constructor for class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter

HdfsWriter - Interface in org.springframework.xd.hadoop.fs

HdfsWriterFactory - Interface in org.springframework.xd.hadoop.fs

HdfsWritingMessageHandler - Class in org.springframework.xd.integration.hadoop.outbound

HdfsWritingMessageHandler(HdfsWriterFactory) - Constructor for class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler

HdfsWritingMessageHandlerFactoryBean - Class in org.springframework.xd.integration.hadoop.config

HdfsWritingMessageHandlerFactoryBean(FileSystem) - Constructor for class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean

HORIZONTAL_LINE - Static variable in class org.springframework.xd.shell.util.UiUtils

HttpCommands - Class in org.springframework.xd.shell.command

Http commands.

HttpCommands() - Constructor for class org.springframework.xd.shell.command.HttpCommands

I

idFromRedisKey(String) - Method in class org.springframework.xd.store.AbstractRedisRepository

increment(String, long, DateTime) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository

Increments the named counter by a specific amount for the given instant.

increment(long) - Method in class org.springframework.xd.analytics.metrics.core.Counter

Increment this counter by a given amount.

increment(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository

Increment the given counter by one, creating it if it did not exist.

increment(String, long) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository

Increment the given counter by the specified amount, creating it if it did not exist.

increment(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository

Increment the FieldValueCounter for a given field name by one, creating missing counters.

increment(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

increment(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

increment(String, long, DateTime) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

increment(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

increment(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

increment(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository

increment(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

increment(String, long, DateTime) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

increment(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

increment(String, long) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

increment(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

increment(String, String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

incrementBytesWritten(long) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

incrementBytesWritten(long) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

incrementBytesWritten(long) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

incrementCounter() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

incrementCounter() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

incrementCounter() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

indexOf(String) - Method in class org.springframework.xd.tuple.DefaultTuple

Find the index in the names collection for the given name.

info() - Method in class org.springframework.xd.dirt.rest.AdminController

info() - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

info() - Method in class org.springframework.xd.shell.XDShell

init() - Method in class org.springframework.xd.integration.hadoop.config.HadoopNamespaceHandler

init() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

initialize() - Method in interface org.springframework.xd.module.Module

initialize() - Method in class org.springframework.xd.module.SimpleModule

initializeCounterIfNecessary() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

initializeCounterIfNecessary() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

initializeCounterIfNecessary() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

initializeModule() - Method in class org.springframework.integration.module.IntegrationModule

InMemoryAggregateCounterRepository - Class in org.springframework.xd.analytics.metrics.memory

In-memory aggregate counter with minute resolution.

InMemoryAggregateCounterRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

InMemoryCounterRepository - Class in org.springframework.xd.analytics.metrics.memory

Memory backed implementation of Counter repository that uses a ConcurrentMap.

InMemoryCounterRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

InMemoryFieldValueCounterRepository - Class in org.springframework.xd.analytics.metrics.memory

Memory backed implementation of FieldValueCounterRepository that uses a ConcurrentMap

InMemoryFieldValueCounterRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository

InMemoryGaugeRepository - Class in org.springframework.xd.analytics.metrics.memory

Memory backed Gauge repository that uses a ConcurrentMap

InMemoryGaugeRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository

InMemoryJobDefinitionRepository - Class in org.springframework.xd.dirt.stream.memory

InMemoryJobDefinitionRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryJobDefinitionRepository

InMemoryMetricRepository<M extends Metric> - Class in org.springframework.xd.analytics.metrics.memory

Memory backed implementation of MetricRepository that uses a ConcurrentMap

InMemoryMetricRepository() - Constructor for class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

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

InMemoryStreamDefinitionRepository - Class in org.springframework.xd.dirt.stream.memory

An in memory store of StreamDefinitions.

InMemoryStreamDefinitionRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository

InMemoryStreamRepository - Class in org.springframework.xd.dirt.stream.memory

In memory implementation of StreamRepository.

InMemoryStreamRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryStreamRepository

InMemoryTapDefinitionRepository - Class in org.springframework.xd.dirt.stream.memory

InMemoryTapDefinitionRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryTapDefinitionRepository

InMemoryTapInstanceRepository - Class in org.springframework.xd.dirt.stream.memory

In memory implementation of TapInstanceRepository.

InMemoryTapInstanceRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryTapInstanceRepository

InMemoryTriggerDefinitionRepository - Class in org.springframework.xd.dirt.stream.memory

InMemoryTriggerDefinitionRepository() - Constructor for class org.springframework.xd.dirt.stream.memory.InMemoryTriggerDefinitionRepository

installMessageConverters(List<HttpMessageConverter<?>>) - Static method in class org.springframework.xd.rest.client.util.RestTemplateMessageConverterUtil

Install message converters we're interested in, with json coming before xml.

instantiateResource(JobDefinition) - Method in class org.springframework.xd.dirt.rest.JobDefinitionResourceAssembler

instantiateResource(AggregateCount) - Method in class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler

instantiateResource(Counter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler

instantiateResource(FieldValueCounter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler

instantiateResource(M) - Method in class org.springframework.xd.dirt.rest.metrics.ShallowMetricResourceAssembler

instantiateResource(StreamDefinition) - Method in class org.springframework.xd.dirt.rest.StreamDefinitionResourceAssembler

instantiateResource(TapDefinition) - Method in class org.springframework.xd.dirt.rest.TapDefinitionResourceAssembler

instantiateResource(TriggerDefinition) - Method in class org.springframework.xd.dirt.rest.TriggerDefinitionResourceAssembler

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

interval - Variable in class org.springframework.xd.analytics.metrics.core.AggregateCount

isAliasedInput() - Method in class org.springframework.xd.module.DeploymentMetadata

Return whether the source end is using an aliased name.

isAliasedOutput() - Method in class org.springframework.xd.module.DeploymentMetadata

Return whether the output end is using an aliased name.

isAutoStartup() - Method in class org.springframework.xd.dirt.container.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

isJmxDisabled() - Method in class org.springframework.xd.dirt.server.options.AbstractOptions

isJobStep() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

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.plugins.job.ModuleJobLauncher

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.options.AbstractOptions

isSingleton() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean

isTap() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

isValidEmail(String) - Static method in class org.springframework.xd.shell.util.CommonUtils

J

JdbcMessagePayloadTransformer - Class in org.springframework.xd.jdbc

Transforms a payload to a Map representation based on provided column names.

JdbcMessagePayloadTransformer() - Constructor for class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer

JdbcMessagePayloadTransformer(Class<Map>) - Constructor for class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer

JobCommands - Class in org.springframework.xd.shell.command

Job commands.

JobCommands() - Constructor for class org.springframework.xd.shell.command.JobCommands

JobDefinition - Class in org.springframework.xd.dirt.stream

JobDefinition(String, String) - Constructor for class org.springframework.xd.dirt.stream.JobDefinition

JobDefinitionRepository - Interface in org.springframework.xd.dirt.stream

JobDefinitionResource - Class in org.springframework.xd.rest.client.domain

Represents a Job Definition.

JobDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.JobDefinitionResource

JobDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain

Dedicated subclass to workaround type erasure.

JobDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.JobDefinitionResource.Page

JobDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest

Knows how to build a REST resource out of our domain model StreamDefinition.

JobDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.JobDefinitionResourceAssembler

JobDeployer - Class in org.springframework.xd.dirt.stream

JobDeployer(JobDefinitionRepository, DeploymentMessageSender, XDParser) - Constructor for class org.springframework.xd.dirt.stream.JobDeployer

jobOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

JobOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available against streams.

jobOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Jobs.

JobPlugin - Class in org.springframework.xd.dirt.plugins.job

Plugin to enable the registration of jobs in a central registry.

JobPlugin() - Constructor for class org.springframework.xd.dirt.plugins.job.JobPlugin

JobsController - Class in org.springframework.xd.dirt.rest

Handles all Job related interactions.

JobsController(JobDeployer, JobDefinitionRepository) - Constructor for class org.springframework.xd.dirt.rest.JobsController

JobTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Job-related part of the API.

JsonBytesToTupleConverter - Class in org.springframework.xd.tuple

JsonBytesToTupleConverter() - Constructor for class org.springframework.xd.tuple.JsonBytesToTupleConverter

JsonNodeFieldExtractor - Class in org.springframework.integration.x.json

Extract a field value from a JsonNode

JsonNodeFieldExtractor(String) - Constructor for class org.springframework.integration.x.json.JsonNodeFieldExtractor

JsonNodeToTupleConverter - Class in org.springframework.xd.tuple

JsonNodeToTupleConverter() - Constructor for class org.springframework.xd.tuple.JsonNodeToTupleConverter

JsonStringToObjectTransformer - Class in org.springframework.integration.x.gemfire

JsonStringToObjectTransformer() - Constructor for class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer

JsonStringToTupleConverter - Class in org.springframework.xd.tuple

JsonStringToTupleConverter() - Constructor for class org.springframework.xd.tuple.JsonStringToTupleConverter

JsonToTupleTransformer - Class in org.springframework.xd.tuple.integration

Converts from a json string into a tuple data structure.

JsonToTupleTransformer() - Constructor for class org.springframework.xd.tuple.integration.JsonToTupleTransformer

JsonUtil - Class in org.springframework.xd.shell.util

Some JSON helper utilities.

K

keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

keyFor(JobDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryJobDefinitionRepository

keyFor(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamDefinitionRepository

keyFor(Stream) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryStreamRepository

keyFor(TapDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryTapDefinitionRepository

keyFor(TapInstance) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryTapInstanceRepository

keyFor(TriggerDefinition) - Method in class org.springframework.xd.dirt.stream.memory.InMemoryTriggerDefinitionRepository

keyFor(D) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository

keyFor(I) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository

keyFor(T) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

keyFor(T) - Method in class org.springframework.xd.store.AbstractRedisRepository

Return the entity id for the given domain object.

L

LabelNode - Class in org.springframework.xd.dirt.stream.dsl

Represents a label attached to a module.

LabelNode(String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.LabelNode

launch(ContainerOptions) - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

launch(ContainerOptions) - Method in interface org.springframework.xd.dirt.launcher.ContainerLauncher

launch(ContainerOptions) - Static method in class org.springframework.xd.dirt.server.ContainerMain

Create a container instance

launchStreamServer(AdminOptions) - 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

list(Pageable, PagedResourcesAssembler<JobDefinition>) - Method in class org.springframework.xd.dirt.rest.JobsController

List job definitions.

list(Pageable, PagedResourcesAssembler<Counter>) - Method in class org.springframework.xd.dirt.rest.metrics.AggregateCountersController

List AggregateCounts that match the given criteria.

list(Pageable, PagedResourcesAssembler<Counter>) - Method in class org.springframework.xd.dirt.rest.metrics.CountersController

List Counters that match the given criteria.

list(Pageable, PagedResourcesAssembler<FieldValueCounter>) - Method in class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController

List FieldValueCounters that match the given criteria.

list(Pageable, PagedResourcesAssembler<Gauge>) - Method in class org.springframework.xd.dirt.rest.metrics.GaugesController

list(Pageable, PagedResourcesAssembler<RichGauge>) - Method in class org.springframework.xd.dirt.rest.metrics.RichGaugesController

list(Pageable, PagedResourcesAssembler<StreamDefinition>) - Method in class org.springframework.xd.dirt.rest.StreamsController

List stream definitions.

list(Pageable, PagedResourcesAssembler<TapDefinition>) - Method in class org.springframework.xd.dirt.rest.TapsController

List Tap definitions.

list(Pageable, PagedResourcesAssembler<TriggerDefinition>) - Method in class org.springframework.xd.dirt.rest.TriggersController

List Trigger definitions.

list() - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations

List the names of the available aggregate counters

list() - Method in interface org.springframework.xd.rest.client.CounterOperations

Retrieve basic information (i.e.

list() - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations

Retrieve basic information (i.e.

list() - Method in interface org.springframework.xd.rest.client.GaugeOperations

List the names of the available gauges.

list() - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate

list() - Method in class org.springframework.xd.rest.client.impl.CounterTemplate

list() - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate

list() - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate

list() - Method in class org.springframework.xd.rest.client.impl.JobTemplate

list() - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate

list() - Method in class org.springframework.xd.rest.client.impl.StreamTemplate

list() - Method in class org.springframework.xd.rest.client.impl.TapTemplate

Returns a List of TapDefinitionResources.

list() - Method in class org.springframework.xd.rest.client.impl.TriggerTemplate

Returns a List of TriggerDefinitionResources.

list() - Method in interface org.springframework.xd.rest.client.JobOperations

List streams known to the system.

list() - Method in interface org.springframework.xd.rest.client.RichGaugeOperations

List the names of the available richgauges

list() - Method in interface org.springframework.xd.rest.client.StreamOperations

List streams known to the system.

list() - Method in interface org.springframework.xd.rest.client.TapOperations

Retrieve a list of taps.

list() - Method in interface org.springframework.xd.rest.client.TriggerOperations

Retrieve a list of triggers.

list() - Method in class org.springframework.xd.shell.command.AggregateCounterCommands

list() - Method in class org.springframework.xd.shell.command.CounterCommands

list() - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands

list() - Method in class org.springframework.xd.shell.command.GaugeCommands

list() - Method in class org.springframework.xd.shell.command.RichGaugeCommands

listJobs() - Method in class org.springframework.xd.shell.command.JobCommands

listProps() - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

listStreams() - Method in class org.springframework.xd.shell.command.StreamCommands

listTaps() - Method in class org.springframework.xd.shell.command.TapCommands

listTriggers() - Method in class org.springframework.xd.shell.command.TriggerCommands

listValues(Pageable, PagedResourcesAssembler<D>) - Method in class org.springframework.xd.dirt.rest.XDController

List module definitions.

loadConfiguration(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

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

LOG - Variable in class org.springframework.xd.shell.hadoop.ConfigurationAware

logContainerInfo(Log, Container, ContainerOptions) - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

logContainerInfo(Log, Container, ContainerOptions) - Method in class org.springframework.xd.dirt.launcher.RabbitContainerLauncher

logContainerInfo(Log, Container, ContainerOptions) - Method in class org.springframework.xd.dirt.launcher.RedisContainerLauncher

logErrorInfo(Exception) - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

logErrorInfo(Exception) - Method in class org.springframework.xd.dirt.launcher.RabbitContainerLauncher

logErrorInfo(Exception) - Method in class org.springframework.xd.dirt.launcher.RedisContainerLauncher

logger - Variable in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

logger - Variable in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

logger - Variable in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

logger - Variable in class org.springframework.xd.dirt.stream.StreamServer

logger - Variable in class org.springframework.xd.module.AbstractPlugin

logger - Variable in class org.springframework.xd.test.AbstractExternalServerAvailableRule

LoggingCacheListener<K,V> - Class in org.springframework.xd.gemfire

LoggingCacheListener() - Constructor for class org.springframework.xd.gemfire.LoggingCacheListener

LoggingCacheListener(String) - Constructor for class org.springframework.xd.gemfire.LoggingCacheListener

logUpdateError(Exception) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

longOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

lookup(String, String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry

lookup(String, String) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry

lookupChannelForLabelOrModule(String, String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

lookupChannelForLabelOrModule(String, String) - Method in interface org.springframework.xd.dirt.stream.dsl.StreamLookupEnvironment

Look up an existing label or module name.

lookupStream(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

lookupStream(String) - Method in interface org.springframework.xd.dirt.stream.dsl.StreamLookupEnvironment

Look up a previously defined stream by name, returns the parsed AST for it.

ls(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

M

main(String[]) - Static method in class org.springframework.xd.dirt.server.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

maskPassword(String) - Static method in class org.springframework.xd.shell.util.CommonUtils

Simple method to replace characters in a String with asterisks to mask the password.

maybeEatStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

MBeanExportingPlugin - Class in org.springframework.xd.dirt.plugins

Exports MBeans from a module using a unique domain name xd.[group].[module]

MBeanExportingPlugin() - Constructor for class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

MediaTypeConverter - Class in org.springframework.xd.shell.converter

Knows how to parse String representations of MediaType.

MediaTypeConverter() - Constructor for class org.springframework.xd.shell.converter.MediaTypeConverter

MessageCounterHandler - Class in org.springframework.xd.analytics.metrics.integration

Counts the number of non-null messages using an underlying CounterRepository.

MessageCounterHandler(CounterRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.MessageCounterHandler

Metric - Interface in org.springframework.xd.analytics.metrics.core

Super interface for all metrics.

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.

MetricResource - Class in org.springframework.xd.rest.client.domain.metrics

Base class for resources that adhere to the Metric interface.

MetricResource(String) - Constructor for class org.springframework.xd.rest.client.domain.metrics.MetricResource

Construct a new resource.

MetricResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.MetricResource

No arg constructor for serialization frameworks.

MetricResource.Page - Class in org.springframework.xd.rest.client.domain.metrics

Dedicated subclass to workaround type erasure.

MetricResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.metrics.MetricResource.Page

MetricUtils - Class in org.springframework.xd.analytics.metrics.core

Utility class, primarily to avoid exposing mutable objects beyond the core package.

MetricUtils() - Constructor for class org.springframework.xd.analytics.metrics.core.MetricUtils

MissingRequiredDefinitionException - Exception in org.springframework.xd.dirt.stream

Exception which is raised when a definition is syntactically correct but a required elements definition is missing.

MissingRequiredDefinitionException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.MissingRequiredDefinitionException

Create a new exception.

mkdir(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

Module - Interface in org.springframework.xd.module

MODULE_TYPE - Static variable in class org.springframework.integration.module.IntegrationModule

ModuleDefinition - Class in org.springframework.xd.module

Defines a module.

ModuleDefinition(String, String) - Constructor for class org.springframework.xd.module.ModuleDefinition

ModuleDefinition(String, String, Resource) - Constructor for class org.springframework.xd.module.ModuleDefinition

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

ModuleJobLauncher - Class in org.springframework.xd.dirt.plugins.job

Executes all jobs defined within a given stream once the context has been started.

ModuleJobLauncher(JobLauncher, JobRegistry, boolean) - Constructor for class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

ModuleNode - Class in org.springframework.xd.dirt.stream.dsl

ModuleNode(List<LabelNode>, String, int, int, ArgumentNode[]) - Constructor for class org.springframework.xd.dirt.stream.dsl.ModuleNode

ModuleReferenceNode - Class in org.springframework.xd.dirt.stream.dsl

ModuleReferenceNode(String, String, int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

ModuleRegistry - Interface in org.springframework.xd.dirt.module

ModuleType - Enum in org.springframework.xd.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

moveFromLocal(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

mv(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

N

name - Variable in class org.springframework.xd.analytics.metrics.core.AggregateCount

NamedResource - Class in org.springframework.xd.rest.client.domain

Abstract base class for all resources that have a name.

NamedResource() - Constructor for class org.springframework.xd.rest.client.domain.NamedResource

No arg constructor for serialization frameworks.

NamedResource(String) - Constructor for class org.springframework.xd.rest.client.domain.NamedResource

NettyHttpInboundChannelAdapter - Class in org.springframework.integration.x.http

NettyHttpInboundChannelAdapter(int) - Constructor for class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter

newRow() - Method in class org.springframework.xd.shell.util.Table

Add a new empty row to the table.

newTuple(List<String>, List<Object>) - Method in class org.springframework.xd.tuple.TupleBuilder

NoOpRedisSerializer - Class in org.springframework.redis.x

A pass-through serializer used when the content is already a byte[]/

NoOpRedisSerializer() - Constructor for class org.springframework.redis.x.NoOpRedisSerializer

NoSuchDefinitionException - Exception in org.springframework.xd.dirt.stream

Exception which is raised when a named resource definition cannot be found.

NoSuchDefinitionException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.NoSuchDefinitionException

Create a new exception.

NoSuchMetricException - Exception in org.springframework.xd.dirt.analytics

Thrown when trying to access a named metric that does not exist.

NoSuchMetricException(String, String) - Constructor for exception org.springframework.xd.dirt.analytics.NoSuchMetricException

Construct a new exception.

NoSuchModuleException - Exception in org.springframework.xd.dirt.module

Thrown when attempting to refer to a module that does not exist.

NoSuchModuleException(String) - Constructor for exception org.springframework.xd.dirt.module.NoSuchModuleException

Create a new exception.

NumberFormatConverter - Class in org.springframework.xd.shell.converter

Knows how to convert from a String to a new NumberFormat instance.

NumberFormatConverter() - Constructor for class org.springframework.xd.shell.converter.NumberFormatConverter

O

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.RabbitModuleEventListener

onApplicationEvent(AbstractModuleEvent) - Method in class org.springframework.xd.dirt.listener.RedisModuleEventListener

onApplicationEvent(ConfigurationModifiedEvent) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware

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.RabbitContainerEventListener

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.RabbitContainerEventListener

onContainerStoppedEvent(ContainerStoppedEvent) - Method in class org.springframework.xd.dirt.listener.RedisContainerEventListener

onException(Exception) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the general error case.

onInit() - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

onInit() - Method in class org.springframework.integration.x.redis.RedisPublishingMessageHandler

onInit() - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter

onInvalidDefintion(DSLException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the case where client tried to deploy something that is has an invalid definition.

onMissingRequiredDefinitionException(MissingRequiredDefinitionException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the case where client referenced an entity that already exists.

onMissingServletRequestParameterException(MissingServletRequestParameterException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the case where client submitted an ill valued request (missing parameter).

onNoSuchMetricException(NoSuchMetricException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

onNoSuchStreamException(NoSuchDefinitionException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the case where client referenced an unknown entity.

onStreamAlreadyDeployedException(AlreadyDeployedException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the case where client tried to deploy something that is already deployed.

onStreamAlreadyExistsException(DefinitionAlreadyExistsException) - Method in class org.springframework.xd.dirt.rest.RestControllerAdvice

Handles the case where client referenced an entity that already exists.

options() - Method in class org.springframework.xd.dirt.rest.AdminController

This RequestMapping exists to handle CORS requests only Ensures that our custom HandlerInterceptor is called

OptionUtils - Class in org.springframework.xd.dirt.server.options

OptionUtils() - Constructor for class org.springframework.xd.dirt.server.options.OptionUtils

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.rabbit - package org.springframework.integration.x.rabbit

org.springframework.integration.x.redis - package org.springframework.integration.x.redis

org.springframework.integration.x.splunk - package org.springframework.integration.x.splunk

org.springframework.integration.x.twitter - package org.springframework.integration.x.twitter

org.springframework.redis.x - package org.springframework.redis.x

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.analytics - package org.springframework.xd.dirt.analytics

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.module - package org.springframework.xd.dirt.module

org.springframework.xd.dirt.plugins - package org.springframework.xd.dirt.plugins

Base Package for Spring XD plugins

org.springframework.xd.dirt.plugins.job - package org.springframework.xd.dirt.plugins.job

Provides classes for the Spring Batch Support

org.springframework.xd.dirt.plugins.stream - package org.springframework.xd.dirt.plugins.stream

org.springframework.xd.dirt.plugins.trigger - package org.springframework.xd.dirt.plugins.trigger

Provides support for adding Triggers.

org.springframework.xd.dirt.rest - package org.springframework.xd.dirt.rest

Provides a REST-style API for interacting with the XD runtime.

org.springframework.xd.dirt.rest.metrics - package org.springframework.xd.dirt.rest.metrics

org.springframework.xd.dirt.server - package org.springframework.xd.dirt.server

Contains the Main classes for Admin and Container.

org.springframework.xd.dirt.server.options - package org.springframework.xd.dirt.server.options

org.springframework.xd.dirt.server.util - package org.springframework.xd.dirt.server.util

org.springframework.xd.dirt.stream - package org.springframework.xd.dirt.stream

org.springframework.xd.dirt.stream.dsl - package org.springframework.xd.dirt.stream.dsl

org.springframework.xd.dirt.stream.memory - package org.springframework.xd.dirt.stream.memory

org.springframework.xd.dirt.stream.redis - package org.springframework.xd.dirt.stream.redis

org.springframework.xd.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.jdbc - package org.springframework.xd.jdbc

org.springframework.xd.module - package org.springframework.xd.module

org.springframework.xd.rest.client - package org.springframework.xd.rest.client

Defines the various REST client operation interfaces.

org.springframework.xd.rest.client.domain - package org.springframework.xd.rest.client.domain

Contains the resources managed by the REST API.

org.springframework.xd.rest.client.domain.metrics - package org.springframework.xd.rest.client.domain.metrics

org.springframework.xd.rest.client.impl - package org.springframework.xd.rest.client.impl

Contains REST client operation implementations.

org.springframework.xd.rest.client.util - package org.springframework.xd.rest.client.util

org.springframework.xd.shell - package org.springframework.xd.shell

Contains core Spring XD Shell classes.

org.springframework.xd.shell.command - package org.springframework.xd.shell.command

Defines the various Spring XD Shell commands.

org.springframework.xd.shell.converter - package org.springframework.xd.shell.converter

org.springframework.xd.shell.hadoop - package org.springframework.xd.shell.hadoop

org.springframework.xd.shell.util - package org.springframework.xd.shell.util

Contains utilities for rendering textual contents (E.g.

org.springframework.xd.store - package org.springframework.xd.store

org.springframework.xd.test - package org.springframework.xd.test

org.springframework.xd.test.rabbit - package org.springframework.xd.test.rabbit

org.springframework.xd.test.redis - package org.springframework.xd.test.redis

org.springframework.xd.tuple - package org.springframework.xd.tuple

org.springframework.xd.tuple.batch - package org.springframework.xd.tuple.batch

org.springframework.xd.tuple.integration - package org.springframework.xd.tuple.integration

org.springframework.xd.tuple.processor - package org.springframework.xd.tuple.processor

ORIGINAL_CONTENT_TYPE_HEADER - Static variable in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

P

padRight(String, int, char) - Static method in class org.springframework.xd.shell.util.CommonUtils

Right-pad a String with a configurable padding character.

padRight(String, int) - Static method in class org.springframework.xd.shell.util.CommonUtils

Right-pad the provided String with empty spaces.

parse(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

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 a stream definition without supplying the stream name up front.

parse(String, String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

Parse a stream definition.

parse(String, String) - Method in class org.springframework.xd.dirt.stream.EnhancedStreamParser

parse(String, String) - Method in interface org.springframework.xd.dirt.stream.XDParser

parseArguments(Parameters) - Method in class org.springframework.xd.dirt.server.options.AbstractOptions.JmxDisabledHandler

parseArguments(Parameters) - Method in class org.springframework.xd.dirt.server.options.AbstractOptions.PayloadTransformerHandler

parseConsumer(Element, ParserContext) - Method in class org.springframework.xd.integration.hadoop.config.HdfsOutboundChannelAdapterParser

parseOptions(String[]) - Static method in class org.springframework.xd.dirt.server.AdminMain

Plugin - Interface in org.springframework.xd.module

position - Variable in exception org.springframework.xd.dirt.stream.dsl.DSLException

postHttp(String, String, File, MediaType) - Method in class org.springframework.xd.shell.command.HttpCommands

postProcessBeanDefinitionRegistry(BeanDefinitionRegistry) - Method in class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

postProcessModule(Module) - Method in class org.springframework.integration.module.IntegrationPlugin

postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.trigger.TriggerPlugin

postProcessModule(Module) - Method in class org.springframework.xd.module.AbstractPlugin

postProcessModule(Module) - Method in interface org.springframework.xd.module.Plugin

Apply changes to the module after it is initialized (generally, this means after its context is refreshed), but before it is started.

postProcessModuleInternal(Module) - Method in class org.springframework.xd.module.AbstractPlugin

Perform any plugin-specific post-refresh initialization.

postProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.integration.module.IntegrationPlugin

postProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

postProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

postProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.trigger.TriggerPlugin

Will add the ConfigurableApplicationContext as an instance variable, so it becomes available when registering a new Module.

postProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.module.AbstractPlugin

postProcessSharedContext(ConfigurableApplicationContext) - Method in interface org.springframework.xd.module.Plugin

Make any necessary changes to the shared context.

preProcessModule(Module) - Method in class org.springframework.integration.module.IntegrationPlugin

preProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

preProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

preProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.trigger.TriggerPlugin

Processes a new Trigger being added.

preProcessModule(Module) - Method in class org.springframework.xd.module.AbstractPlugin

Process the Module and add the Application Context resources necessary to setup the Batch Job.

preProcessModule(Module) - Method in interface org.springframework.xd.module.Plugin

Apply changes to the module before it is initialized (generally, this means before its context is refreshed).

preProcessModuleInternal(Module) - Method in class org.springframework.xd.module.AbstractPlugin

Perform any plugin-specific pre-refresh initialization.

process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.AggregateCounterHandler

process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler

process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.GaugeHandler

process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.MessageCounterHandler

process(Message<?>) - Method in class org.springframework.xd.analytics.metrics.integration.RichGaugeHandler

process(Tuple) - Method in interface org.springframework.xd.tuple.processor.TupleProcessor

processValue(String, Object) - Method in class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler

put(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

put(String, Object) - Method in class org.springframework.xd.tuple.TupleBuilder

R

RabbitAvailableRule - Class in org.springframework.xd.test.rabbit

RabbitAvailableRule() - Constructor for class org.springframework.xd.test.rabbit.RabbitAvailableRule

RabbitChannelRegistry - Class in org.springframework.integration.x.rabbit

A ChannelRegistry implementation backed by RabbitMQ.

RabbitChannelRegistry(ConnectionFactory) - Constructor for class org.springframework.integration.x.rabbit.RabbitChannelRegistry

RabbitContainerEventListener - Class in org.springframework.xd.dirt.listener

RabbitContainerEventListener(ConnectionFactory) - Constructor for class org.springframework.xd.dirt.listener.RabbitContainerEventListener

RabbitContainerLauncher - Class in org.springframework.xd.dirt.launcher

RabbitContainerLauncher(ConnectionFactory) - Constructor for class org.springframework.xd.dirt.launcher.RabbitContainerLauncher

RabbitModuleEventListener - Class in org.springframework.xd.dirt.listener

RabbitModuleEventListener(ConnectionFactory) - Constructor for class org.springframework.xd.dirt.listener.RabbitModuleEventListener

RedisAggregateCounterRepository - Class in org.springframework.xd.analytics.metrics.redis

Redis implementation of AggregateCounterRepository.

RedisAggregateCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

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

RedisCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

RedisCounterRepository(String, RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

RedisFieldValueCounterRepository - Class in org.springframework.xd.analytics.metrics.redis

RedisFieldValueCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

RedisFieldValueCounterRepository(RedisConnectionFactory, String) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

RedisGaugeRepository - Class in org.springframework.xd.analytics.metrics.redis

Redis backed implementation that uses Redis keys to store and update the value.

RedisGaugeRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository

RedisGaugeRepository(RedisConnectionFactory, String) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository

RedisInboundChannelAdapter - Class in org.springframework.integration.x.redis

Clone of SI adapter allowing any object type.

RedisInboundChannelAdapter(RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisInboundChannelAdapter

RedisJobDefinitionRepository - Class in org.springframework.xd.dirt.stream.redis

An implementation of JobDefinitionRepository that persists @{link JobDefinition} in Redis.

RedisJobDefinitionRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisJobDefinitionRepository

redisKeyFromId(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository

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

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

RedisPublishingMessageHandler - Class in org.springframework.integration.x.redis

Temporary - clone of SI, but understands the NoOpRedisSerializer.

RedisPublishingMessageHandler(RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisPublishingMessageHandler

RedisQueueInboundChannelAdapter - Class in org.springframework.integration.x.redis

RedisQueueInboundChannelAdapter(String, RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter

RedisQueueInboundChannelAdapter(String, RedisConnectionFactory, RedisSerializer<?>) - 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

RedisQueueOutboundChannelAdapter(String, RedisConnectionFactory, RedisSerializer<?>) - 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

RedisStreamDefinitionRepository - Class in org.springframework.xd.dirt.stream.redis

An implementation of StreamDefinitionRepository that persists StreamDefinition in Redis.

RedisStreamDefinitionRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository

RedisStreamRepository - Class in org.springframework.xd.dirt.stream.redis

Redis implementation of StreamRepository, uses a RedisStreamDefinitionRepository in turn.

RedisStreamRepository(RedisOperations<String, String>, RedisStreamDefinitionRepository) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisStreamRepository

RedisTapDefinitionRepository - Class in org.springframework.xd.dirt.stream.redis

An implementation of TapDefinitionRepository that persists @{link TapDefinition} in Redis.

RedisTapDefinitionRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisTapDefinitionRepository

RedisTapInstanceRepository - Class in org.springframework.xd.dirt.stream.redis

Redis implementation of TapInstanceRepository, uses a RedisTapDefinitionRepository in turn.

RedisTapInstanceRepository(RedisOperations<String, String>, RedisTapDefinitionRepository) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisTapInstanceRepository

redisTemplate - Variable in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

RedisTriggerDefinitionRepository - Class in org.springframework.xd.dirt.stream.redis

An implementation of TriggerDefinitionRepository that persists TriggerDefinitions to Redis.

RedisTriggerDefinitionRepository(RedisOperations<String, String>) - Constructor for class org.springframework.xd.dirt.stream.redis.RedisTriggerDefinitionRepository

remove(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

removeAttribute(String) - Method in class org.springframework.xd.module.DeploymentMetadata

removeDeployment(String) - Method in class org.springframework.xd.dirt.stream.DeploymentMessageSender

removeModule(Module) - Method in class org.springframework.integration.module.IntegrationPlugin

removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.trigger.TriggerPlugin

removeModule(Module) - Method in class org.springframework.xd.module.AbstractPlugin

removeModule(Module) - Method in interface org.springframework.xd.module.Plugin

Take any actions necessary to remove a module from the system.

renderMapDataAsTable(List<Map<String, Object>>, List<String>) - Static method in class org.springframework.xd.shell.util.UiUtils

Renders a textual representation of the list of provided Map data

renderParameterInfoDataAsTable(Map<String, String>, boolean, int) - Static method in class org.springframework.xd.shell.util.UiUtils

renderParameterInfoDataAsTable(Map<String, String>) - Static method in class org.springframework.xd.shell.util.UiUtils

Renders a textual representation of provided parameter map.

renderTextTable(Table) - Static method in class org.springframework.xd.shell.util.UiUtils

renderTextTable(Table, boolean) - Static method in class org.springframework.xd.shell.util.UiUtils

Renders a textual representation of the provided Table

reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository

Reset the given counter to zero.

reset(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository

Reset the FieldValueCounter to zero for the given field name, creating missing counters.

reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.GaugeRepository

Reset the gauge to zero

reset(String) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeRepository

Reset the gauge to zero and reset any accumulated average, max and min values

reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

reset(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository

reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository

reset(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository

reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

reset(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository

reset(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository

resetBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

resetBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

resetBytesWritten() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

resetRichGauge(RichGauge) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils

resolution - Variable in class org.springframework.xd.analytics.metrics.core.AggregateCount

resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

resolve(StreamLookupEnvironment) - Method in class org.springframework.xd.dirt.stream.dsl.StreamsNode

resolveModuleNodes(StreamLookupEnvironment, List<ModuleNode>) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

Does the lookup of module nodes to see if any previously defined and if so replaces them in this stream

ResourceDefinitionException - Exception in org.springframework.xd.dirt.module

Thrown when a problem is detected with the (DSL) definition of an XD resource.

ResourceDefinitionException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.module.ResourceDefinitionException

ResourceDefinitionException(String) - Constructor for exception org.springframework.xd.dirt.module.ResourceDefinitionException

ResourceDeployer<R extends BaseDefinition> - Interface in org.springframework.xd.dirt.core

Interface for XD Resource Services.

RestConfiguration - Class in org.springframework.xd.dirt.rest

Takes care of infrastructure setup for the web/rest layer.

RestConfiguration() - Constructor for class org.springframework.xd.dirt.rest.RestConfiguration

RestControllerAdvice - Class in org.springframework.xd.dirt.rest

Central class for behavior common to all REST controllers.

RestControllerAdvice() - Constructor for class org.springframework.xd.dirt.rest.RestControllerAdvice

RestTemplateMessageConverterUtil - Class in org.springframework.xd.rest.client.util

Utility class that does two things: Resets a RestTemplate's message converters list to have json support come before xml. Force injects JAXBContexts that know about our particular classes

retrieve(String, Date, Date, AggregateCounterOperations.Resolution) - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations

Retrieve the information for the given named AggregateCounter

retrieve(String) - Method in interface org.springframework.xd.rest.client.CounterOperations

Retrieve information about the given named counter.

retrieve(String) - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations

Retrieve information about the given named field value counter.

retrieve(String) - Method in interface org.springframework.xd.rest.client.GaugeOperations

Retrieve information about the given named gauge.

retrieve(String, Date, Date, AggregateCounterOperations.Resolution) - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate

retrieve(String) - Method in class org.springframework.xd.rest.client.impl.CounterTemplate

retrieve(String) - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate

retrieve(String) - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate

retrieve(String) - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate

retrieve(String) - Method in interface org.springframework.xd.rest.client.RichGaugeOperations

Display the value of the named Rich Gauge

RichGauge - Class in org.springframework.xd.analytics.metrics.core

A gauge which stores the maximum, minimum and average in addition to the current value.

RichGauge(String) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge

Creates an "empty" gauge.

RichGauge(String, double) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge

RichGauge(String, double, double, double, double, double, long) - Constructor for class org.springframework.xd.analytics.metrics.core.RichGauge

RichGaugeCommands - Class in org.springframework.xd.shell.command

Commands for interacting with RichGauge analytics.

RichGaugeCommands() - Constructor for class org.springframework.xd.shell.command.RichGaugeCommands

RichGaugeHandler - Class in org.springframework.xd.analytics.metrics.integration

RichGaugeHandler(RichGaugeRepository, String, double) - Constructor for class org.springframework.xd.analytics.metrics.integration.RichGaugeHandler

richGaugeOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

RichGaugeOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available when dealing with Rich Gauge.

richGaugeOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with RichGauge.

RichGaugeRepository - Interface in org.springframework.xd.analytics.metrics.core

A service for managing RichGauge instances.

RichGaugeResource - Class in org.springframework.xd.rest.client.domain.metrics

The REST representation of a RichGauge.

RichGaugeResource() - Constructor for class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

No-arg constructor for serialization frameworks.

RichGaugeResource(String, double, double, double, double, double, long) - Constructor for class org.springframework.xd.rest.client.domain.metrics.RichGaugeResource

RichGaugesController - Class in org.springframework.xd.dirt.rest.metrics

Exposes representations of Gauges.

RichGaugesController(RichGaugeRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.RichGaugesController

RichGaugeTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the RichGauge part of the metrics API.

RichGaugeTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.RichGaugeTemplate

rm(String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

S

save(S) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

save(S) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

save(Iterable<S>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository

save(S) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

save(Iterable<S>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

save(R) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer

save(String, String, boolean) - Method in class org.springframework.xd.dirt.rest.XDController

Create a new Module.

save(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

save(TapDefinition) - Method in class org.springframework.xd.dirt.stream.TapDeployer

save(S) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

save(S) - Method in class org.springframework.xd.store.AbstractRedisRepository

save(Iterable<S>) - Method in class org.springframework.xd.store.AbstractRedisRepository

save(Iterable<S>) - Method in class org.springframework.xd.store.AbstractRepository

select(String) - Method in class org.springframework.xd.tuple.DefaultTuple

select(String) - Method in interface org.springframework.xd.tuple.Tuple

Use SpEL expression to return a subset of the tuple that matches the expression

sendDeploymentRequests(String, List<ModuleDeploymentRequest>) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

sendDeploymentRequests(String, List<ModuleDeploymentRequest>) - Method in class org.springframework.xd.dirt.stream.DeploymentMessageSender

serialize(byte[]) - Method in class org.springframework.redis.x.NoOpRedisSerializer

serialize(Counter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

serialize(JobDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisJobDefinitionRepository

serialize(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository

serialize(Stream) - Method in class org.springframework.xd.dirt.stream.redis.RedisStreamRepository

serialize(TapDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisTapDefinitionRepository

serialize(TapInstance) - Method in class org.springframework.xd.dirt.stream.redis.RedisTapInstanceRepository

serialize(TriggerDefinition) - Method in class org.springframework.xd.dirt.stream.redis.RedisTriggerDefinitionRepository

serialize(T) - Method in class org.springframework.xd.store.AbstractRedisRepository

Provide a String representation of the domain entity.

serializeId(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

serializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository

serializeId(String) - Method in class org.springframework.xd.dirt.stream.redis.AbstractRedisInstanceRepository

serializeId(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository

Return a String representation of the domain ID.

setActiveProfiles(String[]) - Method in class org.springframework.integration.module.IntegrationModule

setAlpha(double) - Method in class org.springframework.xd.analytics.metrics.core.RichGauge

setAlpha(String, double) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeRepository

Sets the "smoothing constant", "alpha" for use in calculating an exponential moving average for the gauge.

setAlpha(String, double) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository

setAlpha(String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository

setApplicationContext(ApplicationContext) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.container.DefaultContainer

setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.module.ModuleDeployer

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.dirt.module.ModuleDeployer

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

setAttribute(String, String) - Method in class org.springframework.xd.dirt.event.AbstractEvent

setAutoStartup(boolean) - Method in class org.springframework.xd.integration.hadoop.config.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

setBeanClassLoader(ClassLoader) - Method in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

setBeanClassLoader(ClassLoader) - Method in class org.springframework.integration.x.json.TypedJsonMapper

setCollectionName(String) - Method in class org.springframework.xd.batch.item.mongodb.MongoItemWriter

setColumnNames(String) - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer

setConnectTimeout(int) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

The connection timeout for making a connection to Twitter.

setContextPath(String) - Method in class org.springframework.xd.dirt.stream.StreamServer

Set the contextPath to serve requests on.

setConversionService(ConversionService) - Method in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

setConvertWithinTransport(boolean) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

Determines whether any conversion logic is applied within the local transport.

setCounter(long) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

setCounter(long) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

setCounter(long) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

setData(Map<Integer, String>) - Method in class org.springframework.xd.shell.util.TableRow

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

setDefaultTopic(String) - Method in class org.springframework.integration.x.redis.RedisPublishingMessageHandler

setDelimited(boolean) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

Whether "delimited=length" shoud be added to the query.

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

setFilterLevel(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

One of "none", "low" or "medium"

setFollow(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

Restrict the stream to a user or users.

setFormattingConversionService(FormattingConversionService) - Method in class org.springframework.xd.tuple.TupleBuilder

setFs(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

setGaugeValue(Gauge, long) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils

setGroup(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

setGroupName(String) - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

setIndex(int) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

setInputChannelName(String) - Method in class org.springframework.integration.module.config.DefaultChannelExporter

setIsJobStep(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

setJmxProperties(AbstractOptions, ConfigurableEnvironment) - Static method in class org.springframework.xd.dirt.server.options.OptionUtils

setJt(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

setLanguage(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

Filter tweets by language or languages.

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.

setLocations(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

Bound the returned tweets by location(s).

setMaxWidth(int) - Method in class org.springframework.xd.shell.util.TableHeader

Defaults to -1 indicating to ignore the property.

setMessageConverter(MessageConverter) - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

setMessageConverter(MessageConverter) - Method in class org.springframework.integration.x.redis.RedisPublishingMessageHandler

setModule(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

setName(String) - Method in class org.springframework.xd.shell.util.TableHeader

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

setOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

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

setPoller(PollerMetadata) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

Set the poller to use when QueueChannels are used.

setPostProcessContextPaths(String...) - Method in class org.springframework.xd.module.AbstractPlugin

setPrefix(String) - Method in class org.springframework.xd.store.AbstractRedisRepository

Change the prefix after creation.

setProperties(Properties) - Method in class org.springframework.xd.module.ModuleDefinition

setProperty(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands

setQueueSize(int) - Method in class org.springframework.integration.x.channel.registry.LocalChannelRegistry

Set the size of the queue when using QueueChannels.

setReadTimeout(int) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

The read timeout for the underlying URLConnection to the twitter stream.

setRemove(boolean) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

setrep(String, int, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

setRichGaugeAlpha(RichGauge, double) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils

setRichGaugeValue(RichGauge, double) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils

setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

setRolloverThresholdInBytes(long) - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean

setRows(List<TableRow>) - Method in class org.springframework.xd.shell.util.Table

setScripts(Resource[]) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer

setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.x.redis.RedisPublishingMessageHandler

setServletName(String) - Method in class org.springframework.xd.dirt.stream.StreamServer

Set the servletName.

setSinkChannelName(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

setSourceChannelName(String) - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

setStallWarnings(boolean) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

Whether "stall_warnings=true" should be added to the query.

setStartedAt(Date) - Method in class org.springframework.xd.dirt.stream.BaseInstance

Returns the date when this instance was started.

setTableName(String) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer

setTargetException(Exception) - Method in class org.springframework.xd.shell.Target

Sets the exception in case an error occurred during targeting.

setTargetResultMessage(String) - Method in class org.springframework.xd.shell.Target

Set the result messages indicating the success or failure while targeting the Spring XD Admin Server.

setTopics(String...) - Method in class org.springframework.integration.x.redis.RedisInboundChannelAdapter

setTrack(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

Filter tweets by words or phrases.

setTupleToStringConverter(Converter<Tuple, String>) - Method in class org.springframework.xd.tuple.DefaultTuple

setType(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.GaugeRepository

Set the value of the gauge

setValue(String, double) - Method in interface org.springframework.xd.analytics.metrics.core.RichGaugeRepository

Sets the current value of the gauge.

setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository

setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository

setValue(String, long) - Method in class org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository

setValue(String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository

setWidth(int) - Method in class org.springframework.xd.shell.util.TableHeader

setXDAnalytics(Analytics) - Static method in class org.springframework.xd.dirt.server.options.AbstractOptions

Set xd.analytics system property.

setXDHome(String) - Static method in class org.springframework.xd.dirt.server.options.AbstractOptions

Set xd.home system property.

setXDStore(Store) - Static method in class org.springframework.xd.dirt.server.options.AdminOptions

setXDTransport(Transport) - Static method in class org.springframework.xd.dirt.server.options.AbstractOptions

Set xd.transport system property.

ShallowMetricResourceAssembler<M extends Metric> - Class in org.springframework.xd.dirt.rest.metrics

Base class for a ResourceAssembler that builds shallow resources for metrics (exposing only their names, and hence their "self" rel).

ShallowMetricResourceAssembler(Class<?>) - Constructor for class org.springframework.xd.dirt.rest.metrics.ShallowMetricResourceAssembler

SimpleAbstractHdfsItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop

SimpleAbstractHdfsItemWriter() - Constructor for class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter

SimpleHdfsTextItemWriter<T> - Class in org.springframework.xd.batch.item.hadoop

SimpleHdfsTextItemWriter(FileSystem) - Constructor for class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter

SimpleModule - Class in org.springframework.xd.module

SimpleModule(ModuleDefinition, DeploymentMetadata) - Constructor for class org.springframework.xd.module.SimpleModule

SingleTableDatabaseInitializer - Class in org.springframework.xd.jdbc

Class that's intended for initializing a single table and the script used can use a placeholder #table for the table name.

SingleTableDatabaseInitializer() - Constructor for class org.springframework.xd.jdbc.SingleTableDatabaseInitializer

SinkChannelNode - Class in org.springframework.xd.dirt.stream.dsl

SinkChannelNode(ChannelNode, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.SinkChannelNode

size() - Method in class org.springframework.xd.tuple.DefaultTuple

size() - Method in interface org.springframework.xd.tuple.Tuple

Return the number of elements in this tuple.

slice(List<T>, Pageable) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

Post-process the list to only return elements matching the page request.

SourceChannelNode - Class in org.springframework.xd.dirt.stream.dsl

SourceChannelNode(ChannelNode, int, boolean) - Constructor for class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

SourceChannelNode(ModuleReferenceNode, int, boolean) - Constructor for class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

SplunkTransformer - Class in org.springframework.integration.x.splunk

Message consumer that will push the payload to a splunk instance via a TCP-Port.

SplunkTransformer() - Constructor for class org.springframework.integration.x.splunk.SplunkTransformer

SpringXDException - Exception in org.springframework.xd.rest.client.impl

A Java exception that wraps the serialized VndErrors object.

SpringXDException(VndErrors) - Constructor for exception org.springframework.xd.rest.client.impl.SpringXDException

SpringXDOperations - Interface in org.springframework.xd.rest.client

Main entry point for interacting with a running XD system.

SpringXDTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the entry point to the API.

SpringXDTemplate(URI) - Constructor for class org.springframework.xd.rest.client.impl.SpringXDTemplate

start() - Method in class org.springframework.xd.dirt.container.DefaultContainer

start() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

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.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.plugins.job.ModuleJobLauncher

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

Store - Enum in org.springframework.xd.dirt.server.options

The kind of persistence mechanism to use for storing stream definitions, etc.

Stream - Class in org.springframework.xd.dirt.stream

A runtime representation of a running stream.

Stream(StreamDefinition) - Constructor for class org.springframework.xd.dirt.stream.Stream

Create a new stream out of the given StreamDefinition.

StreamCommands - Class in org.springframework.xd.shell.command

StreamCommands() - Constructor for class org.springframework.xd.shell.command.StreamCommands

StreamConfigParser - Class in org.springframework.xd.dirt.stream.dsl

StreamConfigParser(CrudRepository<? extends BaseDefinition, String>) - Constructor for class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

StreamDefinition - Class in org.springframework.xd.dirt.stream

Represents a model for a data flow in the system.

StreamDefinition(String, String) - Constructor for class org.springframework.xd.dirt.stream.StreamDefinition

StreamDefinitionRepository - Interface in org.springframework.xd.dirt.stream

A repository for persisting StreamDefinitions.

StreamDefinitionResource - Class in org.springframework.xd.rest.client.domain

Represents a stream definition, i.e. a flow of data in the system.

StreamDefinitionResource() - Constructor for class org.springframework.xd.rest.client.domain.StreamDefinitionResource

Default constructor for serialization frameworks.

StreamDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.StreamDefinitionResource

StreamDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain

Dedicated subclass to workaround type erasure.

StreamDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.StreamDefinitionResource.Page

StreamDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest

Knows how to build a REST resource out of our domain model StreamDefinition.

StreamDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.StreamDefinitionResourceAssembler

StreamDeployer - Class in org.springframework.xd.dirt.stream

Default implementation of StreamDeployer that emits deployment request messages on a bus and relies on StreamDefinitionRepository and StreamRepository for persistence.

StreamDeployer(StreamDefinitionRepository, DeploymentMessageSender, StreamRepository, XDParser) - Constructor for class org.springframework.xd.dirt.stream.StreamDeployer

StreamLookupEnvironment - Interface in org.springframework.xd.dirt.stream.dsl

A lookup environment is used to resolve a stream.

StreamNode - Class in org.springframework.xd.dirt.stream.dsl

StreamNode(String, List<ModuleNode>, SourceChannelNode, SinkChannelNode) - Constructor for class org.springframework.xd.dirt.stream.dsl.StreamNode

streamOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

streamOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interacting with Streams.

StreamOperations - Interface in org.springframework.xd.rest.client

Interface defining operations available against streams.

StreamPlugin - Class in org.springframework.xd.dirt.plugins.stream

StreamPlugin() - Constructor for class org.springframework.xd.dirt.plugins.stream.StreamPlugin

StreamRepository - Interface in org.springframework.xd.dirt.stream

A repository for persisting Streams.

StreamsController - Class in org.springframework.xd.dirt.rest

Handles all Stream related interaction.

StreamsController(StreamDeployer, StreamDefinitionRepository) - Constructor for class org.springframework.xd.dirt.rest.StreamsController

StreamServer - Class in org.springframework.xd.dirt.stream

StreamServer(XmlWebApplicationContext, int) - Constructor for class org.springframework.xd.dirt.stream.StreamServer

StreamsNode - Class in org.springframework.xd.dirt.stream.dsl

StreamsNode(String, List<StreamNode>) - Constructor for class org.springframework.xd.dirt.stream.dsl.StreamsNode

StreamTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Stream-related part of the API.

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.AstNode

stringify() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

stringify(boolean) - Method in class org.springframework.xd.dirt.stream.dsl.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

supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter

supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter

supports(Class<?>, String) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter

T

Table - Class in org.springframework.xd.shell.util

Provide a basic concept of a table structure containing a map of column headers and a collection of rows.

Table() - Constructor for class org.springframework.xd.shell.util.Table

TableHeader - Class in org.springframework.xd.shell.util

Defines table column headers used by Table.

TableHeader(String, int) - Constructor for class org.springframework.xd.shell.util.TableHeader

Constructor that initializes the table header with the provided header name and the with of the table header.

TableHeader(String) - Constructor for class org.springframework.xd.shell.util.TableHeader

Constructor that initializes the table header with the provided header name.

TableRow - Class in org.springframework.xd.shell.util

Holds the table rows used by Table.

TableRow() - Constructor for class org.springframework.xd.shell.util.TableRow

tail(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

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.rabbit.RabbitChannelRegistry

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

TapCommands - Class in org.springframework.xd.shell.command

Tap commands.

TapCommands() - Constructor for class org.springframework.xd.shell.command.TapCommands

TapDefinition - Class in org.springframework.xd.dirt.stream

TapDefinition(String, String, String) - Constructor for class org.springframework.xd.dirt.stream.TapDefinition

TapDefinition(String, String) - Constructor for class org.springframework.xd.dirt.stream.TapDefinition

TapDefinitionRepository - Interface in org.springframework.xd.dirt.stream

TapDefinitionResource - Class in org.springframework.xd.rest.client.domain

Represents a tap definition

TapDefinitionResource(String, String, String) - Constructor for class org.springframework.xd.rest.client.domain.TapDefinitionResource

TapDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain

Dedicated subclass to workaround type erasure.

TapDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.TapDefinitionResource.Page

TapDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest

Knows how to build a REST resource out of our domain model TapDefinition.

TapDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.TapDefinitionResourceAssembler

TapDeployer - Class in org.springframework.xd.dirt.stream

TapDeployer(TapDefinitionRepository, StreamDefinitionRepository, DeploymentMessageSender, XDParser, TapInstanceRepository) - Constructor for class org.springframework.xd.dirt.stream.TapDeployer

TapInstance - Class in org.springframework.xd.dirt.stream

A runtime representation of a deployed TapDefinition.

TapInstance(TapDefinition) - Constructor for class org.springframework.xd.dirt.stream.TapInstance

Create a new Tap instance out of the given StreamDefinition.

TapInstanceRepository - Interface in org.springframework.xd.dirt.stream

A repository for persisting TapInstances.

tapOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

tapOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Taps.

TapOperations - Interface in org.springframework.xd.rest.client

Interface defining operations against taps.

TapsController - Class in org.springframework.xd.dirt.rest

TapsController(TapDeployer) - Constructor for class org.springframework.xd.dirt.rest.TapsController

TapTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Tap related part of the API.

Target - Class in org.springframework.xd.shell

Encapsulates various data points related to the Admin Server Target, such as target URI, success/error state, exception messages that may have occurred.

Target(String) - Constructor for class org.springframework.xd.shell.Target

Construct a new Target.

target(String) - Method in class org.springframework.xd.shell.XDShell

Target.TargetStatus - Enum in org.springframework.xd.shell

text(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

throwAlreadyDeployedException(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

throwDefinitionAlreadyExistsException(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

throwNoSuchDefinitionException(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

toBytes(Object) - Method in class org.springframework.integration.x.json.TypedJsonMapper

toObject(String) - Method in class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer

toResource(JobDefinition) - Method in class org.springframework.xd.dirt.rest.JobDefinitionResourceAssembler

toResource(AggregateCount) - Method in class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler

toResource(Counter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler

toResource(FieldValueCounter) - Method in class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler

toResource(M) - Method in class org.springframework.xd.dirt.rest.metrics.ShallowMetricResourceAssembler

toResource(StreamDefinition) - Method in class org.springframework.xd.dirt.rest.StreamDefinitionResourceAssembler

toResource(TapDefinition) - Method in class org.springframework.xd.dirt.rest.TapDefinitionResourceAssembler

toResource(TriggerDefinition) - Method in class org.springframework.xd.dirt.rest.TriggerDefinitionResourceAssembler

toString(Object) - Method in class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer

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.core.BaseDefinition

toString() - Method in class org.springframework.xd.dirt.event.AbstractEvent

toString() - Method in class org.springframework.xd.dirt.module.ModuleDeploymentRequest

toString() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode

toString() - Method in class org.springframework.xd.dirt.stream.dsl.ChannelNode

toString() - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode

toString() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode

toString() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleReferenceNode

toString() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode

toString() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode

toString(Token) - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

toString() - Method in class org.springframework.xd.dirt.stream.dsl.StreamConfigParser

toString() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode

toString() - Method in class org.springframework.xd.dirt.stream.TapDefinition

toString() - Method in class org.springframework.xd.dirt.stream.TriggerDefinition

toString() - Method in class org.springframework.xd.module.AbstractModule

toString() - Method in enum org.springframework.xd.module.ModuleType

toString() - Method in class org.springframework.xd.rest.client.domain.TapDefinitionResource

toString() - Method in class org.springframework.xd.rest.client.impl.JobTemplate

toString() - Method in class org.springframework.xd.shell.util.Table

toString() - Method in class org.springframework.xd.tuple.DefaultTuple

toTuple(String) - Method in class org.springframework.xd.tuple.TupleStringMarshaller

touchz(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands

trackMembership(String) - Method in class org.springframework.xd.store.AbstractRedisRepository

Perform bookkeeping of entities managed by this repository.

transform(Object) - Method in class org.springframework.integration.x.json.StringToJsonNodeTransformer

transformInboundIfNecessary(Message<?>, Collection<MediaType>) - Method in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

transformOutboundIfNecessary(Message<?>, MediaType) - Method in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

transformPayload(String) - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer

transformPayload(String) - Method in class org.springframework.xd.tuple.integration.JsonToTupleTransformer

transformPayload(Map<Object, Object>) - Method in class org.springframework.xd.tuple.integration.MapToTupleTransformer

Transport - Enum in org.springframework.xd.dirt.server.options

The kind of transport used for communication between the admin server and container(s).

TriggerCommands - Class in org.springframework.xd.shell.command

Trigger commands.

TriggerCommands() - Constructor for class org.springframework.xd.shell.command.TriggerCommands

TriggerDefinition - Class in org.springframework.xd.dirt.stream

Represents the model for defining Triggers.

TriggerDefinition(String, String) - Constructor for class org.springframework.xd.dirt.stream.TriggerDefinition

TriggerDefinitionRepository - Interface in org.springframework.xd.dirt.stream

Data Repository for TriggerDefinitions.

TriggerDefinitionResource - Class in org.springframework.xd.rest.client.domain

Represents a Trigger Definition.

TriggerDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.TriggerDefinitionResource

TriggerDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain

Dedicated subclass to workaround type erasure.

TriggerDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.TriggerDefinitionResource.Page

TriggerDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest

Knows how to build a REST resource out of our domain model TriggerDefinition.

TriggerDefinitionResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.TriggerDefinitionResourceAssembler

TriggerDeployer - Class in org.springframework.xd.dirt.stream

Responsible for deploying TriggerDefinitions.

TriggerDeployer(TriggerDefinitionRepository, DeploymentMessageSender, XDParser) - Constructor for class org.springframework.xd.dirt.stream.TriggerDeployer

triggerOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate

triggerOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations

Returns the portion of the API for interaction with Triggers.

TriggerOperations - Interface in org.springframework.xd.rest.client

Interface defining operations against triggers.

TriggerPlugin - Class in org.springframework.xd.dirt.plugins.trigger

Plugin to enable the registration of triggers.

TriggerPlugin() - Constructor for class org.springframework.xd.dirt.plugins.trigger.TriggerPlugin

TriggersController - Class in org.springframework.xd.dirt.rest

Handles all Trigger related interactions.

TriggersController(TriggerDeployer) - Constructor for class org.springframework.xd.dirt.rest.TriggersController

TriggerTemplate - Class in org.springframework.xd.rest.client.impl

Implementation of the Trigger related part of the API.

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

TupleJsonMarshaller - Class in org.springframework.xd.tuple

TupleJsonMarshaller() - Constructor for class org.springframework.xd.tuple.TupleJsonMarshaller

TupleProcessor - Interface in org.springframework.xd.tuple.processor

Simple type-safe process callback method that returns another Tuple

TupleRowMapper - Class in org.springframework.xd.tuple.batch

A RowMapper implementation to be used with the Tuple data structure.

TupleRowMapper() - Constructor for class org.springframework.xd.tuple.batch.TupleRowMapper

TupleSqlParameterSource - Class in org.springframework.xd.tuple.batch

Implementation of a SqlParameterSource that translates a Tuple into SQL parameters.

TupleSqlParameterSource(Tuple) - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSource

TupleSqlParameterSourceProvider - Class in org.springframework.xd.tuple.batch

A factory for TupleSqlParameterSources

TupleSqlParameterSourceProvider() - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider

TupleStringMarshaller - Class in org.springframework.xd.tuple

TupleStringMarshaller(Converter<Tuple, String>, Converter<String, Tuple>) - Constructor for class org.springframework.xd.tuple.TupleStringMarshaller

TupleToJsonStringConverter - Class in org.springframework.xd.tuple

TupleToJsonStringConverter() - Constructor for class org.springframework.xd.tuple.TupleToJsonStringConverter

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

TwitterStreamChannelAdapter - Class in org.springframework.integration.x.twitter

Message producer which reads form Twitter's public stream endpoints.

TwitterStreamChannelAdapter(TwitterTemplate) - Constructor for class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter

TypedJsonMapper - Class in org.springframework.integration.x.json

A class that maps objects to JSON.

TypedJsonMapper() - Constructor for class org.springframework.integration.x.json.TypedJsonMapper

TypedJsonMapper.SmartJsonConversionException - Exception in org.springframework.integration.x.json

TypedJsonMapper.SmartJsonConversionException(String, Throwable) - Constructor for exception org.springframework.integration.x.json.TypedJsonMapper.SmartJsonConversionException

TypedJsonMapper.SmartJsonConversionException(String) - Constructor for exception org.springframework.integration.x.json.TypedJsonMapper.SmartJsonConversionException

U

UiUtils - Class in org.springframework.xd.shell.util

Contains utility methods for rendering data to a formatted console output.

undeploy(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer

undeploy(ModuleDeploymentRequest) - Method in class org.springframework.xd.dirt.module.ModuleDeployer

undeploy(String) - Method in class org.springframework.xd.dirt.rest.TriggersController

Request removal of an existing trigger.

undeploy(String) - Method in class org.springframework.xd.dirt.rest.XDController

Request un-deployment of an existing named module.

undeploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer

undeploy(String) - Method in class org.springframework.xd.dirt.stream.JobDeployer

undeploy(String) - Method in class org.springframework.xd.dirt.stream.StreamDeployer

undeploy(String) - Method in class org.springframework.xd.dirt.stream.TapDeployer

undeploy(String) - Method in class org.springframework.xd.dirt.stream.TriggerDeployer

undeployJob(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate

undeployJob(String) - Method in interface org.springframework.xd.rest.client.JobOperations

Undeploy a deployed stream, retaining its definition.

undeployJob(String) - Method in class org.springframework.xd.shell.command.JobCommands

undeployStream(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate

undeployStream(String) - Method in interface org.springframework.xd.rest.client.StreamOperations

Undeploy a deployed stream, retaining its definition.

undeployStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands

updateWidth(int) - Method in class org.springframework.xd.shell.util.TableHeader

Updated the width for this particular column, but only if the value of the passed-in width is higher than the value of the pre-existing width.

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.rest.metrics.AggregateCountersController.Resolution

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.Analytics

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.HadoopDistro

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.Store

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.server.options.Transport

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.stream.AbstractDeployer.ErrorMessage

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages.Kind

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.module.ModuleType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.rest.client.AggregateCounterOperations.Resolution

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.shell.Target.TargetStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.xd.tuple.batch.FieldSetType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.springframework.xd.dirt.rest.metrics.AggregateCountersController.Resolution

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.dirt.server.options.Analytics

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.dirt.server.options.HadoopDistro

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.dirt.server.options.Store

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.dirt.server.options.Transport

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.AbstractDeployer.ErrorMessage

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages.Kind

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.module.ModuleType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.rest.client.AggregateCounterOperations.Resolution

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.shell.Target.TargetStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.xd.tuple.batch.FieldSetType

Returns an array containing the constants of this enum type, in the order they are declared.

VndErrorResponseErrorHandler - Class in org.springframework.xd.rest.client.impl

Extension of DefaultResponseErrorHandler that knows how to de-serialize a VndErrors.VndError structure.

VndErrorResponseErrorHandler(List<HttpMessageConverter<?>>) - Constructor for class org.springframework.xd.rest.client.impl.VndErrorResponseErrorHandler

W

withReplacedVariables(Map<String, ModuleNode.ConsumedArgumentNode>) - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode

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_ANALYTICS_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.DefaultContainer

XD_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.DefaultContainer

Base location for XD config files.

XD_DISABLE_JMX_KEY - Static variable in class org.springframework.xd.dirt.server.options.AbstractOptions

XD_HOME_KEY - Static variable in class org.springframework.xd.dirt.server.options.AbstractOptions

XD_INTERNAL_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.DefaultContainer

Where container related config files reside.

XD_JMX_PORT_KEY - Static variable in class org.springframework.xd.dirt.server.options.AbstractOptions

XD_JSON_OCTET_STREAM_VALUE - Static variable in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

XD_OCTET_STREAM_VALUE - Static variable in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

XD_TEXT_PLAIN_UTF8_VALUE - Static variable in class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

XD_TRANSPORT_KEY - Static variable in class org.springframework.xd.dirt.server.options.AbstractOptions

XDController<D extends BaseDefinition,V extends org.springframework.hateoas.mvc.ResourceAssemblerSupport<D,T>,T extends org.springframework.hateoas.ResourceSupport> - Class in org.springframework.xd.dirt.rest

Base Class for XD Controllers.

XDController(AbstractDeployer<D>, V) - Constructor for class org.springframework.xd.dirt.rest.XDController

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

XDParser - Interface in org.springframework.xd.dirt.stream

XDRuntime - Class in org.springframework.xd.rest.client.domain

Represents information about the XD Runtime.

XDRuntime() - Constructor for class org.springframework.xd.rest.client.domain.XDRuntime

XDRuntimeException - Exception in org.springframework.xd.dirt.core

Base class for all XD-related exceptions.

XDRuntimeException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.core.XDRuntimeException

XDRuntimeException(String) - Constructor for exception org.springframework.xd.dirt.core.XDRuntimeException

XDShell - Class in org.springframework.xd.shell

XDShell() - Constructor for class org.springframework.xd.shell.XDShell

XDShellBannerProvider - Class in org.springframework.xd.shell

Provides the Spring XD specific BannerProvider.

XDShellBannerProvider() - Constructor for class org.springframework.xd.shell.XDShellBannerProvider

XDShellPromptProvider - Class in org.springframework.xd.shell

A provider that sets the shell prompt to xd:>

XDShellPromptProvider() - Constructor for class org.springframework.xd.shell.XDShellPromptProvider

Z

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

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