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

abandon(Long) - Method in class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

ABSOLUTE_FILE_PATH - Static variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

AbstractContainerEvent - Class in org.springframework.xd.dirt.event

AbstractContainerEvent(XDContainer) - 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

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 & java.lang.Comparable<ID>> - Class in org.springframework.xd.store

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

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

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

Base support class for deployers that know how to deal with instances of a definition.

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

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

Base support class for modules, wrapping ModuleDefinition and DeploymentMetadata.

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

Provides common behavior for ModuleRegistry and knows how to handle custom classpath population for storages that support it.

AbstractModuleRegistry() - Constructor for class org.springframework.xd.dirt.module.AbstractModuleRegistry

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

Options shared by both the admin and the container server.

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

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 & java.lang.Comparable<ID>> - Class in org.springframework.xd.store

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

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

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.

addBridge(Bridge) - Method in class org.springframework.integration.x.bus.MessageBusSupport

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

addHandler(MessageHandler) - Method in class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher

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

addJob(String, boolean) - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

Store the job name & isIncrementable flag for the job when there is a registry update

addListener(ApplicationListener<?>) - Method in class org.springframework.xd.dirt.container.XDContainer

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.

ADMIN_PROFILE - Static variable in class org.springframework.xd.dirt.server.AdminServer

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

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

AdminOptions(Transport, Analytics) - Constructor for class org.springframework.xd.dirt.server.options.AdminOptions

AdminServer - Class in org.springframework.xd.dirt.server

AdminServer(AdminOptions) - Constructor for class org.springframework.xd.dirt.server.AdminServer

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.bus.LocalMessageBus

afterPropertiesSet() - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter

afterPropertiesSet() - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter

afterPropertiesSet() - Method in class org.springframework.xd.batch.item.mongodb.MongoItemWriter

afterPropertiesSet() - Method in class org.springframework.xd.dirt.plugins.job.batch.HSQLServerBean

afterPropertiesSet() - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

afterPropertiesSet() - Method in class org.springframework.xd.dirt.server.AdminServer

Create an embedded Tomcat instance and have it run the WebApplicationContext

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 - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

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

asContainerOptions() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions

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

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.

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

Provides basic deployment behavior, whereby running state of deployed definitions is not persisted.

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

Provides basic un-deployment behavior, whereby state of deployed definitions is not dealt with.

BatchJobAlreadyExistsException - Exception in org.springframework.xd.dirt.plugins.job.batch

BatchJobAlreadyExistsException(String) - Constructor for exception org.springframework.xd.dirt.plugins.job.batch.BatchJobAlreadyExistsException

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

Controller for job executions.

BatchJobExecutionsController(JobService) - Constructor for class org.springframework.xd.dirt.rest.BatchJobExecutionsController

BatchJobExecutionsController.StopRequest - Class in org.springframework.xd.dirt.rest

BatchJobExecutionsController.StopRequest() - Constructor for class org.springframework.xd.dirt.rest.BatchJobExecutionsController.StopRequest

BatchJobLocator - Class in org.springframework.xd.dirt.plugins.job.batch

Implementation of ListableJobLocator used by

BatchJobLocator() - Constructor for class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

BatchJobRegistryBeanPostProcessor - Class in org.springframework.xd.dirt.plugins.job

JobRegistryBeanPostProcessor that processes Job bean with name JobPlugin.JOB_BEAN_ID

BatchJobRegistryBeanPostProcessor() - Constructor for class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

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

Controller for batch jobs.

BatchJobsController(JobService) - Constructor for class org.springframework.xd.dirt.rest.BatchJobsController

BeanDefinitionAddingPostProcessor - Class in org.springframework.xd.module

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

