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
ISqlStreamsDataSource	constructStreams(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields) Construct a new data source for streams mode.
String	scheme() Get the scheme of the data source.

Method Detail

scheme

String scheme()

Get the scheme of the data source.

Returns:

the scheme of the data source

constructStreams

ISqlStreamsDataSource constructStreams(URI uri,
                                       String inputFormatClass,
                                       String outputFormatClass,
                                       Properties properties,
                                       List<FieldInfo> fields)

Construct a new data source for streams mode.

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.