org.apache.storm.sql.runtime

## Interface DataSourcesProvider

- All Known Implementing Classes:
    HdfsDataSourcesProvider, KafkaDataSourcesProvider, MongoDataSourcesProvider, RedisDataSourcesProvider, SocketDataSourcesProvider

      public interface DataSourcesProvider

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    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.

Copyright © 2021 The Apache Software Foundation. All rights reserved.