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 DataSource	construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)
static ISqlTridentDataSource	constructTridentDataSource(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
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

construct

public static DataSource construct(URI uri,
                                   String inputFormatClass,
                                   String outputFormatClass,
                                   List<FieldInfo> fields)

constructTridentDataSource

public static ISqlTridentDataSource constructTridentDataSource(URI uri,
                                                               String inputFormatClass,
                                                               String outputFormatClass,
                                                               Properties properties,
                                                               List<FieldInfo> fields)

providerMap

public static Map<String,DataSourcesProvider> providerMap()

Allow unit tests to inject data sources.