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

A

AbstractExternalTable - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Base settings for all external tables;

AbstractExternalTable() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

AbstractGpfdistMessageHandler - Class in org.springframework.cloud.stream.app.gpfdist.sink

Base implementation of Spring Integration MessageHandler handling Message.

AbstractGpfdistMessageHandler() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

AbstractRemoteFileProperties - Class in org.springframework.cloud.stream.app.file.remote

AbstractRemoteFileProperties() - Constructor for class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

AbstractRemoteFileSinkProperties - Class in org.springframework.cloud.stream.app.file.remote

AbstractRemoteFileSinkProperties() - Constructor for class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

AbstractRemoteFileSourceProperties - Class in org.springframework.cloud.stream.app.file.remote

Common properties for remote file sources (e.g.

AbstractRemoteFileSourceProperties() - Constructor for class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

AbstractRemoteServerProperties - Class in org.springframework.cloud.stream.app.file.remote

Common properties for remote servers (e.g.

AbstractRemoteServerProperties() - Constructor for class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

AbstractTcpConnectionFactoryProperties - Class in org.springframework.cloud.stream.app.tcp

Base class for TCP connection factory properties.

AbstractTcpConnectionFactoryProperties() - Constructor for class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

AbstractTcpConnectionFactoryProperties.Encoding - Enum in org.springframework.cloud.stream.app.tcp

AbstractTwitterInboundChannelAdapter - Class in org.springframework.cloud.stream.app.twitterstream.source

Abstract class for the twitter inbound channel adapter.

AbstractTwitterInboundChannelAdapter(TwitterTemplate) - Constructor for class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

AbstractTwitterInboundChannelAdapter.StreamReadingTask - Class in org.springframework.cloud.stream.app.twitterstream.source

adapter() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceConfiguration

adapter() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration

adapter(AbstractConnectionFactory) - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceConfiguration

addGploadSqlAfter(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

addGploadSqlBefore(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

addLocation(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.RuntimeContext

Adds the location.

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFileFactoryBean

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

afterPropertiesSet() - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration

aggregateCounterRepository() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkStoreConfiguration

AggregateCounterSinkConfiguration - Class in org.springframework.cloud.stream.app.aggregate.counter.sink

Configuration class for Aggregate counter sink.

AggregateCounterSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkConfiguration

AggregateCounterSinkProperties - Class in org.springframework.cloud.stream.app.aggregate.counter.sink

AggregateCounterSinkProperties() - Constructor for class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

AggregateCounterSinkStoreConfiguration - Class in org.springframework.cloud.stream.app.aggregate.counter.sink

Configuration class for Redis based aggregate counter.

AggregateCounterSinkStoreConfiguration() - Constructor for class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkStoreConfiguration

allKeysInterest() - Method in class org.springframework.cloud.stream.app.gemfire.source.KeyInterestConfiguration

amazonS3(AWSCredentialsProvider, RegionProvider) - Method in class org.springframework.cloud.stream.app.s3.AmazonS3Configuration

AmazonS3Configuration - Class in org.springframework.cloud.stream.app.s3

AmazonS3Configuration() - Constructor for class org.springframework.cloud.stream.app.s3.AmazonS3Configuration

amazonS3MessageHandler(AmazonS3, ResourceIdResolver, AmazonS3SinkProperties) - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkConfiguration

AmazonS3SinkConfiguration - Class in org.springframework.cloud.stream.app.s3.sink

AmazonS3SinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkConfiguration

AmazonS3SinkProperties - Class in org.springframework.cloud.stream.app.s3.sink

AmazonS3SinkProperties() - Constructor for class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

AmazonS3SourceConfiguration - Class in org.springframework.cloud.stream.app.s3.source

AmazonS3SourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.s3.source.AmazonS3SourceConfiguration

AmazonS3SourceProperties - Class in org.springframework.cloud.stream.app.s3.source

AmazonS3SourceProperties() - Constructor for class org.springframework.cloud.stream.app.s3.source.AmazonS3SourceProperties

amqpChannelAdapter(ConnectionFactory) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkConfiguration

apply(Buffer) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistCodec

asHeader() - Method in enum org.springframework.cloud.stream.app.loggregator.source.LoggregatorMessageSource.LoggregatorHeaders

B

beforeDestroy() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.ReaperTask

BothBits() - Constructor for class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration.BothBits

bridge() - Method in class org.springframework.cloud.stream.app.bridge.processor.BridgeProcessorConfiguration

bridgeMessageHandler() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkConfiguration

BridgeProcessorConfiguration - Class in org.springframework.cloud.stream.app.bridge.processor

A Processor application that connects input and output channels.

BridgeProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.bridge.processor.BridgeProcessorConfiguration

buildUri() - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

C

cacheListeningMessageProducer() - Method in class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceConfiguration

CassandraConfiguration - Class in org.springframework.cloud.stream.app.cassandra

CassandraConfiguration() - Constructor for class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

CassandraConfiguration.CassandraKeyspaceInitializerConfiguration - Class in org.springframework.cloud.stream.app.cassandra

Inner class to execute init scripts on the provided keyspace.

CassandraKeyspaceInitializerConfiguration() - Constructor for class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration.CassandraKeyspaceInitializerConfiguration

CassandraProperties - Class in org.springframework.cloud.stream.app.cassandra

Common properties for the cassandra modules.

CassandraProperties() - Constructor for class org.springframework.cloud.stream.app.cassandra.CassandraProperties

CassandraSinkConfiguration - Class in org.springframework.cloud.stream.app.cassandra.sink

CassandraSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkConfiguration

cassandraSinkMessageHandler() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkConfiguration

CassandraSinkProperties - Class in org.springframework.cloud.stream.app.cassandra.sink

CassandraSinkProperties() - Constructor for class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

clientCache() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfireClientCacheConfiguration

clientRegionFactoryBean() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfireClientRegionConfiguration

cloudCredentials() - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorSourceConfiguration

cloudFoundryClient(CloudCredentials) - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorSourceConfiguration

computeMetricName(Message<?>) - Method in class org.springframework.cloud.stream.app.counter.sink.CounterSinkConfiguration

computeMetricName(Message<?>) - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkConfiguration

container() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceConfiguration

container() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration

ControlFile - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

ControlFile() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

ControlFile.OutputMode - Enum in org.springframework.cloud.stream.app.gpfdist.sink.support

ControlFileFactoryBean - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

ControlFileFactoryBean() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFileFactoryBean

convert(String) - Method in class org.springframework.cloud.stream.app.gemfire.config.InetSocketAddressConverterConfiguration.InetSocketAddressConverter

convert(String) - Method in class org.springframework.cloud.stream.app.jdbc.sink.ShorthandMapConverter

convert(Object, TypeDescriptor, TypeDescriptor) - Method in class org.springframework.cloud.stream.app.pmml.processor.GenericMapConverter

convert(long, TimeUnit) - Method in enum org.springframework.cloud.stream.app.throughput.sink.TimeUnit

convertToStringChannel() - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceConfiguration

convertToStringChannel() - Method in class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceConfiguration

count(Message<?>) - Method in class org.springframework.cloud.stream.app.counter.sink.CounterSinkConfiguration

CounterProperties - Class in org.springframework.cloud.stream.app.counter.sink

Common configuration properties for the Spring Cloud Stream metric modules.

CounterProperties() - Constructor for class org.springframework.cloud.stream.app.counter.sink.CounterProperties

CounterSinkConfiguration - Class in org.springframework.cloud.stream.app.counter.sink

A simple module that counts messages received, using Spring Boot metrics abstraction.

CounterSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.counter.sink.CounterSinkConfiguration

CounterSinkStoreConfiguration - Class in org.springframework.cloud.stream.app.counter.sink

Used to configure the connection and offloading of counters to redis

CounterSinkStoreConfiguration() - Constructor for class org.springframework.cloud.stream.app.counter.sink.CounterSinkStoreConfiguration

createExternalReadableTable(LoadConfiguration, String, List<String>) - Static method in class org.springframework.cloud.stream.app.gpfdist.sink.support.SqlUtils

createInstance() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

createInstance() - Method in class org.springframework.cloud.stream.app.tcp.EncoderDecoderFactoryBean

createLocationString(String[]) - Static method in class org.springframework.cloud.stream.app.gpfdist.sink.support.SqlUtils

Converts string array to greenplum friendly string.

CRON_TRIGGER_OPTION - Static variable in class org.springframework.cloud.stream.app.trigger.TriggerConstants

cronTrigger() - Method in class org.springframework.cloud.stream.app.trigger.TriggerConfiguration

CustomConversionServiceRegistrar - Class in org.springframework.cloud.stream.app.pmml.processor

Registers a DefaultConversionService configured with both an ExpressionConverter and a GenericMapConverter very early in the ApplicationContext lifecycle, so that they get picked up for @ConfigurationProperties binding.

CustomConversionServiceRegistrar() - Constructor for class org.springframework.cloud.stream.app.pmml.processor.CustomConversionServiceRegistrar

CustomConversionServiceRegistrar.CustomDefaultConversionService - Class in org.springframework.cloud.stream.app.pmml.processor

CustomDefaultConversionService() - Constructor for class org.springframework.cloud.stream.app.pmml.processor.CustomConversionServiceRegistrar.CustomDefaultConversionService

D

datasetDefinition() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration

datasetOperations(DatasetRepositoryFactory, DatasetDefinition) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration

datasetRepositoryFactory(Configuration) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration

datasetSinkMessageHandler(DatasetOperations) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration

dataSource(ControlFile) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

dataStoreWriter() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

DataStoreWriterFactoryBean - Class in org.springframework.cloud.stream.app.hdfs.sink

A FactoryBean creating a DataStoreWriter.

DataStoreWriterFactoryBean() - Constructor for class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

DATE_FORMAT - Static variable in class org.springframework.cloud.stream.app.trigger.TriggerConstants

DATE_TRIGGER_OPTION - Static variable in class org.springframework.cloud.stream.app.trigger.TriggerConstants

DateFormat - Annotation Type in org.springframework.cloud.stream.app.time

The annotated String must be a valid SimpleDateFormat pattern.

DateFormat.DateFormatValidator - Class in org.springframework.cloud.stream.app.time

DateFormat.List - Annotation Type in org.springframework.cloud.stream.app.time

Defines several DateFormat annotations on the same element.

DateFormatValidator() - Constructor for class org.springframework.cloud.stream.app.time.DateFormat.DateFormatValidator

DateTrigger - Class in org.springframework.cloud.stream.app.trigger

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

DateTrigger(Date...) - Constructor for class org.springframework.cloud.stream.app.trigger.DateTrigger

dateTrigger() - Method in class org.springframework.cloud.stream.app.trigger.TriggerConfiguration

decoder(Consumer<Buffer>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistCodec

DEFAULT_EXPRESSION - Static variable in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

DEFAULT_LOGLEVEL - Static variable in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

DEFAULT_MESSAGE - Static variable in annotation type org.springframework.cloud.stream.app.time.DateFormat

DEFAULT_PATH - Static variable in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

DEFAULT_PORT - Static variable in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

DEFAULT_THREADS - Static variable in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

DefaultGreenplumLoad - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

DefaultGreenplumLoad(LoadConfiguration, LoadService) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.DefaultGreenplumLoad

DefaultInitializationScriptResource - Class in org.springframework.cloud.stream.app.jdbc.sink

An in-memory script crafted for dropping-creating the table we're working with.

DefaultInitializationScriptResource(JdbcSinkProperties) - Constructor for class org.springframework.cloud.stream.app.jdbc.sink.DefaultInitializationScriptResource

DefaultLoadService - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

DefaultLoadService(JdbcTemplate) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.DefaultLoadService

defaultPoller(Trigger) - Method in class org.springframework.cloud.stream.app.trigger.TriggerConfiguration

destroy() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

destroy() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

destroyInstance(BasicDataSource) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

doSendLine(String) - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

doStart() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

Subclasses may override this method with the start behaviour.

doStart() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

doStart() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceConfiguration

doStart() - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorMessageSource

doStart() - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

doStop() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

Subclasses may override this method with the stop behaviour.

doStop() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

doStop() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceConfiguration

doStop() - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

doWrite(Message<?>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

Subclasses need to implement this method to handle Message in its writer.

doWrite(Message<?>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

dropExternalReadableTable(LoadConfiguration, String) - Static method in class org.springframework.cloud.stream.app.gpfdist.sink.support.SqlUtils

E

EncoderDecoderFactoryBean - Class in org.springframework.cloud.stream.app.tcp

Factory bean for an encoder/decoder based on AbstractTcpConnectionFactoryProperties.Encoding.

EncoderDecoderFactoryBean(AbstractTcpConnectionFactoryProperties.Encoding) - Constructor for class org.springframework.cloud.stream.app.tcp.EncoderDecoderFactoryBean

enhanceFlowForReadingMode(IntegrationFlowBuilder, FileConsumerProperties) - Static method in class org.springframework.cloud.stream.app.file.FileUtils

Enhance an IntegrationFlowBuilder to add flow snippets, depending on FileConsumerProperties.

evaluate(Message<?>) - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorConfiguration

evaluationContext - Variable in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration

execute() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

F

FieldValueCounterSinkConfiguration - Class in org.springframework.cloud.stream.app.field.value.counter.sink

FieldValueCounterSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkConfiguration

FieldValueCounterSinkProperties - Class in org.springframework.cloud.stream.app.field.value.counter.sink

FieldValueCounterSinkProperties() - Constructor for class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

FieldValueCounterSinkStoreConfiguration - Class in org.springframework.cloud.stream.app.field.value.counter.sink

Configuration class for the Field Value Counter.

FieldValueCounterSinkStoreConfiguration() - Constructor for class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkStoreConfiguration

FileConsumerProperties - Class in org.springframework.cloud.stream.app.file

FileConsumerProperties() - Constructor for class org.springframework.cloud.stream.app.file.FileConsumerProperties

fileNameGenerator(FileSinkProperties) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkConfiguration

FileReadingMode - Enum in org.springframework.cloud.stream.app.file

Defines the supported modes of reading and processing files for the File, FTP and SFTP sources.

FileSinkConfiguration - Class in org.springframework.cloud.stream.app.file.sink

Creates a FileWritingMessageHandler bean and registers it as a Service Activator that consumes messages from the Sink input channel.

FileSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.file.sink.FileSinkConfiguration

FileSinkProperties - Class in org.springframework.cloud.stream.app.file.sink

Properties for the file sink.

FileSinkProperties() - Constructor for class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

FileSourceConfiguration - Class in org.springframework.cloud.stream.app.file.source

Creates a FileReadingMessageSource bean and registers it as a Inbound Channel Adapter that sends messages to the Source output channel.

FileSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.file.source.FileSourceConfiguration

fileSourceFlow() - Method in class org.springframework.cloud.stream.app.file.source.FileSourceConfiguration

FileSourceProperties - Class in org.springframework.cloud.stream.app.file.source

Properties for the file source.

FileSourceProperties() - Constructor for class org.springframework.cloud.stream.app.file.source.FileSourceProperties

FileUtils - Class in org.springframework.cloud.stream.app.file

FileUtils() - Constructor for class org.springframework.cloud.stream.app.file.FileUtils

fileWritingMessageHandler(FileNameGenerator, FileSinkProperties) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkConfiguration

filter(Message<?>) - Method in class org.springframework.cloud.stream.app.filter.processor.FilterProcessorConfiguration

filter() - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorConfiguration

FilterProcessorConfiguration - Class in org.springframework.cloud.stream.app.filter.processor

A Processor app that retains or discards messages according to a predicate.

FilterProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.filter.processor.FilterProcessorConfiguration

FilterProcessorProperties - Class in org.springframework.cloud.stream.app.filter.processor

Configuration properties for the Filter Processor app.

FilterProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.filter.processor.FilterProcessorProperties

Format - Enum in org.springframework.cloud.stream.app.gpfdist.sink.support

FsShutdown(int) - Constructor for class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

ftpInboundFlow(FtpSinkProperties, SessionFactory<FTPFile>) - Method in class org.springframework.cloud.stream.app.ftp.sink.FtpSinkConfiguration

ftpInboundFlow(SessionFactory<FTPFile>, FtpSourceProperties, FileConsumerProperties) - Method in class org.springframework.cloud.stream.app.ftp.source.FtpSourceConfiguration

ftpInboundFlow(SftpSinkProperties, SessionFactory<ChannelSftp.LsEntry>) - Method in class org.springframework.cloud.stream.app.sftp.sink.SftpSinkConfiguration

ftpSessionFactory(FtpSessionFactoryProperties) - Method in class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryConfiguration

FtpSessionFactoryConfiguration - Class in org.springframework.cloud.stream.app.ftp

FTP Session factory configuration.

FtpSessionFactoryConfiguration() - Constructor for class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryConfiguration

FtpSessionFactoryProperties - Class in org.springframework.cloud.stream.app.ftp

FTP SessionFactory properties.

FtpSessionFactoryProperties() - Constructor for class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties

FtpSessionFactoryProperties.ClientMode - Enum in org.springframework.cloud.stream.app.ftp

FtpSinkConfiguration - Class in org.springframework.cloud.stream.app.ftp.sink

FtpSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.ftp.sink.FtpSinkConfiguration

FtpSinkProperties - Class in org.springframework.cloud.stream.app.ftp.sink

FtpSinkProperties() - Constructor for class org.springframework.cloud.stream.app.ftp.sink.FtpSinkProperties

FtpSourceConfiguration - Class in org.springframework.cloud.stream.app.ftp.source

FtpSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.ftp.source.FtpSourceConfiguration

FtpSourceProperties - Class in org.springframework.cloud.stream.app.ftp.source

FtpSourceProperties() - Constructor for class org.springframework.cloud.stream.app.ftp.source.FtpSourceProperties

FUNNY_CHARACTERS - Static variable in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

G

GemfireClientCacheConfiguration - Class in org.springframework.cloud.stream.app.gemfire.config

GemfireClientCacheConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.GemfireClientCacheConfiguration

GemfireClientRegionConfiguration - Class in org.springframework.cloud.stream.app.gemfire.config

Client region configuration common to Gemfire spring-cloud-stream apps.

GemfireClientRegionConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.GemfireClientRegionConfiguration

GemfireCqSourceConfiguration - Class in org.springframework.cloud.stream.app.gemfire.cq.source

The Gemfire CQ Source provides a ContinuousQueryMessageProducer which by default, emits an object of type CqEvent.

GemfireCqSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceConfiguration

GemfireCqSourceProperties - Class in org.springframework.cloud.stream.app.gemfire.cq.source

This represents the configuration properties for the Gemfire CQ Source.

GemfireCqSourceProperties() - Constructor for class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceProperties

gemfirePool() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolConfiguration

GemfirePoolConfiguration - Class in org.springframework.cloud.stream.app.gemfire.config

Common Gemfire client pool configuration for spring-cloud-stream apps.

GemfirePoolConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolConfiguration

GemfirePoolProperties - Class in org.springframework.cloud.stream.app.gemfire.config

Gemfire client pool configuration properties

GemfirePoolProperties() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

GemfirePoolProperties.ConnectType - Enum in org.springframework.cloud.stream.app.gemfire.config

GemfireRegionProperties - Class in org.springframework.cloud.stream.app.gemfire.config

GemfireRegionProperties() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.GemfireRegionProperties

GemfireSinkConfiguration - Class in org.springframework.cloud.stream.app.gemfire.sink

GemfireSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkConfiguration

gemfireSinkHandler() - Method in class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkConfiguration

GemfireSinkProperties - Class in org.springframework.cloud.stream.app.gemfire.sink

GemfireSinkProperties() - Constructor for class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkProperties

GemfireSourceConfiguration - Class in org.springframework.cloud.stream.app.gemfire.source

The Gemfire Source provides a CacheListeningMessageProducer which produces a message for cache events.

GemfireSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceConfiguration

GemfireSourceProperties - Class in org.springframework.cloud.stream.app.gemfire.source

This represents the configuration properties for the Gemfire Source.

GemfireSourceProperties() - Constructor for class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceProperties

GenericMapConverter - Class in org.springframework.cloud.stream.app.pmml.processor

A Converter that can convert from a csv String to Map<K, V>, as long as the ConversionService it delegates to can convert from String to K and V.

GenericMapConverter(ConversionService, String, String) - Constructor for class org.springframework.cloud.stream.app.pmml.processor.GenericMapConverter

GenericMapConverter(ConversionService) - Constructor for class org.springframework.cloud.stream.app.pmml.processor.GenericMapConverter

getAccessToken() - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

getAccessTokenSecret() - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

getAcl() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

getAclExpression() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

getApplicationName() - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

getAuthProvider() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getBatchCount() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getBatchPeriod() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getBatchSize() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getBatchTimeout() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getBody() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getBodyExpression() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getBucket() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

getBucketExpression() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

getBufferSize() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

getBufferSize() - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceProperties

getCacheEventExpression() - Method in class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceProperties

getCacheSessions() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

getCharset() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getCharset() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

getCharset() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

getCharset() - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

getClientId() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

getClientMode() - Method in class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties

getCloseTimeout() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getCloudFoundryApi() - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

getCloudFoundryPassword() - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

getCloudFoundryUser() - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

getCodec() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getColumnDelimiter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getColumns() - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

getCompressionType() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getCompressionType() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getCompressionType() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getComputedNameExpression() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getComputedNameExpression() - Method in class org.springframework.cloud.stream.app.counter.sink.CounterProperties

getComputedNameExpression() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

getConnectType() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

getConsistencyLevel() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

getConsumerKey() - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

getConsumerSecret() - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

getContactPoints() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getContactPoints() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getControlFile() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getConverterBeanName() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getConvertibleTypes() - Method in class org.springframework.cloud.stream.app.pmml.processor.GenericMapConverter

getCqEventExpression() - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceProperties

getCron() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getDatabase() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getDate() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getDateFormat() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getDateFormat() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getDateFormatter() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getDbHost() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getDbName() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getDbPassword() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getDbPort() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getDbUser() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getDecoder() - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceProperties

getDefaultOutputChannel() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getDelimiter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getDelimiter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getDelimiter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getDelimiters() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

getDestination() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

getDestinationMappings() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getDirectory() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getDirectory() - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

getDirectory() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getDirectory() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getDirectoryExpression() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getEncoder() - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

getEncoding() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getEntityBasePackages() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getEntityBasePackages() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getErrorTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getEscape() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getEscape() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getExchange() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getExchangeExpression() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getExpectedResponseType() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getExpression() - Method in class org.springframework.cloud.stream.app.filter.processor.FilterProcessorProperties

getExpression() - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

getExpression() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

getExpression() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getExpression() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

getExpression() - Method in class org.springframework.cloud.stream.app.transform.processor.TransformProcessorProperties

getExternalTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getExternalTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getFieldName() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

getFileExtension() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getFileMarkers() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

getFileName() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getFilenameExpression() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

getFilenamePattern() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

getFilenamePattern() - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

getFilenameRegex() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

getFilenameRegex() - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

getFileOpenAttempts() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getFixedDelay() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getFlushCount() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getFlushTime() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getFlushTimeout() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getForceQuote() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getForceQuote() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getFormat() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getFormat() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getFormat() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getFsUri() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getFsUri() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getGpfdistPort() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getGPFDistUri(String, int) - Static method in class org.springframework.cloud.stream.app.gpfdist.sink.support.NetworkUtils

getGploadInputDelimiter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadOutputMatchColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadOutputMode() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadOutputTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadOutputUpdateColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadOutputUpdateCondition() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadSqlAfter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getGploadSqlBefore() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getHeadersExpression() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getHost() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

getHost() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getHost() - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

getHostAddresses() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

getHttpMethod() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getIdleTimeout() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getIdleTimeout() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getIncrementExpression() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getIngestQuery() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

getInitDelay() - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

getInitialDelay() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getInitialize() - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

getInitialRetryInterval() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getInitScript() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getInputs() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

getInUsePrefix() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getInUseSuffix() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getJavaMailProperties() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

getKey() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

getKeyExpression() - Method in class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkProperties

getKeyExpression() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

getKeyExpression() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

getKeyspace() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getKeyspaceCreations() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getKeyspaceName() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getKillDelay() - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

getKnownHostsExpression() - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

getLanguage() - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

getLanguage() - Method in class org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamProperties

getLastException() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

getLevel() - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

getLike() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getLike() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getLocalDir() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

getLocalPort() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistServer

Gets the local port.

getLocations() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getLocations() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getLocations() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.RuntimeContext

Gets the locations.

getLogErrorsInto() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

getLogErrorsInto() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Gets the log errors table.

getLogLevel() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

getMappedRequestHeaders() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getMappedRequestHeaders() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getMarkersJson() - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

getMarkersJson() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

getMatchColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getMatchColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getMatchColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getMatchInstances() - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

getMatchInterface() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

getMatchIpv4() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

getMaxAttempts() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getMaxMessages() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getMaxRetryInterval() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getMaxRowsPerPoll() - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

getMessageCount() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

getMessageSelector() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

getMessageSize() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

getMetricsEnabled() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getMode() - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

getMode() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

getMode() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getMode() - Method in enum org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties.ClientMode

getMode() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getMode() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getMode() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getModelLocation() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

getModelName() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

getModelNameExpression() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

getName() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getName() - Method in class org.springframework.cloud.stream.app.counter.sink.CounterProperties

getName() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

getName() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getName() - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

getNameExpression() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getNameExpression() - Method in class org.springframework.cloud.stream.app.counter.sink.CounterProperties

getNameExpression() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

getNameExpression() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getNamespace() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getNullString() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getNullString() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getNullString() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getObject() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFileFactoryBean

getObject() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getObject() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

getObject() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getObject() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFileFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

getObjectType() - Method in class org.springframework.cloud.stream.app.tcp.EncoderDecoderFactoryBean

getOutputs() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

getParameterThatMayNeedEscaping() - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

getPartitionPath() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

getPartitionPath() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getPassPhrase() - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

getPassword() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getPassword() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

getPassword() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getPath() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

getPayload() - Method in class org.springframework.cloud.stream.app.trigger.SourcePayloadProperties

getPersistentDeliveryMode() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getPhase() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

getPhase() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

getPhase() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

getPort() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getPort() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getPort() - Method in class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties

getPort() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getPort() - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

getPort() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

getPort() - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

getPort() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

getPort() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServer

getPreferInterface() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

getPrivateKey() - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

getProducers() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

getProtocol() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

getQuery() - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceProperties

getQuery() - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

getQueryType() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

getQueue() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

getQueueExpression() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

getQueues() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getQuote() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

getQuote() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

getRateInterval() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getRefreshDelay() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getRegionName() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfireRegionProperties

getRemoteDir() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

getRemoteDir() - Method in class org.springframework.cloud.stream.app.s3.source.AmazonS3SourceProperties

getRemoteFileSeparator() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

getReplyExpression() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getReportEveryMs() - Method in class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkProperties

getRequeue() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getRetryMultiplier() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getRetryPolicy() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

getRfc() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

getRollover() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

getRoutingKey() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getRoutingKeyExpression() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

getSchemaAction() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration

getSchemaAction() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getScript() - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

getScript() - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

getScript() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getScript() - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

getSegmentRejectLimit() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getSegmentRejectLimit() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

getSegmentRejectLimit() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Gets the segment reject limit.

getSegmentRejectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getSegmentRejectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

getSegmentRejectType() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Gets the segment reject type.

getSocketTimeout() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

getSocketTimeout() - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

getSqlAfter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getSqlAfter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getSqlAfter() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getSqlBefore() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getSqlBefore() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getSqlBefore() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getStatementExpression() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

getStreamType() - Method in class org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamProperties

getSubscriptionDurable() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

getSubscriptionName() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

getSubscriptionShared() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

getSuffix() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

getTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getTable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getTableName() - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

getTemporaryRemoteDir() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

getThreads() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

getTimeField() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

getTimeUnit() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

getTmpFileSuffix() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

getTopic() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

getTopicExpression() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

getTransacted() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

getTtl() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

getUpdate() - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

getUpdateColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

getUpdateColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getUpdateColumns() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getUpdateCondition() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

getUpdateCondition() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

getUrl() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

getUrlExpression() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

getUser() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

getUsername() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

getUsername() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

getVariables() - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

getVariables() - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

getVariables() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getVariables() - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

getVariablesLocation() - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

getWithMarkers() - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

getWriterCacheSize() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

gpfdist(GreenplumLoad, TaskScheduler, HostInfoDiscovery) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

GpfdistCodec - Class in org.springframework.cloud.stream.app.gpfdist.sink

Gpfdist related reactor Codec.

GpfdistCodec() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistCodec

GpfdistMessageHandler - Class in org.springframework.cloud.stream.app.gpfdist.sink

Gpfdist related MessageHandler.

GpfdistMessageHandler(int, int, int, int, int, int, String, HostInfoDiscovery) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

Instantiates a new gpfdist message handler.

GpfdistServer - Class in org.springframework.cloud.stream.app.gpfdist.sink

Server implementation around reactor and netty providing endpoint where data can be sent using a gpfdist protocol.

GpfdistServer(Processor<Buffer, Buffer>, int, int, int, int, int) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistServer

Instantiates a new gpfdist server.

GpfdistSinkApplication - Class in org.springframework.cloud.stream.app.gpfdist.sink

Spring Boot app running gpfdist sink application.

GpfdistSinkApplication() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkApplication

GpfdistSinkConfiguration - Class in org.springframework.cloud.stream.app.gpfdist.sink

Configuration for all beans needed for gpfdist sink.

GpfdistSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

GpfdistSinkProperties - Class in org.springframework.cloud.stream.app.gpfdist.sink

Config options for gpfdist sink.

GpfdistSinkProperties() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

greenplumControlFile() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

GreenplumDataSourceFactoryBean - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Factory bean for configuring a DataSource.

GreenplumDataSourceFactoryBean() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

greenplumLoad(LoadConfiguration, DataSource) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

GreenplumLoad - Interface in org.springframework.cloud.stream.app.gpfdist.sink.support

greenplumLoadConfiguration(ReadableTable, ControlFile) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

greenplumReadableTable(ControlFile, HostInfoDiscovery) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

GroovyFilterProcessorConfiguration - Class in org.springframework.cloud.stream.app.groovy.filter.processor

A Processor module that retains or discards messages according to a predicate, expressed as a Groovy script.

GroovyFilterProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorConfiguration

GroovyFilterProcessorProperties - Class in org.springframework.cloud.stream.app.groovy.filter.processor

Configuration properties for the Groovy Filter Processor module.

GroovyFilterProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

GroovyTransformProcessorConfiguration - Class in org.springframework.cloud.stream.app.groovy.transform.processor

A Processor app that transforms messages using a Groovy script.

GroovyTransformProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorConfiguration

GroovyTransformProcessorProperties - Class in org.springframework.cloud.stream.app.groovy.transform.processor

Configuration properties for the Groovy Transform Processor module.

GroovyTransformProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

H

handleMessageInternal(Message<?>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

handler(AbstractConnectionFactory) - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkConfiguration

handleRequest(String, Object) - Method in class org.springframework.cloud.stream.app.http.source.HttpSourceConfiguration

handleRequest(byte[], Object) - Method in class org.springframework.cloud.stream.app.http.source.HttpSourceConfiguration

HdfsDatasetSinkConfiguration - Class in org.springframework.cloud.stream.app.hdfs.dataset.sink

Configuration class for the HDFS DatasetSink.

HdfsDatasetSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration

HdfsDatasetSinkConfiguration.FsShutdown - Class in org.springframework.cloud.stream.app.hdfs.dataset.sink

HdfsDatasetSinkConfiguration.ReaperTask - Class in org.springframework.cloud.stream.app.hdfs.dataset.sink

HdfsDatasetSinkProperties - Class in org.springframework.cloud.stream.app.hdfs.dataset.sink

Used to configure the HDFS Dataset Sink module options that are related to writing using Kite SDK.

HdfsDatasetSinkProperties() - Constructor for class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

hdfsSink(Object) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

HdfsSinkConfiguration - Class in org.springframework.cloud.stream.app.hdfs.sink

Configuration class for the HdfsSink.

HdfsSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

HdfsSinkProperties - Class in org.springframework.cloud.stream.app.hdfs.sink

Used to configure those Hdfs Sink module options that are related to connecting to Hdfs.

HdfsSinkProperties() - Constructor for class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

hostInfoDiscovery() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

HostInfoDiscoveryProperties - Class in org.springframework.cloud.stream.app.gpfdist.sink

Shared boot configuration properties for "spring.net.hostdiscovery".

HostInfoDiscoveryProperties() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

httpClient() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorConfiguration

HttpClientProcessor() - Constructor for class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorConfiguration.HttpClientProcessor

HttpclientProcessorConfiguration - Class in org.springframework.cloud.stream.app.httpclient.processor

A processor app that makes requests to an HTTP resource and emits the response body as a message payload.

HttpclientProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorConfiguration

HttpclientProcessorConfiguration.HttpClientProcessor - Class in org.springframework.cloud.stream.app.httpclient.processor

HttpclientProcessorProperties - Class in org.springframework.cloud.stream.app.httpclient.processor

Configuration properties for the Http Client Processor module.

HttpclientProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

HttpSourceConfiguration - Class in org.springframework.cloud.stream.app.http.source

A source module that listens for HTTP requests and emits the body as a message payload.

HttpSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.http.source.HttpSourceConfiguration

I

inetSocketAddressConverter() - Method in class org.springframework.cloud.stream.app.gemfire.config.InetSocketAddressConverterConfiguration

InetSocketAddressConverter() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.InetSocketAddressConverterConfiguration.InetSocketAddressConverter

InetSocketAddressConverterConfiguration - Class in org.springframework.cloud.stream.app.gemfire.config

InetSocketAddressConverterConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.config.InetSocketAddressConverterConfiguration

InetSocketAddressConverterConfiguration.InetSocketAddressConverter - Class in org.springframework.cloud.stream.app.gemfire.config

init() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraConfiguration.CassandraKeyspaceInitializerConfiguration

init() - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorConfiguration

init() - Method in class org.springframework.cloud.stream.app.websocket.sink.actuator.WebsocketSinkTraceEndpoint

init() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

init() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServer

initChannel(SocketChannel) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServerInitializer

initialize(DateFormat) - Method in class org.springframework.cloud.stream.app.time.DateFormat.DateFormatValidator

initializer() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

IntegrationTestProcessorConfiguration - Class in org.springframework.cloud.stream.app.integration.test.processor

A module that can misbehave, useful for integration testing of module deployers.

IntegrationTestProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorConfiguration

IntegrationTestProcessorProperties - Class in org.springframework.cloud.stream.app.integration.test.processor

Configuration properties for the IntegrationTestProcessor module.

IntegrationTestProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

invoke() - Method in class org.springframework.cloud.stream.app.websocket.sink.actuator.WebsocketSinkTraceEndpoint

isAllowNullValues() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

isAllowUnknownKeys() - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

isApplySequence() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

isAtMostOneBody() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

isAtMostOneModelName() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

isAutoCreateDir() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

isAutoCreateLocalDir() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

isAutoStartup() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

isAutoStartup() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

isAutoStartup() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

isBinary() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

isClose() - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

isCreateKeyspace() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

isDelete() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

isDeleteRemoteFiles() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

isDelimitersAllowed() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

isEnableRetry() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

isEnableSync() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

isExactlyOneUrl() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

isExclusiveOptions() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

isExclusiveOptions() - Method in class org.springframework.cloud.stream.app.counter.sink.CounterProperties

isExclusiveOptions() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

isExclusivePatterns() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

isExclusivePatterns() - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

isExpressionOrScriptValid() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

isFilePropsAllowed() - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

isFileUuid() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

isFormatHeader() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

isGenerateTimestamp() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

isIdleImap() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

isJson() - Method in class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkProperties

isKeeptable() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

isLoopback() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

isMarkAsRead() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

isMetricsEnabled() - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

isMutuallyExclusive() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

isMutuallyExclusive() - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

isMutuallyExclusiveAclAndAclExpression() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

isMutuallyExclusiveBucketAndBucketExpression() - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

isMutuallyExclusiveDirectoryAndDirectoryExpression() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

isMutuallyExclusiveNameAndNameExpression() - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

isNio() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

isNio() - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

isOverwrite() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

isPointToPoint() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

isPreserveTimestamp() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

isPreventDuplicates() - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

isResolutionRequired() - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

isReverseLookup() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

isReverseLookup() - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

isRoutingKeyProvided() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

isRunning() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

isRunning() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

isRunning() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

isRunning() - Method in class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkConfiguration

isSessionTransacted() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

isSingleton() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFileFactoryBean

isSingleton() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

isSingleton() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

isSingleton() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

isSingleton() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

isSplit() - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

isSsl() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

isSubscriptionEnabled() - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

isSupportedProtocol() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

isSupportedRfc() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

isTopic() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

isUseDirectBuffers() - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

isUseTemporaryFilename() - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

isValid(CharSequence, ConstraintValidatorContext) - Method in class org.springframework.cloud.stream.app.time.DateFormat.DateFormatValidator

isWithMarkersValid() - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

J

JdbcCommands - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Utility class helping to execute jdbc operations within a load session.

JdbcCommands(JdbcTemplate) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

jdbcMessageHandler(DataSource) - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration

jdbcMessageSource() - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceConfiguration

JdbcSinkConfiguration - Class in org.springframework.cloud.stream.app.jdbc.sink

A module that writes its incoming payload to an RDBMS using JDBC.

JdbcSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration

JdbcSinkConfiguration.Nested - Class in org.springframework.cloud.stream.app.jdbc.sink

JdbcSinkProperties - Class in org.springframework.cloud.stream.app.jdbc.sink

Holds configuration properties for the Jdbc Sink module.

JdbcSinkProperties() - Constructor for class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

JdbcSourceConfiguration - Class in org.springframework.cloud.stream.app.jdbc.source

A module that reads data from an RDBMS using JDBC and creates a payload with the data.

JdbcSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceConfiguration

JdbcSourceProperties - Class in org.springframework.cloud.stream.app.jdbc.source

Holds configuration properties for the Jdbc Source module.

JdbcSourceProperties() - Constructor for class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

JmsSourceConfiguration - Class in org.springframework.cloud.stream.app.jms.source

A source that receives messages from JMS.

JmsSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.jms.source.JmsSourceConfiguration

JmsSourceProperties - Class in org.springframework.cloud.stream.app.jms.source

Properties for the JMS Source.

JmsSourceProperties() - Constructor for class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

JSON_CONVERTER - Static variable in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

jsonConverter() - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkConfiguration

JsonObjectTransformer - Class in org.springframework.cloud.stream.app.gemfire

JsonObjectTransformer() - Constructor for class org.springframework.cloud.stream.app.gemfire.JsonObjectTransformer

K

keyExpression() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

KeyInterestConfiguration - Class in org.springframework.cloud.stream.app.gemfire.source

The default client cache configuration is to receive events for all keys.

KeyInterestConfiguration() - Constructor for class org.springframework.cloud.stream.app.gemfire.source.KeyInterestConfiguration

L

listener() - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceConfiguration

load() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.DefaultGreenplumLoad

load(RuntimeContext) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.DefaultGreenplumLoad

load(LoadConfiguration) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.DefaultLoadService

load(LoadConfiguration, RuntimeContext) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.DefaultLoadService

load() - Method in interface org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumLoad

load(RuntimeContext) - Method in interface org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumLoad

load(LoadConfiguration) - Method in interface org.springframework.cloud.stream.app.gpfdist.sink.support.LoadService

load(LoadConfiguration, RuntimeContext) - Method in interface org.springframework.cloud.stream.app.gpfdist.sink.support.LoadService

load(LoadConfiguration, String) - Static method in class org.springframework.cloud.stream.app.gpfdist.sink.support.SqlUtils

Builds sql clause to load data into a database.

LoadConfiguration - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

LoadConfiguration() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

LoadConfiguration(String, String, ReadableTable, Mode, List<String>, List<String>, String) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

LoadConfigurationFactoryBean - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

FactoryBean creating instances of a LoadConfiguration.

LoadConfigurationFactoryBean() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

LoadFactoryBean - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

FactoryBean for easy creation and configuration of GreenplumLoad instances.

LoadFactoryBean() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

LoadGeneratorSourceConfiguration - Class in org.springframework.cloud.stream.app.load.generator.source

A source that sends a set amount of empty byte array messages to verify the speed of the infrastructure.

LoadGeneratorSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceConfiguration

LoadGeneratorSourceConfiguration.Producer - Class in org.springframework.cloud.stream.app.load.generator.source

LoadGeneratorSourceProperties - Class in org.springframework.cloud.stream.app.load.generator.source

Holds configuration options for the LoadGenerator source.

LoadGeneratorSourceProperties() - Constructor for class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

LoadService - Interface in org.springframework.cloud.stream.app.gpfdist.sink.support

LoggregatorMessageSource - Class in org.springframework.cloud.stream.app.loggregator.source

Spring Integration inbound adapter that publishes messages whenever a new Loggregator ApplicationLog log message is received.

LoggregatorMessageSource(String, CloudFoundryClient, MessageChannel) - Constructor for class org.springframework.cloud.stream.app.loggregator.source.LoggregatorMessageSource

loggregatorMessageSource(MessageChannel, CloudFoundryClient) - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorSourceConfiguration

LoggregatorMessageSource.LoggregatorHeaders - Enum in org.springframework.cloud.stream.app.loggregator.source

LoggregatorProperties - Class in org.springframework.cloud.stream.app.loggregator.source

Configuration properties for the Loggregator Source module.

LoggregatorProperties() - Constructor for class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

LoggregatorSourceConfiguration - Class in org.springframework.cloud.stream.app.loggregator.source

A source that can be used to read logging messages from Loggregator.

LoggregatorSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.loggregator.source.LoggregatorSourceConfiguration

LogSinkConfiguration - Class in org.springframework.cloud.stream.app.log.sink

LogSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.log.sink.LogSinkConfiguration

logSinkHandler() - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkConfiguration

LogSinkProperties - Class in org.springframework.cloud.stream.app.log.sink

Configuration properties for the Log Sink app.

LogSinkProperties() - Constructor for class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

M

mailInboundFlow() - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceConfiguration

MailSourceConfiguration - Class in org.springframework.cloud.stream.app.mail.source

A source module that listens for mail and emits the content as a message payload.

MailSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.mail.source.MailSourceConfiguration

MailSourceProperties - Class in org.springframework.cloud.stream.app.mail.source

Configuration properties for the Mail Source module.

MailSourceProperties() - Constructor for class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

main(String[]) - Static method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkApplication

main(String[]) - Static method in enum org.springframework.cloud.stream.app.throughput.sink.TimeUnit

matches(TypeDescriptor, TypeDescriptor) - Method in class org.springframework.cloud.stream.app.jdbc.sink.ShorthandMapConverter

matches(TypeDescriptor, TypeDescriptor) - Method in class org.springframework.cloud.stream.app.pmml.processor.GenericMapConverter

MAX_CONTENT_LENGTH - Static variable in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServerInitializer

messageHandler() - Method in class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkConfiguration

metricRepository() - Method in class org.springframework.cloud.stream.app.counter.sink.CounterSinkStoreConfiguration

Mode - Enum in org.springframework.cloud.stream.app.gpfdist.sink.support

N

Nested() - Constructor for class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration.Nested

NetworkUtils - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Various network utilities.

NetworkUtils() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.NetworkUtils

nextExecutionTime(TriggerContext) - Method in class org.springframework.cloud.stream.app.trigger.DateTrigger

nonBootDataSourceInitializer(DataSource, ResourceLoader) - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration

NOT_SET - Static variable in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration

O

onInit() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

onInit() - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

org.springframework.cloud.stream.app.aggregate.counter.sink - package org.springframework.cloud.stream.app.aggregate.counter.sink

org.springframework.cloud.stream.app.annotation - package org.springframework.cloud.stream.app.annotation

org.springframework.cloud.stream.app.bridge.processor - package org.springframework.cloud.stream.app.bridge.processor

org.springframework.cloud.stream.app.cassandra - package org.springframework.cloud.stream.app.cassandra

org.springframework.cloud.stream.app.cassandra.sink - package org.springframework.cloud.stream.app.cassandra.sink

org.springframework.cloud.stream.app.counter.sink - package org.springframework.cloud.stream.app.counter.sink

org.springframework.cloud.stream.app.field.value.counter.sink - package org.springframework.cloud.stream.app.field.value.counter.sink

org.springframework.cloud.stream.app.file - package org.springframework.cloud.stream.app.file

org.springframework.cloud.stream.app.file.remote - package org.springframework.cloud.stream.app.file.remote

org.springframework.cloud.stream.app.file.sink - package org.springframework.cloud.stream.app.file.sink

org.springframework.cloud.stream.app.file.source - package org.springframework.cloud.stream.app.file.source

org.springframework.cloud.stream.app.filter.processor - package org.springframework.cloud.stream.app.filter.processor

org.springframework.cloud.stream.app.ftp - package org.springframework.cloud.stream.app.ftp

org.springframework.cloud.stream.app.ftp.sink - package org.springframework.cloud.stream.app.ftp.sink

org.springframework.cloud.stream.app.ftp.source - package org.springframework.cloud.stream.app.ftp.source

org.springframework.cloud.stream.app.gemfire - package org.springframework.cloud.stream.app.gemfire

org.springframework.cloud.stream.app.gemfire.config - package org.springframework.cloud.stream.app.gemfire.config

org.springframework.cloud.stream.app.gemfire.cq.source - package org.springframework.cloud.stream.app.gemfire.cq.source

org.springframework.cloud.stream.app.gemfire.sink - package org.springframework.cloud.stream.app.gemfire.sink

org.springframework.cloud.stream.app.gemfire.source - package org.springframework.cloud.stream.app.gemfire.source

org.springframework.cloud.stream.app.gpfdist.sink - package org.springframework.cloud.stream.app.gpfdist.sink

org.springframework.cloud.stream.app.gpfdist.sink.support - package org.springframework.cloud.stream.app.gpfdist.sink.support

org.springframework.cloud.stream.app.groovy.filter.processor - package org.springframework.cloud.stream.app.groovy.filter.processor

org.springframework.cloud.stream.app.groovy.transform.processor - package org.springframework.cloud.stream.app.groovy.transform.processor

org.springframework.cloud.stream.app.hdfs.dataset.sink - package org.springframework.cloud.stream.app.hdfs.dataset.sink

org.springframework.cloud.stream.app.hdfs.sink - package org.springframework.cloud.stream.app.hdfs.sink

org.springframework.cloud.stream.app.http.source - package org.springframework.cloud.stream.app.http.source

org.springframework.cloud.stream.app.httpclient.processor - package org.springframework.cloud.stream.app.httpclient.processor

org.springframework.cloud.stream.app.integration.test.processor - package org.springframework.cloud.stream.app.integration.test.processor

org.springframework.cloud.stream.app.jdbc.sink - package org.springframework.cloud.stream.app.jdbc.sink

org.springframework.cloud.stream.app.jdbc.source - package org.springframework.cloud.stream.app.jdbc.source

org.springframework.cloud.stream.app.jms.source - package org.springframework.cloud.stream.app.jms.source

org.springframework.cloud.stream.app.load.generator.source - package org.springframework.cloud.stream.app.load.generator.source

org.springframework.cloud.stream.app.log.sink - package org.springframework.cloud.stream.app.log.sink

org.springframework.cloud.stream.app.loggregator.source - package org.springframework.cloud.stream.app.loggregator.source

org.springframework.cloud.stream.app.mail.source - package org.springframework.cloud.stream.app.mail.source

org.springframework.cloud.stream.app.pmml.processor - package org.springframework.cloud.stream.app.pmml.processor

org.springframework.cloud.stream.app.rabbit.sink - package org.springframework.cloud.stream.app.rabbit.sink

org.springframework.cloud.stream.app.rabbit.source - package org.springframework.cloud.stream.app.rabbit.source

org.springframework.cloud.stream.app.redis.sink - package org.springframework.cloud.stream.app.redis.sink

org.springframework.cloud.stream.app.router.sink - package org.springframework.cloud.stream.app.router.sink

org.springframework.cloud.stream.app.s3 - package org.springframework.cloud.stream.app.s3

org.springframework.cloud.stream.app.s3.sink - package org.springframework.cloud.stream.app.s3.sink

org.springframework.cloud.stream.app.s3.source - package org.springframework.cloud.stream.app.s3.source

org.springframework.cloud.stream.app.scriptable.transform.processor - package org.springframework.cloud.stream.app.scriptable.transform.processor

org.springframework.cloud.stream.app.sftp - package org.springframework.cloud.stream.app.sftp

org.springframework.cloud.stream.app.sftp.sink - package org.springframework.cloud.stream.app.sftp.sink

org.springframework.cloud.stream.app.sftp.source - package org.springframework.cloud.stream.app.sftp.source

org.springframework.cloud.stream.app.splitter.processor - package org.springframework.cloud.stream.app.splitter.processor

org.springframework.cloud.stream.app.syslog.source - package org.springframework.cloud.stream.app.syslog.source

org.springframework.cloud.stream.app.tcp - package org.springframework.cloud.stream.app.tcp

org.springframework.cloud.stream.app.tcp.sink - package org.springframework.cloud.stream.app.tcp.sink

org.springframework.cloud.stream.app.tcp.source - package org.springframework.cloud.stream.app.tcp.source

org.springframework.cloud.stream.app.throughput.sink - package org.springframework.cloud.stream.app.throughput.sink

org.springframework.cloud.stream.app.time - package org.springframework.cloud.stream.app.time

org.springframework.cloud.stream.app.time.source - package org.springframework.cloud.stream.app.time.source

org.springframework.cloud.stream.app.transform.processor - package org.springframework.cloud.stream.app.transform.processor

org.springframework.cloud.stream.app.trigger - package org.springframework.cloud.stream.app.trigger

org.springframework.cloud.stream.app.trigger.source - package org.springframework.cloud.stream.app.trigger.source

org.springframework.cloud.stream.app.twitter - package org.springframework.cloud.stream.app.twitter

org.springframework.cloud.stream.app.twitterstream.source - package org.springframework.cloud.stream.app.twitterstream.source

org.springframework.cloud.stream.app.websocket.sink - package org.springframework.cloud.stream.app.websocket.sink

org.springframework.cloud.stream.app.websocket.sink.actuator - package org.springframework.cloud.stream.app.websocket.sink.actuator

P

periodicTrigger() - Method in class org.springframework.cloud.stream.app.trigger.TriggerConfiguration

PmmlProcessorConfiguration - Class in org.springframework.cloud.stream.app.pmml.processor

A processor that evaluates a machine learning model stored in PMML format.

PmmlProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorConfiguration

PmmlProcessorProperties - Class in org.springframework.cloud.stream.app.pmml.processor

Holds configuration properties for the Pmml Processor module.

PmmlProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

PollableSource - Annotation Type in org.springframework.cloud.stream.app.annotation

The particular InboundChannelAdapter annotation case for Source modules whose logic is based on the poller.

pollingFlow() - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceConfiguration

process(Message<?>) - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkConfiguration

process(Message<?>) - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkConfiguration

process(Message<?>) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorConfiguration.HttpClientProcessor

processValue(String, Object) - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkConfiguration

Producer(int, Source, int, int) - Constructor for class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceConfiguration.Producer

publishTime() - Method in class org.springframework.cloud.stream.app.time.source.TimeSourceConfiguration

Q

queueExpression() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

R

RabbitSinkConfiguration - Class in org.springframework.cloud.stream.app.rabbit.sink

A sink module that sends data to RabbitMQ.

RabbitSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkConfiguration

RabbitSinkProperties - Class in org.springframework.cloud.stream.app.rabbit.sink

Properties for the Rabbit Sink.

RabbitSinkProperties() - Constructor for class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

RabbitSourceConfiguration - Class in org.springframework.cloud.stream.app.rabbit.source

A source module that receives data from RabbitMQ.

RabbitSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration

RabbitSourceProperties - Class in org.springframework.cloud.stream.app.rabbit.source

Properties for the Rabbit Source.

RabbitSourceProperties() - Constructor for class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

rabbitSourceRetryInterceptor() - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration

rabbitTemplate(ConnectionFactory) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkConfiguration

ReadableTable - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Settings for readable external table.

ReadableTable() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

ReadableTableFactoryBean - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

FactoryBean creating instances of a ReadableTable.

ReadableTableFactoryBean() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

reap() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.ReaperTask

ReaperTask() - Constructor for class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.ReaperTask

redisMetricRepository() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkStoreConfiguration

RedisSinkConfiguration - Class in org.springframework.cloud.stream.app.redis.sink

Creates a dedicated RedisConnectionFactory different from the one spring-boot autoconfigure section that the bindings use in spring-cloud-stream.

RedisSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.redis.sink.RedisSinkConfiguration

redisSinkMessageHandler() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkConfiguration

RedisSinkProperties - Class in org.springframework.cloud.stream.app.redis.sink

Used to configure those Redis Sink module options that are not related to connecting to Redis.

RedisSinkProperties() - Constructor for class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.cloud.stream.app.pmml.processor.CustomConversionServiceRegistrar

restTemplate() - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorConfiguration

retryOperations() - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkStoreConfiguration

retryOperations() - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkStoreConfiguration

router(BinderAwareChannelResolver, ScriptVariableGenerator, RouterSinkProperties) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkConfiguration

routerChannel() - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceConfiguration

routerChannel() - Method in class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceConfiguration

RouterSinkConfiguration - Class in org.springframework.cloud.stream.app.router.sink

A sink app that routes to one or more named channels.

RouterSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.router.sink.RouterSinkConfiguration

RouterSinkProperties - Class in org.springframework.cloud.stream.app.router.sink

Properties for the Router Sink; the router can use an expression or groovy script to return either a channel name, or a key to the channel mappings map.

RouterSinkProperties() - Constructor for class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

run() - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceConfiguration.Producer

run() - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter.StreamReadingTask

run() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServer

RuntimeContext - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Runtime context for load operations.

RuntimeContext() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.RuntimeContext

Instantiates a new runtime context.

RuntimeContext(String) - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.RuntimeContext

Instantiates a new runtime context.

S

s3InboundFileSynchronizer(AmazonS3, ResourceIdResolver) - Method in class org.springframework.cloud.stream.app.s3.source.AmazonS3SourceConfiguration

s3InboundFlow(FileConsumerProperties, S3InboundFileSynchronizer) - Method in class org.springframework.cloud.stream.app.s3.source.AmazonS3SourceConfiguration

ScriptableTransformProcessorConfiguration - Class in org.springframework.cloud.stream.app.scriptable.transform.processor

A Processor module that transforms messages using a supplied script.

ScriptableTransformProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorConfiguration

ScriptableTransformProcessorProperties - Class in org.springframework.cloud.stream.app.scriptable.transform.processor

Configuration properties for the Scriptable Transform Processor module.

ScriptableTransformProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

scriptProcessor(ScriptVariableGenerator, RouterSinkProperties) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkConfiguration

scriptVariableGenerator() - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.ScriptVariableGeneratorConfiguration

scriptVariableGenerator() - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.ScriptVariableGeneratorConfiguration

scriptVariableGenerator() - Method in class org.springframework.cloud.stream.app.router.sink.ScriptVariableGeneratorConfiguration

scriptVariableGenerator() - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptVariableGeneratorConfiguration

ScriptVariableGeneratorConfiguration - Class in org.springframework.cloud.stream.app.groovy.filter.processor

Configuration that provides a ScriptVariableGenerator to customize a script.

ScriptVariableGeneratorConfiguration() - Constructor for class org.springframework.cloud.stream.app.groovy.filter.processor.ScriptVariableGeneratorConfiguration

ScriptVariableGeneratorConfiguration - Class in org.springframework.cloud.stream.app.groovy.transform.processor

Configuration that provides a ScriptVariableGenerator to customize a script.

ScriptVariableGeneratorConfiguration() - Constructor for class org.springframework.cloud.stream.app.groovy.transform.processor.ScriptVariableGeneratorConfiguration

ScriptVariableGeneratorConfiguration - Class in org.springframework.cloud.stream.app.router.sink

Configuration that provides a ScriptVariableGenerator to customize a script.

ScriptVariableGeneratorConfiguration() - Constructor for class org.springframework.cloud.stream.app.router.sink.ScriptVariableGeneratorConfiguration

ScriptVariableGeneratorConfiguration - Class in org.springframework.cloud.stream.app.scriptable.transform.processor

Configuration that provides a ScriptVariableGenerator to customize a script.

ScriptVariableGeneratorConfiguration() - Constructor for class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptVariableGeneratorConfiguration

SegmentRejectType - Enum in org.springframework.cloud.stream.app.gpfdist.sink.support

Enumeration of a possible values in a clause section `SEGMENT REJECT LIMIT count [ROWS | PERCENT]`

server() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

setAccessToken(String) - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

setAccessTokenSecret(String) - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

setAcl(CannedAccessControlList) - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

setAclExpression(Expression) - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

setAfterSqls(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

setAllowNullValues(boolean) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setAllowUnknownKeys(boolean) - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.cloud.stream.app.tcp.EncoderDecoderFactoryBean

setApplicationName(String) - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

setApplySequence(boolean) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

setAutoCreateDir(boolean) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

setAutoCreateLocalDir(boolean) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

setAutoStartup(boolean) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

Sets the auto startup.

setAutoStartup(boolean) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setBatchCount(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setBatchPeriod(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setBatchSize(int) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setBatchTimeout(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setBeanFactory(BeanFactory) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setBeforeSqls(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

setBinary(boolean) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setBody(Object) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setBodyExpression(Expression) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setBucket(String) - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

setBucketExpression(Expression) - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

setBufferSize(int) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setBufferSize(int) - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceProperties

setCacheEventExpression(Expression) - Method in class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceProperties

setCacheSessions(Boolean) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

setCharset(String) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setCharset(String) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setCharset(String) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

setCharset(String) - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

setCleanSql(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

setClientId(String) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setClientMode(FtpSessionFactoryProperties.ClientMode) - Method in class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties

setClose(boolean) - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

setCloseTimeout(long) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setCloudFoundryApi(String) - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

setCloudFoundryPassword(String) - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

setCloudFoundryUser(String) - Method in class org.springframework.cloud.stream.app.loggregator.source.LoggregatorProperties

setCodec(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setColumnDelimiter(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setColumns(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setColumns(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setColumns(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setColumns(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setColumns(Map<String, String>) - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

setCompressionType(CompressionType) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setCompressionType(String) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setConfiguration(Configuration) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setConnectTimeout(int) - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

The connection timeout for making a connection to Twitter.

setConnectType(GemfirePoolProperties.ConnectType) - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

setConsistencyLevel(ConsistencyLevel) - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

setConsumerKey(String) - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

setConsumerSecret(String) - Method in class org.springframework.cloud.stream.app.twitter.TwitterCredentials

setContactPoints(String) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setControlFile(Resource) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setControlFile(ControlFile) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

setControlFile(ControlFile) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setControlFile(ControlFile) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setControlFileResource(Resource) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFileFactoryBean

setConverterBeanName(String) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setCqEventExpression(Expression) - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceProperties

setCreateKeyspace(boolean) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setCron(String) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setCsvFormat() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setCsvFormat(Character, Character, String, String[], Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setDatabase(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setDataSource(DataSource) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

setDataStoreWriter(DataStoreWriter<String>) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

setDate(String) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setDateFormat(String) - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

setDateFormat(String) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setDbHost(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setDbHost(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

setDbName(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setDbName(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

setDbPassword(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setDbPassword(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

setDbPort(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setDbPort(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

setDbUser(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setDbUser(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.GreenplumDataSourceFactoryBean

setDecoder(AbstractTcpConnectionFactoryProperties.Encoding) - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceProperties

setDefaultOutputChannel(String) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setDelete(boolean) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setDeleteRemoteFiles(boolean) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

setDelimiter(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setDelimiter(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setDelimiter(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setDelimiters(String) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

setDestination(String) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setDestinationMappings(Properties) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setDirectory(String) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setDirectory(String) - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

setDirectory(String) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setDirectory(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setDirectoryExpression(Expression) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setEnabled(boolean) - Method in class org.springframework.cloud.stream.app.websocket.sink.actuator.WebsocketSinkTraceEndpoint

setEnableRetry(boolean) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setEnableSync(boolean) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setEncoder(AbstractTcpConnectionFactoryProperties.Encoding) - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

setEncoding(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setEntityBasePackages(String[]) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setErrorTable(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setEscape(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setEscape(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setExchange(String) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setExchangeExpression(Expression) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setExpectedResponseType(Class<?>) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setExpression(Expression) - Method in class org.springframework.cloud.stream.app.filter.processor.FilterProcessorProperties

setExpression(String) - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

setExpression(String) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setExpression(Expression) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setExpression(Expression) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

setExpression(Expression) - Method in class org.springframework.cloud.stream.app.transform.processor.TransformProcessorProperties

setExternalTable(ReadableTable) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setExternalTable(ReadableTable) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setFieldName(String) - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

setFileExtension(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setFileMarkers(Boolean) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

setFileName(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setFilenameExpression(Expression) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

setFilenamePattern(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

setFilenamePattern(String) - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

setFilenameRegex(Pattern) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

setFilenameRegex(Pattern) - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

setFileOpenAttempts(int) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setFileUuid(boolean) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setFixedDelay(int) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setFlushCount(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setFlushTime(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setFlushTimeout(long) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setForceQuote(String[]) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setForceQuote(String[]) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setFormat(Format) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setFormat(String) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setFormatHeader(boolean) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

setFsUri(String) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setFsUri(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setGenerateTimestamp(boolean) - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

setGpfdistPort(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setGploadInputDelimiter(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setGploadOutputMatchColumns(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setGploadOutputMode(ControlFile.OutputMode) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setGploadOutputTable(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setGploadOutputUpdateColumns(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setGploadOutputUpdateCondition(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setGreenplumLoad(GreenplumLoad) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

Sets the greenplum load.

setHeadersExpression(Expression) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setHost(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

setHost(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setHost(String) - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

setHostAddresses(InetSocketAddress[]) - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

setHttpMethod(HttpMethod) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setIdleImap(boolean) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setIdleTimeout(long) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setIdleTimeout(long) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setIncrementExpression(Expression) - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

setIngestQuery(String) - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

setInitDelay(int) - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

setInitialDelay(int) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setInitialize(String) - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

setInitialRetryInterval(int) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setInitScript(Resource) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setInputs(Map<String, Expression>) - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

setInUsePrefix(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setInUseSuffix(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setJavaMailProperties(Properties) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setJdbcTemplate(JdbcTemplate) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

setJson(boolean) - Method in class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkProperties

setKeeptable(boolean) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setKey(String) - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

setKeyExpression(String) - Method in class org.springframework.cloud.stream.app.gemfire.sink.GemfireSinkProperties

setKeyExpression(Expression) - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

setKeyExpression(Expression) - Method in class org.springframework.cloud.stream.app.s3.sink.AmazonS3SinkProperties

setKeyspace(String) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setKillDelay(int) - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

setKnownHostsExpression(String) - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

setLanguage(String) - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

setLanguage(String) - Method in class org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamProperties

setLevel(LoggingHandler.Level) - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

setLike(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setLike(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setLoadConfiguration(LoadConfiguration) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadFactoryBean

setLocalDir(File) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

setLocations(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setLocations(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setLocations(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.RuntimeContext

Sets the locations.

setLogErrorsInto(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

setLogErrorsInto(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Sets the log errors table.

setLogLevel(String) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

setLoopback(boolean) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

setMappedRequestHeaders(String[]) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setMappedRequestHeaders(String[]) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setMarkAsRead(boolean) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setMarkersJson(boolean) - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

setMarkersJson(boolean) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

setMatchColumns(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setMatchColumns(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setMatchColumns(String[]) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setMatchInstances(Set<Integer>) - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

setMatchInterface(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

setMatchIpv4(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

setMaxAttempts(int) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setMaxMessages(long) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setMaxMessageSize(int) - Method in class org.springframework.cloud.stream.app.tcp.EncoderDecoderFactoryBean

The maximum message size allowed when decoding.

setMaxRetryInterval(int) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setMaxRowsPerPoll(int) - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

setMessageCount(int) - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

setMessageSelector(String) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setMessageSize(int) - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

setMetricsEnabled(boolean) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setMode(FileReadingMode) - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

setMode(FileExistsMode) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

setMode(FileExistsMode) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setMode(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setMode(Mode) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setMode(Mode) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setModelLocation(Resource) - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

setModelName(String) - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

setModelNameExpression(Expression) - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

setName(String) - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

setName(String) - Method in class org.springframework.cloud.stream.app.counter.sink.CounterProperties

setName(String) - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

setName(String) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setName(String) - Method in class org.springframework.cloud.stream.app.log.sink.LogSinkProperties

setNameExpression(Expression) - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

setNameExpression(Expression) - Method in class org.springframework.cloud.stream.app.counter.sink.CounterProperties

setNameExpression(Expression) - Method in class org.springframework.cloud.stream.app.field.value.counter.sink.FieldValueCounterSinkProperties

setNameExpression(String) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setNamespace(String) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setNio(boolean) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setNio(boolean) - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

setNullString(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setNullString(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setNullString(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setOutputs(Map<String, Expression>) - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorProperties

setOverwrite(boolean) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setParameterThatMayNeedEscaping(String) - Method in class org.springframework.cloud.stream.app.integration.test.processor.IntegrationTestProcessorProperties

setPartitionPath(String) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

setPartitionPath(String) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setPassPhrase(String) - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

setPassword(String) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setPassword(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

setPassword(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setPath(String) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

setPayload(Expression) - Method in class org.springframework.cloud.stream.app.trigger.SourcePayloadProperties

setPersistentDeliveryMode(boolean) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setPhase(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

Sets the phase.

setPhase(int) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setPointToPoint(boolean) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

setPort(int) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setPort(int) - Method in class org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties

setPort(Integer) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setPort(int) - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

setPort(int) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setPort(int) - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

setPort(int) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

setPreferInterface(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.HostInfoDiscoveryProperties

setPrepareSql(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

setPreserveTimestamp(boolean) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSourceProperties

setPreventDuplicates(boolean) - Method in class org.springframework.cloud.stream.app.file.source.FileSourceProperties

setPrivateKey(String) - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

setProducers(int) - Method in class org.springframework.cloud.stream.app.load.generator.source.LoadGeneratorSourceProperties

setProperties(HdfsSinkProperties) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setProtocol(String) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setQuery(String) - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceProperties

setQuery(String) - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

setQueryType(CassandraMessageHandler.Type) - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

setQueue(String) - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

setQueueExpression(Expression) - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

setQueues(String[]) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setQuote(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setQuote(Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

setRateInterval(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

Sets the rate interval.

setRateInterval(int) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setReadTimeout(int) - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

The read timeout for the underlying URLConnection to the twitter stream.

setRefreshDelay(int) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setRegionName(String) - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfireRegionProperties

setRemoteDir(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

setRemoteFileSeparator(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

setReplyExpression(Expression) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setReportEveryMs(int) - Method in class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkProperties

setRequeue(boolean) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setResolutionRequired(boolean) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setRetryMultiplier(double) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setRetryPolicy(RetryPolicy) - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

setReverseLookup(boolean) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setReverseLookup(boolean) - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

setRfc(String) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setRollover(int) - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

setRoutingKey(String) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setRoutingKeyExpression(Expression) - Method in class org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkProperties

setRunSql(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.JdbcCommands

setSchemaAction(SchemaAction) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setScript(Resource) - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

setScript(Resource) - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

setScript(Resource) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setScript(String) - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

setSegmentReject(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Sets the segment reject as a string.

setSegmentRejectLimit(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setSegmentRejectLimit(Integer) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

setSegmentRejectLimit(Integer) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Sets the segment reject limit.

setSegmentRejectType(SegmentRejectType) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setSegmentRejectType(SegmentRejectType) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTable

setSegmentRejectType(SegmentRejectType) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ReadableTableFactoryBean

Sets the segment reject type.

setSessionTransacted(boolean) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setSocketTimeout(int) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

setSocketTimeout(int) - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

setSpelConverter(SpelExpressionConverterConfiguration.SpelConverter) - Method in class org.springframework.cloud.stream.app.pmml.processor.CustomConversionServiceRegistrar.CustomDefaultConversionService

setSplit(boolean) - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

setSqlAfter(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setSqlAfter(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setSqlAfter(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setSqlBefore(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setSqlBefore(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setSqlBefore(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setSqlTaskScheduler(TaskScheduler) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistMessageHandler

Sets the sql task scheduler.

setSsl(boolean) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

setStatementExpression(Expression) - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

setStreamType(TwitterStreamType) - Method in class org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamProperties

setSubscriptionDurable(Boolean) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setSubscriptionEnabled(boolean) - Method in class org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties

setSubscriptionName(String) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setSubscriptionShared(Boolean) - Method in class org.springframework.cloud.stream.app.jms.source.JmsSourceProperties

setSuffix(String) - Method in class org.springframework.cloud.stream.app.file.sink.FileSinkProperties

setTable(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setTable(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setTable(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setTableName(String) - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkProperties

setTaskExecutor(TaskExecutor) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setTaskScheduler(TaskScheduler) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

setTemporaryRemoteDir(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

setTextFormat() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setTextFormat(Character, String, Character) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.AbstractExternalTable

setThreads(int) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

setTimeField(Expression) - Method in class org.springframework.cloud.stream.app.aggregate.counter.sink.AggregateCounterSinkProperties

setTimeUnit(TimeUnit) - Method in interface org.springframework.cloud.stream.app.trigger.TriggerProperties

setTmpFileSuffix(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileProperties

setTopic(String) - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

setTopicExpression(Expression) - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

setTransacted(boolean) - Method in class org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

setTtl(int) - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkProperties

setUp() - Method in class org.springframework.cloud.stream.app.pmml.processor.PmmlProcessorConfiguration

setUpdate(String) - Method in class org.springframework.cloud.stream.app.jdbc.source.JdbcSourceProperties

setUpdateColumns(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkProperties

setUpdateColumns(List<String>) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setUpdateColumns(String[]) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setUpdateCondition(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfiguration

setUpdateCondition(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.LoadConfigurationFactoryBean

setUrl(String) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setUrl(URLName) - Method in class org.springframework.cloud.stream.app.mail.source.MailSourceProperties

setUrlExpression(Expression) - Method in class org.springframework.cloud.stream.app.httpclient.processor.HttpclientProcessorProperties

setUseDirectBuffers(boolean) - Method in class org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties

setUser(String) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile

setUsername(String) - Method in class org.springframework.cloud.stream.app.cassandra.CassandraProperties

setUsername(String) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteServerProperties

setUseTemporaryFilename(boolean) - Method in class org.springframework.cloud.stream.app.file.remote.AbstractRemoteFileSinkProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setVariables(Properties) - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.groovy.filter.processor.GroovyFilterProcessorProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.router.sink.RouterSinkProperties

setVariablesLocation(Resource) - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorProperties

setWithMarkers(Boolean) - Method in class org.springframework.cloud.stream.app.file.FileConsumerProperties

setWriterCacheSize(int) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkProperties

sftpInboundFlow(SessionFactory<ChannelSftp.LsEntry>, SftpSourceProperties, FileConsumerProperties) - Method in class org.springframework.cloud.stream.app.sftp.source.SftpSourceConfiguration

sftpSessionFactory(SftpSessionFactoryProperties) - Method in class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryConfiguration

SftpSessionFactoryConfiguration - Class in org.springframework.cloud.stream.app.sftp

SFTP Session factory configuration.

SftpSessionFactoryConfiguration() - Constructor for class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryConfiguration

SftpSessionFactoryProperties - Class in org.springframework.cloud.stream.app.sftp

SftpSessionFactoryProperties() - Constructor for class org.springframework.cloud.stream.app.sftp.SftpSessionFactoryProperties

SftpSinkConfiguration - Class in org.springframework.cloud.stream.app.sftp.sink

SftpSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.sftp.sink.SftpSinkConfiguration

SftpSinkProperties - Class in org.springframework.cloud.stream.app.sftp.sink

SftpSinkProperties() - Constructor for class org.springframework.cloud.stream.app.sftp.sink.SftpSinkProperties

SftpSourceConfiguration - Class in org.springframework.cloud.stream.app.sftp.source

SftpSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.sftp.source.SftpSourceConfiguration

SftpSourceProperties - Class in org.springframework.cloud.stream.app.sftp.source

SftpSourceProperties() - Constructor for class org.springframework.cloud.stream.app.sftp.source.SftpSourceProperties

shorthandMapConverter() - Method in class org.springframework.cloud.stream.app.jdbc.sink.JdbcSinkConfiguration.Nested

ShorthandMapConverter - Class in org.springframework.cloud.stream.app.jdbc.sink

A Converter from String to Map that accepts csv key:value pairs (similar to what comes out of the box in Spring Core) but also simple key items, in which case the value is assumed to be equal to the key.

ShorthandMapConverter() - Constructor for class org.springframework.cloud.stream.app.jdbc.sink.ShorthandMapConverter

shutdown() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServer

SourcePayloadProperties - Class in org.springframework.cloud.stream.app.trigger

SourcePayloadProperties() - Constructor for class org.springframework.cloud.stream.app.trigger.SourcePayloadProperties

splitterHandler(SplitterProcessorProperties) - Method in class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorConfiguration

SplitterProcessorConfiguration - Class in org.springframework.cloud.stream.app.splitter.processor

A Processor app that splits messages into component parts.

SplitterProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorConfiguration

SplitterProcessorProperties - Class in org.springframework.cloud.stream.app.splitter.processor

Configuration properties for the Splitter Processor app.

SplitterProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.splitter.processor.SplitterProcessorProperties

sqlTaskScheduler() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistSinkConfiguration

SqlUtils - Class in org.springframework.cloud.stream.app.gpfdist.sink.support

Utilities creating various types of sql clauses needed with gpfdist.

SqlUtils() - Constructor for class org.springframework.cloud.stream.app.gpfdist.sink.support.SqlUtils

start() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

start() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistServer

Start a server.

start() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

start() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

start() - Method in class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkConfiguration

startFlow() - Method in class org.springframework.cloud.stream.app.gemfire.cq.source.GemfireCqSourceConfiguration

startFlow() - Method in class org.springframework.cloud.stream.app.gemfire.source.GemfireSourceConfiguration

stop() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

stop(Runnable) - Method in class org.springframework.cloud.stream.app.gpfdist.sink.AbstractGpfdistMessageHandler

stop() - Method in class org.springframework.cloud.stream.app.gpfdist.sink.GpfdistServer

Stop a server.

stop(Runnable) - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

stop() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration.FsShutdown

stop() - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

stop(Runnable) - Method in class org.springframework.cloud.stream.app.hdfs.sink.DataStoreWriterFactoryBean

stop() - Method in class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkConfiguration

StreamReadingTask() - Constructor for class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter.StreamReadingTask

SupportsShorthands - Annotation Type in org.springframework.cloud.stream.app.jdbc.sink

This annotation, when set on a Map field or setter, instructs the conversion service to use the special ShorthandMapConverter.

syslogConverter() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration

SyslogSourceConfiguration - Class in org.springframework.cloud.stream.app.syslog.source

A source app that receives Syslog data.

SyslogSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration

SyslogSourceConfiguration.BothBits - Class in org.springframework.cloud.stream.app.syslog.source

SyslogSourceConfiguration.TcpBits - Class in org.springframework.cloud.stream.app.syslog.source

syslogSourceConnectionFactory(Deserializer<?>) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration.TcpBits

syslogSourceDecoder() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration.TcpBits

SyslogSourceProperties - Class in org.springframework.cloud.stream.app.syslog.source

Properties for the Syslog Source.

SyslogSourceProperties() - Constructor for class org.springframework.cloud.stream.app.syslog.source.SyslogSourceProperties

T

taskExecutor() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

taskScheduler() - Method in class org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

tcpAdapter(AbstractServerConnectionFactory) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration

TcpBits() - Constructor for class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration.TcpBits

tcpBothAdapter(AbstractServerConnectionFactory) - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration

TcpSinkConfiguration - Class in org.springframework.cloud.stream.app.tcp.sink

A sink application that sends data over TCP.

TcpSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.tcp.sink.TcpSinkConfiguration

tcpSinkConnectionFactory(AbstractByteArraySerializer, TcpMessageMapper) - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkConfiguration

tcpSinkEncoder() - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkConfiguration

tcpSinkMapper() - Method in class org.springframework.cloud.stream.app.tcp.sink.TcpSinkConfiguration

TcpSinkProperties - Class in org.springframework.cloud.stream.app.tcp.sink

Properties for the TCP Sink.

TcpSinkProperties() - Constructor for class org.springframework.cloud.stream.app.tcp.sink.TcpSinkProperties

TcpSourceConfiguration - Class in org.springframework.cloud.stream.app.tcp.source

A source module that receives data over TCP.

TcpSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.tcp.source.TcpSourceConfiguration

tcpSourceConnectionFactory(AbstractByteArraySerializer) - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceConfiguration

tcpSourceDecoder() - Method in class org.springframework.cloud.stream.app.tcp.source.TcpSourceConfiguration

TcpSourceProperties - Class in org.springframework.cloud.stream.app.tcp.source

Properties for the TCP Source.

TcpSourceProperties() - Constructor for class org.springframework.cloud.stream.app.tcp.source.TcpSourceProperties

throughputSink(Message<?>) - Method in class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkConfiguration

ThroughputSinkConfiguration - Class in org.springframework.cloud.stream.app.throughput.sink

A simple handler that will count messages and log witnessed throughput at some interval.

ThroughputSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkConfiguration

ThroughputSinkProperties - Class in org.springframework.cloud.stream.app.throughput.sink

Holds configuration options for the throughput Sink.

ThroughputSinkProperties() - Constructor for class org.springframework.cloud.stream.app.throughput.sink.ThroughputSinkProperties

TimeSourceConfiguration - Class in org.springframework.cloud.stream.app.time.source

TimeSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.time.source.TimeSourceConfiguration

TimeUnit - Enum in org.springframework.cloud.stream.app.throughput.sink

Helps with conversion between units of time.

toObject(String) - Method in class org.springframework.cloud.stream.app.gemfire.JsonObjectTransformer

topicExpression() - Method in class org.springframework.cloud.stream.app.redis.sink.RedisSinkProperties

toSink() - Method in class org.springframework.cloud.stream.app.cassandra.sink.CassandraSinkConfiguration

toSink() - Method in class org.springframework.cloud.stream.app.hdfs.dataset.sink.HdfsDatasetSinkConfiguration

toString(Object) - Method in class org.springframework.cloud.stream.app.gemfire.JsonObjectTransformer

transform(Message<?>) - Method in class org.springframework.cloud.stream.app.transform.processor.TransformProcessorConfiguration

transformer() - Method in class org.springframework.cloud.stream.app.groovy.transform.processor.GroovyTransformProcessorConfiguration

transformer() - Method in class org.springframework.cloud.stream.app.scriptable.transform.processor.ScriptableTransformProcessorConfiguration

TransformProcessorConfiguration - Class in org.springframework.cloud.stream.app.transform.processor

A Processor app that transforms messages using a SpEL expression.

TransformProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.app.transform.processor.TransformProcessorConfiguration

TransformProcessorProperties - Class in org.springframework.cloud.stream.app.transform.processor

Configuration properties for the Transform Processor module.

TransformProcessorProperties() - Constructor for class org.springframework.cloud.stream.app.transform.processor.TransformProcessorProperties

TRIGGER_BEAN_NAME - Static variable in class org.springframework.cloud.stream.app.trigger.TriggerConstants

TriggerConfiguration - Class in org.springframework.cloud.stream.app.trigger

TriggerConfiguration() - Constructor for class org.springframework.cloud.stream.app.trigger.TriggerConfiguration

TriggerConstants - Class in org.springframework.cloud.stream.app.trigger

TriggerConstants() - Constructor for class org.springframework.cloud.stream.app.trigger.TriggerConstants

TriggerProperties - Interface in org.springframework.cloud.stream.app.trigger

triggerSource() - Method in class org.springframework.cloud.stream.app.trigger.source.TriggerSourceConfiguration

TriggerSourceConfiguration - Class in org.springframework.cloud.stream.app.trigger.source

Trigger source module.

TriggerSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.trigger.source.TriggerSourceConfiguration

TwitterCredentials - Class in org.springframework.cloud.stream.app.twitter

Twitter credentials.

TwitterCredentials() - Constructor for class org.springframework.cloud.stream.app.twitter.TwitterCredentials

twitterStream(TwitterTemplate) - Method in class org.springframework.cloud.stream.app.twitterstream.source.TwitterstreamSourceConfiguration

TwitterStreamProperties - Class in org.springframework.cloud.stream.app.twitterstream.source

Configuration properties for Twitterstream source.

TwitterStreamProperties() - Constructor for class org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamProperties

TwitterstreamSourceConfiguration - Class in org.springframework.cloud.stream.app.twitterstream.source

TwitterStream source app.

TwitterstreamSourceConfiguration() - Constructor for class org.springframework.cloud.stream.app.twitterstream.source.TwitterstreamSourceConfiguration

TwitterStreamType - Enum in org.springframework.cloud.stream.app.twitterstream.source

Twitter stream types.

twitterTemplate() - Method in class org.springframework.cloud.stream.app.twitterstream.source.TwitterstreamSourceConfiguration

U

udpAdapter() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration

udpBothAdapter() - Method in class org.springframework.cloud.stream.app.syslog.source.SyslogSourceConfiguration

V

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.file.FileReadingMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties.ClientMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties.ConnectType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile.OutputMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.Format

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.SegmentRejectType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.loggregator.source.LoggregatorMessageSource.LoggregatorHeaders

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties.Encoding

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.throughput.sink.TimeUnit

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.springframework.cloud.stream.app.file.FileReadingMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.ftp.FtpSessionFactoryProperties.ClientMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.gemfire.config.GemfirePoolProperties.ConnectType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.ControlFile.OutputMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.Format

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.gpfdist.sink.support.SegmentRejectType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.loggregator.source.LoggregatorMessageSource.LoggregatorHeaders

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.tcp.AbstractTcpConnectionFactoryProperties.Encoding

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.throughput.sink.TimeUnit

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.springframework.cloud.stream.app.twitterstream.source.TwitterStreamType

Returns an array containing the constants of this enum type, in the order they are declared.

W

wait(int) - Method in class org.springframework.cloud.stream.app.twitterstream.source.AbstractTwitterInboundChannelAdapter

websocketSink(Message<?>) - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

WebsocketSinkConfiguration - Class in org.springframework.cloud.stream.app.websocket.sink

WebsocketSinkConfiguration() - Constructor for class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

WebsocketSinkProperties - Class in org.springframework.cloud.stream.app.websocket.sink

Command line arguments available for WebsocketSinkConfiguration.

WebsocketSinkProperties() - Constructor for class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkProperties

WebsocketSinkServer - Class in org.springframework.cloud.stream.app.websocket.sink

Bootstraps a Netty server using the WebsocketSinkServerInitializer.

WebsocketSinkServer() - Constructor for class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServer

WebsocketSinkServerInitializer - Class in org.springframework.cloud.stream.app.websocket.sink

Does some basic initialization and setup.

WebsocketSinkServerInitializer(TraceRepository) - Constructor for class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkServerInitializer

WebsocketSinkTraceEndpoint - Class in org.springframework.cloud.stream.app.websocket.sink.actuator

simple Endpoint implementation that provides access to Websocket messages last sent/received

WebsocketSinkTraceEndpoint(TraceRepository) - Constructor for class org.springframework.cloud.stream.app.websocket.sink.actuator.WebsocketSinkTraceEndpoint

websocketTraceEndpoint() - Method in class org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

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