Package com.amazonaws.athena.connectors.kafka

Class KafkaRecordHandler

java.lang.Object

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

com.amazonaws.athena.connectors.kafka.KafkaRecordHandler

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

public class KafkaRecordHandler
extends RecordHandler

Field Summary

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

configOptions

Constructor Summary

Constructors

Constructor	Description
KafkaRecordHandler(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

KafkaRecordHandler

public KafkaRecordHandler(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