Package com.amazonaws.athena.connectors.google.bigquery

Class BigQueryRecordHandler

java.lang.Object

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

com.amazonaws.athena.connectors.google.bigquery.BigQueryRecordHandler

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

public class BigQueryRecordHandler
extends RecordHandler

This record handler is an example of how you can implement a lambda that calls bigquery and pulls data. This Lambda requires that your BigQuery table is small enough so that a table scan can be completed within 5-10 mins or this lambda will time out and it will fail.

Field Summary

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

configOptions

Constructor Summary

Constructors

Constructor	Description
BigQueryRecordHandler(com.amazonaws.services.s3.AmazonS3 amazonS3, com.amazonaws.services.secretsmanager.AWSSecretsManager secretsManager, com.amazonaws.services.athena.AmazonAthena athena, Map<String,String> configOptions, org.apache.arrow.memory.BufferAllocator allocator)

Method Summary

Modifier and Type	Method	Description
void	readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	A more stream lined option for reading the row data associated with the provided Split.

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

BigQueryRecordHandler

public BigQueryRecordHandler(com.amazonaws.services.s3.AmazonS3 amazonS3,
                             com.amazonaws.services.secretsmanager.AWSSecretsManager secretsManager,
                             com.amazonaws.services.athena.AmazonAthena athena,
                             Map<String,String> configOptions,
                             org.apache.arrow.memory.BufferAllocator allocator)

Method Detail

readWithConstraint

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

Description copied from class: RecordHandler

A more stream lined option for reading the row data associated with the provided Split. This method differs from doReadRecords(...) in that the SDK handles more of the request lifecycle, leaving you to focus more closely on the task of actually reading from your source.

Specified by:

readWithConstraint in class RecordHandler

Parameters:

spiller - A BlockSpiller that should be used to write the row data associated with this Split. The BlockSpiller automatically handles chunking the response, encrypting, and spilling to S3.

recordsRequest - Details of the read request, including: 1. The Split 2. The Catalog, Database, and Table the read request is for. 3. The filtering predicate (if any) 4. The columns required for projection.

queryStatusChecker - A QueryStatusChecker that you can use to stop doing work for a query that has already terminated

Throws:

Exception