Package com.amazonaws.athena.connectors.snowflake

Class SnowflakeEnvironmentProperties

java.lang.Object

com.amazonaws.athena.connector.lambda.connection.EnvironmentProperties

com.amazonaws.athena.connectors.jdbc.JdbcEnvironmentProperties

com.amazonaws.athena.connectors.snowflake.SnowflakeEnvironmentProperties

public class SnowflakeEnvironmentProperties
extends JdbcEnvironmentProperties

Field Summary

Fields

Modifier and Type	Field	Description
static String	ENABLE_S3_EXPORT

Fields inherited from class com.amazonaws.athena.connector.lambda.connection.EnvironmentProperties

logger

Constructor Summary

Constructors

Constructor	Description
SnowflakeEnvironmentProperties(Map<String,String> properties)

Method Summary

Modifier and Type	Method	Description
Map<String,String>	connectionPropertiesToEnvironment(Map<String,String> connectionProperties)	Maps glue connection properties and authentication configuration to Athena federation environment properties like 'default' and 'secret_manager_gcp_creds_name' Default behavior is to not map to Athena federation environment variables
protected String	getConnectionStringPrefix(Map<String,String> connectionProperties)
protected String	getDatabase(Map<String,String> connectionProperties)	For Snowflake, we don't put warehouse, database or schema information to the JDBC String to avoid casing issues.
protected String	getJdbcParametersSeparator()
static Map<String,String>	getSnowFlakeParameter(Map<String,String> baseProperty, Map<String,String> connectionProperties)
boolean	isS3ExportEnabled()

Methods inherited from class com.amazonaws.athena.connectors.jdbc.JdbcEnvironmentProperties

getDatabaseSeparator, getDelimiter, getJdbcParameters

Methods inherited from class com.amazonaws.athena.connector.lambda.connection.EnvironmentProperties

athenaPropertiesToEnvironment, createEnvironment, getGlueConnection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ENABLE_S3_EXPORT

public static final String ENABLE_S3_EXPORT

See Also:

Constant Field Values

Constructor Detail

SnowflakeEnvironmentProperties

public SnowflakeEnvironmentProperties(Map<String,String> properties)

Method Detail

connectionPropertiesToEnvironment

public Map<String,String> connectionPropertiesToEnvironment(Map<String,String> connectionProperties)

Description copied from class: EnvironmentProperties

Maps glue connection properties and authentication configuration to Athena federation environment properties like 'default' and 'secret_manager_gcp_creds_name' Default behavior is to not map to Athena federation environment variables

Overrides:

connectionPropertiesToEnvironment in class JdbcEnvironmentProperties

Parameters:

connectionProperties - contains secret_name and connection properties

getConnectionStringPrefix

protected String getConnectionStringPrefix(Map<String,String> connectionProperties)

Specified by:

getConnectionStringPrefix in class JdbcEnvironmentProperties

getDatabase

protected String getDatabase(Map<String,String> connectionProperties)

For Snowflake, we don't put warehouse, database or schema information to the JDBC String to avoid casing issues.

Overrides:

getDatabase in class JdbcEnvironmentProperties

Parameters:

connectionProperties -

Returns:

getJdbcParametersSeparator

protected String getJdbcParametersSeparator()

Overrides:

getJdbcParametersSeparator in class JdbcEnvironmentProperties

getSnowFlakeParameter

public static Map<String,String> getSnowFlakeParameter(Map<String,String> baseProperty,
                                                             Map<String,String> connectionProperties)

isS3ExportEnabled

public boolean isS3ExportEnabled()