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 aReadRecords
operation.
-
-
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 void
close()
Frees up resources associated with therecords
Block.boolean
equals(Object o)
int
getRecordCount()
Convenience accessor that returns the number of records that were read.Block
getRecords()
Returns the records Block.org.apache.arrow.vector.types.pojo.Schema
getSchema()
Convenience accessor that returns the schema of the records Block.int
hashCode()
String
toString()
-
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 Exception
Frees up resources associated with therecords
Block.- Throws:
Exception
-
-