public static class StorageConnector.JdbcConnector 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 |
connectionString |
description, featurestoreId, id, LOGGER, name, storageConnectorApi, storageConnectorType| Constructor and Description |
|---|
JdbcConnector() |
| Modifier and Type | Method and Description |
|---|---|
String |
getPath(String subPath) |
Map<String,String> |
sparkOptions(DataSource dataSource) |
void |
update() |
refetch, sparkOptionsprotected String connectionString
public Map<String,String> sparkOptions(DataSource dataSource)
sparkOptions in class StorageConnectorpublic void update()
throws FeatureStoreException,
IOException
FeatureStoreExceptionIOExceptionpublic String getPath(String subPath)
getPath in class StorageConnectorCopyright © 2025. All rights reserved.