Package com.amazonaws.athena.connector.lambda.records

Class RemoteReadRecordsResponse

java.lang.Object

com.amazonaws.athena.connector.lambda.request.FederationResponse

com.amazonaws.athena.connector.lambda.records.RecordResponse

com.amazonaws.athena.connector.lambda.records.RemoteReadRecordsResponse

All Implemented Interfaces:

AutoCloseable

public class RemoteReadRecordsResponse
extends RecordResponse

Represents the output of a ReadRecords operation when the output has spilled.

Constructor Summary

Constructors

Constructor	Description
RemoteReadRecordsResponse(String catalogName, org.apache.arrow.vector.types.pojo.Schema schema, List<SpillLocation> remoteBlocks, EncryptionKey encryptionKey)	Constructs a new RemoteReadRecordsResponse object.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	equals(Object o)
EncryptionKey	getEncryptionKey()	Returns the encryption key of the spilled data.
int	getNumberBlocks()	Convenience accessor that returns the number of spilled blocks.
List<SpillLocation>	getRemoteBlocks()	Returns the locations of the spilled data.
org.apache.arrow.vector.types.pojo.Schema	getSchema()	Returns the schema of the spilled data.
int	hashCode()
String	toString()

Methods inherited from class com.amazonaws.athena.connector.lambda.records.RecordResponse

getCatalogName, getRequestType

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RemoteReadRecordsResponse

public RemoteReadRecordsResponse(String catalogName,
                                 org.apache.arrow.vector.types.pojo.Schema schema,
                                 List<SpillLocation> remoteBlocks,
                                 EncryptionKey encryptionKey)

Constructs a new RemoteReadRecordsResponse object.

Parameters:

catalogName - The catalog name the data belongs to.

schema - The schema of the spilled data.

remoteBlocks - The locations of the spilled data.

encryptionKey - The encryption key of the spilled data.

Method Detail

getSchema

public org.apache.arrow.vector.types.pojo.Schema getSchema()

Returns the schema of the spilled data.

Returns:

The schema of the spilled data.

getRemoteBlocks

public List<SpillLocation> getRemoteBlocks()

Returns the locations of the spilled data.

Returns:

The locations of the spilled data.

getNumberBlocks

public int getNumberBlocks()

Convenience accessor that returns the number of spilled blocks.

Returns:

The number of spilled blocks.

getEncryptionKey

public EncryptionKey getEncryptionKey()

Returns the encryption key of the spilled data.

Returns:

The encryption key of the spilled data.

close

public void close()
           throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object