org.apache.storm.sql.runtime

Interface DataSourcesProvider

All Known Implementing Classes:

HdfsDataSourcesProvider, KafkaDataSourcesProvider, MongoDataSourcesProvider, RedisDataSourcesProvider, SocketDataSourcesProvider

public interface DataSourcesProvider

Method Summary

Modifier and Type	Method and Description
DataSource	construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields) Construct a new data source.
ISqlTridentDataSource	constructTrident(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
String	scheme()

Method Detail

scheme

String scheme()

Returns:

the scheme of the data source

construct

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

Construct a new data source.

Parameters:

uri - The URI that specifies the data source. The format of the URI is fully customizable.

inputFormatClass - the name of the class that deserializes data. It is null when unspecified.

outputFormatClass - the name of the class that serializes data. It is null when unspecified.

fields - The name of the fields and the schema of the table.

constructTrident

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