Uses of Interface
org.apache.storm.sql.runtime.ISqlStreamsDataSource
-
-
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 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 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 Description ISqlStreamsDataSource
KafkaDataSourcesProvider. 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 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 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 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 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 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 Description ISqlStreamsDataSource
SocketDataSourcesProvider. constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
-