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

Packages that use ISqlStreamsDataSource

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

Uses of ISqlStreamsDataSource in org.apache.storm.sql

Methods in org.apache.storm.sql that return types with arguments of type ISqlStreamsDataSource

Modifier and Type	Method and Description
Map<String,ISqlStreamsDataSource>	StormSqlContext.getDataSources()

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

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

Modifier and Type	Method and Description
ISqlStreamsDataSource	HdfsDataSourcesProvider.constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)

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

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

Modifier and Type	Method and Description
ISqlStreamsDataSource	KafkaDataSourcesProvider.constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)

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

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

Modifier and Type	Method and Description
ISqlStreamsDataSource	MongoDataSourcesProvider.constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)

Uses of ISqlStreamsDataSource in org.apache.storm.sql.planner.streams

Methods in org.apache.storm.sql.planner.streams that return types with arguments of type ISqlStreamsDataSource

Modifier and Type	Method and Description
Map<String,ISqlStreamsDataSource>	StreamsPlanCreator.getSources()

Method parameters in org.apache.storm.sql.planner.streams with type arguments of type ISqlStreamsDataSource

Modifier and Type	Method and Description
AbstractStreamsProcessor	QueryPlanner.compile(Map<String,ISqlStreamsDataSource> sources, String query)

Constructor parameters in org.apache.storm.sql.planner.streams with type arguments of type ISqlStreamsDataSource

Constructor and Description
StreamsPlanCreator(Map<String,ISqlStreamsDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder)

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

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

Modifier and Type	Method and Description
ISqlStreamsDataSource	RedisDataSourcesProvider.constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties props, List<FieldInfo> fields)

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

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

Modifier and Type	Method and Description
ISqlStreamsDataSource	DataSourcesProvider.constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) Construct a new data source for streams mode.
static ISqlStreamsDataSource	DataSourcesRegistry.constructStreamsDataSource(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) Construct a streams data source.

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

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

Modifier and Type	Method and Description
ISqlStreamsDataSource	SocketDataSourcesProvider.constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)