Uses of Interface
com.amazonaws.athena.connector.lambda.data.BlockSpiller

Packages that use BlockSpiller

Package	Description
com.amazonaws.athena.connector.lambda
com.amazonaws.athena.connector.lambda.data
com.amazonaws.athena.connector.lambda.handlers
com.amazonaws.athena.connectors.aws.cmdb
com.amazonaws.athena.connectors.aws.cmdb.tables
com.amazonaws.athena.connectors.aws.cmdb.tables.ec2
com.amazonaws.athena.connectors.aws.cmdb.tables.s3
com.amazonaws.athena.connectors.cloudwatch
com.amazonaws.athena.connectors.cloudwatch.metrics
com.amazonaws.athena.connectors.docdb
com.amazonaws.athena.connectors.dynamodb
com.amazonaws.athena.connectors.elasticsearch
com.amazonaws.athena.connectors.example
com.amazonaws.athena.connectors.gcs
com.amazonaws.athena.connectors.google.bigquery
com.amazonaws.athena.connectors.hbase
com.amazonaws.athena.connectors.jdbc
com.amazonaws.athena.connectors.jdbc.manager
com.amazonaws.athena.connectors.kafka
com.amazonaws.athena.connectors.msk
com.amazonaws.athena.connectors.msk.consumer
com.amazonaws.athena.connectors.neptune
com.amazonaws.athena.connectors.neptune.propertygraph
com.amazonaws.athena.connectors.neptune.rdf
com.amazonaws.athena.connectors.redis
com.amazonaws.athena.connectors.synapse
com.amazonaws.athena.connectors.timestream
com.amazonaws.athena.connectors.tpcds
com.amazonaws.athena.connectors.vertica

Uses of BlockSpiller in com.amazonaws.athena.connector.lambda

Methods in com.amazonaws.athena.connector.lambda with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	ThrottlingInvoker.setBlockSpiller(BlockSpiller spiller)	Throttling Invoker can decide to propogate the congestion events to Athena if your Lambda has not generated any data yet.
ThrottlingInvoker.Builder	ThrottlingInvoker.Builder.withSpiller(BlockSpiller spiller)

Uses of BlockSpiller in com.amazonaws.athena.connector.lambda.data

Classes in com.amazonaws.athena.connector.lambda.data that implement BlockSpiller

Modifier and Type	Class	Description
class	S3BlockSpiller	Implementation of BlockSpiller which spills Blocks from large results to S3 with optional AES-GCM encryption.

Uses of BlockSpiller in com.amazonaws.athena.connector.lambda.handlers

Methods in com.amazonaws.athena.connector.lambda.handlers with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected abstract void	RecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	A more stream lined option for reading the row data associated with the provided Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.aws.cmdb

Methods in com.amazonaws.athena.connectors.aws.cmdb with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	AwsCmdbRecordHandler.readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)	Delegates to the TableProvider that is registered for the requested table.

Uses of BlockSpiller in com.amazonaws.athena.connectors.aws.cmdb.tables

Methods in com.amazonaws.athena.connectors.aws.cmdb.tables with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	EmrClusterTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls ListClusters and DescribeCluster on the AWS EMR Client returning all clusters that match the supplied predicate and attempting to push down certain predicates (namely queries for specific cluster) to EC2.
void	RdsTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeDBInstances on the AWS RDS Client returning all DB Instances that match the supplied predicate and attempting to push down certain predicates (namely queries for specific DB Instance) to EC2.
void	TableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Effects the requested read against the table, writing result row data using the supplied BlockSpliller.

Uses of BlockSpiller in com.amazonaws.athena.connectors.aws.cmdb.tables.ec2

Methods in com.amazonaws.athena.connectors.aws.cmdb.tables.ec2 with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	EbsTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeVolumes on the AWS EC2 Client returning all volumes that match the supplied predicate and attempting to push down certain predicates (namely queries for specific volumes) to EC2.
void	Ec2TableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeInstances on the AWS EC2 Client returning all instances that match the supplied predicate and attempting to push down certain predicates (namely queries for specific ec2 instance) to EC2.
void	ImagesTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeImagess on the AWS EC2 Client returning all images that match the supplied predicate and attempting to push down certain predicates (namely queries for specific volumes) to EC2.
void	RouteTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeRouteTables on the AWS EC2 Client returning all Routes that match the supplied predicate and attempting to push down certain predicates (namely queries for specific RoutingTables) to EC2.
void	SecurityGroupsTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeSecurityGroups on the AWS EC2 Client returning all SecurityGroup rules that match the supplied predicate and attempting to push down certain predicates (namely queries for specific SecurityGroups) to EC2.
void	SubnetTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeSubnets on the AWS EC2 Client returning all subnets that match the supplied predicate and attempting to push down certain predicates (namely queries for specific subnet) to EC2.
void	VpcTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeVPCs on the AWS EC2 Client returning all VPCs that match the supplied predicate and attempting to push down certain predicates (namely queries for specific VPCs) to EC2.

Uses of BlockSpiller in com.amazonaws.athena.connectors.aws.cmdb.tables.s3

Methods in com.amazonaws.athena.connectors.aws.cmdb.tables.s3 with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	S3BucketsTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeDBInstances on the AWS RDS Client returning all DB Instances that match the supplied predicate and attempting to push down certain predicates (namely queries for specific DB Instance) to EC2.
void	S3ObjectsTableProvider.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls DescribeDBInstances on the AWS RDS Client returning all DB Instances that match the supplied predicate and attempting to push down certain predicates (namely queries for specific DB Instance) to EC2.