BeanDefinitionAddingPostProcessor(ConfigurableEnvironment, 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

beforeShutdown(Module) - Method in class org.springframework.integration.module.IntegrationPlugin

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

beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

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

Perform any cleanup necessary prior to module shutdown

bindConsumer(String, MessageChannel, Collection<MediaType>, boolean) - Method in class org.springframework.integration.x.bus.LocalMessageBus

Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance.

bindConsumer(String, MessageChannel, Collection<MediaType>, boolean) - Method in interface org.springframework.integration.x.bus.MessageBus

Bind a message consumer on a p2p channel

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

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

bindProducer(String, MessageChannel, boolean) - Method in class org.springframework.integration.x.bus.LocalMessageBus

Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.

bindProducer(String, MessageChannel, boolean) - Method in interface org.springframework.integration.x.bus.MessageBus

Bind a message producer on a p2p channel.

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

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

bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in class org.springframework.integration.x.bus.LocalMessageBus

bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in interface org.springframework.integration.x.bus.MessageBus

Bind a message consumer on a pub/sub channel

bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus

bindPubSubConsumer(String, MessageChannel, Collection<MediaType>) - Method in class org.springframework.integration.x.redis.RedisMessageBus

bindPubSubProducer(String, MessageChannel) - Method in class org.springframework.integration.x.bus.LocalMessageBus

bindPubSubProducer(String, MessageChannel) - Method in interface org.springframework.integration.x.bus.MessageBus

Bind a message producer on a pub/sub channel.

bindPubSubProducer(String, MessageChannel) - Method in class org.springframework.integration.x.rabbit.RabbitMessageBus

bindPubSubProducer(String, MessageChannel) - Method in class org.springframework.integration.x.redis.RedisMessageBus

Bridge - Class in org.springframework.integration.x.bus

Represents a Bridge between a specified channel and an endpoint.

Bridge(MessageChannel, AbstractEndpoint) - Constructor for class org.springframework.integration.x.bus.Bridge

bridge(MessageChannel, MessageChannel, String) - Method in class org.springframework.integration.x.bus.LocalMessageBus

bridge(MessageChannel, MessageChannel, String, Collection<MediaType>) - Method in class org.springframework.integration.x.bus.LocalMessageBus

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

buildBeanDefinition(Element, ParserContext) - Method in class org.springframework.xd.integration.reactor.config.ReactorPublishSubscribeChannelParser

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

C

CacheServer - Class in org.springframework.xd.gemfire

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

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

canRead(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor

canWrite(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor

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

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

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

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

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

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.

CompositeModuleRegistry - Class in org.springframework.xd.dirt.module

A ModuleRegistry that delegates to several ModuleRegistries, in order.

CompositeModuleRegistry(ModuleRegistry...) - Constructor for class org.springframework.xd.dirt.module.CompositeModuleRegistry

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

configureRuntime(AbstractOptions, ConfigurableEnvironment) - Static method in class org.springframework.xd.dirt.server.options.OptionUtils

Configure the XD runtime enviroment using parsed command line options

ContainerLauncher - Interface in org.springframework.xd.dirt.launcher

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

Class that encapsulates the creation and configuration of a ContainerLauncher

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

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(XDContainer) - Constructor for class org.springframework.xd.dirt.event.ContainerStartedEvent

ContainerStoppedEvent - Class in org.springframework.xd.dirt.event

ContainerStoppedEvent(XDContainer) - 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

Interface for repositories that now how to deal with Counters.

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

The REST representation of a Counter.

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

No-arg constructor for serialization frameworks.

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

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

Exposes representations of Counters.

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

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

Implements the CounterOperations part of the API.

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

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

createBeanDefinitionBuilder(Class<?>, Element) - Static method in class org.springframework.xd.integration.reactor.config.ReactorNamespaceUtils

Create a BeanDefinitionBuilder that checks for an env attribute and uses that as the Environment bean reference.

createContainerLauncher(ContainerOptions, ApplicationContext) - Method in class org.springframework.xd.dirt.launcher.ContainerLauncherFactory

Creates a new instance of ContainerLauncher.

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

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

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

createJob(String, String, 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

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

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

createSharedChannel(String, Class<T>) - Method in class org.springframework.integration.x.bus.LocalMessageBus

createSqlParameterSource(FieldSet) - Method in class org.springframework.xd.batch.item.jdbc.FieldSetSqlParameterSourceProvider

createSqlParameterSource(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider

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

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

Create a new Stream, optionally deploying it.

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

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

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

D

DateTrigger - Class in org.springframework.xd.module.util

A Trigger implementation that enables execution on a series of Dates.

DateTrigger() - Constructor for class org.springframework.xd.module.util.DateTrigger

DateTrigger(Date...) - Constructor for class org.springframework.xd.module.util.DateTrigger

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

Decrement this counter by a given amount.

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

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

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

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

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

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

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

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

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

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

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

Knows how to construct AggregateCountsResource out of AggregateCount.

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

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

Knows how to assemble CounterResources out of Counters.

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

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

Knows how to create rich representations of FieldValueCounter.

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

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

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

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

DEFAULT_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

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.

definitionKind - Variable in class org.springframework.xd.dirt.stream.AbstractDeployer

Lower-case, singular name of the kind of definition we're deploying.

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

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

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

Delete the given named aggregate counter

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

Delete the counter with given name

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

Delete the given named field value counter

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

Delete the given named gauge.

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

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

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

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

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

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

Delete the given named rich gauge

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Delete all the definitions

deleteAll() - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

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

Request removal of all modules.

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

deleteAll() - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

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

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

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

deleteBridge(String, MessageChannel) - Method in class org.springframework.integration.x.bus.MessageBusSupport

deleteBridges(String) - Method in class org.springframework.integration.x.bus.MessageBusSupport

deleteJob(String) - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

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

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

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

Request deployment of an existing named module.

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

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

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

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

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

deploy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations

Deploy an already created resource.

DeployableResource - Class in org.springframework.xd.rest.client.domain

Abstract base class for resources that represent deployable things.

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

No arg constructor for serialization frameworks.

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

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

deploy all available undeployed resource definitions.

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

Request deployment of all modules.

deployAll() - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

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

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

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

deployAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations

Deploy all the resources known to the system.

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

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

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

Deploy an already created job with additional JobParameters.

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

deploymentInfo(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

Query deployment information about definitions whose ids range from first to last.

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

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

DeploymentMetadata - Class in org.springframework.xd.module

Represents information about a particular module deployment.

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

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

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

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

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(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.RabbitMessageBus

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

destroy() - Method in class org.springframework.xd.dirt.plugins.job.batch.HSQLServerBean

destroy() - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

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

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

destroy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations

Destroy an existing resource.

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

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

destroyAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations

Undeploy all the resources known to the system.

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

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

dispatch(Message<?>) - Method in class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher

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

DistributedJobService - Class in org.springframework.xd.dirt.plugins.job.batch

SimpleJobService in distributed mode

DistributedJobService(SearchableJobInstanceDao, SearchableJobExecutionDao, SearchableStepExecutionDao, JobRepository, JobLauncher, BatchJobLocator, ExecutionContextDao) - Constructor for class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

DomainRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Interface in org.springframework.xd.store

Implemented by XD repositories, exists mainly as a mean to capture several interfaces into one.

doParse(Element, ParserContext, String) - Method in class org.springframework.xd.integration.reactor.config.SyslogInboundChannelAdapterParser

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

doStart() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

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

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

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

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

doStop() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

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

equals(Object) - Method in class org.springframework.integration.x.twitter.XDEntities

equals(Object) - Method in class org.springframework.integration.x.twitter.XDHashTagEntity

equals(Object) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

equals(Object) - Method in class org.springframework.integration.x.twitter.XDMentionEntity

equals(Object) - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

equals(Object) - Method in class org.springframework.integration.x.twitter.XDTweet

equals(Object) - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

equals(Object) - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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(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

ExpandedJobInfo - Class in org.springframework.xd.dirt.plugins.job.batch

A job info for batch jobs that provides more details than the base JobInfo

ExpandedJobInfo(String, int, boolean, boolean, JobExecutionInfo) - Constructor for class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

ExpandedJobParametersConverter - Class in org.springframework.xd.dirt.plugins.job

More flexible implementation of the JobParametersConverter.

ExpandedJobParametersConverter() - Constructor for class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

expressionString - Variable in exception org.springframework.xd.dirt.stream.dsl.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

File based implementation of ModuleRegistry that supports two kinds of modules: the "simple" case is a sole xml file, located in a directory named after the module type, e.g. source/time.xml the "enhanced" case is made up of a directory, where the application context file lives in a config sub-directory e.g. source/time/config/time.xml and extra classpath is loaded from jars in a lib subdirectory e.g. source/time/lib/*.jar

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

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

Return a slice of all definitions.

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

findAllInRange(ID, boolean, ID, boolean) - Method in class org.springframework.xd.store.AbstractInMemoryRepository

findAllInRange(ID, boolean, ID, boolean) - Method in class org.springframework.xd.store.AbstractRedisRepository

findAllInRange(ID, boolean, ID, boolean) - Method in interface org.springframework.xd.store.RangeCapableRepository

Return entities whose ids range between from and to.

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

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

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.

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.launcher.AbstractContainerLauncher

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

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

getAdminServer() - Method in class org.springframework.xd.dirt.server.SingleNodeServer

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.dirt.container.XDContainer

getApplicationContext() - Method in class org.springframework.xd.dirt.server.AdminServer

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.

getBackgroundColor() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The color of the background of the user's Twitter profile page.

getBackgroundImageUrl() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The URL to a background image shown on the user's Twitter profile page.

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

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

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

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

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

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

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

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

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

getBean(String, Class<T>) - Method in class org.springframework.integration.x.bus.LocalMessageBus

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

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

getBigDecimal(String, BigDecimal) - Method in class org.springframework.xd.tuple.DefaultTuple

getBigDecimal(int, BigDecimal) - Method in class org.springframework.xd.tuple.DefaultTuple

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

Read the 'BigDecimal' value at index 'index'.

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

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

getBigDecimal(int, BigDecimal) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'BigDecimal' value at index 'index'.

getBigDecimal(String, BigDecimal) - Method in interface org.springframework.xd.tuple.Tuple

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

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

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

getBoolean(int, String) - Method in class org.springframework.xd.tuple.DefaultTuple

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

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

Read the 'boolean' value at index 'index'.

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

Read the 'boolean' value from field with given 'name'.

getBoolean(int, String) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'boolean' value at index 'index'.

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

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

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

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

getByte(String, byte) - Method in class org.springframework.xd.tuple.DefaultTuple

getByte(int, byte) - Method in class org.springframework.xd.tuple.DefaultTuple

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

Read the 'byte' value at index 'index'.

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

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

getByte(int, byte) - Method in interface org.springframework.xd.tuple.Tuple

Read the 'byte' value at index 'index'.

getByte(String, byte) - Method in interface org.springframework.xd.tuple.Tuple

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

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

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

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

getChannel() - Method in class org.springframework.integration.x.bus.Bridge

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

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

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

getComponentType() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

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

getContainer() - Method in class org.springframework.xd.dirt.server.SingleNodeServer

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

getCreatedAt() - Method in class org.springframework.integration.x.twitter.XDTweet

getCreatedDate() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The date that the Twitter profile was created.

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.

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

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

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

getDescription() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's description

getDispatcher() - Method in class org.springframework.xd.integration.reactor.channel.ReactorPublishSubscribeChannel

getDisplayUrl() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

getDisplayUrl() - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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

getDuration() - Method in class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

getEndpoint() - Method in class org.springframework.integration.x.bus.Bridge

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

getEntities() - Method in class org.springframework.integration.x.twitter.XDTweet

getExitStatus() - Method in class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

getExpandedUrl() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

getExpandedUrl() - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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

getFavoritesCount() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The number of tweets that the user has marked as favorites.

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

getFollowersCount() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The number of followers the user has.

getFriendsCount() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The number of friends the user has (the number of users this user follows).

getFromUser() - Method in class org.springframework.integration.x.twitter.XDTweet

getFromUserId() - Method in class org.springframework.integration.x.twitter.XDTweet

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.

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

getHashTags() - Method in class org.springframework.integration.x.twitter.XDEntities

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.integration.x.twitter.XDMediaEntity

getId() - Method in class org.springframework.integration.x.twitter.XDMentionEntity

getId() - Method in class org.springframework.integration.x.twitter.XDTweet

getId() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's Twitter ID

getId() - Method in class org.springframework.xd.dirt.container.XDContainer

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

getIndices() - Method in class org.springframework.integration.x.twitter.XDHashTagEntity

getIndices() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

getIndices() - Method in class org.springframework.integration.x.twitter.XDMentionEntity

getIndices() - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

getIndices() - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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

getInReplyToScreenName() - Method in class org.springframework.integration.x.twitter.XDTweet

getInReplyToStatusId() - Method in class org.springframework.integration.x.twitter.XDTweet

getInReplyToUserId() - Method in class org.springframework.integration.x.twitter.XDTweet

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

getJdbcTemplate() - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

getJmxPort() - Method in class org.springframework.xd.dirt.container.XDContainer

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

getJob(String) - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

getJobExecutionId() - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController.StopRequest

getJobNames() - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

getJobParameters() - Method in class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

getJobParameters(Properties) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

If ExpandedJobParametersConverter.makeParametersUnique is true the JobParameter with key ExpandedJobParametersConverter.UNIQUE_JOB_PARAMETER_KEY will be added with a random number value.

getJobParameters() - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

Please ensure that JobParametersBean.afterPropertiesSet() is called before obtaining the JobParameters.

getJobParametersForFile(File) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Return JobParameters for the passed-in File.

getJobParametersForJsonString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Converts a String-based JSON map to JobParameters.

getJobParametersForMap(Map<?, ?>) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Will convert the provided Map into JobParameters.

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

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

getLanguage() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's preferred language.

getLanguageCode() - Method in class org.springframework.integration.x.twitter.XDTweet

getLinkColor() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The link color on the user's Twitter profile page.

getListedCount() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The number of lists the user is listed on.

getLocalPort() - Method in class org.springframework.xd.dirt.server.AdminServer

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

getLocation() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's location

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

getMedia() - Method in class org.springframework.integration.x.twitter.XDEntities

getMediaSecureUrl() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

getMediaUrl() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

getMentions() - Method in class org.springframework.integration.x.twitter.XDEntities

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.integration.x.twitter.XDMentionEntity

getName() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's full name

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.dirt.plugins.job.JobFactoryBean

Return the Job for the corresponding #jobName.

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

getObjectType() - Method in class org.springframework.xd.dirt.plugins.job.JobFactoryBean

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.

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

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

getPhase() - Method in class org.springframework.xd.dirt.server.AdminServer

getPhase() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler

getPort() - Method in class org.springframework.xd.dirt.server.AdminServer

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

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

getProfileImageUrl() - Method in class org.springframework.integration.x.twitter.XDTweet

getProfileImageUrl() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The URL of the user's profile image in "normal" size (48x48).

getProfileUrl() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The URL of the user's profile.

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

getPropertyValue(String) - Method in class org.springframework.xd.dirt.container.XDContainer

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

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

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

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

getResourcesLocation() - Method in class org.springframework.xd.dirt.rest.UiResourceIdentifier

getRetweetCount() - Method in class org.springframework.integration.x.twitter.XDTweet

getRetweetedStatus() - Method in class org.springframework.integration.x.twitter.XDTweet

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

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

getRuntimeInfo(XDContainer) - Method in class org.springframework.xd.dirt.launcher.LocalContainerLauncher

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

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

getScreenName() - Method in class org.springframework.integration.x.twitter.XDMentionEntity

getScreenName() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's Twitter screen name

getSerialversionuid() - Static method in class org.springframework.integration.x.twitter.XDTwitterProfile

getServerProperties() - Method in class org.springframework.xd.dirt.plugins.job.batch.HSQLServerBean

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

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

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

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

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

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

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

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

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

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

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

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

getSidebarBorderColor() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The color of the sidebar border on the user's Twitter profile page.

getSidebarFillColor() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The color of the sidebar fill on the user's Twitter profile page.

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.integration.x.twitter.XDTweet

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

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

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

getSpecificTargetClasses() - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor

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

getStartDate() - Method in class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

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

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

getStartTime() - Method in class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

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

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

getStatusesCount() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The number of tweets this user has posted.

getStepExecutionCount() - Method in class org.springframework.xd.dirt.plugins.job.batch.ExpandedJobInfo

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

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.

getText() - Method in class org.springframework.integration.x.twitter.XDHashTagEntity

getText() - Method in class org.springframework.integration.x.twitter.XDTweet

getTextColor() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The text color on the user's Twitter profile page.

getTickerSymbol() - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

getTickerSymbols() - Method in class org.springframework.integration.x.twitter.XDEntities

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

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

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

getTimeZone() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's time zone.

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

getToUserId() - Method in class org.springframework.integration.x.twitter.XDTweet

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.integration.x.twitter.XDMediaEntity

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

getUrl() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

getUrl() - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

getUrl() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's URL

getUrl() - Method in class org.springframework.integration.x.twitter.XDUrlEntity

getUrls() - Method in class org.springframework.integration.x.twitter.XDEntities

getUser() - Method in class org.springframework.integration.x.twitter.XDTweet

getUtcOffset() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

The user's UTC offset in seconds.

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

getXDEntities() - Method in class org.springframework.integration.x.twitter.XDTweet

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

getXDRetweetedStatus() - Method in class org.springframework.integration.x.twitter.XDTweet

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

H

hadoopDistro - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

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.integration.x.twitter.XDEntities

hashCode() - Method in class org.springframework.integration.x.twitter.XDHashTagEntity

hashCode() - Method in class org.springframework.integration.x.twitter.XDMediaEntity

hashCode() - Method in class org.springframework.integration.x.twitter.XDMentionEntity

hashCode() - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

hashCode() - Method in class org.springframework.integration.x.twitter.XDTweet

hashCode() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

hashCode() - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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

HSQLServerBean - Class in org.springframework.xd.dirt.plugins.job.batch

HSQL server mode

HSQLServerBean() - Constructor for class org.springframework.xd.dirt.plugins.job.batch.HSQLServerBean

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

Http commands.

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

httpPort - Variable in class org.springframework.xd.dirt.server.options.AdminOptions

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.integration.reactor.config.ReactorNamespaceHandler

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

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

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

InvalidCommandLineArgumentException - Exception in org.springframework.xd.dirt.server.options

Thrown when there is an invalid command line argument passed into the runtime

InvalidCommandLineArgumentException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.server.options.InvalidCommandLineArgumentException

Create a new InvalidCommandLineArgumentException

InvalidCommandLineArgumentException(String) - Constructor for exception org.springframework.xd.dirt.server.options.InvalidCommandLineArgumentException

Create a new InvalidCommandLineArgumentException

invoke(MethodInvocation) - Method in class org.springframework.xd.dirt.module.support.ThreadContextClassLoaderSetterAdvice

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.

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

isAutoStartup() - Method in class org.springframework.xd.dirt.container.XDContainer

isAutoStartup() - Method in class org.springframework.xd.dirt.server.AdminServer

isAutoStartup() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler

isBackgroundImageTiled() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the background image is tiled.

isContributorsEnabled() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not this profile is enabled for contributors.

isDeployed() - Method in class org.springframework.xd.rest.client.domain.DeployableResource

Return deployment status of the underlying thing, or null if unknown.

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

Whether to also return deployment status when listing definitions.

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

isFavorited() - Method in class org.springframework.integration.x.twitter.XDTweet

isFollowing() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the authenticated user is following this user.

isFollowRequestSent() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not a request has been sent by the authenticating user to follow this user.

isGeoEnabled() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the user has enabled their account with geo location.

isIncrementable(String) - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

isIncrementable(String) - Method in class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

isInputChannel(String, MessageChannel) - Method in class org.springframework.integration.module.config.DefaultChannelExporter

Determine if a given bean is the input channel

isJmxEnabled() - Method in class org.springframework.xd.dirt.container.XDContainer

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

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

isNotificationsEnabled() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the user has mobile notifications enabled.

isOption(String) - Method in class org.springframework.xd.dirt.server.options.CommandLineParser

isOutputChannel(String, MessageChannel) - Method in class org.springframework.integration.module.config.DefaultChannelExporter

Determine if a given bean is an output channel

isProtected() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the user's tweets are protected.

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

isRetweeted() - Method in class org.springframework.integration.x.twitter.XDTweet

isRunning() - Method in class org.springframework.integration.x.bus.Bridge

isRunning() - Method in class org.springframework.xd.dirt.container.XDContainer

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

isRunning() - Method in class org.springframework.xd.dirt.server.AdminServer

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.dirt.plugins.job.JobFactoryBean

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

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

isTranslator() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not this user is a translator.

isValidEmail(String) - Static method in class org.springframework.xd.shell.util.CommonUtils

isVerified() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the user is verified with Twitter.

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

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

jmxEnabled - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

jmxPort - Variable in class org.springframework.xd.dirt.server.options.AdminOptions

jmxPort - Variable in class org.springframework.xd.dirt.server.options.ContainerOptions

JOB_BEAN_ID - Static variable in class org.springframework.xd.dirt.plugins.job.JobPlugin

JOB_NAME_DELIMITER - Static variable in class org.springframework.xd.dirt.plugins.job.JobPlugin

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

A repository for persisting JobDefinitions.

JobDefinitionResource - Class in org.springframework.xd.rest.client.domain

Represents a Job Definition.

JobDefinitionResource(String, String) - Constructor for class org.springframework.xd.rest.client.domain.JobDefinitionResource

JobDefinitionResource.Page - Class in org.springframework.xd.rest.client.domain

Dedicated subclass to workaround type erasure.

JobDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.client.domain.JobDefinitionResource.Page

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

Knows how to build a REST resource out of our domain model StreamDefinition.

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

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

JobDeployer(JobDefinitionRepository, DeploymentMessageSender, XDParser) - Constructor for class org.springframework.xd.dirt.stream.JobDeployer

JobFactoryBean - Class in org.springframework.xd.dirt.plugins.job

JobFactoryBean(JobRegistry, String, String) - Constructor for class org.springframework.xd.dirt.plugins.job.JobFactoryBean

Instantiate the JobFactoryBean with the provided JobRegistry and the name of the Job.

jobinfo(String) - Method in class org.springframework.xd.dirt.rest.BatchJobsController

jobInstances(String, int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobsController

JobLaunchRequestTransformer - Class in org.springframework.xd.dirt.plugins.job

Executes all jobs defined within a given stream once the context has been started.

JobLaunchRequestTransformer(Job) - Constructor for class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

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

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

Interface defining operations available against jobs.

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

Returns the portion of the API for interaction with Jobs.

JobParametersBean - Class in org.springframework.xd.dirt.plugins.job

Prepares the JobParameters for the Spring Bach Jobs.

JobParametersBean(String) - Constructor for class org.springframework.xd.dirt.plugins.job.JobParametersBean

Initializes the JobParametersBean.

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

jobs(int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobsController

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

keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

keyFor(Counter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

keyFor(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(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(String, JobParameters) - Method in class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

launchAdminServer(AdminOptions) - Static method in class org.springframework.xd.dirt.server.AdminMain

Create a new instance of the AdminServer given AdminOptions

launchContainer(ContainerOptions, ApplicationContext) - Static method in class org.springframework.xd.dirt.server.ContainerMain

Create a new instance of XDContainer given ContainerOptions and an optional parent ApplicationContext

launchSingleNodeServer(SingleNodeOptions) - Static method in class org.springframework.xd.dirt.server.SingleNodeMain

Create a new instance of SingleNodeServer given SingleNodeOptions

lifecycleMonitor - Variable in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler

list(int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController

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, XDController.QueryOptions, PagedResourcesAssembler<StreamDefinition>) - Method in class org.springframework.xd.dirt.rest.StreamsController

List stream definitions.

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

List the names of the available aggregate counters

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

Retrieve basic information (i.e.

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

Retrieve basic information (i.e.

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

List the names of the available gauges.

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

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

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

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

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

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

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

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

List jobs known to the system.

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

List the names of the available richgauges

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

List streams known to the system.

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

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

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

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

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

listForJob(String, int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController

listJobExecutionsForJob(String, int, int) - Method in class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

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

listValues(Pageable, XDController.QueryOptions, 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

LocalContainerEventListener - Class in org.springframework.xd.dirt.listener

LocalContainerEventListener() - Constructor for class org.springframework.xd.dirt.listener.LocalContainerEventListener

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

A Container Launcher for a Local (single node) Container

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

LocaleAwareStringToNumberConverterFactory - Class in org.springframework.xd.tuple

Converts from a String any JDK-standard Number implementation.

LocaleAwareStringToNumberConverterFactory(NumberFormat) - Constructor for class org.springframework.xd.tuple.LocaleAwareStringToNumberConverterFactory

LocalMessageBus - Class in org.springframework.integration.x.bus

A simple implementation of MessageBus for in-process use.

LocalMessageBus() - Constructor for class org.springframework.integration.x.bus.LocalMessageBus

locateApplicationContext(String, String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry

Return a resource pointing to an ApplicationContext XML definition file.

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

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

LOG - Variable in class org.springframework.xd.shell.hadoop.ConfigurationAware

logContainerInfo(Log, XDContainer) - Method in class org.springframework.xd.dirt.launcher.AbstractContainerLauncher

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

logErrorInfo(Exception) - Method in class org.springframework.xd.dirt.launcher.LocalContainerLauncher

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.bus.MessageBusSupport

logger - Variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

logger - Variable in class org.springframework.xd.dirt.plugins.job.JobFactoryBean

logger - Variable in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

logger - Variable in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

logger - Variable in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

logger - Variable in class org.springframework.xd.dirt.server.AdminServer

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 class org.springframework.xd.dirt.module.CompositeModuleRegistry

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

Lookup a module of the given type with the given name.

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

The main entry point to create the AdminServer.

main(String[]) - Static method in class org.springframework.xd.dirt.server.ContainerMain

The main entry point to create the XDContainer.

main(String[]) - Static method in class org.springframework.xd.dirt.server.SingleNodeMain

The main entry point to create the AdminServer.

main(String[]) - Static method in class org.springframework.xd.gemfire.CacheServer

makeInstance(D) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

Create an running instance out of the given definition;

makeInstance(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.StreamDeployer

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

maybeLocateClasspath(Resource, String, String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry

Return an array of jar files locations or null if the module is a plain xml file.

maybeLocateClasspath(Resource, String, String) - Method in class org.springframework.xd.dirt.module.FileModuleRegistry

MBeanExportingPlugin - Class in org.springframework.xd.dirt.plugins

Exports MBeans from a module using a unique domain name xd.[group].[module]

MBeanExportingPlugin() - Constructor for class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

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

Knows how to parse String representations of MediaType.

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

MessageBus - Interface in org.springframework.integration.x.bus

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

MessageBusAwareChannelResolver - Class in org.springframework.integration.x.bus

A ChannelResolver implementation that first checks for any channel whose name begins with a colon in the MessageBus.

MessageBusAwareChannelResolver() - Constructor for class org.springframework.integration.x.bus.MessageBusAwareChannelResolver

MessageBusAwareRouterBeanPostProcessor - Class in org.springframework.integration.x.bus

A BeanPostProcessor that sets a MessageBusAwareChannelResolver on any bean of type AbstractMappingMessageRouter within the context.

MessageBusAwareRouterBeanPostProcessor() - Constructor for class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor

MessageBusSupport - Class in org.springframework.integration.x.bus

MessageBusSupport() - Constructor for class org.springframework.integration.x.bus.MessageBusSupport

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

Counts the number of non-null messages using an underlying CounterRepository.

MessageCounterHandler(CounterRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.MessageCounterHandler

MessageRedisSerializer - Class in org.springframework.integration.x.redis

Implementation of RedisSerializer that uses MessageBuilder to deserialize raw bytes into Messages

MessageRedisSerializer() - Constructor for class org.springframework.integration.x.redis.MessageRedisSerializer

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

ModuleDefinition(String, String, Resource, URL[]) - 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

Listens for deployment request messages and instantiates Modules accordingly, applying Plugin logic to them.

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, JobParametersBean) - Constructor for class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher

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

ModuleNode(List<LabelNode>, String, int, int, ArgumentNode[]) - Constructor for class org.springframework.xd.dirt.stream.dsl.ModuleNode

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

nextExecutionTime(TriggerContext) - Method in class org.springframework.xd.module.util.DateTrigger

NONE - Static variable in class org.springframework.xd.dirt.rest.XDController.QueryOptions

NoSuchBatchJobException - Exception in org.springframework.xd.dirt.plugins.job.batch

NoSuchBatchJobException(String) - Constructor for exception org.springframework.xd.dirt.plugins.job.batch.NoSuchBatchJobException

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

Exception which is raised when a named resource definition cannot be found.

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

Create a new exception.

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.

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

Thrown when a definition was assumed to be deployed when it actually was not.

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

Create a new exception.

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

Knows how to convert from a String to a new NumberFormat instance.

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

O

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

onInit() - Method in class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter

onInit() - Method in class org.springframework.xd.dirt.module.ModuleDeployer

onInit() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

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.

optionMetadataCache - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

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.bus - package org.springframework.integration.x.bus

org.springframework.integration.x.gemfire - package org.springframework.integration.x.gemfire

org.springframework.integration.x.http - package org.springframework.integration.x.http

org.springframework.integration.x.json - package org.springframework.integration.x.json

org.springframework.integration.x.rabbit - package org.springframework.integration.x.rabbit

org.springframework.integration.x.redis - package org.springframework.integration.x.redis

org.springframework.integration.x.splunk - package org.springframework.integration.x.splunk

org.springframework.integration.x.twitter - package org.springframework.integration.x.twitter

org.springframework.xd.analytics.metrics.core - package org.springframework.xd.analytics.metrics.core

org.springframework.xd.analytics.metrics.integration - package org.springframework.xd.analytics.metrics.integration

org.springframework.xd.analytics.metrics.memory - package org.springframework.xd.analytics.metrics.memory

org.springframework.xd.analytics.metrics.redis - package org.springframework.xd.analytics.metrics.redis

org.springframework.xd.batch.item.hadoop - package org.springframework.xd.batch.item.hadoop

org.springframework.xd.batch.item.jdbc - package org.springframework.xd.batch.item.jdbc

org.springframework.xd.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.module.support - package org.springframework.xd.dirt.module.support

org.springframework.xd.dirt.plugins - package org.springframework.xd.dirt.plugins

Base Package for Spring XD plugins

org.springframework.xd.dirt.plugins.job - package org.springframework.xd.dirt.plugins.job

Provides classes for the Spring Batch Support

org.springframework.xd.dirt.plugins.job.batch - package org.springframework.xd.dirt.plugins.job.batch

Provides classes for the Spring Batch Admin Support

org.springframework.xd.dirt.plugins.stream - package org.springframework.xd.dirt.plugins.stream

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.integration.reactor.channel - package org.springframework.xd.integration.reactor.channel

org.springframework.xd.integration.reactor.config - package org.springframework.xd.integration.reactor.config

org.springframework.xd.integration.reactor.dispatcher - package org.springframework.xd.integration.reactor.dispatcher

org.springframework.xd.integration.reactor.syslog - package org.springframework.xd.integration.reactor.syslog

org.springframework.xd.jdbc - package org.springframework.xd.jdbc

org.springframework.xd.module - package org.springframework.xd.module

org.springframework.xd.module.util - package org.springframework.xd.module.util

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

org.springframework.xd.tuple.spel - package org.springframework.xd.tuple.spel

ORIGINAL_CONTENT_TYPE_HEADER - Static variable in class org.springframework.integration.x.bus.MessageBusSupport

P

padRight(String, int, char) - Static method in class org.springframework.xd.shell.util.CommonUtils

Right-pad a String with a configurable padding character.

padRight(String, int) - Static method in class org.springframework.xd.shell.util.CommonUtils

Right-pad the provided String with empty spaces.

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 interface org.springframework.xd.dirt.stream.XDParser

parse(String, String) - Method in class org.springframework.xd.dirt.stream.XDStreamParser

parseArgument(String...) - Method in class org.springframework.xd.dirt.server.options.CommandLineParser

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

Parse command line options from a String array into a type safe AdminOptions class.

parseOptions(String[]) - Static method in class org.springframework.xd.dirt.server.ContainerMain

Parse command line options from a String array into a type safe ContainerOptions class.

parseOptions(String[]) - Static method in class org.springframework.xd.dirt.server.SingleNodeMain

Parse command line options from a String array into a type safe SingleNodeOptions class.

Plugin - Interface in org.springframework.xd.module

To be implemented by classes that want to alter how a Module works.

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

postProcessAfterInitialization(Object, String) - Method in class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor

postProcessAfterInitialization(Object, String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

postProcessBeanDefinitionRegistry(BeanDefinitionRegistry) - Method in class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class org.springframework.xd.module.BeanDefinitionAddingPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor

postProcessModule(Module) - Method in class org.springframework.integration.module.IntegrationPlugin

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

postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

postProcessModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

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

Apply changes to the module after it is initialized i.e. 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.

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.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 i.e. before its context is refreshed.

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

Perform any plugin-specific pre-refresh initialization.

preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.integration.module.IntegrationPlugin

preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

preProcessSharedContext(ConfigurableApplicationContext) - Method in class org.springframework.xd.module.AbstractPlugin

preProcessSharedContext(ConfigurableApplicationContext) - Method in interface org.springframework.xd.module.Plugin

Invoked when this plugin is discovered, allows to make any necessary changes to the context which will be used as the parent of all modules.

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

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

RabbitMessageBus - Class in org.springframework.integration.x.rabbit

A MessageBus implementation backed by RabbitMQ.

RabbitMessageBus(ConnectionFactory) - Constructor for class org.springframework.integration.x.rabbit.RabbitMessageBus

RabbitModuleEventListener - Class in org.springframework.xd.dirt.listener

RabbitModuleEventListener(ConnectionFactory) - Constructor for class org.springframework.xd.dirt.listener.RabbitModuleEventListener

RangeCapableRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Interface in org.springframework.xd.store

To be implemented by repositories that know how to return a slice of their data.

REACTOR_ENV_BEAN - Static variable in class org.springframework.xd.integration.reactor.config.ReactorNamespaceUtils

ReactorNamespaceHandler - Class in org.springframework.xd.integration.reactor.config

ReactorNamespaceHandler() - Constructor for class org.springframework.xd.integration.reactor.config.ReactorNamespaceHandler

ReactorNamespaceUtils - Class in org.springframework.xd.integration.reactor.config

Namespace parser helper for creating BeanDefinitionBuilder instances that have a reference to a Reactor Environment as their first constructor parameter.

ReactorNamespaceUtils() - Constructor for class org.springframework.xd.integration.reactor.config.ReactorNamespaceUtils

ReactorProcessorMessageDispatcher - Class in org.springframework.xd.integration.reactor.dispatcher

ReactorProcessorMessageDispatcher() - Constructor for class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher

ReactorProcessorMessageDispatcher(boolean) - Constructor for class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher

ReactorPublishSubscribeChannel - Class in org.springframework.xd.integration.reactor.channel

ReactorPublishSubscribeChannel(MessageDispatcher) - Constructor for class org.springframework.xd.integration.reactor.channel.ReactorPublishSubscribeChannel

ReactorPublishSubscribeChannelParser - Class in org.springframework.xd.integration.reactor.config

ReactorPublishSubscribeChannelParser() - Constructor for class org.springframework.xd.integration.reactor.config.ReactorPublishSubscribeChannelParser

read(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor

RedisAggregateCounterRepository - Class in org.springframework.xd.analytics.metrics.redis

Redis implementation of AggregateCounterRepository.

RedisAggregateCounterRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

RedisAvailableRule - Class in org.springframework.xd.test.redis

RedisAvailableRule() - Constructor for class org.springframework.xd.test.redis.RedisAvailableRule

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

RedisMessageBus - Class in org.springframework.integration.x.redis

A MessageBus implementation backed by Redis.

RedisMessageBus(RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisMessageBus

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 that allows publishing of message types other than String

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

RedisQueueOutboundChannelAdapter - Class in org.springframework.integration.x.redis

RedisQueueOutboundChannelAdapter(String, RedisConnectionFactory) - Constructor for class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter

RedisRichGaugeRepository - Class in org.springframework.xd.analytics.metrics.redis

RedisRichGaugeRepository(RedisConnectionFactory) - Constructor for class org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository

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

redisTemplate - Variable in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

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

removeDeployment(String) - Method in class org.springframework.xd.dirt.stream.DeploymentMessageSender

removeHandler(MessageHandler) - Method in class org.springframework.xd.integration.reactor.dispatcher.ReactorProcessorMessageDispatcher

removeModule(Module) - Method in class org.springframework.integration.module.IntegrationPlugin

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

removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.MBeanExportingPlugin

removeModule(Module) - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin

removeModule(Module) - Method in interface org.springframework.xd.module.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.ChannelNode

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

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

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

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

resolveChannelName(String) - Method in class org.springframework.integration.x.bus.MessageBusAwareChannelResolver

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.

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

Operations common to resources like (Stream, Job, and Tap )

restart(Long) - Method in class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

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

Takes care of infrastructure setup for the web/rest layer.

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

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

Central class for behavior common to all REST controllers.

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

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

run() - Method in class org.springframework.xd.dirt.server.AdminServer

Call's AdminServer.afterPropertiesSet() and AdminServer.start()

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(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(Message<?>) - Method in class org.springframework.integration.x.redis.MessageRedisSerializer

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

set_created_at(Date) - Method in class org.springframework.integration.x.twitter.XDTweet

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.bus.LocalMessageBus

setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.container.XDContainer

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

setApplicationContext(ApplicationContext) - Method in class org.springframework.xd.dirt.module.FileModuleRegistry

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.bus.MessageBusSupport

setBeanClassLoader(ClassLoader) - Method in class org.springframework.integration.x.json.TypedJsonMapper

setBeanClassLoader(ClassLoader) - Method in class org.springframework.xd.dirt.module.ModuleDeployer

setBeanClassLoader(ClassLoader) - Method in class org.springframework.xd.dirt.module.support.ThreadContextClassLoaderSetterAdvice

setBeanFactory(BeanFactory) - Method in class org.springframework.integration.x.bus.MessageBusAwareChannelResolver

setBeanFactory(BeanFactory) - Method in class org.springframework.integration.x.bus.MessageBusAwareRouterBeanPostProcessor

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.server.AdminServer

Set the contextPath to serve requests on.

setConversionService(ConversionService) - Method in class org.springframework.integration.x.bus.MessageBusSupport

setConvertWithinTransport(boolean) - Method in class org.springframework.integration.x.bus.LocalMessageBus

Determines whether any conversion logic is applied within the local transport.

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

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

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

setCreatedAt(Date) - Method in class org.springframework.integration.x.twitter.XDTweet

setData(Map<Integer, String>) - Method in class org.springframework.xd.shell.util.TableRow

setDateFormat(DateFormat) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Will set the DateFormat on the underlying DefaultJobParametersConverter.

setDateFormat(DateFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

Will set the DateFormat on the underlying DefaultJobParametersConverter.

setDateFormat(DateFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

Will set the DateFormat on the underlying DefaultJobParametersConverter.

setDateFormat(DateFormat) - Method in class org.springframework.xd.tuple.batch.TupleFieldSetMapper

The DateFormat used by the resulting Tuple instance returned when converting strings to Dates.

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

setDateFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Allows for setting the DateFormat using a String.

setDateFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

setDateFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

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.

setDeployed(Boolean) - Method in class org.springframework.xd.rest.client.domain.DeployableResource

setDeployments(boolean) - Method in class org.springframework.xd.dirt.rest.XDController.QueryOptions

setDisplayUrl(String) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setDisplayUrl(String) - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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

setEnableDefaultSerializer(boolean) - Method in class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter

setEntities(XDEntities) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setExpandedUrl(String) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setExpandedUrl(String) - Method in class org.springframework.integration.x.twitter.XDUrlEntity

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

setExtractPayload(boolean) - Method in class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter

setFavorited(boolean) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setFromUser(String) - Method in class org.springframework.integration.x.twitter.XDTweet

setFromUserId(long) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setGaugeValue(Gauge, long) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils

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

setGroupName(String) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

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

setHashTags(List<XDHashTagEntity>) - Method in class org.springframework.integration.x.twitter.XDEntities

setHost(String) - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

setId(long) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setId(long) - Method in class org.springframework.integration.x.twitter.XDMentionEntity

setId(long) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setIndices(int[]) - Method in class org.springframework.integration.x.twitter.XDHashTagEntity

setIndices(int[]) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setIndices(int[]) - Method in class org.springframework.integration.x.twitter.XDMentionEntity

setIndices(int[]) - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

setIndices(int[]) - Method in class org.springframework.integration.x.twitter.XDUrlEntity

setInputChannelName(String) - Method in class org.springframework.integration.module.config.DefaultChannelExporter

setInReplyToScreenName(String) - Method in class org.springframework.integration.x.twitter.XDTweet

setInReplyToStatusId(Long) - Method in class org.springframework.integration.x.twitter.XDTweet

setInReplyToUserId(Long) - Method in class org.springframework.integration.x.twitter.XDTweet

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

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

setJdbcTemplate(JdbcOperations) - Method in class org.springframework.xd.dirt.plugins.job.batch.BatchJobLocator

setJobExecutionId(Long) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController.StopRequest

setJobLocator(BatchJobLocator) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

setJobRegistry(JobRegistry) - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor

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.

setLanguageCode(String) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setMakeParametersUnique(boolean) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

If not set, this property defaults to true.

setMakeParametersUnique(boolean) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

If not set, this property defaults to true.

setMakeParametersUnique(boolean) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

If not set, this property defaults to true.

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

Defaults to -1 indicating to ignore the property.

setMedia(List<XDMediaEntity>) - Method in class org.springframework.integration.x.twitter.XDEntities

setMediaSecureUrl(String) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setMediaUrl(String) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setMentions(List<XDMentionEntity>) - Method in class org.springframework.integration.x.twitter.XDEntities

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.integration.x.twitter.XDMentionEntity

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.

setNumberFormat(NumberFormat) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Setter for the NumberFormat which is set on the underlying DefaultJobParametersConverter.

setNumberFormat(NumberFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

Setter for the NumberFormat which is set on the underlying DefaultJobParametersConverter.

setNumberFormat(NumberFormat) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

Setter for the NumberFormat which is set on the underlying DefaultJobParametersConverter.

setNumberFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

Allows for setting the NumberFormat using a String.

setNumberFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

setNumberFormatAsString(String) - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean

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

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

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.bus.LocalMessageBus

Set the poller to use when QueueChannels are used.

setPort(int) - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

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.

setProfileImageUrl(String) - Method in class org.springframework.integration.x.twitter.XDTweet

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.bus.LocalMessageBus

Set the size of the queue when using QueueChannels.

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

The read timeout for the underlying URLConnection to the twitter stream.

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

setRetweetCount(Integer) - Method in class org.springframework.integration.x.twitter.XDTweet

setRetweeted(boolean) - Method in class org.springframework.integration.x.twitter.XDTweet

setRetweetedStatus(XDTweet) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setScreen_Name(String) - Method in class org.springframework.integration.x.twitter.XDMentionEntity

setScreenName(String) - Method in class org.springframework.integration.x.twitter.XDMentionEntity

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

setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter

setSerializer(RedisSerializer<?>) - Method in class org.springframework.integration.x.redis.RedisQueueOutboundChannelAdapter

setServerProperties(Properties) - Method in class org.springframework.xd.dirt.plugins.job.batch.HSQLServerBean

setServletName(String) - Method in class org.springframework.xd.dirt.server.AdminServer

Set the servletName.

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

setSource(String) - Method in class org.springframework.integration.x.twitter.XDTweet

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.

setStringSerializer(RedisSerializer<String>) - Method in class org.springframework.integration.x.redis.MessageRedisSerializer

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.

setText(String) - Method in class org.springframework.integration.x.twitter.XDHashTagEntity

setText(String) - Method in class org.springframework.integration.x.twitter.XDTweet

setTickerSymbol(String) - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

setTickerSymbols(List<XDTickerSymbolEntity>) - Method in class org.springframework.integration.x.twitter.XDEntities

setTimeZone(TimeZone) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController

setTimeZone(TimeZone) - Method in class org.springframework.xd.dirt.rest.BatchJobsController

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

setToUserId(Long) - Method in class org.springframework.integration.x.twitter.XDTweet

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.integration.x.twitter.XDMediaEntity

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.

setUrl(String) - Method in class org.springframework.integration.x.twitter.XDMediaEntity

setUrl(String) - Method in class org.springframework.integration.x.twitter.XDTickerSymbolEntity

setUrl(String) - Method in class org.springframework.integration.x.twitter.XDUrlEntity

setUrls(List<XDUrlEntity>) - Method in class org.springframework.integration.x.twitter.XDEntities

setUser(XDTwitterProfile) - Method in class org.springframework.integration.x.twitter.XDTweet

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

setXDEntities(XDEntities) - Method in class org.springframework.integration.x.twitter.XDTweet

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

showAllInlineMedia() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the user has selected to see all inline media from everyone.

showHelp - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

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

A Module implementation backed by a Spring ApplicationContext.

SimpleModule(ModuleDefinition, DeploymentMetadata) - Constructor for class org.springframework.xd.module.SimpleModule

SimpleModule(ModuleDefinition, DeploymentMetadata, ClassLoader) - Constructor for class org.springframework.xd.module.SimpleModule

SingleNodeMain - Class in org.springframework.xd.dirt.server

The main driver class for the SingleNode Server that has both the AdminServer and XDContainer

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

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

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

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

SingleNodeServer - Class in org.springframework.xd.dirt.server

An XD server configured for a single node

SingleNodeServer(AdminServer, XDContainer) - Constructor for class org.springframework.xd.dirt.server.SingleNodeServer

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.integration.x.bus.Bridge

start() - Method in class org.springframework.xd.dirt.container.XDContainer

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

start() - Method in class org.springframework.xd.dirt.server.AdminServer

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.integration.x.bus.Bridge

stop() - Method in class org.springframework.xd.dirt.container.XDContainer

stop(Runnable) - Method in class org.springframework.xd.dirt.container.XDContainer

stop(Long) - Method in class org.springframework.xd.dirt.plugins.job.batch.DistributedJobService

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

stop() - Method in class org.springframework.xd.dirt.server.AdminServer

stop(Runnable) - Method in class org.springframework.xd.dirt.server.AdminServer

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

stopBridges() - Method in class org.springframework.integration.x.bus.MessageBusSupport

store - Variable in class org.springframework.xd.dirt.server.options.AdminOptions

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

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

SyslogInboundChannelAdapter - Class in org.springframework.xd.integration.reactor.syslog

SyslogInboundChannelAdapter(Environment) - Constructor for class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

SyslogInboundChannelAdapterParser - Class in org.springframework.xd.integration.reactor.config

SyslogInboundChannelAdapterParser() - Constructor for class org.springframework.xd.integration.reactor.config.SyslogInboundChannelAdapterParser

T

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

Provide a basic concept of a table structure containing a map of column headers and a collection of rows.

Table() - Constructor for class org.springframework.xd.shell.util.Table

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

Defines table column headers used by Table.

TableHeader(String, int) - Constructor for class org.springframework.xd.shell.util.TableHeader

Constructor that initializes the table header with the provided header name and the with of the table header.

TableHeader(String) - Constructor for class org.springframework.xd.shell.util.TableHeader

Constructor that initializes the table header with the provided header name.

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

Target - Class in org.springframework.xd.shell

Encapsulates various data points related to the Admin Server Target, such as target URI, success/error state, exception messages that may have occurred.

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

Construct a new Target.

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

Target.TargetStatus - Enum in org.springframework.xd.shell

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

ThreadContextClassLoaderSetterAdvice - Class in org.springframework.xd.dirt.module.support

An advice that will set the thread context ClassLoader to the enclosing ApplicationContext's class loader before invocation and reset it afterwards.

ThreadContextClassLoaderSetterAdvice() - Constructor for class org.springframework.xd.dirt.module.support.ThreadContextClassLoaderSetterAdvice

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

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

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

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

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

toBytes(Object) - Method in class org.springframework.integration.x.json.TypedJsonMapper

toJobLaunchRequest(Message<?>) - Method in class org.springframework.xd.dirt.plugins.job.JobLaunchRequestTransformer

toObject(String) - Method in class org.springframework.integration.x.gemfire.JsonStringToObjectTransformer

toResource(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

toString() - Method in class org.springframework.integration.x.bus.Bridge

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.module.AbstractModule

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

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.bus.MessageBusSupport

transformOutboundIfNecessary(Message<?>, MediaType) - Method in class org.springframework.integration.x.bus.MessageBusSupport

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 - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

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

The kind of transport used for communication between the admin server and container(s).

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

TuplePropertyAccessor - Class in org.springframework.xd.tuple.spel

A PropertyAccessor implementation that enables reading of Tuple values using dot notation within SpEL expressions.

TuplePropertyAccessor() - Constructor for class org.springframework.xd.tuple.spel.TuplePropertyAccessor

TupleRowMapper - Class in org.springframework.xd.tuple.batch

A RowMapper implementation to be used with the Tuple data structure.

TupleRowMapper() - Constructor for class org.springframework.xd.tuple.batch.TupleRowMapper

TupleSqlParameterSource - Class in org.springframework.xd.tuple.batch

Implementation of a SqlParameterSource that translates a Tuple into SQL parameters.

TupleSqlParameterSource(Tuple) - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSource

TupleSqlParameterSourceProvider - Class in org.springframework.xd.tuple.batch

A factory for TupleSqlParameterSources

TupleSqlParameterSourceProvider() - Constructor for class org.springframework.xd.tuple.batch.TupleSqlParameterSourceProvider

TupleStringMarshaller - Class in org.springframework.xd.tuple

TupleStringMarshaller(Converter<Tuple, String>, Converter<String, Tuple>) - Constructor for class org.springframework.xd.tuple.TupleStringMarshaller

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

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

XD UI resource identifier

UiResourceIdentifier(String) - Constructor for class org.springframework.xd.dirt.rest.UiResourceIdentifier

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

Contains utility methods for rendering data to a formatted console output.

unbindConsumer(String, MessageChannel) - Method in interface org.springframework.integration.x.bus.MessageBus

Unbind a specific p2p or pub/sub message consumer

unbindConsumer(String, MessageChannel) - Method in class org.springframework.integration.x.bus.MessageBusSupport

unbindConsumers(String) - Method in interface org.springframework.integration.x.bus.MessageBus

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

unbindConsumers(String) - Method in class org.springframework.integration.x.bus.MessageBusSupport

unbindProducer(String, MessageChannel) - Method in interface org.springframework.integration.x.bus.MessageBus

Unbind a specific p2p or pub/sub message producer

unbindProducer(String, MessageChannel) - Method in class org.springframework.integration.x.bus.MessageBusSupport

unbindProducers(String) - Method in interface org.springframework.integration.x.bus.MessageBus

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

unbindProducers(String) - Method in class org.springframework.integration.x.bus.MessageBusSupport

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

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

Request un-deployment of an existing named module.

undeploy(String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

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

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

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

undeploy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations

Undeploy a deployed resource, retaining its definition.

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

Undeploy all the deployed resources.

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

Request un-deployment of all modules.

undeployAll() - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer

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

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

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

undeployAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations

Undeploy all the resources known to the system.

undeployJob(String, boolean) - Method in class org.springframework.xd.shell.command.JobCommands

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

UNIQUE_JOB_PARAMETER_KEY - Static variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter

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.

useBackgroundImage() - Method in class org.springframework.integration.x.twitter.XDTwitterProfile

Whether or not the user's Twitter profile page uses a background image.

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

write(EvaluationContext, Object, String, Object) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor

X

XD_ANALYTICS - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_BATCH_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.XDContainer

XD_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.XDContainer

Base location for XD config files.

XD_HADOOP_DISTRO - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_HOME - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_HTTP_PORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_INTERNAL_CONFIG_ROOT - Static variable in class org.springframework.xd.dirt.container.XDContainer

Where container related config files reside.

XD_JMX_ENABLED - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_JMX_PORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_JSON_OCTET_STREAM_VALUE - Static variable in class org.springframework.integration.x.bus.MessageBusSupport

XD_OCTET_STREAM_VALUE - Static variable in class org.springframework.integration.x.bus.MessageBusSupport

XD_STORE - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XD_TEXT_PLAIN_UTF8_VALUE - Static variable in class org.springframework.integration.x.bus.MessageBusSupport

XD_TRANSPORT - Static variable in interface org.springframework.xd.dirt.server.options.XDPropertyKeys

XDContainer - Class in org.springframework.xd.dirt.container

XDContainer(String) - Constructor for class org.springframework.xd.dirt.container.XDContainer

Creates a container with a given id

XDContainer() - Constructor for class org.springframework.xd.dirt.container.XDContainer

Default constructor generates a random id

XDContainerLaunchException - Exception in org.springframework.xd.dirt.launcher

Exception thrown when the XDContainer fails to launch.

XDContainerLaunchException(String) - Constructor for exception org.springframework.xd.dirt.launcher.XDContainerLaunchException

XDContainerLaunchException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.launcher.XDContainerLaunchException

XDController<D extends BaseDefinition,A extends org.springframework.hateoas.mvc.ResourceAssemblerSupport<D,R>,R extends NamedResource> - Class in org.springframework.xd.dirt.rest

Base Class for XD Controllers.

XDController(AbstractDeployer<D>, A) - Constructor for class org.springframework.xd.dirt.rest.XDController

XDController.QueryOptions - Class in org.springframework.xd.dirt.rest

Data holder class for controlling how the list methods should behave.

XDController.QueryOptions() - Constructor for class org.springframework.xd.dirt.rest.XDController.QueryOptions

XDDSLMessages - Enum in org.springframework.xd.dirt.stream.dsl

Contains all the messages that can be produced during Spring XD DSL parsing.

XDDSLMessages.Kind - Enum in org.springframework.xd.dirt.stream.dsl

XDEntities - Class in org.springframework.integration.x.twitter

XDEntities() - Constructor for class org.springframework.integration.x.twitter.XDEntities

XDEntities(Entities) - Constructor for class org.springframework.integration.x.twitter.XDEntities

XDHashTagEntity - Class in org.springframework.integration.x.twitter

XDHashTagEntity() - Constructor for class org.springframework.integration.x.twitter.XDHashTagEntity

XDHashTagEntity(HashTagEntity) - Constructor for class org.springframework.integration.x.twitter.XDHashTagEntity

xdHomeDir - Variable in class org.springframework.xd.dirt.server.options.AbstractOptions

XDMediaEntity - Class in org.springframework.integration.x.twitter

XDMediaEntity() - Constructor for class org.springframework.integration.x.twitter.XDMediaEntity

XDMediaEntity(MediaEntity) - Constructor for class org.springframework.integration.x.twitter.XDMediaEntity

XDMentionEntity - Class in org.springframework.integration.x.twitter

XDMentionEntity() - Constructor for class org.springframework.integration.x.twitter.XDMentionEntity

XDMentionEntity(MentionEntity) - Constructor for class org.springframework.integration.x.twitter.XDMentionEntity

XDParser - Interface in org.springframework.xd.dirt.stream

XDPropertyKeys - Interface in org.springframework.xd.dirt.server.options

XD property keys.

XDRuntime - Class in org.springframework.xd.rest.client.domain

Represents information about the XD Runtime.

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

XDRuntimeException - Exception in org.springframework.xd.dirt.core

Base class for all XD-related exceptions.

XDRuntimeException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.core.XDRuntimeException

XDRuntimeException(String) - Constructor for exception org.springframework.xd.dirt.core.XDRuntimeException

XDShell - Class in org.springframework.xd.shell

XDShell() - Constructor for class org.springframework.xd.shell.XDShell

XDShellBannerProvider - Class in org.springframework.xd.shell

Provides the Spring XD specific BannerProvider.

XDShellBannerProvider() - Constructor for class org.springframework.xd.shell.XDShellBannerProvider

XDShellPromptProvider - Class in org.springframework.xd.shell

A provider that sets the shell prompt to xd:>

XDShellPromptProvider() - Constructor for class org.springframework.xd.shell.XDShellPromptProvider

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

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

XDStreamParser(ModuleRegistry) - Constructor for class org.springframework.xd.dirt.stream.XDStreamParser

XDTickerSymbolEntity - Class in org.springframework.integration.x.twitter

XDTickerSymbolEntity() - Constructor for class org.springframework.integration.x.twitter.XDTickerSymbolEntity

XDTickerSymbolEntity(TickerSymbolEntity) - Constructor for class org.springframework.integration.x.twitter.XDTickerSymbolEntity

XDTweet - Class in org.springframework.integration.x.twitter

XDTweet() - Constructor for class org.springframework.integration.x.twitter.XDTweet

XDTweet(Tweet) - Constructor for class org.springframework.integration.x.twitter.XDTweet

XDTwitterProfile - Class in org.springframework.integration.x.twitter

Model class representing a Twitter user's profile information.

XDTwitterProfile() - Constructor for class org.springframework.integration.x.twitter.XDTwitterProfile

XDTwitterProfile(TwitterProfile) - Constructor for class org.springframework.integration.x.twitter.XDTwitterProfile

XDUrlEntity - Class in org.springframework.integration.x.twitter

XDUrlEntity() - Constructor for class org.springframework.integration.x.twitter.XDUrlEntity

XDUrlEntity(UrlEntity) - Constructor for class org.springframework.integration.x.twitter.XDUrlEntity

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