public static class StorageConnector.SnowflakeConnector extends StorageConnector
StorageConnector.AdlsConnector, StorageConnector.BigqueryConnector, StorageConnector.GcsConnector, StorageConnector.HopsFsConnector, StorageConnector.JdbcConnector, StorageConnector.KafkaConnector, StorageConnector.RedshiftConnector, StorageConnector.S3Connector, StorageConnector.SnowflakeConnector
Modifier and Type | Field and 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 |
description, featurestoreId, id, name, storageConnectorApi, storageConnectorType
Constructor and Description |
---|
SnowflakeConnector() |
Modifier and Type | Method and Description |
---|---|
String |
account() |
String |
getPath(String subPath) |
Map<String,String> |
sparkOptions() |
refetch
protected String url
protected String user
protected String password
protected String token
protected String database
protected String schema
protected String warehouse
protected String role
protected String table
protected String application
public String account()
public Map<String,String> sparkOptions()
sparkOptions
in class StorageConnector
public String getPath(String subPath)
getPath
in class StorageConnector
Copyright © 2023. All rights reserved.