Package com.logicalclocks.hsfs

Class StorageConnector.SnowflakeConnector

java.lang.Object

com.logicalclocks.hsfs.StorageConnector

com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector

Enclosing class:

StorageConnector

public static class StorageConnector.SnowflakeConnector
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 String	database
protected String	password
protected String	role
protected String	schema
protected List<Option>	sfOptions
protected String	table
protected String	token
protected String	url
protected String	user
protected String	warehouse

Fields inherited from class com.logicalclocks.hsfs.StorageConnector

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

Constructor Summary

Constructors

Constructor	Description
SnowflakeConnector()

Method Summary

Modifier and Type	Method	Description
String	account()
String	getPath(String subPath)
Map<String,String>	sparkOptions(DataSource dataSource)

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

url

protected String url

user

protected String user

password

protected String password

token

protected String token

database

protected String database

schema

protected String schema

warehouse

protected String warehouse

role

protected String role

table

protected String table

application

protected String application

sfOptions

protected List<Option> sfOptions

Constructor Details

SnowflakeConnector

public SnowflakeConnector()

Method Details

account

public String account()

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