Package com.logicalclocks.hsfs

Class StorageConnector.RedshiftConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.RedshiftConnector

Enclosing class:

StorageConnector

public static class StorageConnector.RedshiftConnector
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 Boolean	autoCreate
protected String	clusterIdentifier
protected String	databaseDriver
protected String	databaseEndpoint
protected String	databaseGroup
protected String	databaseName
protected String	databasePassword
protected Integer	databasePort
protected String	databaseUserName
protected Instant	expiration
protected String	iamRole
protected String	tableName

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

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

Constructor Summary

Constructors

Constructor	Description
RedshiftConnector()

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

clusterIdentifier

protected String clusterIdentifier

databaseDriver

protected String databaseDriver

databaseEndpoint

protected String databaseEndpoint

databaseName

protected String databaseName

databasePort

protected Integer databasePort

tableName

protected String tableName

databaseUserName

protected String databaseUserName

autoCreate

protected Boolean autoCreate

databasePassword

protected String databasePassword

databaseGroup

protected String databaseGroup

iamRole

protected String iamRole

arguments

protected List<Option> arguments

expiration

protected Instant expiration

Constructor Details

RedshiftConnector

public RedshiftConnector()

Method Details

sparkOptions

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

Specified by:

sparkOptions in class StorageConnector

getPath

public String getPath(String subPath)

Specified by:

getPath in class StorageConnector

update

public void update()
            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException