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.