Class DataSourcesRegistry

java.lang.Object
org.apache.storm.sql.runtime.DataSourcesRegistry

public class DataSourcesRegistry extends Object
  • 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 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.