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 ISqlStreamsDataSource` | `constructStreamsDataSource​(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.

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### 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 uri
        `inputFormatClass` - input format class
        `outputFormatClass` - output format class
        `properties` - Properties
        `fields` - fields info list
      Returns:
        StreamsDataSource object

    - #### providerMap

          public static Map<String,​DataSourcesProvider> providerMap()

      Allow unit tests to inject data sources.