Uses of Interface
org.apache.storm.sql.runtime.DataSource

Packages that use DataSource

Package	Description
org.apache.storm.sql.hdfs
org.apache.storm.sql.kafka
org.apache.storm.sql.mongodb
org.apache.storm.sql.redis
org.apache.storm.sql.runtime
org.apache.storm.sql.runtime.datasource.socket

Uses of DataSource in org.apache.storm.sql.hdfs

Methods in org.apache.storm.sql.hdfs that return DataSource

Modifier and Type	Method and Description
DataSource	HdfsDataSourcesProvider.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)

Uses of DataSource in org.apache.storm.sql.kafka

Methods in org.apache.storm.sql.kafka that return DataSource

Modifier and Type	Method and Description
DataSource	KafkaDataSourcesProvider.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)

Uses of DataSource in org.apache.storm.sql.mongodb

Methods in org.apache.storm.sql.mongodb that return DataSource

Modifier and Type	Method and Description
DataSource	MongoDataSourcesProvider.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)

Uses of DataSource in org.apache.storm.sql.redis

Methods in org.apache.storm.sql.redis that return DataSource

Modifier and Type	Method and Description
DataSource	RedisDataSourcesProvider.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)

Uses of DataSource in org.apache.storm.sql.runtime

Methods in org.apache.storm.sql.runtime that return DataSource

Modifier and Type	Method and Description
static DataSource	DataSourcesRegistry.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)
DataSource	DataSourcesProvider.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields) Construct a new data source.

Method parameters in org.apache.storm.sql.runtime with type arguments of type DataSource

Modifier and Type	Method and Description
abstract void	AbstractValuesProcessor.initialize(Map<String,DataSource> data, ChannelHandler result) Initialize the data sources.

Uses of DataSource in org.apache.storm.sql.runtime.datasource.socket

Methods in org.apache.storm.sql.runtime.datasource.socket that return DataSource

Modifier and Type	Method and Description
DataSource	SocketDataSourcesProvider.construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)