Package org.apache.storm.sql.runtime
Class DataSourcesRegistry
- java.lang.Object
-
- org.apache.storm.sql.runtime.DataSourcesRegistry
-
public class DataSourcesRegistry extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static ISqlStreamsDataSourceconstructStreamsDataSource(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)Construct a streams data source.static Map<String,DataSourcesProvider>providerMap()Allow unit tests to inject data sources.
-
-
-
Method Detail
-
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
public static Map<String,DataSourcesProvider> providerMap()
Allow unit tests to inject data sources.
-
-