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

A

abandon(Long) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
 
abandonWhenPercentageFull - Variable in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
ABSOLUTE_FILE_PATH - Static variable in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
 
AbstractBatchJobsController - Class in org.springframework.xd.dirt.rest
Abstract controller that all the XD batch admin controllers extend.
AbstractBatchJobsController() - Constructor for class org.springframework.xd.dirt.rest.AbstractBatchJobsController
 
AbstractBusPropertiesAccessor - Class in org.springframework.xd.dirt.integration.bus
Base class for bus-specific property accessors; common properies are defined here.
AbstractBusPropertiesAccessor(Properties) - Constructor for class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
 
AbstractCodec<T> - Class in org.springframework.xd.dirt.integration.bus.serializer
Support class providing convenience methods for codecs.
AbstractCodec() - Constructor for class org.springframework.xd.dirt.integration.bus.serializer.AbstractCodec
 
AbstractComponentScanningBeanDefinitionProvider - Class in org.springframework.xd.dirt.container.initializer
 
AbstractComponentScanningBeanDefinitionProvider() - Constructor for class org.springframework.xd.dirt.container.initializer.AbstractComponentScanningBeanDefinitionProvider
 
AbstractDeployer<D extends BaseDefinition> - Class in org.springframework.xd.dirt.stream
Abstract implementation of the @link ResourceDeployer interface.
AbstractDeployer(ZooKeeperConnection, PagingAndSortingRepository<D, String>, XDParser, ParsingContext) - Constructor for class org.springframework.xd.dirt.stream.AbstractDeployer
 
AbstractEvent<S> - Class in org.springframework.xd.dirt.event
 
AbstractEvent(S) - Constructor for class org.springframework.xd.dirt.event.AbstractEvent
 
AbstractExternalResourceTestSupport<R> - Class in org.springframework.xd.test
Abstract base class for JUnit Rules that detect the presence of some external resource.
AbstractExternalResourceTestSupport(String) - Constructor for class org.springframework.xd.test.AbstractExternalResourceTestSupport
 
AbstractFieldMappingAwareDataMapper - Class in org.springframework.xd.analytics.ml
 
AbstractFieldMappingAwareDataMapper() - Constructor for class org.springframework.xd.analytics.ml.AbstractFieldMappingAwareDataMapper
AbstractFieldMappingAwareDataMapper(String) - Constructor for class org.springframework.xd.analytics.ml.AbstractFieldMappingAwareDataMapper
AbstractFromMessageConverter - Class in org.springframework.xd.dirt.integration.bus.converter
Base class for converters applied via Spring Integration 4.x data type channels.
AbstractFromMessageConverter(MimeType) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Creates a converter that ignores content-type message headers
AbstractFromMessageConverter(Collection<MimeType>) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
 
AbstractFromMessageConverter(Collection<MimeType>, MimeType, ContentTypeResolver) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Creates a converter that handles one or more content-type message headers
AbstractFromMessageConverter(Collection<MimeType>, Collection<MimeType>, ContentTypeResolver) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Creates a converter that handles one or more content-type message headers and one or more target MIME types
AbstractFromMessageConverter(MimeType, MimeType) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Creates a converter that requires a specific content-type message header
AbstractFromMessageConverter(MimeType, Collection<MimeType>) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Creates a converter that requires a specific content-type message header and supports multiple target MIME types.
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
 
AbstractImportToJdbcOptionsMetadata - Class in org.springframework.xd.jdbc
Factors out options that are common to modules/jobs that import into a db table.
AbstractImportToJdbcOptionsMetadata() - Constructor for class org.springframework.xd.jdbc.AbstractImportToJdbcOptionsMetadata
 
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(ZooKeeperConnection, PagingAndSortingRepository<D, String>, DomainRepository<I, String>, XDParser, ParsingContext) - Constructor for class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
 
AbstractJobPlugin - Class in org.springframework.xd.dirt.plugins
Abstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related to job plugins.
AbstractJobPlugin(MessageBus) - Constructor for class org.springframework.xd.dirt.plugins.AbstractJobPlugin
 
AbstractMailSource<T extends AbstractMailSource<T>> - Class in org.springframework.xd.test.fixtures
Base class support for both "mail" and "imap".
AbstractMailSource() - Constructor for class org.springframework.xd.test.fixtures.AbstractMailSource
 
AbstractMessageBusBinderPlugin - Class in org.springframework.xd.dirt.plugins
Abstract Plugin that has common implementation methods to bind/unbind Module's message producers and consumers to/from MessageBus.
AbstractMessageBusBinderPlugin(MessageBus) - Constructor for class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
AbstractMessageBusBinderPlugin(MessageBus, ZooKeeperConnection) - Constructor for class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
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
 
AbstractMetricSink - Class in org.springframework.xd.test.fixtures
Base class for Metrics related sinks, makes sure named metric is deleted at end of test.
AbstractMetricSink(JLineShellComponent, String, String) - Constructor for class org.springframework.xd.test.fixtures.AbstractMetricSink
 
AbstractModule - Class in org.springframework.xd.module.core
Base support class for modules, wrapping ModuleDescriptor and ModuleDeploymentProperties.
AbstractModule(ModuleDescriptor, ModuleDeploymentProperties) - Constructor for class org.springframework.xd.module.core.AbstractModule
 
AbstractModuleEvent - Class in org.springframework.xd.dirt.event
 
AbstractModuleEvent(Module, String) - Constructor for class org.springframework.xd.dirt.event.AbstractModuleEvent
 
AbstractModuleFixture<F extends AbstractModuleFixture<F>> - Class in org.springframework.xd.test.fixtures
Base class for objects that can be incorporated in a stream definition by calling their AbstractModuleFixture.toString() method.
AbstractModuleFixture() - Constructor for class org.springframework.xd.test.fixtures.AbstractModuleFixture
 
AbstractModuleRegistry - Class in org.springframework.xd.dirt.module
Provides common behavior for ModuleRegistry and knows how to handle custom classpath population for storages that support it.
AbstractModuleRegistry() - Constructor for class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
AbstractPlugin - Class in org.springframework.xd.dirt.plugins
Abstract Plugin that contains no-op and common implementing methods.
AbstractPlugin() - Constructor for class org.springframework.xd.dirt.plugins.AbstractPlugin
 
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
 
AbstractResourceBeanDefinitionProvider - Class in org.springframework.xd.dirt.container.initializer
A OrderedContextInitializer base class for loading XML or Groovy Bean Definitions into the target Container Context.
AbstractResourceBeanDefinitionProvider() - Constructor for class org.springframework.xd.dirt.container.initializer.AbstractResourceBeanDefinitionProvider
 
AbstractSingleNodeNamedChannelModule<T extends org.springframework.messaging.MessageChannel> - Class in org.springframework.xd.dirt.test
Base class for SingleNodeNamedChannel resources used to bind a MessageChannel to a shared channel using a MessageBus.
AbstractSingleNodeNamedChannelModule(MessageBus, T, String) - Constructor for class org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule
 
AbstractSingleNodeNamedChannelModuleFactory - Class in org.springframework.xd.dirt.test
Base class for factories used to create NamedChannelSource and NamedChannelSink.
AbstractSingleNodeNamedChannelModuleFactory(MessageBus) - Constructor for class org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModuleFactory
 
AbstractSingleNodeNamedChannelSink - Class in org.springframework.xd.dirt.test.sink
Base class for SingleNode named channel sink types.
AbstractSingleNodeNamedChannelSink(MessageBus, String) - Constructor for class org.springframework.xd.dirt.test.sink.AbstractSingleNodeNamedChannelSink
 
AbstractSingleNodeNamedChannelSource - Class in org.springframework.xd.dirt.test.source
Base class for SingleNode named channel source types.
AbstractSingleNodeNamedChannelSource(MessageBus, SubscribableChannel, String) - Constructor for class org.springframework.xd.dirt.test.source.AbstractSingleNodeNamedChannelSource
 
AbstractSingleNodeProcessingChain - Class in org.springframework.xd.dirt.test.process
A helper class for building single node streams that use a NamedChannelSource and NamedChannelSink.
AbstractSingleNodeProcessingChain(SingleNodeApplication, String, String) - Constructor for class org.springframework.xd.dirt.test.process.AbstractSingleNodeProcessingChain
 
AbstractSingleNodeProcessingChain(SingleNodeApplication, String, String, String) - Constructor for class org.springframework.xd.dirt.test.process.AbstractSingleNodeProcessingChain
 
AbstractStreamPlugin - Class in org.springframework.xd.dirt.plugins
Abstract class that extends AbstractMessageBusBinderPlugin and has common implementation methods related to stream plugins.
AbstractStreamPlugin(MessageBus) - Constructor for class org.springframework.xd.dirt.plugins.AbstractStreamPlugin
 
AbstractStreamPlugin(MessageBus, ZooKeeperConnection) - Constructor for class org.springframework.xd.dirt.plugins.AbstractStreamPlugin
 
AbstractTcpConnectionFactoryOptionsMetadata - Class in org.springframework.xd.tcp
Base class for options metadata that deal with a tcp connection factory in some way.
AbstractTcpConnectionFactoryOptionsMetadata() - Constructor for class org.springframework.xd.tcp.AbstractTcpConnectionFactoryOptionsMetadata
 
AbstractTwitterInboundChannelAdapter - Class in org.springframework.integration.x.twitter
 
AbstractTwitterInboundChannelAdapter(TwitterTemplate) - Constructor for class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter
 
AbstractTwitterInboundChannelAdapter.StreamReadingTask - Class in org.springframework.integration.x.twitter
 
AbstractTwitterInboundChannelAdapter.StreamReadingTask() - Constructor for class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter.StreamReadingTask
 
add(Object) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport.SetBuilder
 
add(ModuleOption) - Method in class org.springframework.xd.module.options.SimpleModuleOptionsMetadata
 
addAll(Set<Object>) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport.SetBuilder
 
addBinding(Binding) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
addChildren(List<ModuleDescriptor>) - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Add the list of children to the list of sub modules.
addComponents(Resource) - Method in class org.springframework.xd.module.core.CompositeModule
 
addComponents(Resource) - Method in interface org.springframework.xd.module.core.Module
 
addComponents(Resource) - Method in class org.springframework.xd.module.core.SimpleModule
 
addDelegate(ModuleRegistry) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
 
addHeader(Integer, TableHeader) - Method in class org.springframework.xd.shell.util.Table
 
addJob(String, boolean, boolean) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Store the job name , job parameterer incrementable and job restartable flags for the job when there is a registry update
addListener(ZooKeeperConnectionListener) - Method in class org.springframework.xd.dirt.zookeeper.ZooKeeperConnection
addListener(ApplicationListener<?>) - Method in class org.springframework.xd.module.core.CompositeModule
 
addListener(ApplicationListener<?>) - Method in interface org.springframework.xd.module.core.Module
 
addListener(ApplicationListener<?>) - Method in class org.springframework.xd.module.core.SimpleModule
 
AddModuleOptionsExpansionStrategy - Class in org.springframework.xd.dirt.stream.completion
Adds missing module options at the end of a well formed stream definition.
AddModuleOptionsExpansionStrategy(ModuleDefinitionRepository, ModuleOptionsMetadataResolver) - Constructor for class org.springframework.xd.dirt.stream.completion.AddModuleOptionsExpansionStrategy
Construct a new AddModuleOptionsExpansionStrategy for use in detecting missing module options.
addOption(DetailedModuleDefinitionResource.Option) - Method in class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource
 
addParameters(Map<String, String>) - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Add the contents of the provided map to the map of module parameters.
addPathListener(String, PathChildrenCacheListener) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Add a PathChildrenCacheListener for the given path.
addProperties(Properties) - Method in class org.springframework.xd.module.core.CompositeModule
 
addProperties(Properties) - Method in interface org.springframework.xd.module.core.Module
 
addProperties(Properties) - Method in class org.springframework.xd.module.core.SimpleModule
 
