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.

Field Summary

Fields

Modifier and Type	Field and Description
static String	COLLECTION_NAME
static String	DEFAULT_VALUE_SERIALIZED_FIELD
static String	SCHEME_NAME
static String	TRIDENT_VALUE_SERIALIZED_FIELD
static String	VALUE_SERIALIZED_FIELD

Constructor Summary

Constructors

Constructor and Description
MongoDataSourcesProvider()

Method Summary

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.

Methods inherited from class java.lang.Object

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

Field Detail

SCHEME_NAME

public static final String SCHEME_NAME

See Also:

Constant Field Values

VALUE_SERIALIZED_FIELD

public static final String VALUE_SERIALIZED_FIELD

See Also:

Constant Field Values

TRIDENT_VALUE_SERIALIZED_FIELD

public static final String TRIDENT_VALUE_SERIALIZED_FIELD

See Also:

Constant Field Values

DEFAULT_VALUE_SERIALIZED_FIELD

public static final String DEFAULT_VALUE_SERIALIZED_FIELD

See Also:

Constant Field Values

COLLECTION_NAME

public static final String COLLECTION_NAME

See Also:

Constant Field Values

Constructor Detail

MongoDataSourcesProvider

public MongoDataSourcesProvider()

Method Detail

scheme

public String scheme()

Description copied from interface: DataSourcesProvider

Get the scheme of the data source.

Specified by:

scheme in interface DataSourcesProvider

Returns:

the scheme of the data source

constructStreams

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

Description copied from interface: DataSourcesProvider

Construct a new data source for streams mode.

Specified by:

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