org.apache.storm.sql.mongodb

Class MongoDataSourcesProvider

java.lang.Object

org.apache.storm.sql.mongodb.MongoDataSourcesProvider

All Implemented Interfaces:

DataSourcesProvider

public class MongoDataSourcesProvider
extends Object
implements DataSourcesProvider

Create a MongoDB sink based on the URI and properties. The URI has the format of mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]. The properties are in JSON format which specifies the name of the MongoDB collection and etc.

Constructor Summary

Constructors

Constructor and Description
MongoDataSourcesProvider()

Method Summary

Modifier and Type	Method and Description
DataSource	construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields) Construct a new data source.
ISqlTridentDataSource	constructTrident(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
String	scheme()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MongoDataSourcesProvider

public MongoDataSourcesProvider()

Method Detail

scheme

public String scheme()

Specified by:

scheme in interface DataSourcesProvider

Returns:

the scheme of the data source

construct

public DataSource construct(URI uri,
                            String inputFormatClass,
                            String outputFormatClass,
                            List<FieldInfo> fields)

Description copied from interface: DataSourcesProvider

Construct a new data source.

Specified by:

construct in interface DataSourcesProvider

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.

constructTrident

public ISqlTridentDataSource constructTrident(URI uri,
                                              String inputFormatClass,
                                              String outputFormatClass,
                                              Properties properties,
                                              List<FieldInfo> fields)

Specified by:

constructTrident in interface DataSourcesProvider