addProposals(String, List<ModuleDescriptor>, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.AddModuleOptionsExpansionStrategy
 
addProposals(String, List<ModuleDescriptor>, CompletionKind, int, List<String>) - Method in interface org.springframework.xd.dirt.stream.completion.CompletionExpansionStrategy
Perform code completion by adding proposals to the proposals list.
addProposals(String, E, CompletionKind, int, List<String>) - Method in interface org.springframework.xd.dirt.stream.completion.CompletionRecoveryStrategy
Perform code completion by adding proposals to the proposals list.
addProposals(String, CheckpointedStreamDefinitionException, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.EmptyStartYieldsModulesRecoveryStrategy
 
addProposals(String, StreamDefinitionException, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.ExpandOneDashToTwoDashesRecoveryStrategy
 
addProposals(String, CheckpointedStreamDefinitionException, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.ModulesAfterPipeRecoveryStrategy
 
addProposals(String, CheckpointedStreamDefinitionException, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.OptionNameAfterDashDashRecoveryStrategy
 
addProposals(String, List<ModuleDescriptor>, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.PipeIntoOtherModulesExpansionStrategy
 
addProposals(String, NoSuchModuleException, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.UnfinishedModuleNameRecoveryStrategy
 
addProposals(String, CheckpointedStreamDefinitionException, CompletionKind, int, List<String>) - Method in class org.springframework.xd.dirt.stream.completion.UnfinishedOptionNameRecoveryStrategy
 
addresses(String) - Method in class org.springframework.xd.test.fixtures.RabbitSink
Sets the addresses for the fixture
addRow(String...) - Method in class org.springframework.xd.shell.util.Table
 
addScript(Resource) - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
 
addSource(Object) - Method in class org.springframework.xd.module.core.SimpleModule
 
addStepNames(String, Collection<String>) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Add the collection of step names into XD_JOB_REGISTRY_STEP_NAMES for a given job.
addValue(Date, long) - Method in class org.springframework.xd.rest.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_PASSWORD - Static variable in class org.springframework.xd.test.fixtures.DisposableMailSupport
 
ADMIN_PROFILE - Static variable in class org.springframework.xd.dirt.util.XdProfiles
 
ADMIN_TOKEN - Static variable in class org.springframework.xd.integration.util.ConfigUtil
 
ADMIN_USER - Static variable in class org.springframework.xd.test.fixtures.DisposableMailSupport
 
adminContext() - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
 
AdminController - Class in org.springframework.xd.dirt.rest
 
AdminController(EntityLinks) - Constructor for class org.springframework.xd.dirt.rest.AdminController
 
AdminOptions - Class in org.springframework.xd.dirt.server.options
Holds configuration options that are valid for the Admin server, when using distributed mode.
AdminOptions() - Constructor for class org.springframework.xd.dirt.server.options.AdminOptions
 
AdminPortNotAvailableException - Exception in org.springframework.xd.dirt.server
Exception thrown when the configured admin port is not available to use.
AdminPortNotAvailableException(String) - Constructor for exception org.springframework.xd.dirt.server.AdminPortNotAvailableException
Construct an AdminPortNotAvailableException.
ADMINS - Static variable in class org.springframework.xd.dirt.zookeeper.Paths
Name of admins (that could participate to become leader) node.
AdminServerApplication - Class in org.springframework.xd.dirt.server
 
AdminServerApplication() - Constructor for class org.springframework.xd.dirt.server.AdminServerApplication
 
afterChunk(ChunkContext) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
 
afterChunkError(ChunkContext) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
 
afterCreate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterDestroy(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterInvalidate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterJob(JobExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdJobExecutionListener
 
afterProcess(I, Object) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
 
afterPropertiesSet() - Method in class org.springframework.xd.batch.hsqldb.server.HSQLServerBean
 
afterPropertiesSet() - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
 
afterPropertiesSet() - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
afterPropertiesSet() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
afterPropertiesSet() - Method in class org.springframework.xd.hadoop.fs.DatasetDefinitionFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcBatchItemWriter
 
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReader
 
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReaderFactory
 
afterPropertiesSet() - Method in class org.springframework.xd.jdbc.SingleTableDatabaseInitializer
 
afterPropertiesSet() - Method in class org.springframework.xd.shell.command.ConfigCommands
Initialize the default Target for the XD Admin Server.
afterRead(I) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
 
afterRegionClear(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterRegionCreate(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterRegionDestroy(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterRegionInvalidate(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterRegionLive(RegionEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterReturningInvocation(ParseResult, Object) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
 
afterReturningInvocation(ParseResult, Object) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
 
afterSave(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
Callback method that subclasses may override to get a chance to act on newly saved definitions.
afterStep(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.FileDeletionStepExecutionListener
 
afterStep(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdStepExecutionListener
 
afterThrowingInvocation(ParseResult, Throwable) - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
 
afterThrowingInvocation(ParseResult, Throwable) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
 
afterUpdate(EntryEvent<K, V>) - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
afterWrite(List<? extends Object>) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
 
aggrCounterOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
 
aggrCounterOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations
Returns the portion of the API for interaction with Aggregate Counters.
AggregateCount - Class in org.springframework.xd.analytics.metrics.core
Represents the data returned from an aggregate count query.
AggregateCount(String, Interval, long[], AggregateCountResolution) - Constructor for class org.springframework.xd.analytics.metrics.core.AggregateCount
 
AggregateCounterCommands - Class in org.springframework.xd.shell.command
Commands for interacting with aggregate counter analytics.
AggregateCounterCommands() - Constructor for class org.springframework.xd.shell.command.AggregateCounterCommands
 
AggregateCounterHandler - Class in org.springframework.xd.analytics.metrics.integration
 
AggregateCounterHandler(AggregateCounterRepository, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.AggregateCounterHandler
 
AggregateCounterOperations - Interface in org.springframework.xd.rest.client
Interface defining operations available when dealing with Aggregate Counters.
AggregateCounterOperations.Resolution - Enum in org.springframework.xd.rest.client
 
AggregateCounterRepository - Interface in org.springframework.xd.analytics.metrics.core
A repository to interact with Aggregate Counters.
AggregateCountersController - Class in org.springframework.xd.dirt.rest.metrics
Exposes representations of AggregateCounts.
AggregateCountersController(AggregateCounterRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.AggregateCountersController
 
AggregateCounterSink - Class in org.springframework.xd.test.fixtures
Fixture class for an aggregate counter.
AggregateCounterSink(JLineShellComponent, String) - Constructor for class org.springframework.xd.test.fixtures.AggregateCounterSink
 
AggregateCounterSinkOptionsMetadata - Class in org.springframework.xd.analytics.metrics.metadata
Captures options for the aggregate-counter sink module.
AggregateCounterSinkOptionsMetadata() - Constructor for class org.springframework.xd.analytics.metrics.metadata.AggregateCounterSinkOptionsMetadata
 
AggregateCounterTemplate - Class in org.springframework.xd.rest.client.impl
Implementation of the Aggregate Counter part of the metrics API.
AggregateCounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.AggregateCounterTemplate
 
AggregateCountResolution - Enum in org.springframework.xd.analytics.metrics.core
The resolution options available for querying an aggregate counter.
AggregateCountsResource - Class in org.springframework.xd.rest.domain.metrics
The REST representation of an Aggregate Count.
AggregateCountsResource() - Constructor for class org.springframework.xd.rest.domain.metrics.AggregateCountsResource
No-arg constructor for serialization frameworks.
AggregateCountsResource(String) - Constructor for class org.springframework.xd.rest.domain.metrics.AggregateCountsResource
 
AggregatorProcessorModuleOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata
Describes options to the aggregator processor module.
AggregatorProcessorModuleOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
AggregatorProcessorModuleOptionsMetadata.StoreKind - Enum in org.springframework.xd.dirt.modules.metadata
 
ALL_MEDIA_TYPES - Static variable in class org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule
 
ALLOCATED - Static variable in class org.springframework.xd.dirt.zookeeper.Paths
Name of the deployment modules node that are allocated to containers.
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.
alternateUsernameAllowed - Variable in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
Analytic<I,O> - Interface in org.springframework.xd.analytics.ml
Base interface for the definition of analytical logic.
appendToFile(String) - Method in class org.springframework.xd.test.fixtures.FileSource
 
appendToFile(String) - Method in class org.springframework.xd.test.fixtures.TailSource
 
appendToRemoteFile(String, String, String, String, String) - Static method in class org.springframework.xd.integration.util.StreamUtils
Appends the payload to an existing file on a remote EC2 Instance.
ApplicationUtils - Class in org.springframework.xd.dirt.server
 
ApplicationUtils() - Constructor for class org.springframework.xd.dirt.server.ApplicationUtils
 
apply(Statement, Description) - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport
 
AppMaster - Class in org.springframework.xd.yarn
 
AppMaster() - Constructor for class org.springframework.xd.yarn.AppMaster
 
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
 
ArrivingContainerModuleRedeployer - Class in org.springframework.xd.dirt.server
The ModuleRedeployer that deploys the unallocated stream/job modules upon a new container arrival.
ArrivingContainerModuleRedeployer(ZooKeeperConnection, ContainerRepository, StreamFactory, JobFactory, PathChildrenCache, PathChildrenCache, PathChildrenCache, ContainerMatcher, DeploymentUnitStateCalculator) - Constructor for class org.springframework.xd.dirt.server.ArrivingContainerModuleRedeployer
Constructs ArrivingContainerModuleRedeployer
AsciidocLinkChecker - Class in org.springframework.xd.documentation
A tool that checks that for files that will form the whole "concatenated" documentation, any link of the form
AsciidocLinkChecker(String) - Constructor for class org.springframework.xd.documentation.AsciidocLinkChecker
 
asPropertySource() - Method in class org.springframework.xd.module.options.ModuleOptions
 
asPropertySource() - Method in class org.springframework.xd.module.options.PrefixNarrowingModuleOptions
 
Assertions - Class in org.springframework.xd.shell.util
Various utility methods when dealing with shell commands.
assertReceived(URL, String, String, String, int) - Method in class org.springframework.xd.integration.util.XdEc2Validation
Verifies that the instances for the channel and module has in fact processed the correct number of messages.
assertReceived(URL, String, int) - Method in class org.springframework.xd.integration.util.XdEc2Validation
Retrieves the stream and verifies that all modules in the stream processed the data.
asStringArray(String, String[]) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Convert a comma-delimited String property to a String[] if present, or return the default value.
AstNode - Class in org.springframework.xd.dirt.stream.dsl
Common supertype for the ast nodes built during stream parsing.
AstNode(int, int) - Constructor for class org.springframework.xd.dirt.stream.dsl.AstNode
 
atMostOneOf(Object...) - Static method in class org.springframework.xd.shell.util.Assertions
Accepts 2*N arguments, even ones being names and odd ones being values for those names.
available() - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
 
available() - Method in class org.springframework.xd.shell.command.CounterCommands
 
available() - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
 
available() - Method in class org.springframework.xd.shell.command.GaugeCommands
 
available() - Method in class org.springframework.xd.shell.command.JobCommands
 
available() - Method in class org.springframework.xd.shell.command.ModuleCommands
 
available() - Method in class org.springframework.xd.shell.command.RichGaugeCommands
 
available() - Method in class org.springframework.xd.shell.command.RuntimeCommands
 
available() - Method in class org.springframework.xd.shell.command.StreamCommands
 
AvailableSocketPorts - Class in org.springframework.xd.test.fixtures
Utility class to find available server ports.

B

BACK_OFF_INITIAL_INTERVAL - Static variable in interface org.springframework.xd.dirt.integration.bus.BusProperties
The retry back off initial interval.
BACK_OFF_MAX_INTERVAL - Static variable in interface org.springframework.xd.dirt.integration.bus.BusProperties
The retry back off max interval.
BACK_OFF_MULTIPLIER - Static variable in interface org.springframework.xd.dirt.integration.bus.BusProperties
The retry back off multiplier.
BannerUtils - Class in org.springframework.xd.dirt.util
Provides utilities for rendering graphical console output.
BaseDefinition - Class in org.springframework.xd.dirt.core
Represents the base model for a data flow in the system.
BaseDefinition() - Constructor for class org.springframework.xd.dirt.core.BaseDefinition
 
BaseDefinition(String, String) - Constructor for class org.springframework.xd.dirt.core.BaseDefinition
Create a new definition.
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, Map<String, String>) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
Provides basic deployment behavior, whereby running state of deployed definitions is not persisted.
BATCH_EXCEPTION - Static variable in class org.springframework.xd.dirt.plugins.job.BatchJobHeaders
 
BATCH_LISTENER_EVENT_TYPE - Static variable in class org.springframework.xd.dirt.plugins.job.BatchJobHeaders
 
batchDatabaseInitializer() - Method in class org.springframework.xd.batch.hsqldb.server.HsqlServerApplication
 
batchDatabaseInitializer() - Method in class org.springframework.xd.dirt.server.AdminServerApplication
 
BatchJobAlreadyExistsException - Exception in org.springframework.xd.dirt.job
Exception thrown when the batch job with the given name already exists.
BatchJobAlreadyExistsException(String) - Constructor for exception org.springframework.xd.dirt.job.BatchJobAlreadyExistsException
 
BatchJobAlreadyExistsInRegistryException - Exception in org.springframework.xd.dirt.plugins.job
Exception thrown when a batch job already exists in the JobRegistry.
BatchJobAlreadyExistsInRegistryException(String) - Constructor for exception org.springframework.xd.dirt.plugins.job.BatchJobAlreadyExistsInRegistryException
Creates a new BatchJobAlreadyExistsInRegistryException with the given job name.
BatchJobDeleteFilesOptionMixin - Class in org.springframework.xd.module.options.mixins
Batch job option for delete files after import.
BatchJobDeleteFilesOptionMixin() - Constructor for class org.springframework.xd.module.options.mixins.BatchJobDeleteFilesOptionMixin
 
BatchJobExecutionsController - Class in org.springframework.xd.dirt.rest
Controller for batch job executions.
BatchJobExecutionsController() - Constructor for class org.springframework.xd.dirt.rest.BatchJobExecutionsController
 
BatchJobFieldDelimiterOptionMixin - Class in org.springframework.xd.module.options.mixins
Batch job option for the delimiter in the file (csv file etc.).
BatchJobFieldDelimiterOptionMixin() - Constructor for class org.springframework.xd.module.options.mixins.BatchJobFieldDelimiterOptionMixin
 
BatchJobFieldNamesOptionMixin - Class in org.springframework.xd.module.options.mixins
Batch job option for fields names in the file (csv file etc.,).
BatchJobFieldNamesOptionMixin() - Constructor for class org.springframework.xd.module.options.mixins.BatchJobFieldNamesOptionMixin
 
BatchJobHeaders - Class in org.springframework.xd.dirt.plugins.job
Headers definitions used by the batch job plugin.
BatchJobInstancesController - Class in org.springframework.xd.dirt.rest
Controller for batch job instances.
BatchJobInstancesController() - Constructor for class org.springframework.xd.dirt.rest.BatchJobInstancesController
 
BatchJobListener<P> - Class in org.springframework.xd.dirt.plugins.job.support.listener
Abstract batch job listener that sends batch job listener payload to the SubscribableChannel notification channel.
BatchJobListener(SubscribableChannel, SubscribableChannel) - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.BatchJobListener
 
BatchJobRegistryBeanPostProcessor - Class in org.springframework.xd.dirt.plugins.job
JobRegistryBeanPostProcessor that processes batch job from the job module.
BatchJobRegistryBeanPostProcessor() - Constructor for class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
 
BatchJobResourcesOptionMixin - Class in org.springframework.xd.module.options.mixins
Batch job option for resources (Spring resources) to import.
BatchJobResourcesOptionMixin() - Constructor for class org.springframework.xd.module.options.mixins.BatchJobResourcesOptionMixin
 
BatchJobRestartableOptionMixin - Class in org.springframework.xd.module.options.mixins
Batch job option for restartable.
BatchJobRestartableOptionMixin() - Constructor for class org.springframework.xd.module.options.mixins.BatchJobRestartableOptionMixin
 
BatchJobsController - Class in org.springframework.xd.dirt.rest
Controller for batch jobs and job instances, job executions on a given batch job.
BatchJobsController() - Constructor for class org.springframework.xd.dirt.rest.BatchJobsController
 
BatchListenerEventType - Enum in org.springframework.xd.dirt.plugins.job.support.listener
Enumerations to help identify various Batch job events being issued.
BatchStepExecutionsController - Class in org.springframework.xd.dirt.rest
Controller for returning Batch StepExecutions.
BatchStepExecutionsController() - Constructor for class org.springframework.xd.dirt.rest.BatchStepExecutionsController
 
BeanPropertiesPropertySource<T> - Class in org.springframework.xd.dirt.server.options
A PropertySource that exposes the javabeans properties of an object as properties.
BeanPropertiesPropertySource(String, T) - Constructor for class org.springframework.xd.dirt.server.options.BeanPropertiesPropertySource
 
beforeChunk(ChunkContext) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdChunkListener
 
beforeDelete(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.
beforeDelete(D) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
 
beforeDelete(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.StreamDeployer
Callback method that subclasses may override to get a chance to act on definitions that are about to be deleted.
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
 
beforeJob(JobExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdJobExecutionListener
 
beforeProcess(I) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
 
beforeRead() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
 
beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractPlugin
 
beforeShutdown(Module) - Method in class org.springframework.xd.dirt.plugins.job.JobPartitionerPlugin
 
beforeShutdown(Module) - Method in interface org.springframework.xd.module.core.Plugin
Perform any cleanup necessary prior to module shutdown
beforeStep(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.FileDeletionStepExecutionListener
 
beforeStep(StepExecution) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdStepExecutionListener
 
beforeWrite(List<? extends Object>) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener
 
binary(boolean) - Method in class org.springframework.xd.test.fixtures.FileSink
 
binary(boolean) - Method in class org.springframework.xd.test.fixtures.SimpleFileSink
Set the state of the binary flag for the SimpleFileSink instance.
bind() - Method in class org.springframework.xd.dirt.test.AbstractSingleNodeNamedChannelModule
 
bind() - Method in class org.springframework.xd.dirt.test.sink.SingleNodeNamedQueueSink
 
bind() - Method in class org.springframework.xd.dirt.test.sink.SingleNodeNamedTopicSink
 
bind() - Method in class org.springframework.xd.dirt.test.source.SingleNodeNamedQueueSource
 
bind() - Method in class org.springframework.xd.dirt.test.source.SingleNodeNamedTopicSource
 
bindConsumer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.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, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Bind a message consumer on a p2p channel
bindConsumer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
bindConsumer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
bindConsumerAndProducers(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
Bind input/output channel of the module's message consumer/producers to MessageBus's message source/target entities.
bindDynamicProducer(String, Properties) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
For the local bus we bridge the router "output" channel to a queue channel; the queue channel gets the name and the source channel is named 'dynamic.output.to.' + name.
bindDynamicProducer(String, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Create a channel and bind a producer dynamically, creating the infrastructure required by the bus technology.
bindDynamicProducer(String, Properties) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Dynamically create a producer for the named channel.
bindDynamicPubSubProducer(String, Properties) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
For the local bus we bridge the router "output" channel to a pub/sub channel; the pub/sub channel gets the name and the source channel is named 'dynamic.output.to.' + name.
bindDynamicPubSubProducer(String, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Create a channel and bind a producer dynamically, creating the infrastructure required by the bus technology to broadcast messages to consumers.
bindDynamicPubSubProducer(String, Properties) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Dynamically create a producer for the named channel.
bindExistingProducerDirectlyIfPossible(String, MessageChannel) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Attempt to bind a producer directly (avoiding the bus) if there is already a local producer.
Binding - Class in org.springframework.xd.dirt.integration.bus
Represents a binding between a module's channel and an adapter endpoint that connects to the MessageBus.
bindNewProducerDirectlyIfPossible(String, SubscribableChannel, AbstractBusPropertiesAccessor) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Attempt to create a direct binding (avoiding the bus) if the consumer is local.
bindProducer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.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, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Bind a message producer on a p2p channel.
bindProducer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
bindProducer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
bindPubSubConsumer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
bindPubSubConsumer(String, MessageChannel, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Bind a message consumer on a pub/sub channel
bindPubSubConsumer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
bindPubSubConsumer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
bindPubSubProducer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
bindPubSubProducer(String, MessageChannel, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Bind a message producer on a pub/sub channel.
bindPubSubProducer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
bindPubSubProducer(String, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
bindReplier(String, MessageChannel, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
bindReplier(String, MessageChannel, MessageChannel, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Bind a consumer that handles requests from a requestor and asynchronously sends replies.
bindReplier(String, MessageChannel, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
bindReplier(String, MessageChannel, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
bindRequestor(String, MessageChannel, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
bindRequestor(String, MessageChannel, MessageChannel, Properties) - Method in interface org.springframework.xd.dirt.integration.bus.MessageBus
Bind a producer that expects async replies.
bindRequestor(String, MessageChannel, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
bindRequestor(String, MessageChannel, MessageChannel, Properties) - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
bridge(String, MessageChannel, MessageChannel, String, LocalMessageBus.LocalBusPropertiesAccessor) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
bridge(String, MessageChannel, MessageChannel, String, Collection<MediaType>, LocalMessageBus.LocalBusPropertiesAccessor) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
build() - Method in class org.springframework.xd.dirt.core.Job.Builder
Create a new instance of Job.
build() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Build the path string using the field values.
build() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Build the path string using the field values.
build() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Build the path string using the field values.
build() - Method in class org.springframework.xd.dirt.core.Stream.Builder
Create a new instance of Stream.
build() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Build the path string using the field values.
build() - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport.SetBuilder
 
build(String...) - Static method in class org.springframework.xd.dirt.zookeeper.Paths
Return a string with the provided path elements separated by a slash /.
build() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return a new instance of ModuleDescriptor.
build() - Method in class org.springframework.xd.tuple.TupleBuilder
 
buildConvertedMessage(Object, MessageHeaders, MimeType) - Method in class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Convenience method to construct a converted message
buildMap() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
buildPartitionRoutingExpression(String) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
buildPath() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
Return the ZooKeeper path that this module deployment status should be written to
buildRetryTemplateIfRetryEnabled(AbstractBusPropertiesAccessor) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Create and configure a retry template if the consumer 'maxAttempts' property is set.
buildTapChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractJobPlugin
 
buildTapChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
buildTapChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractStreamPlugin
 
buildUri() - Method in class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter
 
buildUri() - Method in class org.springframework.integration.x.twitter.TwitterSearchChannelAdapter
 
buildUri() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
 
buildWithNamespace() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Build the path string using the field values, including the namespace prefix.
buildWithNamespace() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Build the path string using the field values, including the namespace prefix.
buildWithNamespace() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Build the path string using the field values, including the namespace prefix.
buildWithNamespace() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Build the path string using the field values, including the namespace prefix.
buildWithNamespace(String...) - Static method in class org.springframework.xd.dirt.zookeeper.Paths
Return a string with the provided path elements separated by a slash /.
BusProperties - Interface in org.springframework.xd.dirt.integration.bus
Common bus properties.
BusTestUtils - Class in org.springframework.xd.dirt.integration.bus
 
BusTestUtils() - Constructor for class org.springframework.xd.dirt.integration.bus.BusTestUtils
 
ByteArrayToStringMessageConverter - Class in org.springframework.xd.dirt.integration.bus.converter
A MessageConverter to convert from byte[] to String applying the Charset provided in the content-type header if any.
ByteArrayToStringMessageConverter() - Constructor for class org.springframework.xd.dirt.integration.bus.converter.ByteArrayToStringMessageConverter
 
bytesToMap(byte[]) - Static method in class org.springframework.xd.dirt.zookeeper.ZooKeeperUtils
Convert a byte array containing a JSON string to a map of key/value pairs.

C

CacheServer - Class in org.springframework.xd.gemfire.server
A simple driver class to run a Gemfire cache server.
CacheServer() - Constructor for class org.springframework.xd.gemfire.server.CacheServer
 
calculate(DeploymentUnit, ModuleDeploymentPropertiesProvider<ModuleDeploymentProperties>, Collection<ModuleDeploymentStatus>) - Method in class org.springframework.xd.dirt.server.DefaultStateCalculator
For a given deployment unit (stream or job) calculate the overall status.
calculate(DeploymentUnit, ModuleDeploymentPropertiesProvider<ModuleDeploymentProperties>, Collection<ModuleDeploymentStatus>) - Method in interface org.springframework.xd.dirt.server.DeploymentUnitStateCalculator
For a given deployment unit (stream or job) calculate the overall status.
calculateColumnWidths() - Method in class org.springframework.xd.shell.util.Table
 
canConvertFrom(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
 
canConvertTo(Object, MessageHeaders) - Method in class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Not supported by default
canRead(EvaluationContext, Object, String) - Method in class org.springframework.xd.integration.hadoop.partition.MessagePartitionKeyPropertyAccessor
 
canRead(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
 
canWrite(EvaluationContext, Object, String) - Method in class org.springframework.xd.integration.hadoop.partition.MessagePartitionKeyPropertyAccessor
 
canWrite(EvaluationContext, Object, String) - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
 
cat(String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
chain(SingleNodeApplication, String, String) - Static method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport
 
chain(SingleNodeApplication, String, String, String) - Static method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport
 
chainConsumer(SingleNodeApplication, String, String) - Static method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport
 
chainConsumer(SingleNodeApplication, String, String, String) - Static method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport
 
chainProducer(SingleNodeApplication, String, String) - Static method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport
 
chainProducer(SingleNodeApplication, String, String, String) - Static method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainSupport
 
ChannelNode - Class in org.springframework.xd.dirt.stream.dsl
 
ChannelNode(ChannelType, int, int, List<String>, List<String>) - Constructor for class org.springframework.xd.dirt.stream.dsl.ChannelNode
 
ChannelType - Enum in org.springframework.xd.dirt.stream.dsl
 
CheckpointedStreamDefinitionException - Exception in org.springframework.xd.dirt.stream.dsl
An extension of StreamDefinitionException that remembers the point up to which parsing went OK (signaled by a '*' in the dumped message).
CheckpointedStreamDefinitionException(String, int, int, int, List<Token>, XDDSLMessages, Object...) - Constructor for exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
Construct a new exception
chgrp(boolean, String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
childEvent(CuratorFramework, PathChildrenCacheEvent) - Method in class org.springframework.xd.dirt.server.ContainerListener
childEvent(CuratorFramework, PathChildrenCacheEvent) - Method in class org.springframework.xd.dirt.server.InitialDeploymentListener

Handle child events for the Paths.STREAMS path.

ChildPathIterator<T> - Class in org.springframework.xd.dirt.zookeeper
Iterator over ChildData instances that are managed by PathChildrenCache.
ChildPathIterator(Converter<ChildData, T>, PathChildrenCache) - Constructor for class org.springframework.xd.dirt.zookeeper.ChildPathIterator
Construct a ChildPathIterator.
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
 
CHUNK_EVENTS_SUFFIX - Static variable in interface org.springframework.xd.dirt.plugins.job.support.listener.XDJobListenerConstants
 
ChunkContextInfo - Class in org.springframework.xd.dirt.plugins.job.support.listener
 
ChunkContextInfo() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
 
cleanup() - Method in class org.springframework.xd.test.fixtures.AbstractMetricSink
 
cleanup() - Method in interface org.springframework.xd.test.fixtures.Disposable
Free up resources that this fixture may have created.
cleanup() - Method in class org.springframework.xd.test.fixtures.DisposableFileSupport
 
cleanup() - Method in class org.springframework.xd.test.fixtures.DisposableMailSupport
 
cleanup() - Method in class org.springframework.xd.test.fixtures.FileSource
 
cleanup() - Method in class org.springframework.xd.test.fixtures.JdbcSink
If using a in memory database this method will shutdown the database.
cleanup() - Method in class org.springframework.xd.test.fixtures.TcpSink
 
cleanup() - Static method in class org.springframework.xd.test.RandomConfigurationSupport
 
cleanupResource() - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport
Perform cleanup of the AbstractExternalResourceTestSupport.resource field, which is guaranteed to be non null.
cleanupResource() - Method in class org.springframework.xd.test.hadoop.HadoopFileSystemTestSupport
 
cleanupResource() - Method in class org.springframework.xd.test.mqtt.MqttTestSupport
 
cleanupResource() - Method in class org.springframework.xd.test.rabbit.RabbitTestSupport
 
cleanupResource() - Method in class org.springframework.xd.test.redis.RedisTestSupport
 
clear() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
clear() - Method in class org.springframework.xd.module.ModuleDeploymentProperties
ClientApp - Class in org.springframework.xd.yarn
 
ClientApp() - Constructor for class org.springframework.xd.yarn.ClientApp
 
ClientTcpConnectionFactoryOptionsMetadataMixin - Class in org.springframework.xd.tcp
Mixin for options metadata that configure a client tcp connection factory.
ClientTcpConnectionFactoryOptionsMetadataMixin() - Constructor for class org.springframework.xd.tcp.ClientTcpConnectionFactoryOptionsMetadataMixin
 
close() - Method in class org.springframework.xd.batch.item.hadoop.HdfsTextItemWriter
 
close() - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
 
close() - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
 
close() - Method in class org.springframework.xd.gemfire.server.LoggingCacheListener
 
close() - Method in class org.springframework.xd.hadoop.fs.DatasetWriter
 
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
 
collect(ConfigurableListableBeanFactory) - Method in class org.springframework.xd.module.options.DefaultModuleOptionsMetadataCollector
 
collectionName(String) - Method in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
Sets the name of the collection where the data will be written.
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
 
columns(String) - Method in class org.springframework.xd.test.fixtures.JdbcSink
allows a user to set the columns (comma delimited list) that the sink will write its results to.
CommandLinePropertySourceOverridingListener<T extends CommonOptions> - Class in org.springframework.xd.dirt.server.options
An ApplicationListener that will parse command line options and also replace the default boot commandline PropertySource with those values.
CommandLinePropertySourceOverridingListener(T) - Constructor for class org.springframework.xd.dirt.server.options.CommandLinePropertySourceOverridingListener
 
CommonDistributedOptions - Class in org.springframework.xd.dirt.server.options
Holds options that are common to both admin and container servers, when used in distributed mode.
CommonDistributedOptions() - Constructor for class org.springframework.xd.dirt.server.options.CommonDistributedOptions
 
CommonOptions - Class in org.springframework.xd.dirt.server.options
Base class for command line options that are common to absolutely every setup (single and distributed).
CommonOptions() - Constructor for class org.springframework.xd.dirt.server.options.CommonOptions
 
CommonUtils - Class in org.springframework.xd.shell.util
Contains common non-ui related helper methods for rendering text to the console.
compareTo(Container) - Method in class org.springframework.xd.dirt.cluster.Container
compareTo(ContainerAttributes) - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
Compares using the containerId.
compareTo(BaseDefinition) - Method in class org.springframework.xd.dirt.core.BaseDefinition
 
compareTo(ModuleMetadata) - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
Compares ModuleMetadata using module id.
compareTo(ModuleRedeployer.ModuleDeployment) - Method in class org.springframework.xd.dirt.server.ModuleRedeployer.ModuleDeployment
 
compareTo(Job) - Method in class org.springframework.xd.dirt.stream.Job
 
compareTo(Stream) - Method in class org.springframework.xd.dirt.stream.Stream
 
compareTo(ModuleDefinition) - Method in class org.springframework.xd.module.ModuleDefinition
Compares the module definitions using the name of the ModuleDefinition
compareTo(ModuleDescriptor) - Method in class org.springframework.xd.module.ModuleDescriptor
compareTo(ModuleDescriptor.Key) - Method in class org.springframework.xd.module.ModuleDescriptor.Key
complete(CompletionKind, String, int) - Method in class org.springframework.xd.dirt.stream.completion.CompletionProvider
 
CompletionConverter - Class in org.springframework.xd.shell.converter
A converter that provides DSL completion wherever parts of stream definitions may appear.
CompletionConverter() - Constructor for class org.springframework.xd.shell.converter.CompletionConverter
 
CompletionExpansionStrategy - Interface in org.springframework.xd.dirt.stream.completion
Used to enhance a well formed stream definition by adding yet more text to it (e.g. adding more options to a module).
CompletionKind - Enum in org.springframework.xd.rest.domain
Used to represent the context in which the code completion facility is invoked.
CompletionOperations - Interface in org.springframework.xd.rest.client
Provides access to the dsl completion facility.
completionOperations() - Method in class org.springframework.xd.rest.client.impl.SpringXDTemplate
 
completionOperations() - Method in interface org.springframework.xd.rest.client.SpringXDOperations
Returns the portion of the API for providing code completion.
CompletionProvider - Class in org.springframework.xd.dirt.stream.completion
Provides code completion on a (maybe ill-formed) stream definition.
CompletionProvider(XDParser, List<CompletionRecoveryStrategy<? extends Exception>>, List<CompletionExpansionStrategy>) - Constructor for class org.springframework.xd.dirt.stream.completion.CompletionProvider
Construct a new CompletionProvider given a list of recovery strategies and expansion strategies.
CompletionRecoveryStrategy<E extends java.lang.Exception> - Interface in org.springframework.xd.dirt.stream.completion
Used to provide completions on ill-formed stream definitions, after an initial (failed) parse.
completions(CompletionKind, String, int) - Method in class org.springframework.xd.dirt.rest.CompletionsController
Return a list of possible completions given a prefix string that the user has started typing.
completions(CompletionKind, String, int) - Method in interface org.springframework.xd.rest.client.CompletionOperations
Return the list of completions that are compatible with the given DSL prefix.
completions(CompletionKind, String, int) - Method in class org.springframework.xd.rest.client.impl.CompletionTemplate
 
CompletionsController - Class in org.springframework.xd.dirt.rest
Exposes completion for stream-like definitions as a REST endpoint.
CompletionsController(CompletionProvider) - Constructor for class org.springframework.xd.dirt.rest.CompletionsController
 
CompletionTemplate - Class in org.springframework.xd.rest.client.impl
Implements the CompletionOperations part of the API.
composeModule(String, String) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
 
composeModule(String, String) - Method in interface org.springframework.xd.rest.client.ModuleOperations
Compose a new virtual Module.
CompositeCodec<P> - Class in org.springframework.xd.dirt.integration.bus.serializer
A codec that can delegate to one out of many codecs, depending on the type of the object to serialize/deserialize.
CompositeCodec(Map<Class<?>, AbstractCodec<P>>, MultiTypeCodec<P>) - Constructor for class org.springframework.xd.dirt.integration.bus.serializer.CompositeCodec
 
CompositeCodec(MultiTypeCodec<P>) - Constructor for class org.springframework.xd.dirt.integration.bus.serializer.CompositeCodec
 
CompositeMessageConverterFactory - Class in org.springframework.xd.dirt.integration.bus.converter
A factory for creating an instance of CompositeMessageConverter for a given target MIME type
CompositeMessageConverterFactory(Collection<AbstractFromMessageConverter>) - Constructor for class org.springframework.xd.dirt.integration.bus.converter.CompositeMessageConverterFactory
 
CompositeModule - Class in org.springframework.xd.module.core
 
CompositeModule(ModuleDescriptor, ModuleDeploymentProperties, List<Module>) - Constructor for class org.springframework.xd.module.core.CompositeModule
 
CompositeModuleDefinitionService - Class in org.springframework.xd.dirt.stream
Provides save, delete and dependency operations for managing a composite module definition.
CompositeModuleDefinitionService(ModuleDefinitionRepository, XDStreamParser) - Constructor for class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
 
concatArrays(List<long[]>, int, int) - Static method in class org.springframework.xd.analytics.metrics.core.MetricUtils
 
CONCURRENCY - Static variable in interface org.springframework.xd.dirt.integration.bus.BusProperties
The minimum number of concurrent deliveries.
ConfigCommands - Class in org.springframework.xd.shell.command
Defines several shell commands in order to configure the shell itself.
ConfigCommands() - Constructor for class org.springframework.xd.shell.command.ConfigCommands
 
ConfigLocations - Class in org.springframework.xd.dirt.util
Static constants for configuration locations.
Configuration - Class in org.springframework.xd.shell
Encapsulates various configuration properties for the shell such as Target and the configurable TimeZone.
Configuration() - Constructor for class org.springframework.xd.shell.Configuration
Constructor initializing the default timezone using TimeUtils.getJvmTimeZone()
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
 
configure(HttpSecurity) - Method in class org.springframework.xd.dirt.web.config.SecurityConfiguration
 
configure(URI) - Method in class org.springframework.xd.integration.reactor.net.NetServerSpecFactoryBean
 
configurer() - Method in class org.springframework.xd.dirt.rest.RestConfiguration
 
configureZooKeeperConnection(ZooKeeperConnection) - Method in interface org.springframework.xd.dirt.zookeeper.ZooKeeperConnectionConfigurer
 
ConfigUtil - Class in org.springframework.xd.integration.util
Tools to create and read configuration files for an environment deployed on EC2.
ConfigUtil() - Constructor for class org.springframework.xd.integration.util.ConfigUtil
 
connectionProperties - Variable in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
ConsoleUserInput - Class in org.springframework.xd.shell.command
UserInput that uses Standard in and out.
ConsoleUserInput() - Constructor for class org.springframework.xd.shell.command.ConsoleUserInput
 
CONSUMER - Static variable in class org.springframework.xd.dirt.integration.bus.Binding
 
CONSUMER_RETRY_PROPERTIES - Static variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
Container - Class in org.springframework.xd.dirt.cluster
Domain object for an XD container.
Container(String, Map<String, String>) - Constructor for class org.springframework.xd.dirt.cluster.Container
Construct a Container object.
CONTAINER_ID_KEY - Static variable in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
CONTAINER_PROFILE - Static variable in class org.springframework.xd.dirt.util.XdProfiles
 
CONTAINER_TOKEN - Static variable in class org.springframework.xd.integration.util.ConfigUtil
 
ContainerAttributes - Class in org.springframework.xd.dirt.cluster
Metadata for a Container instance.
ContainerAttributes() - Constructor for class org.springframework.xd.dirt.cluster.ContainerAttributes
Default constructor generates a random id.
ContainerAttributes(String) - Constructor for class org.springframework.xd.dirt.cluster.ContainerAttributes
Constructor to be called when the id is already known.
ContainerAttributes(Map<? extends String, ? extends String>) - Constructor for class org.springframework.xd.dirt.cluster.ContainerAttributes
Constructor to be called when the attributes are already known.
containerAttributes() - Method in class org.springframework.xd.dirt.server.ContainerServerApplication
 
containerContext() - Method in class org.springframework.xd.dirt.server.SingleNodeApplication
 
ContainerInfoPlugin - Class in org.springframework.xd.dirt.plugins
A plugin that exposes information about the container to the Environment.
ContainerInfoPlugin(ContainerAttributes) - Constructor for class org.springframework.xd.dirt.plugins.ContainerInfoPlugin
 
ContainerListener - Class in org.springframework.xd.dirt.server
Listener implementation that is invoked when containers are added/removed/modified.
ContainerListener(ZooKeeperConnection, ContainerRepository, StreamFactory, JobFactory, PathChildrenCache, PathChildrenCache, PathChildrenCache, ContainerMatcher, DeploymentUnitStateCalculator) - Constructor for class org.springframework.xd.dirt.server.ContainerListener
Construct a ContainerListener.
ContainerMatcher - Interface in org.springframework.xd.dirt.cluster
Strategy interface for matching a ModuleDescriptor to one of the candidate container nodes.
containerMatcher - Variable in class org.springframework.xd.dirt.server.InitialDeploymentListener
Container matcher for matching modules to containers.
ContainerOptions - Class in org.springframework.xd.dirt.server.options
Holds configuration options that are valid for the Container node, when using distributed mode.
ContainerOptions() - Constructor for class org.springframework.xd.dirt.server.options.ContainerOptions
 
ContainerRegistrar - Class in org.springframework.xd.dirt.server
An instance of this class, registered as a bean in the context for a Container, will handle the registration of that Container's metadata with ZooKeeper by creating an ephemeral node.
ContainerRegistrar(ZooKeeperConnection, ContainerAttributes, ContainerRepository, StreamFactory, JobFactory, ModuleOptionsMetadataResolver, ModuleDeployer) - Constructor for class org.springframework.xd.dirt.server.ContainerRegistrar
Create an instance that will register the provided ContainerAttributes whenever the underlying ZooKeeperConnection is established.
ContainerRepository - Interface in org.springframework.xd.dirt.container.store
Repository for persisting Container entities.
containerRepository - Variable in class org.springframework.xd.dirt.server.InitialDeploymentListener
Repository from which to obtain containers in the cluster.
CONTAINERS - Static variable in class org.springframework.xd.dirt.zookeeper.Paths
Name of containers node.
ContainersController - Class in org.springframework.xd.dirt.rest
Handles interaction with the runtime containers/and its modules.
ContainersController(ContainerRepository) - Constructor for class org.springframework.xd.dirt.rest.ContainersController
 
ContainerServerApplication - Class in org.springframework.xd.dirt.server
The boot application class for a Container server.
ContainerServerApplication() - Constructor for class org.springframework.xd.dirt.server.ContainerServerApplication
 
ContainerShutdownException - Exception in org.springframework.xd.dirt.cluster
Exception thrown when shutting down the container from admin server.
ContainerShutdownException() - Constructor for exception org.springframework.xd.dirt.cluster.ContainerShutdownException
Construct a ContainerShutdownException.
ContainerShutdownException(String) - Constructor for exception org.springframework.xd.dirt.cluster.ContainerShutdownException
Construct a ContainerShutdownException with a description.
containsKey(Object) - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
containsKey(Object) - Method in class org.springframework.xd.module.ModuleDeploymentProperties
containsValue(Object) - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
containsValue(Object) - Method in class org.springframework.xd.module.ModuleDeploymentProperties
ConversionException - Exception in org.springframework.xd.dirt.integration.bus.converter
Exception thrown when an error is encountered during message conversion.
ConversionException(String) - Constructor for exception org.springframework.xd.dirt.integration.bus.converter.ConversionException
 
ConversionException(String, Throwable) - Constructor for exception org.springframework.xd.dirt.integration.bus.converter.ConversionException
 
convert(String) - Method in class org.springframework.xd.dirt.plugins.stream.CustomMimeTypeConverter
 
convert(ChildData) - Method in class org.springframework.xd.dirt.zookeeper.ZooKeeperUtils.StripPathConverter
convert(FieldSet) - Method in class org.springframework.xd.mongodb.FieldSetConverter
 
convert(Tuple) - Method in class org.springframework.xd.mongodb.TupleWriteConverter
 
convert(byte[]) - Method in class org.springframework.xd.tuple.JsonBytesToTupleConverter
 
convert(JsonNode) - Method in class org.springframework.xd.tuple.JsonNodeToTupleConverter
 
convert(String) - Method in class org.springframework.xd.tuple.JsonStringToTupleConverter
 
convert(String) - Method in class org.springframework.xd.tuple.StringToDateConverter
 
convert(Tuple) - Method in class org.springframework.xd.tuple.TupleToJsonStringConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.ByteArrayToStringMessageConverter
Don't need to manipulate message headers.
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.JavaToSerializedMessageConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.JsonToPojoMessageConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.JsonToTupleMessageConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.PojoToJsonMessageConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.PojoToStringMessageConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.SerializedToJavaMessageConverter
 
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.StringToByteArrayMessageConverter
Don't need to manipulate message headers.
convertFromInternal(Message<?>, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.converter.TupleToJsonMessageConverter
 
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.CompletionConverter
 
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter
 
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter
 
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter
 
convertFromText(String, Class<?>, String) - Method in class org.springframework.xd.shell.converter.QualifiedModuleNameConverter
 
convertJsonToList(String) - Static method in class org.springframework.xd.shell.util.JsonUtil
 
convertJsonToMap(String) - Static method in class org.springframework.xd.shell.util.JsonUtil
 
convertToInternal(Object, MessageHeaders) - Method in class org.springframework.xd.dirt.integration.bus.converter.AbstractFromMessageConverter
Not supported by default
convertToJson(Object) - Static method in class org.springframework.xd.shell.util.JsonUtil
 
copy(byte[], FSDataOutputStream) - Method in class org.springframework.xd.batch.item.hadoop.SimpleHdfsTextItemWriter
Simple not optimized copy
copy(byte[], FSDataOutputStream) - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriter
Simple not optimized copy
copyFileToRemote(String, String, URI, File, long) - Static method in class org.springframework.xd.integration.util.StreamUtils
Copy a file from test machine to remote machine.
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() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
 
copyOf() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
 
copyToLocal(String, String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
count() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
count() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
count() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
count() - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
count() - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
count() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
count() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
count() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
count() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
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
 
COUNT_KEY - Static variable in class org.springframework.xd.module.ModuleDeploymentProperties
Key for the count property.
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.domain.metrics
The REST representation of a Counter.
CounterResource() - Constructor for class org.springframework.xd.rest.domain.metrics.CounterResource
No-arg constructor for serialization frameworks.
CounterResource(String, long) - Constructor for class org.springframework.xd.rest.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
 
CounterSink - Class in org.springframework.xd.test.fixtures
Fixture class for an "simple" counter.
CounterSink(JLineShellComponent, String) - Constructor for class org.springframework.xd.test.fixtures.CounterSink
 
CounterTemplate - Class in org.springframework.xd.rest.client.impl
Implements the CounterOperations part of the API.
CounterTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.CounterTemplate
 
cp(String, String) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
 
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
 
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
create(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
 
createAndDeployStream(StreamDefinition) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Create and deploy a stream.
createAndRegisterChannel(String) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport.SharedChannelProvider
 
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.
createDataFileOnRemote(String, String, String, String, String) - Static method in class org.springframework.xd.integration.util.StreamUtils
Creates a file on a remote EC2 machine with the payload as its contents.
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
 
createDefinition(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
 
createDefinition(String, String) - Method in class org.springframework.xd.dirt.stream.JobDeployer
 
createDefinition(String, String) - Method in class org.springframework.xd.dirt.stream.StreamDeployer
createHandler() - Method in class org.springframework.xd.integration.hadoop.config.HdfsStoreMessageHandlerFactoryBean
 
createInstance() - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitConnectionFactoryBean
 
createJob(String, Map<String, String>) - Method in class org.springframework.xd.dirt.job.JobFactory
Create a new instance of Job for the given name and properties.
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
 
createKey() - Method in class org.springframework.xd.module.ModuleDescriptor
Create a new ModuleDescriptor.Key for this ModuleDescriptor.
createModule(String, String) - Method in class org.springframework.xd.shell.command.ModuleCommands
 
createModuleDeploymentProperties(Map<String, String>, ModuleDescriptor) - Static method in class org.springframework.xd.dirt.util.DeploymentPropertiesUtility
Based on the deployment properties for a Stream/Job, create an instance of ModuleDeploymentProperties for a specific module in the Stream/Job.
createModuleDeploymentRequestsPath(CuratorFramework, ModuleDescriptor, RuntimeModuleDeploymentProperties) - Method in class org.springframework.xd.dirt.server.InitialDeploymentListener
createNamedChannelSink(String) - Method in class org.springframework.xd.dirt.test.sink.SingleNodeNamedChannelSinkFactory
 
createNamedChannelSource(String) - Method in class org.springframework.xd.dirt.test.source.SingleNodeNamedChannelSourceFactory
 
createQueue() - Method in class org.springframework.xd.test.fixtures.RabbitSource
Creates an instance of the queue on the rabbit broker.
createRemoteDirectory(String, String, String, int) - Static method in class org.springframework.xd.integration.util.StreamUtils
Creates a directory on a remote machine.
createSharedChannel(String) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport.SharedChannelProvider
 
createSink() - Method in class org.springframework.xd.dirt.test.process.AbstractSingleNodeProcessingChain
 
createSink() - Method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChain
 
createSink() - Method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainConsumer
 
createSink() - Method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainProducer
 
createSource() - Method in class org.springframework.xd.dirt.test.process.AbstractSingleNodeProcessingChain
 
createSource() - Method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChain
 
createSource() - Method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainConsumer
 
createSource() - Method in class org.springframework.xd.dirt.test.process.SingleNodeProcessingChainProducer
 
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, Map<String, String>) - Method in class org.springframework.xd.dirt.stream.StreamFactory
Create a new instance of Stream for the given name and properties.
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.DatasetWriterFactory
 
createWriter() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
createWriter() - Method in interface org.springframework.xd.hadoop.fs.HdfsWriterFactory
 
CRITERIA_KEY - Static variable in class org.springframework.xd.module.ModuleDeploymentProperties
Key for the criteria property.
CustomMimeTypeConverter - Class in org.springframework.xd.dirt.plugins.stream
A custom converter for MediaType that accepts a plain java class name as a shorthand for application/x-java-object;type=the.qualified.ClassName.
CustomMimeTypeConverter() - Constructor for class org.springframework.xd.dirt.plugins.stream.CustomMimeTypeConverter
 

D

DatabaseVendorFriendlyNameFactoryBean - Class in org.springframework.xd.dirt.jdbc.util
A factory bean that returns a friendly string name from database metadata.
DatabaseVendorFriendlyNameFactoryBean() - Constructor for class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
 
DatasetDefinitionFactoryBean - Class in org.springframework.xd.hadoop.fs
FactoryBean that creates a default DatasetDefinition
DatasetDefinitionFactoryBean() - Constructor for class org.springframework.xd.hadoop.fs.DatasetDefinitionFactoryBean
 
DatasetOutboundChannelAdapterParser - Class in org.springframework.xd.integration.hadoop.config
Parser for the 'dataset-outbound-channel-adapter' element.
DatasetOutboundChannelAdapterParser() - Constructor for class org.springframework.xd.integration.hadoop.config.DatasetOutboundChannelAdapterParser
 
DatasetWriter - Class in org.springframework.xd.hadoop.fs
 
DatasetWriter(DatasetOperations) - Constructor for class org.springframework.xd.hadoop.fs.DatasetWriter
 
DatasetWriterFactory - Class in org.springframework.xd.hadoop.fs
 
DatasetWriterFactory(DatasetOperations) - Constructor for class org.springframework.xd.hadoop.fs.DatasetWriterFactory
 
DatasetWritingMessageHandlerFactoryBean - Class in org.springframework.xd.integration.hadoop.config
Factory bean used to create HdfsWritingMessageHandler
DatasetWritingMessageHandlerFactoryBean(DatasetOperations) - Constructor for class org.springframework.xd.integration.hadoop.config.DatasetWritingMessageHandlerFactoryBean
 
DateFormatMixin - Class in org.springframework.xd.module.options.mixins
Provides a dateFormat module option, meant to hold a pattern that conforms to SimpleDateFormat.
DateFormatMixin() - Constructor for class org.springframework.xd.module.options.mixins.DateFormatMixin
 
DateTrigger - Class in org.springframework.xd.module.support
A Trigger implementation that enables execution on a series of Dates.
DateTrigger(Date...) - Constructor for class org.springframework.xd.module.support.DateTrigger
 
decrement(long) - Method in class org.springframework.xd.analytics.metrics.core.Counter
Decrement this counter by a given amount.
decrement(String) - Method in interface org.springframework.xd.analytics.metrics.core.CounterRepository
Decrement the given counter, creating it if it did not exist.
decrement(String, String) - Method in interface org.springframework.xd.analytics.metrics.core.FieldValueCounterRepository
Decrement the FieldValueCounter for a given field name by one, creating missing counters.
decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
decrement(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository
 
decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryFieldValueCounterRepository
 
decrement(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
decrement(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
decrement(String, String, double) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
DeepAggregateCountResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics
Knows how to construct AggregateCountsResource out of AggregateCount.
DeepAggregateCountResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepAggregateCountResourceAssembler
 
DeepCounterResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics
Knows how to assemble CounterResources out of Counters.
DeepCounterResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepCounterResourceAssembler
 
DeepFieldValueCounterResourceAssembler - Class in org.springframework.xd.dirt.rest.metrics
Knows how to create rich representations of FieldValueCounter.
DeepFieldValueCounterResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.metrics.DeepFieldValueCounterResourceAssembler
 
DEFAULT - Static variable in class org.springframework.xd.shell.converter.NumberFormatConverter
 
DEFAULT_ADDRESSES - Static variable in class org.springframework.xd.test.fixtures.RabbitSink
 
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_CLIENT_CONNECT_STRING - Static variable in class org.springframework.xd.dirt.zookeeper.ZooKeeperConnection
The default client connect string.
DEFAULT_COLLECTION_NAME - Static variable in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
 
DEFAULT_DATA_PATH - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants
Default writer path.
DEFAULT_DIRECTORY - Static variable in class org.springframework.xd.test.fixtures.FileJdbcJob
 
DEFAULT_DIRECTORY - Static variable in class org.springframework.xd.test.fixtures.FilePollHdfsJob
 
DEFAULT_DIRECTORY - Static variable in class org.springframework.xd.test.fixtures.HdfsJdbcJob
 
DEFAULT_DIRECTORY - Static variable in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
 
DEFAULT_DIRECTORY - Static variable in class org.springframework.xd.test.fixtures.HdfsSink
 
DEFAULT_DIRECTORY - Static variable in class org.springframework.xd.test.fixtures.JdbcHdfsJob
 
DEFAULT_EXCHANGE - Static variable in class org.springframework.xd.test.fixtures.RabbitSink
 
DEFAULT_EXCHANGE - Static variable in class org.springframework.xd.test.fixtures.RabbitSource
 
DEFAULT_FIELD_NAME_MAPPING_SPLIT_TOKEN - Static variable in class org.springframework.xd.analytics.ml.AbstractFieldMappingAwareDataMapper
 
DEFAULT_FILE_NAME - Static variable in class org.springframework.xd.test.fixtures.FileJdbcJob
 
DEFAULT_FILE_NAME - Static variable in class org.springframework.xd.test.fixtures.FilePollHdfsJob
 
DEFAULT_FILE_NAME - Static variable in class org.springframework.xd.test.fixtures.HdfsJdbcJob
 
DEFAULT_FILE_NAME - Static variable in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
 
DEFAULT_FILE_NAME - Static variable in class org.springframework.xd.test.fixtures.HdfsSink
 
DEFAULT_FILE_NAME - Static variable in class org.springframework.xd.test.fixtures.JdbcHdfsJob
 
DEFAULT_FILE_SUFFIX - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
DEFAULT_GROUP - Static variable in interface org.springframework.xd.module.options.spi.ValidationGroupsProvider
 
DEFAULT_HOST - Static variable in class org.springframework.xd.shell.Target
 
DEFAULT_HOST - Static variable in class org.springframework.xd.test.fixtures.SyslogTcpSource
 
DEFAULT_HOST - Static variable in class org.springframework.xd.test.fixtures.SyslogUdpSource
 
DEFAULT_HOST_NAME - Static variable in class org.springframework.xd.test.fixtures.FtpHdfsJob
 
DEFAULT_ID_FIELD - Static variable in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
 
DEFAULT_ID_FILE_NAMING_STRATEGY - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants
Default bean id for file naming policy.
DEFAULT_ID_FILE_ROLLOVER_STRATEGY - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants
Default bean id for file rollover policy.
DEFAULT_ID_STORE_WRITER - Static variable in class org.springframework.xd.integration.hadoop.IntegrationHadoopSystemConstants
Default bean id for store writer.
DEFAULT_MODE - Static variable in class org.springframework.xd.test.fixtures.SimpleFileSink
 
DEFAULT_NAMES - Static variable in class org.springframework.xd.test.fixtures.FileJdbcJob
 
DEFAULT_NAMES - Static variable in class org.springframework.xd.test.fixtures.HdfsJdbcJob
 
DEFAULT_NAMES - Static variable in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
 
DEFAULT_PASSWORD - Static variable in class org.springframework.xd.shell.Target
 
DEFAULT_PORT - Static variable in class org.springframework.xd.shell.Target
 
DEFAULT_PORT - Static variable in class org.springframework.xd.test.fixtures.FtpHdfsJob
 
DEFAULT_PORT - Static variable in class org.springframework.xd.test.fixtures.JmsSource
 
DEFAULT_PORT - Static variable in class org.springframework.xd.test.fixtures.SyslogTcpSource
 
DEFAULT_PORT - Static variable in class org.springframework.xd.test.fixtures.SyslogUdpSource
 
DEFAULT_QUEUE - Static variable in class org.springframework.xd.test.fixtures.RabbitSource
 
DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES - Static variable in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
DEFAULT_ROUTING_KEY - Static variable in class org.springframework.xd.test.fixtures.RabbitSink
 
DEFAULT_SCHEME - Static variable in class org.springframework.xd.shell.Target
 
DEFAULT_SQL - Static variable in class org.springframework.xd.test.fixtures.JdbcHdfsJob
 
DEFAULT_TABLE_NAME - Static variable in class org.springframework.xd.test.fixtures.FileJdbcJob
 
DEFAULT_TABLE_NAME - Static variable in class org.springframework.xd.test.fixtures.HdfsJdbcJob
 
DEFAULT_TARGET - Static variable in class org.springframework.xd.shell.Target
 
DEFAULT_USERNAME - Static variable in class org.springframework.xd.shell.Target
 
DEFAULT_XD_DATE_FORMAT_PATTERN - Static variable in class org.springframework.xd.rest.domain.util.TimeUtils
 
DEFAULT_XD_DATE_TIME_FORMAT_PATTERN - Static variable in class org.springframework.xd.rest.domain.util.TimeUtils
 
DEFAULT_XD_DURATION_FORMAT_PATTERN - Static variable in class org.springframework.xd.rest.domain.util.TimeUtils
 
DEFAULT_XD_TIME_FORMAT_PATTERN - Static variable in class org.springframework.xd.rest.domain.util.TimeUtils
 
DEFAULT_XD_TIMEZONE_ID - Static variable in class org.springframework.xd.rest.domain.util.TimeUtils
 
defaultBackOffInitialInterval - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
defaultBackOffMaxInterval - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
defaultBackOffMultiplier - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
defaultConcurrency - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
DefaultContainerMatcher - Class in org.springframework.xd.dirt.cluster
Implementation of ContainerMatcher that returns a collection of containers to deploy a ModuleDescriptor to.
DefaultContainerMatcher() - Constructor for class org.springframework.xd.dirt.cluster.DefaultContainerMatcher
Creates a container matcher instance and prepares the SpEL evaluation context to support Map properties directly.
DefaultDistributedTestSupport - Class in org.springframework.xd.distributed.util
 
DefaultDistributedTestSupport() - Constructor for class org.springframework.xd.distributed.util.DefaultDistributedTestSupport
 
defaultInstance - Static variable in class org.springframework.xd.module.ModuleDeploymentProperties
Default instance of ModuleDeploymentProperties.
defaultMaxAttempts - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
DefaultModuleDeploymentPropertiesProvider - Class in org.springframework.xd.dirt.server
Default implementation that retrieves the ModuleDeploymentProperties for the given ModuleDescriptor.
DefaultModuleDeploymentPropertiesProvider(DeploymentUnit) - Constructor for class org.springframework.xd.dirt.server.DefaultModuleDeploymentPropertiesProvider
 
DefaultModuleOptionsMetadataCollector - Class in org.springframework.xd.module.options
A (fake) PlaceholderConfigurer that will collect the placeholders it encounters and derive a ModuleOption out of them.
DefaultModuleOptionsMetadataCollector() - Constructor for class org.springframework.xd.module.options.DefaultModuleOptionsMetadataCollector
 
DefaultModuleOptionsMetadataResolver - Class in org.springframework.xd.module.options
The default implementation of ModuleOptionsMetadataResolver that deals with simple modules and reads the companion .properties file sitting next to the module definition.
DefaultModuleOptionsMetadataResolver(ConversionService) - Constructor for class org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver
Construct a new DefaultModuleOptionsMetadataResolver that will use the provided conversion service when converting from String to rich object (supported for PojoModuleOptionsMetadata only).
DefaultModuleOptionsMetadataResolver() - Constructor for class org.springframework.xd.module.options.DefaultModuleOptionsMetadataResolver
Construct a new DefaultModuleOptionsMetadataResolver, using no particular conversion service for PojoModuleOptionsMetadata.
DefaultStateCalculator - Class in org.springframework.xd.dirt.server
Default DeploymentUnitStateCalculator implementation for streams and jobs.
DefaultStateCalculator() - Constructor for class org.springframework.xd.dirt.server.DefaultStateCalculator
 
DefaultTuple - Class in org.springframework.xd.tuple
Default implementation of Tuple interface
DefaultTuple(List<String>, List<Object>, FormattingConversionService) - Constructor for class org.springframework.xd.tuple.DefaultTuple
 
DefaultTupleConversionService - Class in org.springframework.xd.tuple
Base ConversionService implementation suitable for use with Tuple
DefaultTupleConversionService() - Constructor for class org.springframework.xd.tuple.DefaultTupleConversionService
 
DefinitionAlreadyExistsException - Exception in org.springframework.xd.dirt.stream
Exception which is raised when a resource definition with the same name already exists.
DefinitionAlreadyExistsException(String, String) - Constructor for exception org.springframework.xd.dirt.stream.DefinitionAlreadyExistsException
Create a new exception.
definitionKind - Variable in class org.springframework.xd.dirt.stream.AbstractDeployer
Used in exception messages as well as indication to the parser.
DelegatingModuleOptionsMetadataResolver - Class in org.springframework.xd.module.options
A ModuleOptionsMetadataResolver that will invoke several other ModuleOptionsMetadataResolver instances in turn and merge their results (flattening them).
DelegatingModuleOptionsMetadataResolver() - Constructor for class org.springframework.xd.module.options.DelegatingModuleOptionsMetadataResolver
 
DelegatingModuleRegistry - Class in org.springframework.xd.dirt.module
A ModuleRegistry that delegates to several ModuleRegistries, in order.
DelegatingModuleRegistry(ModuleRegistry...) - Constructor for class org.springframework.xd.dirt.module.DelegatingModuleRegistry
 
delete(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
delete(Counter) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
delete(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
delete(M) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
delete(Iterable<? extends M>) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
delete(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
 
delete(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
delete(FieldValueCounter) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
delete(Iterable<? extends FieldValueCounter>) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
delete(String) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
delete(Container) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
delete(Iterable<? extends Container>) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
delete(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
Delete the Definition using the provided name.
delete(ModuleDefinition) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
 
delete(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
 
delete(String, ModuleType, String) - Method in interface org.springframework.xd.dirt.module.ModuleDependencyRepository
Remove an atomic dependency from a module (composed or not) to some target (stream, or composed module).
delete(String, ModuleType) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDefinitionRepository
 
delete(ModuleDefinition) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDefinitionRepository
 
delete(String, ModuleType, String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDependencyRepository
 
delete(String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
delete(ModuleMetadata) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
delete(Iterable<? extends ModuleMetadata>) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
delete(ModuleType, String) - Method in class org.springframework.xd.dirt.rest.ModulesController
Delete a (composite) module.
delete(String) - Method in class org.springframework.xd.dirt.rest.XDController
Request removal of an existing resource definition (stream or job).
delete(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
 
delete(String, ModuleType) - Method in class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
 
delete(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
delete(JobDefinition) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
delete(Iterable<? extends JobDefinition>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
delete(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
delete(Job) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
delete(Iterable<? extends Job>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
delete(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
delete(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
delete(Iterable<? extends StreamDefinition>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
delete(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
delete(Stream) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
delete(Iterable<? extends Stream>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
delete(String) - Method in interface org.springframework.xd.rest.client.AggregateCounterOperations
Delete the given named aggregate counter
delete(String) - Method in interface org.springframework.xd.rest.client.CounterOperations
Delete the counter with given name
delete(String) - Method in interface org.springframework.xd.rest.client.FieldValueCounterOperations
Delete the given named field value counter
delete(String) - Method in interface org.springframework.xd.rest.client.GaugeOperations
Delete the given named gauge.
delete(String) - Method in class org.springframework.xd.rest.client.impl.AggregateCounterTemplate
 
delete(String) - Method in class org.springframework.xd.rest.client.impl.CounterTemplate
 
delete(String) - Method in class org.springframework.xd.rest.client.impl.FieldValueCounterTemplate
 
delete(String) - Method in class org.springframework.xd.rest.client.impl.GaugeTemplate
 
delete(String) - Method in class org.springframework.xd.rest.client.impl.RichGaugeTemplate
 
delete(String) - Method in interface org.springframework.xd.rest.client.RichGaugeOperations
Delete the given named rich gauge
delete(String) - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
 
delete(String) - Method in class org.springframework.xd.shell.command.CounterCommands
 
delete(String) - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
 
delete(String) - Method in class org.springframework.xd.shell.command.GaugeCommands
 
delete(String) - Method in class org.springframework.xd.shell.command.RichGaugeCommands
 
delete(ID) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
delete(T) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
delete(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
delete(Iterable<? extends T>) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
delete(T) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
delete(Iterable<? extends T>) - Method in class org.springframework.xd.store.AbstractRepository
 
deleteAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
deleteAll() - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
deleteAll() - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
deleteAll() - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
deleteAll() - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
Delete all the definitions
deleteAll() - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
deleteAll() - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Delete all the registry and step name entries.
deleteAll() - Method in class org.springframework.xd.dirt.rest.XDController
Request removal of all definitions.
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.zookeeper.ZooKeeperJobDefinitionRepository
 
deleteAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
deleteAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
deleteAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
deleteAll() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
deleteAll() - Method in class org.springframework.xd.store.AbstractRedisRepository
 
deleteBinding(String, MessageChannel) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
deleteBindings(String) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
deleteDependencies(ModuleDependencyRepository, ModuleDefinition, String) - Static method in class org.springframework.xd.dirt.module.support.ModuleDefinitionRepositoryUtils
 
deleteDependencies(ModuleDependencyRepository, StreamDefinition) - Static method in class org.springframework.xd.dirt.stream.StreamDefinitionRepositoryUtils
Delete the dependencies of each module to its containing stream.
deleteJobRegistry(String) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Delete the job entry from the registry table.
deleteModule(String, RESTModuleType) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
 
deleteModule(String, RESTModuleType) - Method in interface org.springframework.xd.rest.client.ModuleOperations
Request deletion of module with given name and type.
deleteStream(String) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Delete a stream.
DepartingContainerModuleRedeployer - Class in org.springframework.xd.dirt.server
The ModuleRedeployer that re-deploys the stream/job modules that were deployed into the departing container.
DepartingContainerModuleRedeployer(ZooKeeperConnection, ContainerRepository, StreamFactory, JobFactory, PathChildrenCache, ContainerMatcher, DeploymentUnitStateCalculator) - Constructor for class org.springframework.xd.dirt.server.DepartingContainerModuleRedeployer
Constructs DepartingContainerModuleRedeployer
DependencyException - Exception in org.springframework.xd.dirt.module
Thrown when performing an action cannot be carried over because some dependency would be broken.
DependencyException(String, String, ModuleType, Set<String>) - Constructor for exception org.springframework.xd.dirt.module.DependencyException
 
deploy(String, Map<String, String>) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
Deploy a resource (job or stream).
deploy(String, String) - Method in class org.springframework.xd.dirt.rest.XDController
Request deployment of an existing definition resource.
deploy(String, Map<String, String>) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
 
deploy(String, String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
 
deploy(String, String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
 
deploy(String, String) - Method in interface org.springframework.xd.rest.client.ResourceOperations
Deploy an already created resource.
DeployableResource - Class in org.springframework.xd.rest.domain
Abstract base class for resources that represent deployable units.
DeployableResource() - Constructor for class org.springframework.xd.rest.domain.DeployableResource
No arg constructor for serialization frameworks.
DeployableResource(String) - Constructor for class org.springframework.xd.rest.domain.DeployableResource
 
deployAndStore(Module, ModuleDescriptor) - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
deployJob(String, String) - Method in class org.springframework.xd.shell.command.JobCommands
 
deploymentInfo(String, String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
Query deployment information about definitions whose ids range from first to last.
deploymentInfo(String) - Method in class org.springframework.xd.dirt.stream.AbstractInstancePersistingDeployer
Query deployment information about the definition whose ID is provided.
DeploymentLoader - Class in org.springframework.xd.dirt.server
Utility for loading streams and jobs for the purpose of deployment.
DeploymentLoader() - Constructor for class org.springframework.xd.dirt.server.DeploymentLoader
 
deploymentPropertiesProvider - Variable in class org.springframework.xd.dirt.server.RuntimeModuleDeploymentPropertiesProvider
DeploymentPropertiesUtility - Class in org.springframework.xd.dirt.util
Class that provides utility methods to handle module deployment properties.
DeploymentPropertiesUtility() - Constructor for class org.springframework.xd.dirt.util.DeploymentPropertiesUtility
 
DEPLOYMENTS - Static variable in class org.springframework.xd.dirt.zookeeper.Paths
Name of deployments node.
DeploymentStatusRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Interface in org.springframework.xd.dirt.core
Interface definition for repositories that support the reporting of deployment unit state.
DeploymentSupervisor - Class in org.springframework.xd.dirt.server
Process that watches ZooKeeper for Container arrivals and departures from the XD cluster.
DeploymentSupervisor(ZooKeeperConnection, ContainerRepository, StreamDefinitionRepository, JobDefinitionRepository, ModuleDefinitionRepository, ModuleOptionsMetadataResolver, ContainerMatcher, DeploymentUnitStateCalculator) - Constructor for class org.springframework.xd.dirt.server.DeploymentSupervisor
Construct a DeploymentSupervisor.
DeploymentUnit - Interface in org.springframework.xd.dirt.core
DeploymentUnit is a collection of modules that are intended to be deployed as a single unit.
deploymentUnit - Variable in class org.springframework.xd.dirt.server.ModuleRedeployer.ModuleDeployment
 
DeploymentUnitStateCalculator - Interface in org.springframework.xd.dirt.server
Calculates the overall status for a deployment unit (stream or job).
DeploymentUnitStatus - Class in org.springframework.xd.dirt.core
Status for a DeploymentUnit.
DeploymentUnitStatus(DeploymentUnitStatus.State) - Constructor for class org.springframework.xd.dirt.core.DeploymentUnitStatus
Construct a DeploymentUnitStatus.
DeploymentUnitStatus(DeploymentUnitStatus.State, String) - Constructor for class org.springframework.xd.dirt.core.DeploymentUnitStatus
Construct a DeploymentUnitStatus with an error description.
DeploymentUnitStatus(Map<String, String>) - Constructor for class org.springframework.xd.dirt.core.DeploymentUnitStatus
Construct a DeploymentUnitStatus using the entries in the provided map.
DeploymentUnitStatus.State - Enum in org.springframework.xd.dirt.core
Deployment unit states.
deployModules(Container) - Method in class org.springframework.xd.dirt.server.ArrivingContainerModuleRedeployer
Handle the arrival of a container.
deployModules(Container) - Method in class org.springframework.xd.dirt.server.DepartingContainerModuleRedeployer
Handle the departure of a container.
deployModules(Container) - Method in class org.springframework.xd.dirt.server.ModuleRedeployer
Deploy unallocated/orphaned modules.
deployStream(StreamDefinition) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Deploy a stream.
deployStream(StreamDefinition, Map<String, String>) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Deploy a stream with properties.
deployStream(StreamDefinition, Map<String, String>, boolean) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Deploy a stream with properties and allow return on incomplete deployment
deployStream(String, String) - Method in class org.springframework.xd.shell.command.StreamCommands
 
describeTo(Description) - Method in class org.springframework.xd.test.fixtures.EventuallyMatcher
 
describeTo(Description) - Method in class org.springframework.xd.test.fixtures.FileSink.FileSinkContentsMatcher
 
describeTo(Description) - Method in class org.springframework.xd.test.fixtures.MetricHasSimpleValueMatcher
 
deserialize(String, String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
deserialize(byte[]) - Method in class org.springframework.xd.dirt.integration.bus.serializer.AbstractCodec
Deserialize a byte array.
deserialize(InputStream, Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.serializer.CompositeCodec
 
deserialize(byte[], Class<?>) - Method in class org.springframework.xd.dirt.integration.bus.serializer.CompositeCodec
 
deserialize(InputStream, Class<? extends T>) - Method in interface org.springframework.xd.dirt.integration.bus.serializer.MultiTypeCodec
Deserialize an object of a given type
deserialize(byte[], Class<? extends T>) - Method in interface org.springframework.xd.dirt.integration.bus.serializer.MultiTypeCodec
Deserialize an object of a given type
deserialize(JsonParser, DeserializationContext) - Method in class org.springframework.xd.rest.client.impl.support.JobParameterJacksonDeserializer
 
deserialize(ID, String) - Method in class org.springframework.xd.store.AbstractRedisRepository
Deserialize from the String representation to the domain object.
deserializeId(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository
 
deserializeId(String) - Method in class org.springframework.xd.store.AbstractRedisRepository
Deserialize an entity id from its String representation.
deserializePayloadIfNecessary(Message<?>) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
destroy() - Method in class org.springframework.xd.batch.hsqldb.server.HSQLServerBean
 
destroy() - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus
 
destroy() - Method in class org.springframework.xd.dirt.integration.redis.RedisMessageBus
 
destroy() - Method in class org.springframework.xd.dirt.plugins.job.BatchJobRegistryBeanPostProcessor
 
destroy() - Method in class org.springframework.xd.dirt.server.DeploymentSupervisor
destroy() - Method in class org.springframework.xd.dirt.stream.JobDeployer
 
destroy() - Method in class org.springframework.xd.dirt.test.process.AbstractSingleNodeProcessingChain
 
destroy() - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterFactoryBean
 
destroy() - Method in class org.springframework.xd.module.core.CompositeModule
 
destroy() - Method in interface org.springframework.xd.module.core.Module
Destroy this module's application context.
destroy() - Method in class org.springframework.xd.module.core.SimpleModule
 
destroy(String) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
 
destroy(String) - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
 
destroy(String) - Method in interface org.springframework.xd.rest.client.ResourceOperations
Destroy an existing resource.
destroyAll() - Method in class org.springframework.xd.rest.client.impl.JobTemplate
 
destroyAll() - Method in class org.springframework.xd.rest.client.impl.StreamTemplate
 
destroyAll() - Method in interface org.springframework.xd.rest.client.ResourceOperations
Undeploy all the resources known to the system.
destroyAllJobs(boolean) - Method in class org.springframework.xd.shell.command.JobCommands
 
destroyAllStreams(URL) - Static method in class org.springframework.xd.integration.util.StreamUtils
Removes all the streams from the cluster.
destroyAllStreams(boolean) - Method in class org.springframework.xd.shell.command.StreamCommands
 
destroyJob(String) - Method in class org.springframework.xd.shell.command.JobCommands
 
destroyModule(ModuleCommands.QualifiedModuleName) - Method in class org.springframework.xd.shell.command.ModuleCommands
 
destroyQueue() - Method in class org.springframework.xd.test.fixtures.RabbitSource
Creates an instance of the queue on the rabbit broker.
destroyStream(String) - Method in class org.springframework.xd.shell.command.StreamCommands
 
DetailedContainer - Class in org.springframework.xd.dirt.cluster
Domain object for an XD container with detailed info (deployed modules, messageRates etc.,).
DetailedContainer(Container) - Constructor for class org.springframework.xd.dirt.cluster.DetailedContainer
Construct a RuntimeContainer object.
DetailedContainerResource - Class in org.springframework.xd.rest.domain
Represents container info model.
DetailedContainerResource(Map<String, String>, int, List<ModuleMetadataResource>, Map<String, HashMap<String, Double>>) - Constructor for class org.springframework.xd.rest.domain.DetailedContainerResource
Construct ContainerResource using the container attributes and deployed modules.
DetailedContainerResource.Page - Class in org.springframework.xd.rest.domain
Dedicated subclass to workaround type erasure.
DetailedContainerResource.Page() - Constructor for class org.springframework.xd.rest.domain.DetailedContainerResource.Page
 
DetailedJobInfo - Class in org.springframework.xd.dirt.job
A job info for batch jobs that provides more details than the base JobInfo
DetailedJobInfo(String, int, boolean, boolean, JobExecutionInfo, boolean) - Constructor for class org.springframework.xd.dirt.job.DetailedJobInfo
Construct detailed job info.
DetailedJobInfoResource - Class in org.springframework.xd.rest.domain
Represents Expanded Batch job info that has more details on batch jobs.
DetailedJobInfoResource(String, int, boolean, boolean, JobExecutionInfoResource, boolean) - Constructor for class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
DetailedJobInfoResourceAssembler - Class in org.springframework.xd.dirt.rest
Knows how to build a REST resource out of our domain model DetailedJobInfo.
DetailedJobInfoResourceAssembler() - Constructor for class org.springframework.xd.dirt.rest.DetailedJobInfoResourceAssembler
 
DetailedModuleDefinitionResource - Class in org.springframework.xd.rest.domain
Extends ModuleDefinitionResource with information about module options.
DetailedModuleDefinitionResource() - Constructor for class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource
Default constructor for serialization frameworks.
DetailedModuleDefinitionResource(String, String, boolean) - Constructor for class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource
 
DetailedModuleDefinitionResource.Option - Class in org.springframework.xd.rest.domain
 
DetailedModuleDefinitionResource.Option(String, String, String, String, boolean) - Constructor for class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource.Option
 
DetailedModuleDefinitionResource.Page - Class in org.springframework.xd.rest.domain
Dedicated subclass to workaround type erasure.
DetailedModuleDefinitionResource.Page() - Constructor for class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource.Page
 
DetailedModuleDefinitionResourceAssembler - Class in org.springframework.xd.dirt.rest
DetailedModuleDefinitionResourceAssembler(ModuleOptionsMetadataResolver) - Constructor for class org.springframework.xd.dirt.rest.DetailedModuleDefinitionResourceAssembler
 
details(long, long) - Method in class org.springframework.xd.dirt.rest.BatchStepExecutionsController
Inspect the StepExecution with the provided Step Execution Id
determinePartition(Message<?>, MessageBusSupport.PartitioningMetadata) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Determine the partition to which to send this message.
dir(String) - Method in class org.springframework.xd.test.fixtures.HdfsJdbcJob
Sets the directory where the file will be read from the hdfs.
dir(String) - Method in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
Sets the directory where the file will be read from the hdfs.
dir(String) - Method in class org.springframework.xd.test.fixtures.SimpleFileSink
Establishes the directory the SimpleFileSink will write the file.
DIRECT - Static variable in class org.springframework.xd.dirt.integration.bus.Binding
 
DIRECT_BINDING_ALLOWED - Static variable in interface org.springframework.xd.dirt.integration.bus.BusProperties
If true, the bus will attempt to create a direct binding between the producer and consumer.
directChannelProvider - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Used in the canonical case, when the binding does not involve an alias name.
directory(String) - Method in class org.springframework.xd.test.fixtures.FilePollHdfsJob
Sets the directory that the hdfs will write to.
directoryName(String) - Method in class org.springframework.xd.test.fixtures.HdfsSink
Sets the directory that the file will be written on hdfs
display(String, DateTime, DateTime, AggregateCountResolution) - Method in class org.springframework.xd.dirt.rest.metrics.AggregateCountersController
Retrieve counts for a given time interval, using some precision.
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.CountersController
Retrieve information about a specific counter.
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.FieldValueCountersController
 
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.GaugesController
 
display(String) - Method in class org.springframework.xd.dirt.rest.metrics.RichGaugesController
 
display(String) - Method in class org.springframework.xd.dirt.rest.XDController
Retrieve information about a single ResourceSupport.
display(String, String, String, Integer, Integer, AggregateCounterOperations.Resolution, NumberFormat) - Method in class org.springframework.xd.shell.command.AggregateCounterCommands
 
display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.CounterCommands
 
display(String, NumberFormat, int) - Method in class org.springframework.xd.shell.command.FieldValueCounterCommands
 
display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.GaugeCommands
 
display(long) - Method in class org.springframework.xd.shell.command.JobCommands
 
display(String, NumberFormat) - Method in class org.springframework.xd.shell.command.RichGaugeCommands
 
displayBanner(String, String) - Static method in class org.springframework.xd.dirt.util.BannerUtils
 
displayBeans(Map<String, Object>, String) - Static method in class org.springframework.xd.dirt.server.ApplicationUtils
 
displayForJobname(String) - Method in class org.springframework.xd.dirt.rest.ModulesMetadataController
Will return a collection of ModuleMetadata that are associated with the provided jobname request parameter.
displayJobExecution(long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
 
displayJobExecution(long) - Method in interface org.springframework.xd.rest.client.JobOperations
Retrieve a specific Job Execution for the provided jobExecutionId.
displayJobInstance(long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
 
displayJobInstance(long) - Method in interface org.springframework.xd.rest.client.JobOperations
Retrieve a specific instance of a job, given its intanceId.
displayJobInstance(long) - Method in class org.springframework.xd.shell.command.JobCommands
 
displayMetrics(PagedResources<MetricResource>) - Method in class org.springframework.xd.shell.command.AbstractMetricsCommands
Render a table with information about a list of metrics
displayStepExecution(long, long) - Method in class org.springframework.xd.rest.client.impl.JobTemplate
 
displayStepExecution(long, long) - Method in interface org.springframework.xd.rest.client.JobOperations
Retrieve a specific StepExecutionInfoResource for the provided jobExecutionId and stepExecutionId.
displayStepExecution(long, long) - Method in class org.springframework.xd.shell.command.JobCommands
 
Disposable - Interface in org.springframework.xd.test.fixtures
To be implemented by fixtures that need special cleanup when a test is done.
DisposableFileSupport<F extends DisposableFileSupport<F>> - Class in org.springframework.xd.test.fixtures
Base class for stream elements that deal with file locations.
DisposableFileSupport() - Constructor for class org.springframework.xd.test.fixtures.DisposableFileSupport
 
DisposableFileSupport(File) - Constructor for class org.springframework.xd.test.fixtures.DisposableFileSupport
 
DisposableMailSupport<T extends DisposableMailSupport<T>> - Class in org.springframework.xd.test.fixtures
Base class for fixtures that interact with a mail server.
DisposableMailSupport() - Constructor for class org.springframework.xd.test.fixtures.DisposableMailSupport
 
DistributedJobLocator - Class in org.springframework.xd.dirt.plugins.job
Implementation of ListableJobLocator used by DistributedJobService.
DistributedJobLocator() - Constructor for class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
 
DistributedJobService - Class in org.springframework.xd.dirt.plugins.job
SimpleJobService in distributed mode
DistributedJobService(SearchableJobInstanceDao, SearchableJobExecutionDao, SearchableStepExecutionDao, JobRepository, JobLauncher, DistributedJobLocator, ExecutionContextDao) - Constructor for class org.springframework.xd.dirt.plugins.job.DistributedJobService
 
DistributedTestSupport - Interface in org.springframework.xd.distributed.util
Provides support methods for building distributed system tests.
doBindDynamicProducer(String, String, Properties) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Create a producer for the named channel and bind it to the bus.
doBindDynamicPubSubProducer(String, String, Properties) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
Create a producer for the named channel and bind it to the bus.
doDateFormat(EvaluationContext, Object, String, List<TypeDescriptor>) - Method in class org.springframework.xd.integration.hadoop.partition.MessagePartitionKeyMethodResolver
Create a MethodExecutor using MessageDateFormatMethodExecutor.
doDeserialize(Kryo, Input) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.FileCodec
 
doDeserialize(Kryo, Input, Class<? extends Object>) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.PojoCodec
 
doDeserialize(Kryo, Input) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.StringCodec
 
doDeserialize(Kryo, Input) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.TupleCodec
 
DomainRepository<T,ID extends java.io.Serializable & java.lang.Comparable<ID>> - Interface in org.springframework.xd.store
Implemented by XD repositories, exists mainly as a mean to capture several interfaces into one.
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterParser
 
doParse(Element, ParserContext, String) - Method in class org.springframework.xd.integration.reactor.config.SyslogInboundChannelAdapterParser
 
doSendLine(String) - Method in class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter
 
doSendLine(String) - Method in class org.springframework.integration.x.twitter.TwitterSearchChannelAdapter
 
doSendLine(String) - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
 
doSerialize(File, Kryo, Output) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.FileCodec
 
doSerialize(Object, Kryo, Output) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.PojoCodec
 
doSerialize(String, Kryo, Output) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.StringCodec
 
doSerialize(Tuple, Kryo, Output) - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.TupleCodec
 
doStart() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
 
doStart() - Method in class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter
 
doStart() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
Subclasses may override this method with the start behaviour.
doStart() - Method in class org.springframework.xd.integration.reactor.net.NetServerInboundChannelAdapter
 
doStart() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
 
doStop() - Method in class org.springframework.integration.x.http.NettyHttpInboundChannelAdapter
 
doStop() - Method in class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter
 
doStop() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsDataStoreMessageHandler
 
doStop() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsPartitionDataStoreMessageHandler
 
doStop() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
Subclasses may override this method with the stop behaviour.
doStop() - Method in class org.springframework.xd.integration.reactor.net.NetServerInboundChannelAdapter
 
doStop() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
 
downloadConfigurationFile(RESTModuleType, String) - Method in class org.springframework.xd.rest.client.impl.ModuleTemplate
 
downloadConfigurationFile(RESTModuleType, String) - Method in interface org.springframework.xd.rest.client.ModuleOperations
Get the configuration file associated with the provided module information.
downloadDefinition(ModuleType, String) - Method in class org.springframework.xd.dirt.rest.ModulesController
Retrieve the configuration file for the provided module information.
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsDataStoreMessageHandler
 
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsPartitionDataStoreMessageHandler
 
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
Subclasses need to implement this method to handle Message in its writer.
doWrite(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
driverClassName - Variable in class org.springframework.xd.jdbc.JdbcConnectionMixin
 
dropCollection(String) - Method in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
The drops the collection.
dropTable(String) - Method in class org.springframework.xd.test.fixtures.JdbcSink
 
du(String, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
dumpContainerApplicationContextConfiguration(ApplicationContext) - Static method in class org.springframework.xd.dirt.server.ApplicationUtils
Dump container context configuration details to stdout
dumpContextConfiguration() - Method in class org.springframework.xd.dirt.server.ContainerServerApplication
 

E

EMBEDDED_ZK_CONNECT - Static variable in class org.springframework.xd.dirt.server.SharedServerContextConfiguration
 
EmbeddedZooKeeper - Class in org.springframework.xd.dirt.zookeeper
Helper class to start an embedded instance of standalone (non clustered) ZooKeeper.
EmbeddedZooKeeper() - Constructor for class org.springframework.xd.dirt.zookeeper.EmbeddedZooKeeper
Construct an EmbeddedZooKeeper with a random port.
EmbeddedZooKeeper(int) - Constructor for class org.springframework.xd.dirt.zookeeper.EmbeddedZooKeeper
Construct an EmbeddedZooKeeper with the provided port.
EmptyStartYieldsModulesRecoveryStrategy - Class in org.springframework.xd.dirt.stream.completion
Proposes module names when the user has either typed nothing typed a channel name followed by a ">"
EmptyStartYieldsModulesRecoveryStrategy(XDParser, ModuleDefinitionRepository) - Constructor for class org.springframework.xd.dirt.stream.completion.EmptyStartYieldsModulesRecoveryStrategy
Construct a new EmptyStartYieldsModulesRecoveryStrategy given the parser and ModuleDefinition repository.
EncoderDecoderMixins - Class in org.springframework.xd.tcp
Provides mixins for encoder/decoder options.
EncoderDecoderMixins.BufferSizeMixin - Class in org.springframework.xd.tcp
Adds a bufferSize option (default 2048), to be used alongside a decoder/encoder (or both) option.
EncoderDecoderMixins.BufferSizeMixin() - Constructor for class org.springframework.xd.tcp.EncoderDecoderMixins.BufferSizeMixin
 
EncoderDecoderMixins.DecoderMixin - Class in org.springframework.xd.tcp
Adds an decoder option (default CRLF) and activates a profile named after the chosen decoder.
EncoderDecoderMixins.DecoderMixin() - Constructor for class org.springframework.xd.tcp.EncoderDecoderMixins.DecoderMixin
 
EncoderDecoderMixins.EncoderMixin - Class in org.springframework.xd.tcp
Adds an encoder option (default CRLF) and activates a profile named after the chosen encoder.
EncoderDecoderMixins.EncoderMixin() - Constructor for class org.springframework.xd.tcp.EncoderDecoderMixins.EncoderMixin
 
EncoderDecoderMixins.Encoding - Enum in org.springframework.xd.tcp
 
endpos - Variable in class org.springframework.xd.dirt.stream.dsl.AstNode
 
ensureNotStarted() - Method in class org.springframework.xd.test.fixtures.DisposableMailSupport
 
ensurePath(CuratorFramework, String) - Static method in class org.springframework.xd.dirt.zookeeper.Paths
Ensure the existence of the given path.
ensureReady(AbstractModuleFixture<?>, String, int, int) - Static method in class org.springframework.xd.test.fixtures.AvailableSocketPorts
Verifies that the port to the broker is available.
ensureReady() - Method in class org.springframework.xd.test.fixtures.JmsSource
Ensure that the Jms broker socket is available by polling it for up to 2 seconds
ensureReady() - Method in class org.springframework.xd.test.fixtures.MqttSource
Ensure that the Mqtt broker socket is available by polling it for up to 2 seconds
ensureReady() - Method in class org.springframework.xd.test.fixtures.RabbitSink
Ensure that the each Rabbit broker socket is available by polling it for up to 2 seconds
ensureReady() - Method in class org.springframework.xd.test.fixtures.RabbitSource
Ensure that the Rabbit broker socket is available by polling it for up to 2 seconds
ensureReady() - Method in class org.springframework.xd.test.fixtures.SimpleHttpSource
Ensure that the source is ready to take requests by sending http header requests to the source for up to 2 seconds.
ensureReady(int) - Method in class org.springframework.xd.test.fixtures.SimpleHttpSource
Ensure that the source is ready to take requests by sending http header requests for up to the timeout specified in millisecionds, sleeping 100 ms between attempts.
ensureReady() - Method in class org.springframework.xd.test.fixtures.TcpSource
Ensure that the TcpSource socket is available by polling it for up to 2 seconds
ensureStarted() - Method in class org.springframework.xd.test.fixtures.DisposableMailSupport
 
ensureTemplate() - Method in class org.springframework.xd.distributed.util.DefaultDistributedTestSupport
Return an instance of SpringXDTemplate based on the port configured for the admin server started by DistributedTestSupport.startup().
ensureTemplate() - Method in interface org.springframework.xd.distributed.util.DistributedTestSupport
Return an instance of SpringXDTemplate based on the port configured for the admin server started by DistributedTestSupport.startup().
entrySet() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
entrySet() - Method in class org.springframework.xd.module.ModuleDeploymentProperties
environment - Variable in class org.springframework.xd.dirt.util.XdConfigLoggingInitializer
 
EnvironmentAwareModuleOptionsMetadataResolver - Class in org.springframework.xd.module.options
A decorator around another ModuleOptionsMetadataResolver that will provide default values for module options using the environment.
EnvironmentAwareModuleOptionsMetadataResolver() - Constructor for class org.springframework.xd.module.options.EnvironmentAwareModuleOptionsMetadataResolver
 
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.cluster.Container
equals(Object) - Method in class org.springframework.xd.dirt.core.BaseDefinition
 
equals(Object) - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
 
equals(Object) - Method in class org.springframework.xd.dirt.stream.dsl.Token
 
equals(Object) - Method in class org.springframework.xd.module.ModuleDescriptor.Key
equals(Object) - Method in class org.springframework.xd.shell.util.Table
 
equals(Object) - Method in class org.springframework.xd.shell.util.TableHeader
 
equals(Object) - Method in class org.springframework.xd.shell.util.TableRow
 
equals(Object) - Method in class org.springframework.xd.tuple.DefaultTuple
 
errorHtml(HttpServletRequest) - Method in class org.springframework.xd.dirt.rest.XdErrorController
 
evaluate(I) - Method in interface org.springframework.xd.analytics.ml.Analytic
Evaluates the encoded Analytic against the given input.
evaluate(I) - Method in class org.springframework.xd.analytics.ml.MappedAnalytic
Evaluates the encoded Analytic against the given input.
evaluateInternal(MI) - Method in class org.springframework.xd.analytics.ml.MappedAnalytic
Performs the actual evaluation with the mapped input values.
evaluationContext - Variable in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
EventuallyMatcher<U> - Class in org.springframework.xd.test.fixtures
A matcher that will evaluate another matcher repeatedly until it matches, or fail after some number of attempts.
EventuallyMatcher(Matcher<U>) - Constructor for class org.springframework.xd.test.fixtures.EventuallyMatcher
 
EventuallyMatcher(Matcher<U>, int, int) - Constructor for class org.springframework.xd.test.fixtures.EventuallyMatcher
 
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.
exchange(String) - Method in class org.springframework.xd.test.fixtures.RabbitSink
Sets the exchange for the fixture
exclude(String...) - Method in class org.springframework.xd.dirt.server.options.ResourcePatternScanningOptionHandler
 
execute(StepContribution, ChunkContext) - Method in class org.springframework.batch.integration.x.RemoteFileToHadoopTasklet
 
execute(EvaluationContext, Object, Object...) - Method in class org.springframework.xd.integration.hadoop.partition.MessageDateFormatMethodExecutor
 
executeBatchJob() - Method in class org.springframework.xd.dirt.plugins.job.ModuleJobLauncher
 
ExecutionContextJacksonMixIn - Class in org.springframework.xd.dirt.plugins.job.support
Jackson MixIn for the JSON serialization of the ExecutionContext class, which is used by the StepExecution class.
ExecutionContextJacksonMixIn() - Constructor for class org.springframework.xd.dirt.plugins.job.support.ExecutionContextJacksonMixIn
 
ExecutionContextJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support
Jackson MixIn for ExecutionContext de-serialization.
ExecutionContextJacksonMixIn() - Constructor for class org.springframework.xd.rest.client.impl.support.ExecutionContextJacksonMixIn
 
executionsForJob(String, int, int) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController
Return a paged collection of job executions for a given job.
ExistingXDEntityConverter - Class in org.springframework.xd.shell.converter
A no-op converter from String to String, but that helps with completion in names of already existing entities.
ExistingXDEntityConverter() - Constructor for class org.springframework.xd.shell.converter.ExistingXDEntityConverter
 
exists(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
exists(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
exists(String) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
exists(String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
exists(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
exists(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
exists(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
exists(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
exists(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
exists(ID) - Method in class org.springframework.xd.store.AbstractRepository
 
ExitStatusJacksonMixIn - Class in org.springframework.xd.rest.client.impl.support
Jackson MixIn for ExitStatus de-serialization.
ExpandedJobParametersConverter - Class in org.springframework.xd.dirt.plugins.job
More flexible implementation of the JobParametersConverter.
ExpandedJobParametersConverter() - Constructor for class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
Default Constructor, initializing DefaultJobParametersConverter.setDateFormat(DateFormat) with TimeUtils.getDefaultDateFormat().
ExpandOneDashToTwoDashesRecoveryStrategy - Class in org.springframework.xd.dirt.stream.completion
Provides completion when the user has typed in the first dash to a module option.
ExpandOneDashToTwoDashesRecoveryStrategy(XDParser) - Constructor for class org.springframework.xd.dirt.stream.completion.ExpandOneDashToTwoDashesRecoveryStrategy
Construct a new ExpandOneDashToTwoDashesRecoveryStrategy given the parser.
expression(String) - Method in class org.springframework.xd.test.fixtures.Transform
Sets the expression to be used by the transform
ExpressionOrScriptMixin - Class in org.springframework.xd.module.options.mixins
A standard mixin for modules that do some transformation based on either a script or a SpEL expression.
ExpressionOrScriptMixin() - Constructor for class org.springframework.xd.module.options.mixins.ExpressionOrScriptMixin
 
expressionString - Variable in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
 
expunge() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
extract(Tuple) - Method in class org.springframework.xd.tuple.batch.TupleFieldExtractor
 
extractConsumerProducerProperties(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
extractFieldNameMappingFrom(List<String>) - Method in class org.springframework.xd.analytics.ml.AbstractFieldMappingAwareDataMapper
Transforms the list of field name mapping pairs to a Map from a name to a new name.
extractKey(Message<?>) - Method in interface org.springframework.xd.dirt.integration.bus.PartitionKeyExtractorStrategy
 

F

failedComponentName() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
 
failedComponentName() - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
fairQueue - Variable in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
FieldSetConverter - Class in org.springframework.xd.mongodb
A converter that maps from the batch FieldSet world to Mongo's DBObject.
FieldSetConverter() - Constructor for class org.springframework.xd.mongodb.FieldSetConverter
 
FieldSetSqlParameterSourceProvider - Class in org.springframework.xd.batch.item.jdbc
An ItemSqlParameterSourceProvider that will derive parameters from a FieldSet.
FieldSetSqlParameterSourceProvider() - Constructor for class org.springframework.xd.batch.item.jdbc.FieldSetSqlParameterSourceProvider
 
FieldSetType - Enum in org.springframework.xd.tuple.batch
Enum used to provide typing information when reading from a file.
FieldValueCounter - Class in org.springframework.xd.analytics.metrics.core
Represents the data stored in a Counter for multiple field-value pairs.
FieldValueCounter(String) - Constructor for class org.springframework.xd.analytics.metrics.core.FieldValueCounter
 
FieldValueCounter(String, Map<String, Double>) - Constructor for class org.springframework.xd.analytics.metrics.core.FieldValueCounter
 
FieldValueCounterCommands - Class in org.springframework.xd.shell.command
Commands for interacting with field value counter analytics.
FieldValueCounterCommands() - Constructor for class org.springframework.xd.shell.command.FieldValueCounterCommands
 
FieldValueCounterHandler - Class in org.springframework.xd.analytics.metrics.integration
Counts the occurrence of values for a set of JavaBean properties or Tuple fields using a FieldValueCounterService.
FieldValueCounterHandler(FieldValueCounterRepository, String, String) - Constructor for class org.springframework.xd.analytics.metrics.integration.FieldValueCounterHandler
 
FieldValueCounterOperations - Interface in org.springframework.xd.rest.client
Interface defining operations available when dealing with Field Value Counters.
FieldValueCounterRepository - Interface in org.springframework.xd.analytics.metrics.core
A repository to save, delete and find FieldValueCounter instances.
FieldValueCounterResource - Class in org.springframework.xd.rest.domain.metrics
A deep representation of a FieldValueCounter
FieldValueCounterResource() - Constructor for class org.springframework.xd.rest.domain.metrics.FieldValueCounterResource
No arg constructor for serialization frameworks.
FieldValueCounterResource(String, Map<String, Double>) - Constructor for class org.springframework.xd.rest.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
 
FieldValueCounterSinkOptionsMetadata - Class in org.springframework.xd.analytics.metrics.metadata
Captures options for the field-value-counter sink module.
FieldValueCounterSinkOptionsMetadata() - Constructor for class org.springframework.xd.analytics.metrics.metadata.FieldValueCounterSinkOptionsMetadata
 
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
 
file(String, String) - Method in class org.springframework.xd.integration.fixtures.Sinks
Construct a new fileSink that will write the result to the dir and filename specified.
file() - Method in class org.springframework.xd.integration.fixtures.Sinks
Construct a new fileSink that will write the result to the xd output directory using the stream name as the filename.
file(String, String) - Method in class org.springframework.xd.integration.fixtures.Sources
Construct a new SimpleFileSource using the provided directory and filename
file - Variable in class org.springframework.xd.test.fixtures.DisposableFileSupport
 
FileCodec - Class in org.springframework.xd.dirt.integration.bus.serializer.kryo
 
FileCodec() - Constructor for class org.springframework.xd.dirt.integration.bus.serializer.kryo.FileCodec
 
FileDeletionStepExecutionListener - Class in org.springframework.xd.dirt.plugins.job.support.listener
Step listener which can be used to delete files once they have been successfully processed by XD.
FileDeletionStepExecutionListener() - Constructor for class org.springframework.xd.dirt.plugins.job.support.listener.FileDeletionStepExecutionListener
 
fileExists(String) - Method in class org.springframework.xd.integration.util.HadoopUtils
Verifies that the file exists.
fileJdbcJob() - Method in class org.springframework.xd.integration.fixtures.Jobs
Create an instance of the FileJdbc job with the default target dir, fileName, tableName and column names.
FileJdbcJob - Class in org.springframework.xd.test.fixtures
A test fixture that represents the FileJdbc Job
FileJdbcJob(String, String, String, String) - Constructor for class org.springframework.xd.test.fixtures.FileJdbcJob
Construct a new FileJdbcJob using the provided directory and file names.
FileJdbcJobOptionsMetadata - Class in org.springframework.xd.jdbc
Captures options for the filejdbc job.
FileJdbcJobOptionsMetadata() - Constructor for class org.springframework.xd.jdbc.FileJdbcJobOptionsMetadata
 
fileName(String) - Method in class org.springframework.xd.test.fixtures.FilePollHdfsJob
Sets the fileName that the hdfs will write to.
fileName(String) - Method in class org.springframework.xd.test.fixtures.HdfsJdbcJob
Sets the fileName of the file to be read
fileName(String) - Method in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
Sets the fileName of the file to be read
fileName(String) - Method in class org.springframework.xd.test.fixtures.HdfsSink
Sets the file Name that the hdfs sink will write the data.
fileName(String) - Method in class org.springframework.xd.test.fixtures.SimpleFileSink
Establishes the filename the SimpleFileSink will associate with the file.
filePollHdfsJob(String) - Method in class org.springframework.xd.integration.fixtures.Jobs
Creates an instance of the FilePollHdfsJob using defaults.
FilePollHdfsJob - Class in org.springframework.xd.test.fixtures
Test fixture that creates a File Poll Hdfs Job.
FilePollHdfsJob(String, String, String) - Constructor for class org.springframework.xd.test.fixtures.FilePollHdfsJob
Initializes an instance of FilePollHdfsJob
FilePollHdfsJobOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata
Describes the options for the filepollhdfs job.
FilePollHdfsJobOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.FilePollHdfsJobOptionsMetadata
 
fileRemove(String) - Method in class org.springframework.xd.integration.util.HadoopUtils
Recursively removes files in a directory or if only a file just that file.
FileSink - Class in org.springframework.xd.test.fixtures
Support class to capture output of a sink in a File.
FileSink() - Constructor for class org.springframework.xd.test.fixtures.FileSink
Create a file sink, but make sure that the future file is not present yet, so it can be waited upon with FileSink.getContents().
FileSink.FileSinkContentsMatcher - Class in org.springframework.xd.test.fixtures
A matcher on the String contents of the sink, that delegates to another (String) matcher.
FileSink.FileSinkContentsMatcher(Matcher<String>) - Constructor for class org.springframework.xd.test.fixtures.FileSink.FileSinkContentsMatcher
 
FileSinkOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata
Holds options to the 'file' sink module.
FileSinkOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata
 
FileSinkOptionsMetadata.Mode - Enum in org.springframework.xd.dirt.modules.metadata
 
FileSource - Class in org.springframework.xd.test.fixtures
Support class that represents the file source module.
FileSource() - Constructor for class org.springframework.xd.test.fixtures.FileSource
 
filesToFetch(String) - Method in interface org.springframework.batch.integration.x.RemoteFilePartitioner.Gateway
 
find(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDependencyRepository
Return the set of things that depend on the given module.
find(String, ModuleType) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDependencyRepository
 
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(Sort) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
findAll(Pageable) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
findAll() - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
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(Sort) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
findAll(Pageable) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
findAll() - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
findAll() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
 
findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
 
findAll(Sort) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
findAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
findAll(Sort) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
findAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
findAll(Sort) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
findAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
findAll(Sort) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
findAll(Pageable) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
findAll() - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
findAll(Iterable<String>) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
findAll() - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
findAll(Pageable) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
findAll(Sort) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
findAll() - Method in class org.springframework.xd.store.AbstractRedisRepository
 
findAll(Iterable<ID>) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
findAll(Pageable) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
findAll(Sort) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
findAll(Iterable<ID>) - Method in class org.springframework.xd.store.AbstractRepository
 
findAllByContainerId(Pageable, String) - Method in interface org.springframework.xd.dirt.module.store.ModuleMetadataRepository
Find paged ModuleMetadata for all the modules deployed into the given container.
findAllByContainerId(Pageable, String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
Find the module metadata for the modules that are deployed into the given container.
findAllByContainerId(String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
Find all the modules that are deployed into this container.
findAllByModuleId(Pageable, String) - Method in interface org.springframework.xd.dirt.module.store.ModuleMetadataRepository
Find paged ModuleMetadata for the modules of given moduleId.
findAllByModuleId(Pageable, String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
Find all module metadata by the given module id.
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
Return entities whose ids range between from and to.
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
findAllInRange(String, boolean, String, boolean) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
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.
findAllRuntimeContainers(Pageable) - Method in interface org.springframework.xd.dirt.container.store.ContainerRepository
 
findAllRuntimeContainers(Pageable) - Method in class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
Find all the s in the XD cluster.
findByNameAndType(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
 
findByNameAndType(String, ModuleType) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDefinitionRepository
 
findByType(Pageable, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
 
findByType(Pageable, ModuleType) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDefinitionRepository
 
findDefinition(String, ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
findDefinition(String, ModuleType) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
 
findDefinition(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry
Lookup a module of the given type with the given name.
findDefinitions(String) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
findDefinitions(ModuleType) - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
findDefinitions() - Method in class org.springframework.xd.dirt.module.AbstractModuleRegistry
 
findDefinitions(String) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
 
findDefinitions(ModuleType) - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
 
findDefinitions() - Method in class org.springframework.xd.dirt.module.DelegatingModuleRegistry
 
findDefinitions(String) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry
Searches the registry for the name specified and returns all module definitions that match the name regardless of module type.
findDefinitions(ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleRegistry
Searches the registry for the type specified and returns all module definitions that match the type.
findDefinitions() - Method in interface org.springframework.xd.dirt.module.ModuleRegistry
Returns all module definitions.
findDefinitions(ModuleType) - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
 
findDefinitions() - Method in class org.springframework.xd.dirt.module.RedisModuleRegistry
 
findDependentModules(String, ModuleType) - Method in interface org.springframework.xd.dirt.module.ModuleDefinitionRepository
 
findDependentModules(String, ModuleType) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleDefinitionRepository
 
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 class org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository
findOne(String) - Method in interface org.springframework.xd.dirt.core.ResourceDeployer
Retrieves a single Definition or null if none is found.
findOne(String, String) - Method in interface org.springframework.xd.dirt.module.store.ModuleMetadataRepository
Find ModuleMetadata for the module that has the given module id and deployed into given container.
findOne(String, String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
Find the module metadata for the modules that are deployed into the given container and module id.
findOne(String) - Method in class org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository
 
findOne(String) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
 
findOne(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository
 
findOne(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
findOne(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository
 
findOne(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
findOne(ID) - Method in class org.springframework.xd.store.AbstractInMemoryRepository
 
findOne(ID) - Method in class org.springframework.xd.store.AbstractRedisRepository
 
FixtureUtils - Class in org.springframework.xd.test.fixtures.util
Utility to support common tasks done by fixtures.
FixtureUtils() - Constructor for class org.springframework.xd.test.fixtures.util.FixtureUtils
 
FlattenedCompositeModuleOptionsMetadata - Class in org.springframework.xd.module.options
A composite ModuleOptionsMetadata made of several ModuleOptionsMetadata that will appear "flattened".
FlattenedCompositeModuleOptionsMetadata(List<? extends ModuleOptionsMetadata>) - Constructor for class org.springframework.xd.module.options.FlattenedCompositeModuleOptionsMetadata
 
folder - Variable in class org.springframework.xd.test.fixtures.AbstractMailSource
 
forConsumer(String, AbstractEndpoint, MessageChannel, AbstractBusPropertiesAccessor) - Static method in class org.springframework.xd.dirt.integration.bus.Binding
 
forDirectProducer(String, MessageChannel, AbstractEndpoint, AbstractBusPropertiesAccessor) - Static method in class org.springframework.xd.dirt.integration.bus.Binding
 
format(Date, StringBuffer, FieldPosition) - Method in class org.springframework.xd.rest.domain.util.ISO8601DateFormatWithMilliSeconds
 
formatDeploymentProperties(Map<String, String>) - Static method in class org.springframework.xd.dirt.util.DeploymentPropertiesUtility
Returns a String representation of deployment properties as a comma separated list of key=value pairs.
formatMessage(int, Object...) - Method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages
Produce a complete message including the prefix, the position (if known) and with the inserts applied to the message.
forProducer(String, MessageChannel, AbstractEndpoint, AbstractBusPropertiesAccessor) - Static method in class org.springframework.xd.dirt.integration.bus.Binding
 
from(String) - Method in class org.springframework.xd.test.fixtures.MailSink
 
fromBindException(String, ModuleType, BindException) - Static method in exception org.springframework.xd.dirt.plugins.ModuleConfigurationException
Construct an exception following a configuration exception on a particular module.
fromClassName(String) - Static method in enum org.springframework.xd.dirt.job.StepType
 
fromClassName(String) - Static method in enum org.springframework.xd.dirt.job.TaskletType
 
fromModuleDescriptor(ModuleDescriptor) - Static method in class org.springframework.xd.module.ModuleDescriptor.Builder
Create a Builder object pre-populated with the configuration for the provided ModuleDescriptor.
fromString(String) - Static method in class org.springframework.xd.tuple.TupleBuilder
 
FromStringCharsetMixin - Class in org.springframework.xd.module.options.mixins
A standard mixin for modules that do conversion from String to bytes.
FromStringCharsetMixin() - Constructor for class org.springframework.xd.module.options.mixins.FromStringCharsetMixin
 
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
 
ftpHdfsJob() - Method in class org.springframework.xd.integration.fixtures.Jobs
 
FtpHdfsJob - Class in org.springframework.xd.test.fixtures
Test fixture that creates a Ftp Hdfs Job.
FtpHdfsJob(String, String) - Constructor for class org.springframework.xd.test.fixtures.FtpHdfsJob
 
FtpHdfsJobOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata
Describes the options for the ftphdfs job.
FtpHdfsJobOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.FtpHdfsJobOptionsMetadata
 
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.domain.metrics
The REST representation of a Gauge.
GaugeResource() - Constructor for class org.springframework.xd.rest.domain.metrics.GaugeResource
No-arg constructor for serialization frameworks.
GaugeResource(String, long) - Constructor for class org.springframework.xd.rest.domain.metrics.GaugeResource
 
GaugesController - Class in org.springframework.xd.dirt.rest.metrics
Exposes representations of Gauges.
GaugesController(GaugeRepository) - Constructor for class org.springframework.xd.dirt.rest.metrics.GaugesController
 
GaugeTemplate - Class in org.springframework.xd.rest.client.impl
Implementation of the Gauge part of the metrics API.
GaugeTemplate(AbstractTemplate) - Constructor for class org.springframework.xd.rest.client.impl.GaugeTemplate
 
GemfireCQSourceOptionsMetadata - Class in org.springframework.xd.gemfire
Describes options to the gemfire-cq source module.
GemfireCQSourceOptionsMetadata() - Constructor for class org.springframework.xd.gemfire.GemfireCQSourceOptionsMetadata
 
GemfireServerSinkModuleOptionsMetadata - Class in org.springframework.xd.gemfire
Captures module options for the "gemfire-server" and "gemfire-json-server" sink modules.
GemfireServerSinkModuleOptionsMetadata() - Constructor for class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
 
GemfireSourceOptionsMetadata - Class in org.springframework.xd.gemfire
Describes options to the gemfire source module.
GemfireSourceOptionsMetadata() - Constructor for class org.springframework.xd.gemfire.GemfireSourceOptionsMetadata
 
generateModuleFromJackson(String, Map<?, ?>) - Static method in class org.springframework.xd.integration.util.jmxresult.Module
Retrieves the module data from the key and value data returned from Jackson.
generateSplunkEvent(Object) - Method in class org.springframework.integration.x.splunk.SplunkTransformer
 
GeneratorException - Exception in org.springframework.xd.test.generator
Core exception for generators.
GeneratorException(String, Throwable) - Constructor for exception org.springframework.xd.test.generator.GeneratorException
Constructs a new GeneratorException instance.
get(Object) - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
get(Object) - Method in class org.springframework.xd.module.ModuleDeploymentProperties
get(String, String, boolean, boolean) - Method in class org.springframework.xd.shell.hadoop.FsShellCommands
 
getAbandonWhenPercentageFull() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getAccessToken() - Method in class org.springframework.integration.x.twitter.TwitterStreamOptionsMetadata
 
getAccessTokenSecret() - Method in class org.springframework.integration.x.twitter.TwitterStreamOptionsMetadata
 
getAckMode() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getAddresses() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitConnectionMixin
 
getAdminServerPort() - Method in class org.springframework.xd.test.RandomConfigurationSupport
 
getAdminServerUrl() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getAggregation() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getAllModuleDeploymentRequests() - Method in class org.springframework.xd.dirt.server.ModuleRedeployer
Get all the module deployment requests.
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.CompletionConverter
 
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.ExistingXDEntityConverter
 
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.MediaTypeConverter
 
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.NumberFormatConverter
 
getAllPossibleValues(List<Completion>, Class<?>, String, String, MethodTarget) - Method in class org.springframework.xd.shell.converter.QualifiedModuleNameConverter
 
getAllRestartableJobs() - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Get all the deployed job names that can be restarted.
getAlpha() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
getAlpha() - Method in class org.springframework.xd.analytics.metrics.metadata.RichGaugeSinkOptionsMetadata
 
getAlpha() - Method in class org.springframework.xd.rest.domain.metrics.RichGaugeResource
 
getApplicationContext() - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
getApplicationContext() - Method in class org.springframework.xd.dirt.plugins.AbstractPlugin
 
getApplicationContext() - Method in class org.springframework.xd.module.core.SimpleModule
 
getArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
 
getArgumentsAsProperties() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
 
getAttribute(String) - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
Get the attribute value by given name.
getAttributes() - Method in class org.springframework.xd.dirt.cluster.Container
getAttributes() - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
getAttributes() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
 
getAttributes() - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
Get all the container attributes.
getAvailableContainers(URL) - Static method in class org.springframework.xd.integration.util.StreamUtils
Creates a map of container Id's and the associated host.
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.domain.metrics.RichGaugeResource
Return the average value for the gauge.
getBackOffInitialInterval(long) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the 'backOffInitialInterval' property or the default value.
getBackOffMaxInterval(long) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the 'backOffMaxInterval' property or the default value.
getBackOffMultiplier(double) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the 'backOffMultiplier' property or the default value.
getBanner() - Method in class org.springframework.xd.shell.XDShellBannerProvider
 
getBaseDir() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
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
 
getBcc() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getBean(String, Class<T>) - Method in class org.springframework.xd.dirt.integration.bus.LocalMessageBus
 
getBeanClass(Element) - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterParser
 
getBeanFactory() - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
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'.
getBufferSize() - Method in class org.springframework.xd.tcp.EncoderDecoderMixins.BufferSizeMixin
 
getByte(String) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getByte(int) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getByte(String, byte) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getByte(int, byte) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getByte(int) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'byte' value at index 'index'.
getByte(String) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'byte' value from column with given 'name'.
getByte(int, byte) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'byte' value at index 'index'.
getByte(String, byte) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'byte' value from column with given 'name'.
getBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
 
getBytesWritten() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
 
getBytesWritten() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
 
getCacheEventExpression() - Method in class org.springframework.xd.gemfire.GemfireSourceOptionsMetadata
 
getCandidateTypes() - Method in exception org.springframework.xd.dirt.module.NoSuchModuleException
 
getCc() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getChannel() - Method in class org.springframework.xd.dirt.integration.bus.Binding
 
getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
 
getChannelName() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
 
getChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.SinkChannelNode
 
getChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.SourceChannelNode
 
getChannelType() - Method in class org.springframework.xd.dirt.stream.dsl.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'.
getCharset() - Method in class org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata
 
getCharset() - Method in class org.springframework.xd.http.HttpClientProcessorOptionsMetadata
 
getCharset() - Method in class org.springframework.xd.mail.MailSourceOptionsMetadata
 
getCharset() - Method in class org.springframework.xd.module.options.mixins.FromStringCharsetMixin
 
getCharset() - Method in class org.springframework.xd.module.options.mixins.ToStringCharsetMixin
 
getCheckpointPointer() - Method in exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
 
getCheckpointPosition() - Method in exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
 
getChildren() - Method in class org.springframework.xd.module.ModuleDescriptor
If this is a composite module, this list contains the modules that this module consists of; otherwise this list is empty.
getClassName() - Method in enum org.springframework.xd.dirt.job.StepType
 
getClassName() - Method in enum org.springframework.xd.dirt.job.TaskletType
 
getClasspath() - Method in interface org.springframework.xd.dirt.module.store.ModuleDefinitionMixin
 
getClasspath() - Method in class org.springframework.xd.module.ModuleDefinition
 
getClient() - Method in class org.springframework.xd.dirt.server.ModuleRedeployer
Return the Curator framework client.
getClient() - Method in class org.springframework.xd.dirt.zookeeper.ZooKeeperConnection
Provides access to the underlying CuratorFramework instance.
getClientId() - Method in class org.springframework.xd.dirt.modules.metadata.JmsSourceModuleOptionsMetadata
 
getClientId() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSinkOptionsMetadata
 
getClientId() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
 
getClientPort() - Method in class org.springframework.xd.dirt.zookeeper.EmbeddedZooKeeper
Returns the port that clients should use to connect to this embedded server.
getClientTimeZone() - Method in class org.springframework.xd.shell.Configuration
 
getCodec() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
getCollectionName() - Method in class org.springframework.xd.module.options.mixins.IntoMongoDbOptionMixin
 
getColumns() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
getColumns() - Method in class org.springframework.xd.jdbc.JdbcMessagePayloadTransformer
 
getColumns() - Method in class org.springframework.xd.jdbc.JdbcSinkModuleOptionsMetadata
 
getComponent(Class<T>) - Method in class org.springframework.xd.module.core.CompositeModule
 
getComponent(String, Class<T>) - Method in class org.springframework.xd.module.core.CompositeModule
 
getComponent(Class<T>) - Method in interface org.springframework.xd.module.core.Module
 
getComponent(String, Class<T>) - Method in interface org.springframework.xd.module.core.Module
 
getComponent(Class<T>) - Method in class org.springframework.xd.module.core.SimpleModule
 
getComponent(String, Class<T>) - Method in class org.springframework.xd.module.core.SimpleModule
 
getComponentType() - Method in class org.springframework.integration.x.twitter.TwitterSearchChannelAdapter
 
getComponentType() - Method in class org.springframework.integration.x.twitter.TwitterStreamChannelAdapter
 
getComponentType() - Method in class org.springframework.xd.integration.reactor.net.NetServerInboundChannelAdapter
 
getComponentType() - Method in class org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter
 
getComposedModuleDefinitions() - Method in class org.springframework.xd.module.ModuleDefinition
 
getComputedNativeOptions() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
 
getConcurrency(int) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the 'concurrency' property or the default value.
getConcurrency() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getConfiguration() - Method in class org.springframework.xd.shell.hadoop.ConfigurationModifiedEvent
 
getConfiguration() - Method in class org.springframework.xd.test.hadoop.HadoopFileSystemTestSupport
 
getConnectionProperties() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getConnectTimeout() - Method in class org.springframework.integration.x.twitter.TwitterMixin
 
getConsumerKey() - Method in class org.springframework.integration.x.twitter.TwitterMixin
 
getConsumerSecret() - Method in class org.springframework.integration.x.twitter.TwitterMixin
 
getContainer() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the container name.
getContainer() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Return the container name.
getContainer() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the container name.
getContainer() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
 
getContainerId() - Method in class org.springframework.xd.dirt.event.AbstractModuleEvent
 
getContainerId() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getContainerId() - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
Get container id.
getContainerId() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getContainerLogLocation() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getContainerPidsFromURL(URL, String, String) - Static method in class org.springframework.xd.integration.util.StreamUtils
Retrieves the container pids for a remote machine.
getContentType() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getContext() - Method in class org.springframework.xd.dirt.server.AdminServerApplication
 
getConverter(Class<T>) - Method in class org.springframework.xd.tuple.LocaleAwareStringToNumberConverterFactory
 
getConverterClass() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
 
getConverterClass() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getCorrelation() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getCount() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
getCount() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getCount() - Method in class org.springframework.xd.module.ModuleDeploymentProperties
Return the number of container instances this module should be deployed to.
getCount() - Method in class org.springframework.xd.rest.domain.metrics.RichGaugeResource
 
getCounter() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
 
getCounter() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
 
getCounter() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
 
getCounterFromName(String) - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
 
getCounterFromName(String) - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
 
getCounterFromName(String) - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
 
getCounts() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
 
getCounts(String, int, AggregateCountResolution) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository
Query function which returns the last 'n' points for a particular resolution.
getCounts(String, Interval, AggregateCountResolution) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository
Query function to allow the counts for a specific interval to be retrieved.
getCounts(String, int, DateTime, AggregateCountResolution) - Method in interface org.springframework.xd.analytics.metrics.core.AggregateCounterRepository
Queries by requesting a number of points, ending on the given date (inclusive).
getCounts(String, int, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
getCounts(String, Interval, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
getCounts(String, int, DateTime, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository
 
getCounts(String, int, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
 
getCounts(String, int, DateTime, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
 
getCounts(String, Interval, AggregateCountResolution) - Method in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
For each query, we need to convert the interval into two variations.
getCriteria() - Method in class org.springframework.xd.module.ModuleDeploymentProperties
Return the criteria expression to evaluate against container attributes to determine deployment candidates for this module.
getCron() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
 
getCustomAttributes() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
Retrieve the custom attributes for this container.
getDatabaseName() - Method in class org.springframework.xd.module.options.mixins.IntoMongoDbOptionMixin
 
getDataNodePort() - Method in class org.springframework.xd.integration.util.XdEnvironment
The hadoop data node port that is available for this environment.
getDataSource() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getDate() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
 
getDate(int) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getDate(String) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getDate(String, Date) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getDate(int, Date) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getDate(int) - Method in interface org.springframework.xd.tuple.Tuple
Read the java.util.Date value in default format at designated column index.
getDate(String) - Method in interface org.springframework.xd.tuple.Tuple
Read the java.util.Date value in default format at designated column with given name.
getDate(int, Date) - Method in interface org.springframework.xd.tuple.Tuple
Read the java.util.Date value in default format at designated column index using the supplied defaultValue if the field value is a zero length string or null.
getDate(String, Date) - Method in interface org.springframework.xd.tuple.Tuple
Read the java.util.Date value in default format at designated column with given name.
getDateFormat() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
 
getDateFormat() - Method in class org.springframework.xd.dirt.plugins.job.JobPluginMetadataResolver.JobOptionsMetadata
 
getDateFormat() - Method in class org.springframework.xd.module.options.mixins.DateFormatMixin
 
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.
getDbkind() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getDecoder() - Method in class org.springframework.xd.tcp.EncoderDecoderMixins.DecoderMixin
 
getDefaultDateFormat() - Static method in class org.springframework.xd.rest.domain.util.TimeUtils
 
getDefaultDateTimeFormat() - Static method in class org.springframework.xd.rest.domain.util.TimeUtils
 
getDefaultDurationFormat() - Static method in class org.springframework.xd.rest.domain.util.TimeUtils
 
getDefaultMetaVariable() - Method in class org.springframework.xd.dirt.server.options.ResourcePatternScanningOptionHandler
 
getDefaultTimeFormat() - Static method in class org.springframework.xd.rest.domain.util.TimeUtils
 
getDefaultTimeZone() - Static method in class org.springframework.xd.rest.domain.util.TimeUtils
 
getDefaultValue() - Method in class org.springframework.xd.module.options.ModuleOption
 
getDefaultValue() - Method in class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource.Option
 
getDefinition() - Method in class org.springframework.xd.dirt.core.BaseDefinition
Returns a String representation of the desired data flow, expressed in the XD DSL.
getDefinition() - Method in class org.springframework.xd.dirt.stream.BaseInstance
Return the underlying definition.
getDefinition() - Method in class org.springframework.xd.module.ModuleDefinition
 
getDefinition() - Method in class org.springframework.xd.rest.domain.JobDefinitionResource
 
getDefinition() - Method in class org.springframework.xd.rest.domain.StreamDefinitionResource
 
getDefinitionRepository() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
 
getDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
 
getDeleteFiles() - Method in class org.springframework.xd.module.options.mixins.BatchJobDeleteFilesOptionMixin
 
getDelimiter() - Method in class org.springframework.xd.module.options.mixins.BatchJobFieldDelimiterOptionMixin
 
getDeliveryMode() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
 
getDependents() - Method in exception org.springframework.xd.dirt.module.DependencyException
 
getDeployedModules() - Method in class org.springframework.xd.dirt.cluster.DetailedContainer
 
getDeployedModules() - Method in class org.springframework.xd.dirt.module.ModuleDeployer
 
getDeployedModules() - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Get all currently deployed modules.
getDeployedModules() - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
Get the list of deployed modules.
getDeployer() - Method in class org.springframework.xd.dirt.rest.XDController
 
getDeploymentOrderIterator() - Method in class org.springframework.xd.dirt.core.Stream
Return an iterator that indicates the order of module deployments for this stream.
getDeploymentPath(D) - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
Return the ZooKeeper path used for deployment requests for the given definition.
getDeploymentPath(JobDefinition) - Method in class org.springframework.xd.dirt.stream.JobDeployer
 
getDeploymentPath(StreamDefinition) - Method in class org.springframework.xd.dirt.stream.StreamDeployer
Return the ZooKeeper path used for deployment requests for the given definition.
getDeploymentProperties() - Method in interface org.springframework.xd.dirt.core.DeploymentUnit
Properties used to indicate deployment information for this deployment unit.
getDeploymentProperties() - Method in class org.springframework.xd.dirt.core.Job
Return the deployment properties for this job.
getDeploymentProperties() - Method in class org.springframework.xd.dirt.core.Stream
Return the deployment properties for this stream.
getDeploymentProperties() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getDeploymentProperties() - Method in class org.springframework.xd.module.core.AbstractModule
 
getDeploymentProperties() - Method in interface org.springframework.xd.module.core.Module
 
getDeploymentProperties() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getDeploymentSize() - Method in class org.springframework.xd.dirt.cluster.DetailedContainer
 
getDeploymentSize() - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
Get the number of modules deployed into the container.
getDeploymentStatus(ID) - Method in interface org.springframework.xd.dirt.core.DeploymentStatusRepository
For the given deployment unit id, return the deployment status.
getDeploymentStatus() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getDeploymentStatus(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository
 
getDeploymentStatus(String) - Method in class org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository
 
getDeploymentStatus() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getDeploymentUnitName() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Return the deployment unit name.
getDeploymentUnitName() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Return the deployment unit (Stream/Job) name.
getDescription() - Method in class org.springframework.xd.module.options.ModuleOption
 
getDescription() - Method in class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource.Option
 
getDescriptor() - Method in class org.springframework.xd.module.core.AbstractModule
 
getDescriptor() - Method in interface org.springframework.xd.module.core.Module
 
getDestination() - Method in class org.springframework.xd.dirt.modules.metadata.JmsSourceModuleOptionsMetadata
 
getDir() - Method in class org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata
 
getDirectory() - Method in class org.springframework.xd.dirt.modules.metadata.FilePollHdfsJobOptionsMetadata
 
getDirectory() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
getDispatcher() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
getDisplayableContents() - Method in class org.springframework.xd.shell.Target.Credentials
 
getDisplayName() - Method in enum org.springframework.xd.dirt.job.StepType
 
getDisplayName() - Method in enum org.springframework.xd.dirt.job.TaskletType
 
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'.
getDriverClassName() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getDriverClassName() - Method in class org.springframework.xd.jdbc.JdbcConnectionMixin
 
getDslName() - Method in class org.springframework.xd.test.fixtures.AbstractMetricSink
 
getDuration() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getDuration() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getDuration() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getDuration() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
 
getDuration() - Method in class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
getDuration() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getDuration() - Method in class org.springframework.xd.rest.domain.StepExecutionProgressInfoResource
 
getDurationMillis() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getEC2RunningInstances(String, String, String) - Static method in class org.springframework.xd.integration.util.StreamUtils
Returns a list of active instances from the specified ec2 region.
getEncoder() - Method in class org.springframework.xd.tcp.EncoderDecoderMixins.EncoderMixin
 
getEndMessage() - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerMessageHandler
 
getEndMessage() - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerOptionsMetadata
 
getEndpoint() - Method in class org.springframework.xd.dirt.integration.bus.Binding
 
getEndPos() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode
 
getErrorDescription() - Method in class org.springframework.xd.dirt.core.DeploymentUnitStatus
Return the error description for the deployment unit; may be null.
getErrorDescription() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
 
getEstimatedPercentComplete() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
 
getEstimatedPercentCompleteMessage() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
 
getExchange() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
 
getExecutionCount() - Method in class org.springframework.xd.dirt.job.JobInfo
 
getExecutionCount() - Method in class org.springframework.xd.rest.domain.JobInfoResource
 
getExecutionId() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getExecutionId() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getExitCode() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getExitStatus() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getExitStatus() - Method in class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
getExpression() - Method in class org.springframework.xd.dirt.modules.metadata.LogSinkOptionsMetadata
 
getExpression() - Method in class org.springframework.xd.dirt.modules.metadata.SplitterProcessorOptionsMetadata
 
getExpression() - Method in class org.springframework.xd.mail.MailSourceOptionsMetadata
 
getExpression() - Method in class org.springframework.xd.module.options.mixins.ExpressionOrScriptMixin
 
getExpressionString() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
 
getExpressionStringUntilCheckpoint() - Method in exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
Return the parsed expression until the last known, well formed position.
getExtensionsBasePackages() - Method in class org.springframework.xd.dirt.container.initializer.AbstractComponentScanningBeanDefinitionProvider
 
getExtensionsBasePackages() - Method in class org.springframework.xd.dirt.container.initializer.PluginContextComponentScanningExtensionsInitializer
 
getExtensionsLocations() - Method in class org.springframework.xd.dirt.container.initializer.AbstractResourceBeanDefinitionProvider
Subclasses implement this to return extensions locations (null is ok).
getExtensionsLocations() - Method in class org.springframework.xd.dirt.container.initializer.PluginContextResourceExtensionsInitializer
 
getExtensionsLocations() - Method in class org.springframework.xd.dirt.container.initializer.PluginsInitializer
 
getExtensionWithDot() - Method in class org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata
Return dot + suffix if suffix is set, or the empty string otherwise.
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.
getFieldMappingEntrySplitToken() - Method in class org.springframework.xd.analytics.ml.AbstractFieldMappingAwareDataMapper
 
getFieldName() - Method in class org.springframework.xd.analytics.metrics.metadata.FieldValueCounterSinkOptionsMetadata
 
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.domain.metrics.FieldValueCounterResource
 
getFileContentsFromHdfs(String) - Method in class org.springframework.xd.integration.util.HadoopUtils
Retrieves the file from the hdfs file system.
getFileDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
 
getFileExtension() - Method in class org.springframework.xd.dirt.modules.metadata.FilePollHdfsJobOptionsMetadata
 
getFileExtension() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
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.dirt.modules.metadata.FilePollHdfsJobOptionsMetadata
 
getFileName() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
 
getFileName() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
getFileStatus(String) - Method in class org.springframework.xd.integration.util.HadoopUtils
Retrieves the file status for the file path specified.
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
 
getFilterLevel() - Method in class org.springframework.integration.x.twitter.TwitterStreamOptionsMetadata
 
getFinished() - Method in class org.springframework.xd.rest.domain.StepExecutionProgressInfoResource
 
getFixedDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
 
getFixedDelay() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
 
getFixedDelay() - Method in class org.springframework.xd.mail.MailSourceOptionsMetadata
 
getFixedDelay() - Method in class org.springframework.xd.tcp.TcpClientSourceOptionsMetadata
 
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'.
getFolder() - Method in class org.springframework.xd.mail.MailSourceOptionsMetadata
 
getFollow() - Method in class org.springframework.integration.x.twitter.TwitterStreamOptionsMetadata
 
getFormat() - Method in class org.springframework.xd.dirt.modules.metadata.TimeSourceOptionsMetadata
 
getFraming() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
getFrom() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getFromEnd() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
 
getFsUri() - Method in class org.springframework.xd.module.options.mixins.HadoopConfigurationMixin
 
getGeocode() - Method in class org.springframework.integration.x.twitter.TwitterSearchOptionsMetadata
 
getGroup() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return name of deployable unit this module instance belongs to (such as a stream or job).
getGroup() - Method in class org.springframework.xd.module.ModuleDescriptor
Return name of deployable unit this module instance belongs to (such as a stream or job).
getGroup() - Method in class org.springframework.xd.module.ModuleDescriptor.Key
Return the name of the stream.
getGroups() - Method in class org.springframework.xd.dirt.cluster.Container
Return the set of groups this container belongs to.
getGroups() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
getGroups() - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
Get container group(s).
getHADOOP_DISTRO() - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
 
getHADOOP_DISTRO() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
 
getHadoopConfiguration() - Method in class org.springframework.xd.shell.hadoop.ConfigurationAware
Gets the hadoop configuration.
getHeaderBorder(Map<Integer, TableHeader>) - Static method in class org.springframework.xd.shell.util.UiUtils
Renders the Table header border, based on the map of provided headers.
getHeaders() - Method in class org.springframework.xd.shell.util.Table
 
getHost() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
getHost() - Method in class org.springframework.xd.dirt.modules.metadata.FtpHdfsJobOptionsMetadata
 
getHost() - Static method in class org.springframework.xd.dirt.util.RuntimeUtils
Return the name of the host for the machine running this process.
getHost() - Method in class org.springframework.xd.gemfire.GemfireCQSourceOptionsMetadata
 
getHost() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
 
getHost() - Method in class org.springframework.xd.gemfire.GemfireSourceOptionsMetadata
 
getHost() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
getHost() - Method in class org.springframework.xd.mail.MailServerMixin
 
getHost() - Method in class org.springframework.xd.module.options.mixins.IntoMongoDbOptionMixin
 
getHost() - Method in class org.springframework.xd.splunk.SplunkSinkOptionsMetadata
 
getHost() - Method in class org.springframework.xd.tcp.ClientTcpConnectionFactoryOptionsMetadataMixin
 
getHostname() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getHttp(String) - Method in class org.springframework.xd.shell.command.HttpCommands
 
getHttpMethod() - Method in class org.springframework.xd.http.HttpClientProcessorOptionsMetadata
 
getHttpPort() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getId() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
getId() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getId() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
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.
getIdField() - Method in class org.springframework.xd.dirt.modules.metadata.HdfsMongodbJobOptionsMetadata
 
getIdGenerator() - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport
 
getIdGenerator() - Static method in class org.springframework.xd.tuple.DefaultTuple
 
getIndex() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return position in stream/job definition relative to the other modules in the definition.
getIndex() - Method in class org.springframework.xd.module.ModuleDescriptor
Return position in stream/job definition relative to the other modules in the definition.
getIndexOfLabel(String) - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getInitializeDatabase() - Method in class org.springframework.xd.jdbc.AbstractImportToJdbcOptionsMetadata
 
getInitializerScript() - Method in class org.springframework.xd.jdbc.AbstractImportToJdbcOptionsMetadata
 
getInitialSize() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getInitSQL() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getInputChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractJobPlugin
 
getInputChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
getInputChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractStreamPlugin
 
getInserts() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
 
getInstanceId() - Method in class org.springframework.xd.dirt.job.JobInstanceInfo
 
getInstanceId() - Method in class org.springframework.xd.rest.domain.JobInstanceInfoResource
 
getInt(String) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getInt(int) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getInt(String, int) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getInt(int, int) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getInt(int) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'int' value at index 'index'.
getInt(String) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'int' value from column with given 'name'.
getInt(int, int) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'int' value at index 'index'.
getInt(String, int) - Method in interface org.springframework.xd.tuple.Tuple
Read the 'int' value from column with given 'name'.
getInterval() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
 
getIp() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
getIpAddress() - Static method in class org.springframework.xd.dirt.util.RuntimeUtils
Return a non loopback IPv4 address for the machine running this process.
getJavaTypeForContentType(MimeType, ClassLoader) - Static method in class org.springframework.xd.dirt.integration.bus.converter.MessageConverterUtils
Map the contentType to a target class.
getJdbcInterceptors() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getJdbcTemplate() - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
 
getJdbcTemplate() - Method in class org.springframework.xd.test.fixtures.JdbcSink
 
getJmsHost() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getJmsPort() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getJmxPort() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getJob(String) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Get simple batch job representation for the given job name.
getJob(String) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobService
 
getJobExecution() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getJobExecution() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getJobExecutionId() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getJobExecutionId() - Method in class org.springframework.xd.rest.domain.StepExecutionInfoResource
 
getJobExecutionInfo(long) - Method in class org.springframework.xd.dirt.rest.BatchJobExecutionsController
 
getJobExecutions() - Method in class org.springframework.xd.dirt.job.JobInstanceInfo
 
getJobExecutions() - Method in class org.springframework.xd.rest.domain.JobInstanceInfoResource
 
getJobId() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getJobId() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getJobInstance() - Method in class org.springframework.xd.dirt.job.JobInstanceInfo
 
getJobInstance(long) - Method in class org.springframework.xd.dirt.rest.BatchJobInstancesController
Return job instance info by the given instance id.
getJobInstanceId() - Method in class org.springframework.xd.dirt.job.JobInfo
 
getJobInstanceId() - Method in class org.springframework.xd.rest.domain.JobInfoResource
 
getJobModuleDescriptor() - Method in class org.springframework.xd.dirt.core.Job
Return the job module descriptor.
getJobName() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the job name.
getJobName() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getJobName() - Method in class org.springframework.xd.rest.domain.JobInstanceInfoResource
 
getJobNames() - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Get all the deployed job names.
getJobParameters() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getJobParameters() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getJobParameters(Properties) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
If ExpandedJobParametersConverter.makeParametersUnique is true the JobParameter with key ExpandedJobParametersConverter.UNIQUE_JOB_PARAMETER_KEY will be added with a random number value.
getJobParameters() - Method in class org.springframework.xd.dirt.plugins.job.JobParametersBean
Please ensure that JobParametersBean.afterPropertiesSet() is called before obtaining the JobParameters.
getJobParameters() - Method in class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
getJobParameters() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getJobParametersAsString(JobParameters) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
This method will convert JobParameters to a JSON String.
getJobParametersAsString(JobParameters, boolean) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
This method will convert JobParameters to a JSON String.
getJobParametersForFile(File) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
Return JobParameters for the passed-in File.
getJobParametersForJsonString(String) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
Converts a String-based JSON map to JobParameters.
getJobParametersForMap(Map<?, ?>) - Method in class org.springframework.xd.dirt.plugins.job.ExpandedJobParametersConverter
Will convert the provided Map into JobParameters.
getJobParametersString() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getJobParametersString() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getJobStepNames(String) - Method in class org.springframework.xd.dirt.plugins.job.DistributedJobLocator
Get all the steps' names of a given job name.
getJvmTimeZone() - Static method in class org.springframework.xd.rest.domain.util.TimeUtils
 
getKey() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
 
getKeyExpression() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
 
getKind() - Method in class org.springframework.xd.dirt.stream.dsl.Token
 
getKind() - Method in enum org.springframework.xd.dirt.stream.dsl.XDDSLMessages
 
getKryoInstance() - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.FileCodec
 
getKryoInstance() - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.PojoCodec
 
getKryoInstance() - Method in class org.springframework.xd.dirt.integration.bus.serializer.kryo.TupleCodec
 
getLabel() - Method in class org.springframework.xd.module.ModuleDescriptor.Key
Return the module label.
getLabelName() - Method in class org.springframework.xd.dirt.stream.dsl.LabelNode
 
getLabelName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
Return the label for this module, that is: an explicit label if provided the module name if no label was provided
getLanguage() - Method in class org.springframework.integration.x.twitter.AbstractTwitterInboundChannelAdapter
 
getLanguage() - Method in class org.springframework.integration.x.twitter.TwitterMixin
 
getLastExecutionInfo() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getLength() - Method in enum org.springframework.xd.dirt.stream.dsl.TokenKind
 
getLengthFieldLength() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
getLevel() - Method in class org.springframework.xd.dirt.modules.metadata.LogSinkOptionsMetadata
 
getListeners() - Method in class org.springframework.xd.dirt.plugins.job.JobPluginMetadataResolver.JobOptionsMetadata
 
getLocalContainerPids(String) - Static method in class org.springframework.xd.integration.util.StreamUtils
Retrieves the container pids on the local machine.
getLocalTime(Date) - Method in class org.springframework.xd.shell.Configuration
Returns a String formatted Date/Time using the configured Configuration.clientTimeZone.
getLocalTime(Date, TimeZone) - Static method in class org.springframework.xd.shell.util.CommonUtils
Return a date/time formatted String for the provided Date and TimeZone.
getLocations() - Method in class org.springframework.integration.x.twitter.TwitterStreamOptionsMetadata
 
getLocations() - Method in class org.springframework.xd.dirt.container.initializer.AbstractResourceBeanDefinitionProvider
This will prepend "classpath*:" to each location if no Resource prefix provided.
getLocations() - Method in class org.springframework.xd.dirt.container.initializer.PluginsInitializer
 
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'.
getManagementPort() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
getMappedRequestHeaders() - Method in class org.springframework.xd.module.options.mixins.MappedRequestHeadersMixin
 
getMappedResponseHeaders() - Method in class org.springframework.xd.module.options.mixins.MappedResponseHeadersMixin
 
getMax() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
getMax() - Method in class org.springframework.xd.rest.domain.metrics.RichGaugeResource
 
getMaxActive() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getMaxAge() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getMaxAttempts(int) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the 'maxAttempts' property or the default value.
getMaxConcurrency(int) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the 'maxConcurrency' property or the default value.
getMaxConcurrency() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getMaxIdle() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getMaxSendDuration() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getMaxWait() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getMaxWidth() - Method in class org.springframework.xd.shell.util.TableHeader
 
getMbean() - Method in class org.springframework.xd.integration.util.jmxresult.JMXRequest
 
getMeanErrorRate() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getMeanErrorRatio() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getMeanSendDuration() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getMeanSendRate() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getMessage() - Method in exception org.springframework.xd.dirt.module.NoSuchModuleException
 
getMessage() - Method in exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
 
getMessage() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
 
getMessage() - Method in exception org.springframework.xd.rest.client.impl.SpringXDException
 
getMessageCode() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
 
getMessageRates() - Method in class org.springframework.xd.dirt.cluster.DetailedContainer
 
getMessageRates() - Method in class org.springframework.xd.rest.domain.DetailedContainerResource
 
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.domain.metrics.RichGaugeResource
 
getMinEvictableIdleTimeMillis() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getMinIdle() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getMinSendDuration() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getMode() - Method in class org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata
 
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, String, int) - Method in class org.springframework.xd.dirt.test.SingleNodeIntegrationTestSupport
Get a deployed module instance.
getModuleChannel() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getModuleDefinition() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
 
getModuleDefinition() - Method in class org.springframework.xd.module.ModuleDescriptor
Return the ModuleDefinition for this module.
getModuleDefinitionRepository() - Method in class org.springframework.xd.dirt.stream.CompositeModuleDefinitionService
 
getModuleDefinitions() - Method in class org.springframework.xd.dirt.core.BaseDefinition
 
getModuleDescriptor(String) - Method in class org.springframework.xd.dirt.core.Stream
Return the module descriptor for the provided label and type.
getModuleDescriptors() - Method in interface org.springframework.xd.dirt.core.DeploymentUnit
List of modules that comprise this deployment unit.
getModuleDescriptors() - Method in class org.springframework.xd.dirt.core.Job
List of modules that comprise this deployment unit.
getModuleDescriptors() - Method in class org.springframework.xd.dirt.core.Stream
Return the ordered list of modules for this stream as a List.
getModuleDescriptorsAsDeque() - Method in class org.springframework.xd.dirt.core.Stream
Return the ordered list of modules for this stream.
getModuleId() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getModuleInstanceAsString() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the string representation of the module instance that has the following dot limited values.
getModuleInstanceAsString() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Return the string representation of the module instance that has the following dot limited values.
getModuleInstanceAsString() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the string representation of the module instance that has the following dot limited values.
getModuleLabel() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the module label.
getModuleLabel() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Return the module label.
getModuleLabel() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Return the module label.
getModuleLabel() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the module label.
getModuleLabel() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return symbolic name of a module.
getModuleLabel() - Method in class org.springframework.xd.module.ModuleDescriptor
Return symbolic name of a module.
getModuleName() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getModuleName() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return name of module.
getModuleName() - Method in class org.springframework.xd.module.ModuleDescriptor
Return name of module.
getModuleNodes() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getModuleOptions() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getModuleOptions() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getModuleOptionsMetadata() - Method in interface org.springframework.xd.dirt.module.store.ModuleDefinitionMixin
 
getModules() - Method in class org.springframework.xd.integration.util.jmxresult.JMXValue
 
getModuleSequence() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the module sequence.
getModuleSequence() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Return the module sequence.
getModuleSequence() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Return the module sequence.
getModuleSequence() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the module sequence.
getModuleSequence() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
 
getModuleSequenceAsString() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the module sequence as string.
getModuleSequenceAsString() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Return the module sequence as string.
getModuleSequenceAsString() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the module sequence as string.
getModuleSequenceAsString() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
 
getModulesForDeploymentUnit(Collection<ModuleDeploymentRequestsPath>, String) - Static method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Return all the modules for a given deployment unit name.
getModuleType() - Method in class org.springframework.xd.dirt.core.JobDeploymentsPath
Return the module type.
getModuleType() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentRequestsPath
Return the module type.
getModuleType() - Method in class org.springframework.xd.dirt.core.ModuleDeploymentsPath
Return the module type.
getModuleType() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the module type.
getModuleType() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getModuleType() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getMongoDbFactory() - Method in class org.springframework.xd.integration.util.XdEnvironment
The mongo db factory to be used for the tests.
getMongoHost() - Method in class org.springframework.xd.integration.util.XdEnvironment
Retrieves the host where the mongo server is running.
getMongoPort() - Method in class org.springframework.xd.integration.util.XdEnvironment
Retrieves the port that the mongo server is monitoring.
getName() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
 
getName() - Method in class org.springframework.xd.analytics.metrics.core.Counter
 
getName() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
 
getName() - Method in class org.springframework.xd.analytics.metrics.core.Gauge
 
getName() - Method in interface org.springframework.xd.analytics.metrics.core.Metric
Return the name of the metric.
getName() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
getName() - Method in class org.springframework.xd.analytics.metrics.metadata.MetricNameMixin
 
getName() - Method in class org.springframework.xd.dirt.cluster.Container
Return the container name.
getName() - Method in class org.springframework.xd.dirt.core.BaseDefinition
Returns a unique name given to that stream definition.
getName() - Method in interface org.springframework.xd.dirt.core.DeploymentUnit
The name for this deployment unit, typically used as a unique identifier for this deployment unit type.
getName() - Method in class org.springframework.xd.dirt.core.Job
Return the name of this job.
getName() - Method in class org.springframework.xd.dirt.core.Stream
Return the name of this stream.
getName() - Method in class org.springframework.xd.dirt.integration.bus.Binding
 
getName() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getName() - Method in class org.springframework.xd.dirt.job.JobInfo
 
getName() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getName() - Method in exception org.springframework.xd.dirt.module.DependencyException
 
getName() - Method in exception org.springframework.xd.dirt.module.ModuleAlreadyExistsException
 
getName() - Method in exception org.springframework.xd.dirt.module.NoSuchModuleException
 
getName() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getName() - Method in class org.springframework.xd.dirt.modules.metadata.FileSinkOptionsMetadata
 
getName() - Method in class org.springframework.xd.dirt.modules.metadata.LogSinkOptionsMetadata
 
getName() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
 
getName() - Method in class org.springframework.xd.dirt.stream.dsl.ArgumentNode
 
getName() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
 
getName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getName() - Method in class org.springframework.xd.module.core.AbstractModule
 
getName() - Method in interface org.springframework.xd.module.core.Module
 
getName() - Method in class org.springframework.xd.module.ModuleDefinition
 
getName() - Method in class org.springframework.xd.module.options.ModuleOption
 
getName() - Method in class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource.Option
 
getName() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getName() - Method in class org.springframework.xd.rest.domain.JobInfoResource
 
getName() - Method in class org.springframework.xd.rest.domain.ModuleDefinitionResource
 
getName() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getName() - Method in class org.springframework.xd.rest.domain.NamedResource
Return the name of the represented entity.
getName() - Method in class org.springframework.xd.shell.util.TableHeader
 
getName() - Method in class org.springframework.xd.test.fixtures.AbstractMetricSink
 
getNameNode() - Method in class org.springframework.xd.integration.util.XdEnvironment
The hadoop name node that is available for this environment.
getNames() - Method in class org.springframework.xd.module.options.mixins.BatchJobFieldNamesOptionMixin
 
getNumberFormat() - Method in class org.springframework.xd.dirt.plugins.job.JobPluginMetadataResolver.JobOptionsMetadata
 
getObject() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
 
getObject() - Method in class org.springframework.xd.hadoop.fs.DatasetDefinitionFactoryBean
 
getObject() - Method in class org.springframework.xd.integration.hadoop.config.DatasetWritingMessageHandlerFactoryBean
 
getObject() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
 
getObject() - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterFactoryBean
 
getObject() - Method in class org.springframework.xd.integration.reactor.net.NetServerSpecFactoryBean
 
getObject() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReaderFactory
 
getObjectName(Object, String) - Method in class org.springframework.xd.dirt.module.jmx.ModuleObjectNamingStrategy
 
getObjectType() - Method in class org.springframework.xd.dirt.integration.rabbit.RabbitConnectionFactoryBean
 
getObjectType() - Method in class org.springframework.xd.dirt.jdbc.util.DatabaseVendorFriendlyNameFactoryBean
 
getObjectType() - Method in class org.springframework.xd.hadoop.fs.DatasetDefinitionFactoryBean
 
getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.DatasetWritingMessageHandlerFactoryBean
 
getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean
 
getObjectType() - Method in class org.springframework.xd.integration.hadoop.config.StoreWriterFactoryBean
 
getObjectType() - Method in class org.springframework.xd.integration.reactor.net.NetServerSpecFactoryBean
 
getObjectType() - Method in class org.springframework.xd.jdbc.NamedColumnJdbcItemReaderFactory
 
getOffendingName() - Method in exception org.springframework.xd.dirt.analytics.NoSuchMetricException
Return the name that was not found.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.AlreadyDeployedException
Return the name of the already deployed definition.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.DefinitionAlreadyExistsException
Return the definition name that was in conflict.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.NoSuchDefinitionException
Return the name of the definition that could not be found.
getOffendingName() - Method in exception org.springframework.xd.dirt.stream.NotDeployedException
Return the name of the definition that could not be found.
getOptions() - Method in class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryGaugeRepository
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository
 
getOrCreate(String) - Method in class org.springframework.xd.analytics.metrics.memory.InMemoryRichGaugeRepository
 
getOrder() - Method in class org.springframework.xd.dirt.container.initializer.AbstractComponentScanningBeanDefinitionProvider
 
getOrder() - Method in class org.springframework.xd.dirt.container.initializer.PluginContextComponentScanningExtensionsInitializer
 
getOrder() - Method in class org.springframework.xd.dirt.container.initializer.PluginContextResourceExtensionsInitializer
 
getOrder() - Method in class org.springframework.xd.dirt.container.initializer.PluginsInitializer
 
getOrder() - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
getOrder() - Method in class org.springframework.xd.dirt.plugins.AbstractPlugin
 
getOrder() - Method in class org.springframework.xd.dirt.plugins.job.JobPlugin
 
getOrder() - Method in class org.springframework.xd.dirt.plugins.stream.StreamPlugin
 
getOutputChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractJobPlugin
 
getOutputChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractMessageBusBinderPlugin
 
getOutputChannelName(Module) - Method in class org.springframework.xd.dirt.plugins.AbstractStreamPlugin
 
getOwner() - Method in class org.springframework.xd.splunk.SplunkSinkOptionsMetadata
 
getPagedData(Pageable, List<T>) - Method in class org.springframework.xd.dirt.util.PagingUtility
Get the paged data of the given list.
getParameters() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return parameters for module.
getParameters() - Method in class org.springframework.xd.module.ModuleDescriptor
Return parameters for module.
getPartitionCount() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
The number of partitions for this module.
getPartitionIndex() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
The partition index that this consumer supports.
getPartitionKeyExpression() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
The expression to determine the partition key, evaluated against the message as the root object.
getPartitionKeyExtractorClass() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
A class name for extracting partition keys from messages.
getPartitionResultsTimeout() - Method in class org.springframework.xd.dirt.modules.metadata.FtpHdfsJobOptionsMetadata
 
getPartitionSelectorClass() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
A class name for calculating a partition from a key.
getPartitionSelectorExpression() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
The expression evaluated against the partition key to determine the partition to which the message will be sent.
getPassword() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getPassword() - Method in class org.springframework.xd.dirt.modules.metadata.FtpHdfsJobOptionsMetadata
 
getPassword() - Method in class org.springframework.xd.dirt.modules.metadata.MqttConnectionMixin
 
getPassword() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitConnectionMixin
 
getPassword() - Method in class org.springframework.xd.jdbc.JdbcConnectionMixin
 
getPassword() - Method in class org.springframework.xd.mail.MailServerMixin
 
getPassword() - Method in class org.springframework.xd.module.options.types.Password
 
getPassword() - Method in class org.springframework.xd.shell.Target.Credentials
 
getPassword() - Method in class org.springframework.xd.splunk.SplunkSinkOptionsMetadata
 
getPayload() - Method in class org.springframework.xd.dirt.modules.metadata.TriggerSourceOptionsMetadata
 
getPercentageComplete() - Method in class org.springframework.xd.rest.domain.StepExecutionProgressInfoResource
 
getPhase() - Method in class org.springframework.xd.dirt.zookeeper.EmbeddedZooKeeper
getPhase() - Method in class org.springframework.xd.dirt.zookeeper.ZooKeeperConnection
getPhase() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
 
getPhase() - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
getPid() - Method in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
getPid() - Static method in class org.springframework.xd.dirt.util.RuntimeUtils
Return the process id for this process.
getPort() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getPort() - Method in class org.springframework.xd.dirt.modules.metadata.FtpHdfsJobOptionsMetadata
 
getPort() - Method in class org.springframework.xd.dirt.modules.metadata.HttpSourceOptionsMetadata
 
getPORT() - Method in class org.springframework.xd.dirt.server.options.AdminOptions
 
getPORT() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
 
getPort() - Method in class org.springframework.xd.gemfire.GemfireCQSourceOptionsMetadata
 
getPort() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
 
getPort() - Method in class org.springframework.xd.gemfire.GemfireSourceOptionsMetadata
 
getPort() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
getPort() - Method in class org.springframework.xd.mail.MailServerMixin
 
getPort() - Method in class org.springframework.xd.module.options.mixins.IntoMongoDbOptionMixin
 
getPort() - Method in class org.springframework.xd.splunk.SplunkSinkOptionsMetadata
 
getPort() - Method in class org.springframework.xd.tcp.ClientTcpConnectionFactoryOptionsMetadataMixin
 
getPort() - Method in class org.springframework.xd.tcp.ServerTcpConnectionFactoryOptionsMetadataMixin
 
getPosition() - Method in exception org.springframework.xd.dirt.stream.dsl.StreamDefinitionException
 
getPrefetch() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getPrefix() - Method in class org.springframework.xd.store.AbstractRedisRepository
 
getPrivateKey(String) - Static method in class org.springframework.xd.integration.util.ConfigUtil
Retrieves the private key from a file, so we can execute commands on the container.
getPrivateKey() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getPrompt() - Method in class org.springframework.xd.shell.XDShellPromptProvider
 
getProperties() - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the underlying properties object.
getProperties() - Method in class org.springframework.xd.module.core.CompositeModule
 
getProperties() - Method in interface org.springframework.xd.module.core.Module
 
getProperties() - Method in class org.springframework.xd.module.core.SimpleModule
 
getPropertiesAccessor() - Method in class org.springframework.xd.dirt.integration.bus.Binding
 
getPropertiesFromArtifact() - Static method in class org.springframework.xd.integration.util.ConfigUtil
This method retrieves the information from the artifact and returns it as Properties.
getProperty(String) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the property for the key, or null if it doesn't exist.
getProperty(String, String) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the property for the key, or the default value if the property doesn't exist.
getProperty(String, boolean) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the property for the key, or the default value if the property doesn't exist.
getProperty(String, int) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the property for the key, or the default value if the property doesn't exist.
getProperty(String, long) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the property for the key, or the default value if the property doesn't exist.
getProperty(String, double) - Method in class org.springframework.xd.dirt.integration.bus.AbstractBusPropertiesAccessor
Return the property for the key, or the default value if the property doesn't exist.
getProperty(String) - Method in class org.springframework.xd.dirt.server.options.BeanPropertiesPropertySource
 
getProperty(String) - Method in class org.springframework.xd.shell.hadoop.ConfigurationCommands
 
getPropertyNames() - Method in class org.springframework.xd.dirt.server.options.BeanPropertiesPropertySource
 
getProtocol() - Method in class org.springframework.xd.mail.MailSourceOptionsMetadata
 
getProvider() - Method in class org.springframework.xd.dirt.modules.metadata.JmsSourceModuleOptionsMetadata
 
getProviderName() - Method in class org.springframework.xd.shell.XDShellBannerProvider
 
getProviderName() - Method in class org.springframework.xd.shell.XDShellPromptProvider
 
getQos() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSinkOptionsMetadata
 
getQuery() - Method in class org.springframework.integration.x.twitter.TwitterSearchOptionsMetadata
 
getQuery() - Method in class org.springframework.xd.gemfire.GemfireCQSourceOptionsMetadata
 
getQueues() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getRabbitConnectionFactory() - Method in class org.springframework.xd.integration.util.XdEnvironment
 
getRabbitMQHost() - Method in class org.springframework.xd.integration.util.XdEnvironment
Default value is the same as the admin server host.
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).
getReadTimeout() - Method in class org.springframework.integration.x.twitter.TwitterMixin
 
getReceiveCount() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getReceivedBytes() - Method in class org.springframework.xd.test.fixtures.TcpSink
Return the bytes received by the sink
getReceiveErrorCount() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getRegionName() - Method in class org.springframework.xd.gemfire.GemfireServerSinkModuleOptionsMetadata
 
getRegionName() - Method in class org.springframework.xd.gemfire.GemfireSourceOptionsMetadata
 
getRelease() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getRemoveAbandonedTimeout() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getReOpen() - Method in class org.springframework.xd.dirt.modules.metadata.TailSourceOptionsMetadata
 
getReplyTimeout() - Method in class org.springframework.xd.http.HttpClientProcessorOptionsMetadata
 
getReplyTo() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getRequest() - Method in class org.springframework.xd.integration.util.jmxresult.JMXChannelResult
 
getRequest() - Method in class org.springframework.xd.integration.util.jmxresult.JMXResult
 
getRequest() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getResolution() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
 
getResource() - Method in interface org.springframework.xd.dirt.module.store.ModuleDefinitionMixin
 
getResource() - Method in class org.springframework.xd.module.ModuleDefinition
 
getResource(String) - Method in class org.springframework.xd.module.support.ParentLastURLClassLoader
 
getResource() - Method in class org.springframework.xd.test.AbstractExternalResourceTestSupport
 
getResources() - Method in class org.springframework.xd.module.options.mixins.BatchJobResourcesOptionMixin
 
getResources(String) - Method in class org.springframework.xd.module.support.ParentLastURLClassLoader
 
getRestartable() - Method in class org.springframework.xd.module.options.mixins.BatchJobRestartableOptionMixin
 
getResultType() - Method in class org.springframework.integration.x.twitter.TwitterSearchOptionsMetadata
 
getRetryPolicy() - Method in class org.springframework.xd.dirt.zookeeper.ZooKeeperConnection
Return the Curator retry policy.
getRollover() - Method in class org.springframework.xd.dirt.modules.metadata.FilePollHdfsJobOptionsMetadata
 
getRollover() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
getRolloverThresholdInBytes() - Method in class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter
 
getRolloverThresholdInBytes() - Method in class org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter
 
getRolloverThresholdInBytes() - Method in class org.springframework.xd.hadoop.fs.AbstractHdfsWriter
 
getRolloverThresholdInBytes() - Method in class org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory
 
getRoutingKey() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSinkOptionsMetadata
 
getRows() - Method in class org.springframework.xd.shell.util.Table
 
getRuntimeModules(URL) - Static method in class org.springframework.xd.integration.util.StreamUtils
Return a list of container id's where the module is deployed
getSampleUnit() - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerMessageHandler
 
getSampleUnit() - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerOptionsMetadata
 
getScript() - Method in class org.springframework.xd.module.options.mixins.ExpressionOrScriptMixin
 
getSendCount() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getSendErrorCount() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getSequence() - Method in class org.springframework.xd.module.RuntimeModuleDeploymentProperties
Get the module sequence.
getSequenceAsString() - Method in class org.springframework.xd.module.RuntimeModuleDeploymentProperties
Get the module sequence as string.
getServerProperties() - Method in class org.springframework.xd.batch.hsqldb.server.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'.
getSingleObject(String) - Method in class org.springframework.xd.test.fixtures.HdfsMongoDbJob
Returns a single object from the collection.
getSinkChannelName() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return name of sink channel, if defined by the stream/job definition.
getSinkChannelName() - Method in class org.springframework.xd.module.ModuleDescriptor
Return name of sink channel, if defined by the stream/job definition.
getSinkChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getSocketTimeout() - Method in class org.springframework.xd.tcp.AbstractTcpConnectionFactoryOptionsMetadata
 
getSource() - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
getSourceChannelName() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return name of source channel, if defined by the stream/job definition.
getSourceChannelName() - Method in class org.springframework.xd.module.ModuleDescriptor
Return name of source channel, if defined by the stream/job definition.
getSourceChannelNode() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getSpecificTargetClasses() - Method in class org.springframework.xd.integration.hadoop.partition.MessagePartitionKeyPropertyAccessor
 
getSpecificTargetClasses() - Method in class org.springframework.xd.tuple.spel.TuplePropertyAccessor
 
getSpringXDOperations() - Method in class org.springframework.xd.shell.XDShell
 
getSql() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
getSslPropertiesLocation() - Method in class org.springframework.xd.dirt.modules.metadata.HttpSourceOptionsMetadata
 
getSslPropertiesLocation() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitConnectionMixin
 
getStackTrace(Throwable) - Static method in class org.springframework.xd.dirt.zookeeper.ZooKeeperUtils
Return the full stack trace for a Throwable.
getStandardDeviationSendDuration() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getStartDate() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getStartDate() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getStartDate() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getStartDate() - Method in class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
getStartDate() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getStartedAt() - Method in class org.springframework.xd.dirt.stream.BaseInstance
 
getStartMessage() - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerMessageHandler
 
getStartMessage() - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerOptionsMetadata
 
getStartPos() - Method in class org.springframework.xd.dirt.stream.dsl.AstNode
 
getStartTime() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getStartTime() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getStartTime() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getStartTime() - Method in class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
getStartTime() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getState() - Method in class org.springframework.xd.dirt.core.DeploymentUnitStatus
Return the state of the deployment unit.
getState() - Method in class org.springframework.xd.dirt.server.ModuleDeploymentStatus
 
getStatus() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getStatus() - Method in class org.springframework.xd.dirt.stream.BaseInstance
 
getStatus() - Method in class org.springframework.xd.integration.util.jmxresult.JMXChannelResult
 
getStatus() - Method in class org.springframework.xd.integration.util.jmxresult.JMXResult
 
getStatus() - Method in class org.springframework.xd.rest.domain.DeployableResource
Return status of the underlying deployment unit, or null if unknown.
getStatus() - Method in class org.springframework.xd.shell.Target
Return the target status, which is either Success or Error.
getStepExecution() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getStepExecution() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
 
getStepExecution() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
 
getStepExecution() - Method in class org.springframework.xd.rest.domain.StepExecutionInfoResource
 
getStepExecution() - Method in class org.springframework.xd.rest.domain.StepExecutionProgressInfoResource
 
getStepExecutionCount() - Method in class org.springframework.xd.dirt.job.DetailedJobInfo
 
getStepExecutionCount() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getStepExecutionCount() - Method in class org.springframework.xd.rest.domain.DetailedJobInfoResource
 
getStepExecutionCount() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getStepExecutionHistory() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
 
getStepExecutionHistory() - Method in class org.springframework.xd.rest.domain.StepExecutionProgressInfoResource
 
getStepExecutionId() - Method in class org.springframework.xd.dirt.job.StepExecutionProgressInfo
 
getStepType() - Method in class org.springframework.xd.dirt.job.StepExecutionInfo
 
getStepType() - Method in class org.springframework.xd.rest.domain.StepExecutionInfoResource
 
getStore() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getStreamData() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getStreamName() - Method in class org.springframework.xd.dirt.core.StreamDeploymentsPath
Return the stream name.
getStreamName() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getStreamText() - Method in class org.springframework.xd.dirt.stream.dsl.StreamNode
 
getString(String) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getString(int) - Method in class org.springframework.xd.tuple.DefaultTuple
 
getString(String) - Method in interface org.springframework.xd.tuple.Tuple
Read the String value given the field 'name'.
getString(int) - Method in interface org.springframework.xd.tuple.Tuple
Read the String value given the index position
getStringRepresentation() - Method in enum org.springframework.xd.dirt.stream.dsl.ChannelType
 
getSubject() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getSubscriptionName() - Method in class org.springframework.xd.dirt.modules.metadata.JmsSourceModuleOptionsMetadata
 
getSuspectTimeout() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getTableName() - Method in class org.springframework.xd.jdbc.AbstractImportToJdbcOptionsMetadata
 
getTableName() - Method in class org.springframework.xd.jdbc.JdbcHdfsOptionsMetadata
 
getTarget() - Method in class org.springframework.xd.shell.Configuration
Return the Target which encapsulates not only the Target URI but also success/error messages + status.
getTargetCredentials() - Method in class org.springframework.xd.shell.Target
Returns the target credentials
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.
getTcpPort() - Method in class org.springframework.xd.splunk.SplunkSinkOptionsMetadata
 
getTimeBetweenEvictionRunsMillis() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getTimeField() - Method in class org.springframework.xd.analytics.metrics.metadata.AggregateCounterSinkOptionsMetadata
 
getTimeout() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getTimeSinceLastSend() - Method in class org.springframework.xd.integration.util.jmxresult.Module
 
getTimestamp() - Method in class org.springframework.xd.integration.util.jmxresult.JMXChannelResult
 
getTimestamp() - Method in class org.springframework.xd.integration.util.jmxresult.JMXResult
 
getTimestamp() - Method in class org.springframework.xd.tuple.DefaultTuple
 
getTimestamp() - Method in interface org.springframework.xd.tuple.Tuple
Get the creation timestamp of this tuple, not included in comparisons for equality
getTimeZone() - Method in class org.springframework.xd.dirt.job.JobExecutionInfo
 
getTimeZone() - Method in class org.springframework.xd.rest.domain.JobExecutionInfoResource
 
getTimeZoneNameWithOffset(TimeZone) - Static method in class org.springframework.xd.shell.util.CommonUtils
Returns the timezone name as well as the UTC offset.
getTo() - Method in class org.springframework.xd.mail.MailSinkOptionsMetadata
 
getTokenChars() - Method in enum org.springframework.xd.dirt.stream.dsl.TokenKind
 
getTokenPointer() - Method in exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
 
getTokens() - Method in exception org.springframework.xd.dirt.stream.dsl.CheckpointedStreamDefinitionException
 
getTopic() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSinkOptionsMetadata
 
getTopics() - Method in class org.springframework.xd.dirt.modules.metadata.MqttSourceOptionsMetadata
 
getTotal() - Method in class org.springframework.xd.analytics.metrics.core.AggregateCount
 
getTrack() - Method in class org.springframework.integration.x.twitter.TwitterStreamOptionsMetadata
 
getTransport() - Method in class org.springframework.xd.integration.reactor.net.NetServerSourceOptionsMetadata
 
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
getTwitterAccessToken() - Method in class org.springframework.xd.integration.util.XdEnvironment
The Twitter Access Token
getTwitterAccessTokenSecret() - Method in class org.springframework.xd.integration.util.XdEnvironment
The Twitter Access Token Secret
getTwitterConsumerKey() - Method in class org.springframework.xd.integration.util.XdEnvironment
The twitter consumer key
getTwitterConsumerSecretKey() - Method in class org.springframework.xd.integration.util.XdEnvironment
The twitter consumer secret key
getTxSize() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitSourceOptionsMetadata
 
getType() - Method in class org.springframework.xd.dirt.event.AbstractEvent
 
getType() - Method in class org.springframework.xd.dirt.integration.bus.Binding
 
getType() - Method in exception org.springframework.xd.dirt.module.DependencyException
 
getType() - Method in exception org.springframework.xd.dirt.module.ModuleAlreadyExistsException
 
getType() - Method in class org.springframework.xd.integration.util.jmxresult.JMXRequest
 
getType() - Method in class org.springframework.xd.module.core.AbstractModule
 
getType() - Method in interface org.springframework.xd.module.core.Module
 
getType() - Method in class org.springframework.xd.module.ModuleDefinition
 
getType() - Method in class org.springframework.xd.module.ModuleDescriptor.Builder
Return the module type.
getType() - Method in class org.springframework.xd.module.ModuleDescriptor
Return the module type.
getType() - Method in class org.springframework.xd.module.ModuleDescriptor.Key
Return the module type.
getType() - Method in class org.springframework.xd.module.options.ModuleOption
 
getType() - Method in class org.springframework.xd.rest.domain.DetailedModuleDefinitionResource.Option
 
getType() - Method in class org.springframework.xd.rest.domain.ModuleDefinitionResource
 
getUnitName() - Method in class org.springframework.xd.dirt.module.store.ModuleMetadata
 
getUnitName() - Method in class org.springframework.xd.rest.domain.ModuleMetadataResource
 
getUrl() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getUrl() - Method in class org.springframework.xd.dirt.modules.metadata.MqttConnectionMixin
 
getUrl() - Method in class org.springframework.xd.http.HttpClientProcessorOptionsMetadata
 
getUrl() - Method in class org.springframework.xd.jdbc.JdbcConnectionMixin
 
getUsername() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
getUsername() - Method in class org.springframework.xd.dirt.modules.metadata.FtpHdfsJobOptionsMetadata
 
getUsername() - Method in class org.springframework.xd.dirt.modules.metadata.MqttConnectionMixin
 
getUsername() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitConnectionMixin
 
getUsername() - Method in class org.springframework.xd.jdbc.JdbcConnectionMixin
 
getUsername() - Method in class org.springframework.xd.mail.MailServerMixin
 
getUsername() - Method in class org.springframework.xd.shell.Target.Credentials
 
getUsername() - Method in class org.springframework.xd.splunk.SplunkSinkOptionsMetadata
 
getUseSSL() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitConnectionMixin
 
getValidationInterval() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getValidationQuery() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
getValidatorClassName() - Method in class org.springframework.xd.jdbc.JdbcConnectionPoolMixin
 
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(Expression, Message<?>, Class<T>) - Method in class org.springframework.xd.integration.hadoop.partition.MessageExpressionMethods
Gets the value.
getValue() - Method in class org.springframework.xd.integration.util.jmxresult.JMXChannelResult
 
getValue() - Method in class org.springframework.xd.integration.util.jmxresult.JMXResult
 
getValue() - Method in class org.springframework.xd.rest.domain.metrics.CounterResource
Return the value for the counter.
getValue() - Method in class org.springframework.xd.rest.domain.metrics.GaugeResource
Return the value for the gauge.
getValue() - Method in class org.springframework.xd.rest.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.domain.metrics.AggregateCountsResource
Returns a date-sorted view of counts.
getValues() - Method in class org.springframework.xd.tuple.DefaultTuple
Return the values for all the fields in this tuple
getValues() - Method in interface org.springframework.xd.tuple.Tuple
Return the values for all the fields in this tuple
getVersion() - Static method in class org.springframework.xd.dirt.util.BannerUtils
 
getVersion() - Method in class org.springframework.xd.shell.XDShellBannerProvider
Returns the version information as found in the manifest file (set during release).
getVhost() - Method in class org.springframework.xd.dirt.modules.metadata.RabbitConnectionMixin
 
getWelcomeMessage() - Method in class org.springframework.xd.shell.XDShellBannerProvider
 
getWidth() - Method in class org.springframework.xd.shell.util.TableHeader
 
getXD_ANALYTICS() - Method in class org.springframework.xd.dirt.server.options.CommonDistributedOptions
 
getXD_ANALYTICS() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
 
getXD_CONTAINER_GROUPS() - Method in class org.springframework.xd.dirt.server.options.ContainerOptions
 
getXD_MGMT_PORT() - Method in class org.springframework.xd.dirt.server.options.CommonOptions
 
getXD_TRANSPORT() - Method in class org.springframework.xd.dirt.server.options.SingleNodeOptions
 
getZooKeeperConnection() - Method in class org.springframework.xd.dirt.stream.AbstractDeployer
Return the ZooKeeper connection.
getZSetData(String) - Method in class org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository
 
greenMail - Variable in class org.springframework.xd.test.fixtures.DisposableMailSupport
 
GROUPS_KEY - Static variable in class org.springframework.xd.dirt.cluster.ContainerAttributes
 
groupsToValidate() - Method in class org.springframework.xd.dirt.modules.metadata.AggregatorProcessorModuleOptionsMetadata
 
groupsToValidate() - Method in interface org.springframework.xd.module.options.spi.ValidationGroupsProvider
 

H

HadoopConfigurationMixin - Class in org.springframework.xd.module.options.mixins
Factors out common configuration options for Hadoop.
HadoopConfigurationMixin() - Constructor for class org.springframework.xd.module.options.mixins.HadoopConfigurationMixin
 
HadoopFileSystemTestSupport - Class in org.springframework.xd.test.hadoop
 
HadoopFileSystemTestSupport() - Constructor for class org.springframework.xd.test.hadoop.HadoopFileSystemTestSupport
 
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
 
HadoopUtils - Class in org.springframework.xd.integration.util
HDFS shell utilities required for testing hdfs
HadoopUtils(XdEnvironment) - Constructor for class org.springframework.xd.integration.util.HadoopUtils
Initializes the hadoop utils with the name node that was specified in the environment.
handleError(ClientHttpResponse) - Method in class org.springframework.xd.rest.client.impl.VndErrorResponseErrorHandler
 
handleMessage(Message<?>) - Method in class org.springframework.xd.dirt.integration.bus.MessageBusSupport.DirectHandler
 
handleMessage(Message<?>) - Method in class org.springframework.xd.integration.throughput.ThroughputSamplerMessageHandler
 
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsStoreMessageHandler
 
handleMessageInternal(Message<?>) - Method in class org.springframework.xd.integration.hadoop.outbound.HdfsWritingMessageHandler
 
handleUnknown(String, Object) - Method in class org.springframework.xd.integration.util.jmxresult.JMXValue
Extracts the module data from the Json.
hasArguments() - Method in class org.springframework.xd.dirt.stream.dsl.ModuleNode
 
HasDisplayValue<T> - Interface in org.springframework.xd.test.fixtures
Marker interface for entities whose 'display' command returns a simple representation.
hasFieldName(String) - Method in class org.springframework.xd.tuple.DefaultTuple
 
hasFieldName(String) - Method in interface org.springframework.xd.tuple.Tuple
Return true if the tuple contains a field of the given name
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.Counter
 
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.FieldValueCounter
 
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.Gauge
 
hashCode() - Method in class org.springframework.xd.analytics.metrics.core.RichGauge
 
hashCode() - Method in class org.springframework.xd.dirt.cluster.Container
hashCode() - Method in class org.springframework.xd.dirt.core.BaseDefinition
 
hashCode() - Method in class org.springframework.xd.dirt.plugins.job.support.listener.ChunkContextInfo
 
hashCode() - Method in class org.springframework.xd.dirt.stream.dsl.Token
 
hashCode() - Method in class org.springframework.xd.module.ModuleDescriptor.Key
hashCode() - Method in class org.springframework.xd.shell.util.Table
 
hashCode() - Method in class org.springframework.xd.shell.util.TableHeader
 
hashCode() - Method in class org.springframework.xd.shell.util.TableRow
 
hashCode() - Method in class org.springframework.xd.tuple.DefaultTuple
 
hashOperations - Variable in class org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository
 
hasNext() - Method in class org.springframework.xd.dirt.zookeeper.ChildPathIterator
hasPayload() - Method in enum org.springframework.xd.dirt.stream.dsl.TokenKind
 
hasValue(String) - Method in class org.springframework.xd.tuple.batch.TupleSqlParameterSource
 
hdfs() - Method in class org.springframework.xd.integration.fixtures.Sinks
Constructs a hdfs sink with a directory of /xd/acceptancetest & a file name of ACCTEST
HdfsDataStoreMessageHandler - Class in org.springframework.xd.integration.hadoop.outbound
Spring Integration MessageHandler handling Message writing into hdfs using DataStoreWriter.
HdfsDataStoreMessageHandler(DataStoreWriter<String>) - Constructor for class org.springframework.xd.integration.hadoop.outbound.HdfsDataStoreMessageHandler
Instantiates a new hdfs data store message handler.
hdfsJdbcJob() - Method in class org.springframework.xd.integration.fixtures.Jobs
Create an instance of the HdfsJdbc job with the default target dir, fileName, tableName and column names.
HdfsJdbcJob - Class in org.springframework.xd.test.fixtures
A test fixture that represents the HdfsJdbc Job
HdfsJdbcJob(String, String, String, String) - Constructor for class org.springframework.xd.test.fixtures.HdfsJdbcJob
Construct a new HdfsJdbcJob using the provided directory and file names.
hdfsMongoDb() - Method in class org.springframework.xd.integration.fixtures.Jobs
Create a new HdfsMongoDbJob that constructs a job that will read data from hdfs and output to mongo using default values.
HdfsMongoDbJob - Class in org.springframework.xd.test.fixtures
A test fixture that represents the HdfsMongoDb Job
HdfsMongoDbJob(String, String, String, String, String, MongoDbFactory) - Constructor for class org.springframework.xd.test.fixtures.HdfsMongoDbJob
Construct a new HdfsMongoDbJob using the provided directory and file names.
HdfsMongodbJobOptionsMetadata - Class in org.springframework.xd.dirt.modules.metadata
Options for Hdfs to Mongodb export job module.
HdfsMongodbJobOptionsMetadata() - Constructor for class org.springframework.xd.dirt.modules.metadata.HdfsMongodbJobOptionsMetadata
 
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
 
HdfsPartitionDataStoreMessageHandler - Class in org.springframework.xd.integration.hadoop.outbound
Spring Integration MessageHandler handling Message writing into hdfs using PartitionDataStoreWriter.
HdfsPartitionDataStoreMessageHandler(PartitionDataStoreWriter<String, Message<?>>) - Constructor for class org.springframework.xd.integration.hadoop.outbound.HdfsPartitionDataStoreMessageHandler
Instantiates a new hdfs partition data store message handler.
HdfsSink - Class in org.springframework.xd.test.fixtures
A test fixture that allows testing of the 'hdfs' sink module.
HdfsSink(String, String) - Constructor for class org.springframework.xd.test.fixtures.