Class ReadRecordsResponse
- java.lang.Object
-
- com.amazonaws.athena.connector.lambda.request.FederationResponse
-
- com.amazonaws.athena.connector.lambda.records.RecordResponse
-
- com.amazonaws.athena.connector.lambda.records.ReadRecordsResponse
-
- All Implemented Interfaces:
AutoCloseable
public class ReadRecordsResponse extends RecordResponse
Represents the output of aReadRecordsoperation.
-
-
Constructor Summary
Constructors Constructor Description ReadRecordsResponse(String catalogName, Block records)Constructs a new ReadRecordsResponse object.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Frees up resources associated with therecordsBlock.booleanequals(Object o)intgetRecordCount()Convenience accessor that returns the number of records that were read.BlockgetRecords()Returns the records Block.org.apache.arrow.vector.types.pojo.SchemagetSchema()Convenience accessor that returns the schema of the records Block.inthashCode()StringtoString()-
Methods inherited from class com.amazonaws.athena.connector.lambda.records.RecordResponse
getCatalogName, getRequestType
-
-
-
-
Method Detail
-
getSchema
public org.apache.arrow.vector.types.pojo.Schema getSchema()
Convenience accessor that returns the schema of the records Block.- Returns:
- The schema of the records Block.
-
getRecords
public Block getRecords()
Returns the records Block.- Returns:
- The records Block.
-
getRecordCount
public int getRecordCount()
Convenience accessor that returns the number of records that were read.- Returns:
- The number of records that were read.
-
close
public void close() throws ExceptionFrees up resources associated with therecordsBlock.- Throws:
Exception
-
-