Package com.amazonaws.athena.connectors.jdbc

Class MultiplexingJdbcCompositeHandler

java.lang.Object

com.amazonaws.athena.connector.lambda.handlers.CompositeHandler

com.amazonaws.athena.connectors.jdbc.MultiplexingJdbcCompositeHandler

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

Direct Known Subclasses:

DataLakeGen2MuxCompositeHandler, Db2As400MuxCompositeHandler, Db2MuxCompositeHandler, HiveMuxCompositeHandler, HiveMuxCompositeHandler, ImpalaMuxCompositeHandler, MySqlMuxCompositeHandler, OracleMuxCompositeHandler, PostGreSqlMuxCompositeHandler, RedshiftMuxCompositeHandler, SaphanaMuxCompositeHandler, SnowflakeMuxCompositeHandler, SqlServerMuxCompositeHandler, SynapseMuxCompositeHandler, TeradataMuxCompositeHandler

public class MultiplexingJdbcCompositeHandler
extends CompositeHandler

Boilerplate composite handler that allows us to use a single Lambda function for both Metadata and Data. Automatically chooses to use either the Mux*Handlers or normal *Handlers depending on if catalog connection strings are being used.

Constructor Summary

Constructors

Constructor	Description
MultiplexingJdbcCompositeHandler(Class<? extends MultiplexingJdbcMetadataHandler> muxMetadataHandlerClass, Class<? extends MultiplexingJdbcRecordHandler> muxRecordHandlerClass, Class<? extends JdbcMetadataHandler> metadataHandlerClass, Class<? extends JdbcRecordHandler> recordHandlerClass)

Method Summary

Methods inherited from class com.amazonaws.athena.connector.lambda.handlers.CompositeHandler

handleRequest, handleRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplexingJdbcCompositeHandler

public MultiplexingJdbcCompositeHandler(Class<? extends MultiplexingJdbcMetadataHandler> muxMetadataHandlerClass,
                                        Class<? extends MultiplexingJdbcRecordHandler> muxRecordHandlerClass,
                                        Class<? extends JdbcMetadataHandler> metadataHandlerClass,
                                        Class<? extends JdbcRecordHandler> recordHandlerClass)
                                 throws ReflectiveOperationException

Throws:

ReflectiveOperationException