Package com.amazonaws.athena.connectors.msk

Class AmazonMskRecordHandler

java.lang.Object

com.amazonaws.athena.connector.lambda.handlers.RecordHandler

com.amazonaws.athena.connectors.msk.AmazonMskRecordHandler

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

public class AmazonMskRecordHandler
extends RecordHandler

Field Summary

Fields inherited from class com.amazonaws.athena.connector.lambda.handlers.RecordHandler

configOptions

Constructor Summary

Constructors

Constructor	Description
AmazonMskRecordHandler(software.amazon.awssdk.services.s3.S3Client amazonS3, software.amazon.awssdk.services.secretsmanager.SecretsManagerClient secretsManager, software.amazon.awssdk.services.athena.AthenaClient athena, Map<String,String> configOptions)

Method Summary

Modifier and Type	Method	Description
void	readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	generates the sql to executes on basis of where condition and executes it.

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

doHandleRequest, doReadRecords, getSecret, getSpillConfig, handleRequest, onPing, resolveSecrets

Methods inherited from class java.lang.Object

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

Constructor Detail

AmazonMskRecordHandler

public AmazonMskRecordHandler(software.amazon.awssdk.services.s3.S3Client amazonS3,
                              software.amazon.awssdk.services.secretsmanager.SecretsManagerClient secretsManager,
                              software.amazon.awssdk.services.athena.AthenaClient athena,
                              Map<String,String> configOptions)

Method Detail

readWithConstraint

public void readWithConstraint(BlockSpiller spiller,
                               ReadRecordsRequest recordsRequest,
                               QueryStatusChecker queryStatusChecker)
                        throws Exception

generates the sql to executes on basis of where condition and executes it.

Specified by:

readWithConstraint in class RecordHandler

Parameters:

spiller - - instance of BlockSpiller

recordsRequest - - instance of ReadRecordsRequest

queryStatusChecker - - instance of QueryStatusChecker

Throws:

Exception