Package com.amazonaws.athena.connector.lambda.data

Class S3BlockSpillReader

java.lang.Object

com.amazonaws.athena.connector.lambda.data.S3BlockSpillReader

public class S3BlockSpillReader
extends Object

Constructor Summary

Constructors

Constructor	Description
S3BlockSpillReader(software.amazon.awssdk.services.s3.S3Client amazonS3, BlockAllocator allocator)

Method Summary

Modifier and Type	Method	Description
byte[]	read(S3SpillLocation spillLocation, EncryptionKey key)	Reads spilled data as a byte[].
Block	read(S3SpillLocation spillLocation, EncryptionKey key, org.apache.arrow.vector.types.pojo.Schema schema)	Reads a spilled block.

Methods inherited from class java.lang.Object

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

Constructor Detail

S3BlockSpillReader

public S3BlockSpillReader(software.amazon.awssdk.services.s3.S3Client amazonS3,
                          BlockAllocator allocator)

Method Detail

read

public Block read(S3SpillLocation spillLocation,
                  EncryptionKey key,
                  org.apache.arrow.vector.types.pojo.Schema schema)

Reads a spilled block.

Parameters:

spillLocation - The location to read the spilled Block from.

key - The encryption key to use when reading the spilled Block.

schema - The Schema to use when deserializing the spilled Block.

Returns:

The Block stored at the spill location.

read

public byte[] read(S3SpillLocation spillLocation,
                   EncryptionKey key)

Reads spilled data as a byte[].

Parameters:

spillLocation - The location to read the spilled Block from.

key - The encryption key to use when reading the spilled Block.

Returns:

The Block stored at the spill location.