Package com.logicalclocks.hsfs

Class StorageConnector.MongoDbConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.MongoDbConnector

Enclosing class:

StorageConnector

public static class StorageConnector.MongoDbConnector
extends StorageConnector

Nested Class Summary

Nested classes/interfaces inherited from class com.logicalclocks.hsfs.StorageConnector

StorageConnector.AdlsConnector, StorageConnector.BigqueryConnector, StorageConnector.GcsConnector, StorageConnector.GlueConnector, StorageConnector.HopsFsConnector, StorageConnector.JdbcConnector, StorageConnector.KafkaConnector, StorageConnector.MongoDbConnector, StorageConnector.RedshiftConnector, StorageConnector.S3Connector, StorageConnector.SapHanaConnector, StorageConnector.SnowflakeConnector, StorageConnector.SqlConnector

Field Summary

Fields

Modifier and Type	Field	Description
protected String	authMechanism
protected String	authSource
protected String	collection
protected String	connectionString
protected String	database
static final String	MONGODB_FORMAT
protected List<Option>	options
protected String	password
protected String	user

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

description, featurestoreId, id, LOGGER, name, storageConnectorApi, storageConnectorType

Constructor Summary

Constructors

Constructor	Description
MongoDbConnector()

Method Summary

Modifier and Type	Method	Description
String	getPath(String subPath)
Map<String,String>	sparkOptions(DataSource dataSource)
void	update()

Methods inherited from class com.logicalclocks.hsfs.StorageConnector

refetch, sparkOptions

Methods inherited from class java.lang.Object

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

Field Details

MONGODB_FORMAT

public static final String MONGODB_FORMAT

See Also:

• Constant Field Values

connectionString

protected String connectionString

database

protected String database

collection

protected String collection

user

protected String user

password

protected String password

authSource

protected String authSource

authMechanism

protected String authMechanism

options

protected List<Option> options

Constructor Details

MongoDbConnector

public MongoDbConnector()

Method Details

sparkOptions

public Map<String,String> sparkOptions(DataSource dataSource)
                                throws FeatureStoreException

Specified by:

sparkOptions in class StorageConnector

Throws:

FeatureStoreException

update

public void update()
            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getPath

public String getPath(String subPath)

Specified by:

getPath in class StorageConnector