Package com.logicalclocks.hsfs

Class StorageConnector.SapHanaConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.SapHanaConnector

Enclosing class:

StorageConnector

public static class StorageConnector.SapHanaConnector
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 String	application
protected List<Option>	arguments
protected String	database
static final int	DEFAULT_PORT
static final String	DRIVER
protected String	host
protected String	password
protected Integer	port
protected String	schema
protected String	table
protected String	user

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

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

Constructor Summary

Constructors

Constructor	Description
SapHanaConnector()

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

DRIVER

public static final String DRIVER

See Also:

• Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

• Constant Field Values

host

protected String host

port

protected Integer port

database

protected String database

schema

protected String schema

table

protected String table

user

protected String user

password

protected String password

application

protected String application

arguments

protected List<Option> arguments

Constructor Details

SapHanaConnector

public SapHanaConnector()

Method Details

sparkOptions

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

Specified by:

sparkOptions in class StorageConnector

Throws:

FeatureStoreException

update

public void update()
            throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

getPath

public String getPath(String subPath)

Specified by:

getPath in class StorageConnector