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 ISqlStreamsDataSourceHdfsDataSourcesProvider. 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 ISqlStreamsDataSourceKafkaDataSourcesProvider. 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 AbstractStreamsProcessorQueryPlanner. 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 ISqlStreamsDataSourceRedisDataSourcesProvider. 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 ISqlStreamsDataSourceDataSourcesProvider. constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)Construct a new data source for streams mode.static ISqlStreamsDataSourceDataSourcesRegistry. 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 ISqlStreamsDataSourceSocketDataSourcesProvider. constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
-