Package org.apache.storm.sql.runtime
Class DataSourcesRegistry
java.lang.Object
org.apache.storm.sql.runtime.DataSourcesRegistry
- 
Method SummaryModifier and TypeMethodDescriptionstatic ISqlStreamsDataSourceconstructStreamsDataSource(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) Construct a streams data source.static Map<String,DataSourcesProvider> Allow unit tests to inject data sources.
- 
Method Details- 
constructStreamsDataSourcepublic static ISqlStreamsDataSource constructStreamsDataSource(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) Construct a streams data source.- Parameters:
- uri- data source uri
- inputFormatClass- input format class
- outputFormatClass- output format class
- properties- Properties
- fields- fields info list
- Returns:
- StreamsDataSource object
 
- 
providerMapAllow unit tests to inject data sources.
 
-