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

Interface BlockSpiller

All Superinterfaces:

BlockWriter

All Known Implementing Classes:

S3BlockSpiller

public interface BlockSpiller
extends BlockWriter

Used to write blocks which may require chunking and optionally spilling via a secondary communication channel.

Nested Class Summary

Nested classes/interfaces inherited from interface com.amazonaws.athena.connector.lambda.data.BlockWriter

BlockWriter.RowWriter

Method Summary

Modifier and Type	Method	Description
void	close()	Frees any resources associated with the BlockSpiller.
Block	getBlock()	Provides access to the single buffered block in the event that spilled() is false.
ConstraintEvaluator	getConstraintEvaluator()	Provides access to the ConstraintEvaluator that will be applied to the generated Blocks.
List<SpillLocation>	getSpillLocations()	Provides access to the manifest of SpillLocation(s) if spilled is true.
boolean	spilled()	Indicates if any part of the response written thus far has been spilled.

Methods inherited from interface com.amazonaws.athena.connector.lambda.data.BlockWriter

writeRows

Method Detail

spilled

boolean spilled()

Indicates if any part of the response written thus far has been spilled.

Returns:

True if at least 1 block has spilled, False otherwise.

getBlock

Block getBlock()

Provides access to the single buffered block in the event that spilled() is false.

Returns:

getSpillLocations

List<SpillLocation> getSpillLocations()

Provides access to the manifest of SpillLocation(s) if spilled is true.

Returns:

close

void close()

Frees any resources associated with the BlockSpiller.

getConstraintEvaluator

ConstraintEvaluator getConstraintEvaluator()

Provides access to the ConstraintEvaluator that will be applied to the generated Blocks.

Specified by:

getConstraintEvaluator in interface BlockWriter