Interface DataSourcesProvider

    • 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.