Uses of BlockSpiller in com.amazonaws.athena.connectors.cloudwatch

Methods in com.amazonaws.athena.connectors.cloudwatch with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	CloudwatchRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Scans Cloudwatch Logs using the LogStream and optional Time stamp filters.

Uses of BlockSpiller in com.amazonaws.athena.connectors.cloudwatch.metrics

Methods in com.amazonaws.athena.connectors.cloudwatch.metrics with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	MetricsRecordHandler.readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)	Scans Cloudwatch Metrics for the list of available metrics or the samples for a specific metric.

Uses of BlockSpiller in com.amazonaws.athena.connectors.docdb

Methods in com.amazonaws.athena.connectors.docdb with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	DocDBRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Scans DocumentDB using the scan settings set on the requested Split by DocDBeMetadataHandler.

Uses of BlockSpiller in com.amazonaws.athena.connectors.dynamodb

Methods in com.amazonaws.athena.connectors.dynamodb with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	DynamoDBRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Reads data from DynamoDB by submitting either a Query or a Scan, depending on the type of split, and includes any filters specified in the split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.elasticsearch

Methods in com.amazonaws.athena.connectors.elasticsearch with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	ElasticsearchRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Used to read the row data associated with the provided Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.example

Methods in com.amazonaws.athena.connectors.example with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	ExampleRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Used to read the row data associated with the provided Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.gcs

Methods in com.amazonaws.athena.connectors.gcs with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	GcsRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Used to read the row data associated with the provided Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.google.bigquery

Methods in com.amazonaws.athena.connectors.google.bigquery with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	BigQueryRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)

Uses of BlockSpiller in com.amazonaws.athena.connectors.hbase

Methods in com.amazonaws.athena.connectors.hbase with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	HbaseRecordHandler.readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest request, QueryStatusChecker queryStatusChecker)	Scans HBase using the scan settings set on the requested Split by HbaseMetadataHandler.

Uses of BlockSpiller in com.amazonaws.athena.connectors.jdbc

Methods in com.amazonaws.athena.connectors.jdbc with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	MultiplexingJdbcRecordHandler.readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)

Uses of BlockSpiller in com.amazonaws.athena.connectors.jdbc.manager

Methods in com.amazonaws.athena.connectors.jdbc.manager with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	JdbcRecordHandler.readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)

Uses of BlockSpiller in com.amazonaws.athena.connectors.kafka

Methods in com.amazonaws.athena.connectors.kafka with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	KafkaRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	generates the sql to executes on basis of where condition and executes it.

Uses of BlockSpiller in com.amazonaws.athena.connectors.msk

Methods in com.amazonaws.athena.connectors.msk with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	AmazonMskRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	generates the sql to executes on basis of where condition and executes it.

Uses of BlockSpiller in com.amazonaws.athena.connectors.msk.consumer

Methods in com.amazonaws.athena.connectors.msk.consumer with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	BaseMskConsumer.consume(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, SplitParameters splitParameters, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
void	MskConsumer.consume(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, SplitParameters splitParameters, org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer)	Consume topic data as batch.
protected abstract void	BaseMskConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)
protected void	MskAvroConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,org.apache.avro.generic.GenericRecord> record)
protected void	MskDefaultConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,TopicResultSet> record)
protected void	MskProtobufConsumer.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,com.google.protobuf.DynamicMessage> record)
void	MskRecordProcessor.processRecord(BlockSpiller spiller, SplitParameters splitParameters, org.apache.kafka.clients.consumer.ConsumerRecord<String,T> record)

Uses of BlockSpiller in com.amazonaws.athena.connectors.neptune

Methods in com.amazonaws.athena.connectors.neptune with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	NeptuneRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Used to read the row data associated with the provided Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.neptune.propertygraph

Methods in com.amazonaws.athena.connectors.neptune.propertygraph with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	PropertyGraphHandler.executeQuery(ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, BlockSpiller spiller, Map<String,String> configOptions)	Used to read the row data associated with the provided Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.neptune.rdf

Methods in com.amazonaws.athena.connectors.neptune.rdf with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	RDFHandler.executeQuery(ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, BlockSpiller spiller, Map<String,String> configOptions)	Performance considerations: If no constraints are provided, it gets THE WHOLE DATASET.

Uses of BlockSpiller in com.amazonaws.athena.connectors.redis

Methods in com.amazonaws.athena.connectors.redis with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	RedisRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)

Uses of BlockSpiller in com.amazonaws.athena.connectors.synapse

Methods in com.amazonaws.athena.connectors.synapse with parameters of type BlockSpiller

Modifier and Type	Method	Description
void	SynapseRecordHandler.readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)

Uses of BlockSpiller in com.amazonaws.athena.connectors.timestream

Methods in com.amazonaws.athena.connectors.timestream with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	TimestreamRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Scans TimeStream.

Uses of BlockSpiller in com.amazonaws.athena.connectors.tpcds

Methods in com.amazonaws.athena.connectors.tpcds with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	TPCDSRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Generated TPCDS data for the given Table and scale factor as defined by the requested Split.

Uses of BlockSpiller in com.amazonaws.athena.connectors.vertica

Methods in com.amazonaws.athena.connectors.vertica with parameters of type BlockSpiller

Modifier and Type	Method	Description
protected void	VerticaRecordHandler.readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Used to read the row data associated with the provided Split.