Package com.amazonaws.athena.connectors.neptune.qpt

Class NeptuneGremlinQueryPassthrough

java.lang.Object

com.amazonaws.athena.connectors.neptune.qpt.NeptuneGremlinQueryPassthrough

All Implemented Interfaces:

QueryPassthroughSignature

public final class NeptuneGremlinQueryPassthrough
extends Object
implements QueryPassthroughSignature

A Singleton class that implements QPT signature interface to define the Neptune Gremlin (PropertyGraph Type) Query Passthrough Function's signature that will be used to inform the engine how to define QPT Function for a Neptune connector

Field Summary

Fields

Modifier and Type	Field	Description
static String	COLLECTION
static String	COMPONENT_TYPE
static String	DATABASE
static String	NAME
static String	SCHEMA_NAME
static String	TRAVERSE

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
NeptuneGremlinQueryPassthrough()

Method Summary

Modifier and Type	Method	Description
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

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

TRAVERSE

public static final String TRAVERSE

See Also:

Constant Field Values

COMPONENT_TYPE

public static final String COMPONENT_TYPE

See Also:

Constant Field Values

Constructor Detail

NeptuneGremlinQueryPassthrough

public NeptuneGremlinQueryPassthrough()

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