Package com.logicalclocks.hsfs

Class StorageConnector.JdbcConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.JdbcConnector

Enclosing class:

StorageConnector

public static class StorageConnector.JdbcConnector
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 List<Option>	arguments
protected String	connectionString

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

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

Constructor Summary

Constructors

Constructor	Description
JdbcConnector()

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

connectionString

protected String connectionString

arguments

protected List<Option> arguments

Constructor Details

JdbcConnector

public JdbcConnector()

Method Details

sparkOptions

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

Specified by:

sparkOptions in class StorageConnector

update

public void update()
            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getPath

public String getPath(String subPath)

Specified by:

getPath in class StorageConnector