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 and 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.

Copyright © 2021 The Apache Software Foundation. All rights reserved.