org.apache.storm.sql.runtime

Class DataSourcesRegistry

java.lang.Object

org.apache.storm.sql.runtime.DataSourcesRegistry

public class DataSourcesRegistry
extends Object

Method Summary

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.