Package com.amazonaws.athena.connector.validation

Class LambdaRecordProvider

java.lang.Object

com.amazonaws.athena.connector.validation.LambdaRecordProvider

public class LambdaRecordProvider
extends Object

This class offers a convenience method to retrieve records from a deployed Lambda.

Method Summary

Modifier and Type	Method	Description
static ReadRecordsResponse	readRecords(String catalog, TableName tableName, Constraints constraints, org.apache.arrow.vector.types.pojo.Schema schema, Split split, String recordFunction, FederatedIdentity identity)	This method builds and executes a ReadRecordsRequest against the specified Lambda function.

Methods inherited from class java.lang.Object

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

Method Detail

readRecords

public static ReadRecordsResponse readRecords(String catalog,
                                              TableName tableName,
                                              Constraints constraints,
                                              org.apache.arrow.vector.types.pojo.Schema schema,
                                              Split split,
                                              String recordFunction,
                                              FederatedIdentity identity)

This method builds and executes a ReadRecordsRequest against the specified Lambda function.

Parameters:

catalog - the catalog name to be passed to Lambda

tableName - the schema-qualified table name indicating the table for which splits should be retrieved

constraints - the constraints to be applied to the request

schema - the schema of the table in question

split - the split to be read in this request

recordFunction - the name of the Lambda function to call

identity - the identity of the caller

Returns:

the response