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 and Description |
|---|
MongoDataSourcesProvider() |
| Modifier and Type | Method and Description |
|---|---|
DataSource |
construct(URI uri,
String inputFormatClass,
String outputFormatClass,
List<FieldInfo> fields) |
ISqlTridentDataSource |
constructTrident(URI uri,
String inputFormatClass,
String outputFormatClass,
Properties properties,
List<FieldInfo> fields) |
String |
scheme() |
public String scheme()
scheme in interface DataSourcesProviderpublic DataSource construct(URI uri, String inputFormatClass, String outputFormatClass, List<FieldInfo> fields)
construct in interface DataSourcesProviderpublic ISqlTridentDataSource constructTrident(URI uri, String inputFormatClass, String outputFormatClass, Properties properties, List<FieldInfo> fields)
constructTrident in interface DataSourcesProviderCopyright © 2021 The Apache Software Foundation. All Rights Reserved.