com.logicalclocks.hsfs

Class StorageConnector.RdsConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.RdsConnector

Enclosing class:

StorageConnector

public static class StorageConnector.RdsConnector
extends StorageConnector

Nested Class Summary

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

StorageConnector.AdlsConnector, StorageConnector.BigqueryConnector, StorageConnector.GcsConnector, StorageConnector.HopsFsConnector, StorageConnector.JdbcConnector, StorageConnector.KafkaConnector, StorageConnector.RdsConnector, StorageConnector.RedshiftConnector, StorageConnector.S3Connector, StorageConnector.SnowflakeConnector

Field Summary

Fields

Modifier and Type	Field and Description
protected List<Option>	arguments
protected String	database
protected String	host
protected String	password
protected Integer	port
protected String	user

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

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

Constructor Summary

Constructors

Constructor and Description
RdsConnector()

Method Summary

Modifier and Type	Method and Description
String	getPath(String subPath)
Map<String,String>	sparkOptions(DataSource dataSource) Set spark options specific to Rds.
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 Detail

host

protected String host

port

protected Integer port

database

protected String database

user

protected String user

password

protected String password

arguments

protected List<Option> arguments

Constructor Detail

RdsConnector

public RdsConnector()

Method Detail

sparkOptions

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

Set spark options specific to Rds.

Specified by:

sparkOptions in class StorageConnector

Returns:

Map

update

public void update()
            throws FeatureStoreException,
                   IOException

Throws:

FeatureStoreException

IOException

getPath

public String getPath(String subPath)

Specified by:

getPath in class StorageConnector