Package org.apache.storm.sql.runtime
Class DataSourcesRegistry
java.lang.Object
org.apache.storm.sql.runtime.DataSourcesRegistry
-
Method Summary
Modifier and TypeMethodDescriptionstatic ISqlStreamsDataSource
constructStreamsDataSource
(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
-
constructStreamsDataSource
public static ISqlStreamsDataSource constructStreamsDataSource(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) Construct a streams data source.- Parameters:
uri
- data source uriinputFormatClass
- input format classoutputFormatClass
- output format classproperties
- Propertiesfields
- fields info list- Returns:
- StreamsDataSource object
-
providerMap
Allow unit tests to inject data sources.
-