Package com.amazonaws.athena.connectors.influxdb

Class InfluxDBQueryPassthrough

java.lang.Object

com.amazonaws.athena.connectors.influxdb.InfluxDBQueryPassthrough

All Implemented Interfaces:

QueryPassthroughSignature

public class InfluxDBQueryPassthrough
extends Object
implements QueryPassthroughSignature

Query passthrough signature for InfluxDB 3. Exposed to Athena as the table function system.query(DATABASE => '<db>', QUERY => '<native SQL>').

Unlike a fully SQL-inferred passthrough, InfluxDB 3's Flight SQL client is bound to a specific database, so the caller must supply both the target DATABASE and the native QUERY to run against it.

Field Summary

Fields

Modifier and Type	Field	Description
static List<String>	ARGUMENTS
static String	DATABASE
static String	NAME
static String	QUERY
static String	SCHEMA_NAME

Fields inherited from interface com.amazonaws.athena.connector.lambda.metadata.optimizations.querypassthrough.QueryPassthroughSignature

DEFAULT_ENABLE_QUERY_PASSTHROUGH_STATE, ENABLE_QUERY_PASSTHROUGH, SCHEMA_FUNCTION_NAME

Constructor Summary

Constructors

Constructor	Description
InfluxDBQueryPassthrough()

Method Summary

Modifier and Type	Method	Description
void	assertEnabled(Map<String,String> configOptions)	Enforces the enable_query_passthrough flag at execution time.
void	customConnectorVerifications(Map<String,String> engineQptArguments)	Provides a mechanism to perform custom connector verification logic.
List<String>	getFunctionArguments()
String	getFunctionName()
String	getFunctionSchema()
org.slf4j.Logger	getLogger()	note: due to needing to stay compatible with JDK8; we can't use JDK9 private method

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.amazonaws.athena.connector.lambda.metadata.optimizations.querypassthrough.QueryPassthroughSignature

addQueryPassthroughCapabilityIfEnabled, allowQueryPassthrough, getFunctionSignature, getQueryPassthroughCapabilities, verify, verifyFunctionSignature

Field Detail

DATABASE

public static final String DATABASE

See Also:

Constant Field Values

QUERY

public static final String QUERY

See Also:

Constant Field Values

SCHEMA_NAME

public static final String SCHEMA_NAME

See Also:

Constant Field Values

NAME

public static final String NAME

See Also:

Constant Field Values

ARGUMENTS

public static final List<String> ARGUMENTS

Constructor Detail

InfluxDBQueryPassthrough

public InfluxDBQueryPassthrough()

Method Detail

getFunctionSchema

public String getFunctionSchema()

Specified by:

getFunctionSchema in interface QueryPassthroughSignature

Returns:

QPT Function's Schema (also known as a domain or namepsace)

getFunctionName

public String getFunctionName()

Specified by:

getFunctionName in interface QueryPassthroughSignature

Returns:

QPT Function's name

getFunctionArguments

public List<String> getFunctionArguments()

Specified by:

getFunctionArguments in interface QueryPassthroughSignature

Returns:

Query Passthrough Function's Arguments

getLogger

public org.slf4j.Logger getLogger()

Description copied from interface: QueryPassthroughSignature

note: due to needing to stay compatible with JDK8; we can't use JDK9 private method

Specified by:

getLogger in interface QueryPassthroughSignature

Returns:

a logger

customConnectorVerifications

public void customConnectorVerifications(Map<String,String> engineQptArguments)

Description copied from interface: QueryPassthroughSignature

Provides a mechanism to perform custom connector verification logic.

Specified by:

customConnectorVerifications in interface QueryPassthroughSignature

assertEnabled

public void assertEnabled(Map<String,String> configOptions)

Enforces the enable_query_passthrough flag at execution time.

Throws:

AthenaConnectorException - with OPERATION_NOT_SUPPORTED_EXCEPTION if enable_query_passthrough is not true