Package com.amazonaws.athena.connectors.hbase.qpt

Class HbaseQueryPassthrough

java.lang.Object

com.amazonaws.athena.connectors.hbase.qpt.HbaseQueryPassthrough

All Implemented Interfaces:

QueryPassthroughSignature

public final class HbaseQueryPassthrough
extends Object
implements QueryPassthroughSignature

Field Summary

Fields

Modifier and Type	Field	Description
static String	COLLECTION
static String	DATABASE
static String	FILTER
static String	NAME
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
HbaseQueryPassthrough()

Method Summary

Modifier and Type	Method	Description
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
void	verify(Map<String,String> engineQptArguments)	verify that the arguments returned by the engine are the same that the connector defined.

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, customConnectorVerifications, getFunctionSignature, getQueryPassthroughCapabilities, verifyFunctionSignature

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

SCHEMA_NAME

public static final String SCHEMA_NAME

See Also:

Constant Field Values

DATABASE

public static final String DATABASE

See Also:

Constant Field Values

COLLECTION

public static final String COLLECTION

See Also:

Constant Field Values

FILTER

public static final String FILTER

See Also:

Constant Field Values

Constructor Detail

HbaseQueryPassthrough

public HbaseQueryPassthrough()

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

verify

public void verify(Map<String,String> engineQptArguments)
            throws IllegalArgumentException

verify that the arguments returned by the engine are the same that the connector defined. In the parent class verify function, all argument values are mandatory. However, in the overridden function, we've removed the condition that checks whether the HBase FILTER argument value is empty. This modification allows for the possibility of an empty FILTER argument value without triggering an exception.

Specified by:

verify in interface QueryPassthroughSignature

Parameters:

engineQptArguments -

Throws:

IllegalArgumentException