Package org.apache.storm.sql.runtime
Interface DataSourcesProvider
-
- All Known Implementing Classes:
HdfsDataSourcesProvider
,KafkaDataSourcesProvider
,RedisDataSourcesProvider
,SocketDataSourcesProvider
public interface DataSourcesProvider
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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 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.
-
-