public static class StorageConnector.RdsConnector extends StorageConnector
StorageConnector.AdlsConnector, StorageConnector.BigqueryConnector, StorageConnector.GcsConnector, StorageConnector.HopsFsConnector, StorageConnector.JdbcConnector, StorageConnector.KafkaConnector, StorageConnector.RdsConnector, StorageConnector.RedshiftConnector, StorageConnector.S3Connector, StorageConnector.SnowflakeConnector
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 |
description, featurestoreId, id, LOGGER, name, storageConnectorApi, storageConnectorType
Constructor and Description |
---|
RdsConnector() |
Modifier and Type | Method and Description |
---|---|
String |
getPath(String subPath) |
Map<String,String> |
sparkOptions(DataSource dataSource)
Set spark options specific to Rds.
|
void |
update() |
refetch, sparkOptions
protected String host
protected Integer port
protected String database
protected String user
protected String password
public Map<String,String> sparkOptions(DataSource dataSource)
sparkOptions
in class StorageConnector
public void update() throws FeatureStoreException, IOException
FeatureStoreException
IOException
public String getPath(String subPath)
getPath
in class StorageConnector
Copyright © 2025. All rights reserved.