Package org.apache.storm.sql.runtime
Class DataSourcesRegistry
java.lang.Object
org.apache.storm.sql.runtime.DataSourcesRegistry
-
Method Summary
Modifier 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
-
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.
-