Uses of Interface
org.apache.storm.sql.runtime.ISqlStreamsDataSource
Package
Description
-
Uses of ISqlStreamsDataSource in org.apache.storm.sql
-
Uses of ISqlStreamsDataSource in org.apache.storm.sql.hdfs
Modifier and TypeMethodDescriptionHdfsDataSourcesProvider.constructStreams
(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) -
Uses of ISqlStreamsDataSource in org.apache.storm.sql.kafka
Modifier and TypeMethodDescriptionKafkaDataSourcesProvider.constructStreams
(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) -
Uses of ISqlStreamsDataSource in org.apache.storm.sql.planner.streams
Modifier and TypeMethodDescriptionQueryPlanner.compile
(Map<String, ISqlStreamsDataSource> sources, String query) ModifierConstructorDescriptionStreamsPlanCreator
(Map<String, ISqlStreamsDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder) -
Uses of ISqlStreamsDataSource in org.apache.storm.sql.redis
Modifier and TypeMethodDescriptionRedisDataSourcesProvider.constructStreams
(URI uri, String inputFormatClass, String outputFormatClass, Properties props, List<FieldInfo> fields) -
Uses of ISqlStreamsDataSource in org.apache.storm.sql.runtime
Modifier and TypeMethodDescriptionDataSourcesProvider.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
Modifier and TypeMethodDescriptionSocketDataSourcesProvider.constructStreams
(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)