Package org.apache.storm.sql.runtime

Interface DataSourcesProvider

All Known Implementing Classes:

HdfsDataSourcesProvider, KafkaDataSourcesProvider, RedisDataSourcesProvider, SocketDataSourcesProvider

public interface DataSourcesProvider

Method Summary

Modifier and Type	Method	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 Details

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.