Uses of Class
com.amazonaws.athena.connector.lambda.QueryStatusChecker
-
-
Uses of QueryStatusChecker in com.amazonaws.athena.connector.lambda.handlers
Methods in com.amazonaws.athena.connector.lambda.handlers with parameters of type QueryStatusChecker Modifier and Type Method Description abstract void
MetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Used to get the partitions that must be read from the request table in order to satisfy the requested predicate.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 QueryStatusChecker in com.amazonaws.athena.connectors.aws.cmdb
Methods in com.amazonaws.athena.connectors.aws.cmdb with parameters of type QueryStatusChecker Modifier and Type Method Description void
AwsCmdbMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Delegates to the TableProvider that is registered for the requested table.protected void
AwsCmdbRecordHandler. readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)
Delegates to the TableProvider that is registered for the requested table. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.aws.cmdb.tables
Methods in com.amazonaws.athena.connectors.aws.cmdb.tables with parameters of type QueryStatusChecker 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 QueryStatusChecker in com.amazonaws.athena.connectors.aws.cmdb.tables.ec2
Methods in com.amazonaws.athena.connectors.aws.cmdb.tables.ec2 with parameters of type QueryStatusChecker 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 QueryStatusChecker in com.amazonaws.athena.connectors.aws.cmdb.tables.s3
Methods in com.amazonaws.athena.connectors.aws.cmdb.tables.s3 with parameters of type QueryStatusChecker 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 QueryStatusChecker in com.amazonaws.athena.connectors.clickhouse
Methods in com.amazonaws.athena.connectors.clickhouse with parameters of type QueryStatusChecker Modifier and Type Method Description void
ClickHouseMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.cloudera
Methods in com.amazonaws.athena.connectors.cloudera with parameters of type QueryStatusChecker Modifier and Type Method Description void
HiveMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
Used to get the hive partitions that must be read from the request table in order to satisfy the requested predicate.void
ImpalaMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
Used to get the Impala partitions that must be read from the request table in order to satisfy the requested predicate. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.cloudwatch
Methods in com.amazonaws.athena.connectors.cloudwatch with parameters of type QueryStatusChecker Modifier and Type Method Description void
CloudwatchMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Gets the list of LogStreams that need to be scanned to satisfy the requested table.protected void
CloudwatchRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Scans Cloudwatch Logs using the LogStream and optional Time stamp filters. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.cloudwatch.metrics
Methods in com.amazonaws.athena.connectors.cloudwatch.metrics with parameters of type QueryStatusChecker Modifier and Type Method Description void
MetricsMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Our table doesn't support complex layouts or partitioning so we simply make this method a NoOp and the SDK will automatically generate a single placeholder partition for us since Athena needs at least 1 partition returned if there is potetnailly any data to read.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 QueryStatusChecker in com.amazonaws.athena.connectors.datalakegen2
Methods in com.amazonaws.athena.connectors.datalakegen2 with parameters of type QueryStatusChecker Modifier and Type Method Description void
DataLakeGen2MetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
The partitions are being implemented based on the type of data externally in case of Gen 2. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.db2
Methods in com.amazonaws.athena.connectors.db2 with parameters of type QueryStatusChecker Modifier and Type Method Description void
Db2MetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
A partition is represented by a partition column(s) of type varchar. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.db2as400
Methods in com.amazonaws.athena.connectors.db2as400 with parameters of type QueryStatusChecker Modifier and Type Method Description void
Db2As400MetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
A partition is represented by a partition column(s) of type varchar. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.docdb
Methods in com.amazonaws.athena.connectors.docdb with parameters of type QueryStatusChecker Modifier and Type Method Description void
DocDBMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Our table doesn't support complex layouts or partitioning so we simply make this method a NoOp.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 QueryStatusChecker in com.amazonaws.athena.connectors.dynamodb
Methods in com.amazonaws.athena.connectors.dynamodb with parameters of type QueryStatusChecker Modifier and Type Method Description void
DynamoDBMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Generates hash key partitions if possible or generates a single partition with the heuristically determined optimal scan segment count specified inside of itprotected 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 QueryStatusChecker in com.amazonaws.athena.connectors.elasticsearch
Methods in com.amazonaws.athena.connectors.elasticsearch with parameters of type QueryStatusChecker Modifier and Type Method Description void
ElasticsearchMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Elasticsearch does not support partitioning so this method is a NoOp.protected void
ElasticsearchRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Used to read the row data associated with the provided Split. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.example
Methods in com.amazonaws.athena.connectors.example with parameters of type QueryStatusChecker Modifier and Type Method Description void
ExampleMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Used to get the partitions that must be read from the request table in order to satisfy the requested predicate.protected void
ExampleRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Used to read the row data associated with the provided Split. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.gcs
Methods in com.amazonaws.athena.connectors.gcs with parameters of type QueryStatusChecker Modifier and Type Method Description void
GcsMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Used to get the partitions that must be read from the request table in order to satisfy the requested predicate.protected void
GcsRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Used to read the row data associated with the provided Split. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.google.bigquery
Methods in com.amazonaws.athena.connectors.google.bigquery with parameters of type QueryStatusChecker Modifier and Type Method Description void
BigQueryMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Currently not supporting Partitions since Bigquery having quota limits with triggering concurrent queries and having bit complexity to extract and use the partitions in the query instead we are using limit and offset for non constraints query with basic concurrency limitvoid
BigQueryRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.hbase
Methods in com.amazonaws.athena.connectors.hbase with parameters of type QueryStatusChecker Modifier and Type Method Description void
HbaseMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Our table doesn't support complex layouts or partitioning so leave this as a NoOp and the SDK will notice that we do not have any partition columns, nor have we set an custom fields using enhancePartitionSchema(...), and as a result the SDK will generate a single place holder partition for us.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 QueryStatusChecker in com.amazonaws.athena.connectors.hortonworks
Methods in com.amazonaws.athena.connectors.hortonworks with parameters of type QueryStatusChecker Modifier and Type Method Description void
HiveMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
Used to get the hive partitions that must be read from the request table in order to satisfy the requested predicate. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.jdbc
Methods in com.amazonaws.athena.connectors.jdbc with parameters of type QueryStatusChecker Modifier and Type Method Description void
MultiplexingJdbcMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
void
MultiplexingJdbcRecordHandler. readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.jdbc.manager
Methods in com.amazonaws.athena.connectors.jdbc.manager with parameters of type QueryStatusChecker Modifier and Type Method Description abstract void
JdbcMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
void
JdbcRecordHandler. readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.kafka
Methods in com.amazonaws.athena.connectors.kafka with parameters of type QueryStatusChecker Modifier and Type Method Description void
KafkaMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Since the kafka partition is not a part of the topic schema as well as not part of topic message data, we should not implement this method.void
KafkaRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
generates the sql to executes on basis of where condition and executes it. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.msk
Methods in com.amazonaws.athena.connectors.msk with parameters of type QueryStatusChecker Modifier and Type Method Description void
AmazonMskMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Since the kafka partition is not a part of the topic schema as well as not part of topic message data, we should not implement this method.void
AmazonMskRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
generates the sql to executes on basis of where condition and executes it. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.msk.consumer
Methods in com.amazonaws.athena.connectors.msk.consumer with parameters of type QueryStatusChecker 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. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.mysql
Methods in com.amazonaws.athena.connectors.mysql with parameters of type QueryStatusChecker Modifier and Type Method Description void
MySqlMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.neptune
Methods in com.amazonaws.athena.connectors.neptune with parameters of type QueryStatusChecker Modifier and Type Method Description void
NeptuneMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Our table doesn't support complex layouts or partitioning so we simply make this method a NoOp.protected void
NeptuneRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Used to read the row data associated with the provided Split. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.neptune.propertygraph
Methods in com.amazonaws.athena.connectors.neptune.propertygraph with parameters of type QueryStatusChecker 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 QueryStatusChecker in com.amazonaws.athena.connectors.neptune.rdf
Methods in com.amazonaws.athena.connectors.neptune.rdf with parameters of type QueryStatusChecker 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 QueryStatusChecker in com.amazonaws.athena.connectors.oracle
Methods in com.amazonaws.athena.connectors.oracle with parameters of type QueryStatusChecker Modifier and Type Method Description void
OracleMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
If it is a table with no partition, then data will be fetched with single split. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.postgresql
Methods in com.amazonaws.athena.connectors.postgresql with parameters of type QueryStatusChecker Modifier and Type Method Description void
PostGreSqlMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.redis
Methods in com.amazonaws.athena.connectors.redis with parameters of type QueryStatusChecker Modifier and Type Method Description void
RedisMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Even though our table doesn't support complex layouts or partitioning, we need to convey that there is at least 1 partition to read as part of the query or Athena will assume partition pruning found no candidate layouts to read.protected void
RedisRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.saphana
Methods in com.amazonaws.athena.connectors.saphana with parameters of type QueryStatusChecker Modifier and Type Method Description void
SaphanaMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
We are first checking if input table is a view, if it's a view, it will not have any partition info and data will be fetched with single split.If it is a table with no partition, then data will be fetched with single split. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.snowflake
Methods in com.amazonaws.athena.connectors.snowflake with parameters of type QueryStatusChecker Modifier and Type Method Description void
SnowflakeMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
Snowflake manual partition logic based upon number of records -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.sqlserver
Methods in com.amazonaws.athena.connectors.sqlserver with parameters of type QueryStatusChecker Modifier and Type Method Description void
SqlServerMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
Check whether input table is a view or not. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.synapse
Methods in com.amazonaws.athena.connectors.synapse with parameters of type QueryStatusChecker Modifier and Type Method Description void
SynapseMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
Partition metadata queries will be extracted from template files, we can check whether the table is partitioned or not using these queries.void
SynapseRecordHandler. readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.teradata
Methods in com.amazonaws.athena.connectors.teradata with parameters of type QueryStatusChecker Modifier and Type Method Description void
TeradataMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)
-
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.timestream
Methods in com.amazonaws.athena.connectors.timestream with parameters of type QueryStatusChecker Modifier and Type Method Description void
TimestreamMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Our table doesn't support complex layouts or partitioning so we simply make this method a NoOp.protected void
TimestreamRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Scans TimeStream. -
Uses of QueryStatusChecker in com.amazonaws.athena.connectors.tpcds
Methods in com.amazonaws.athena.connectors.tpcds with parameters of type QueryStatusChecker Modifier and Type Method Description void
TPCDSMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
We do not support partitioning at this time since Partition Pruning Performance is not part of the dimensions we test using TPCDS.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 QueryStatusChecker in com.amazonaws.athena.connectors.vertica
Methods in com.amazonaws.athena.connectors.vertica with parameters of type QueryStatusChecker Modifier and Type Method Description void
VerticaMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)
Used to get the partitions that must be read from the request table in order to satisfy the requested predicate.protected void
VerticaRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)
Used to read the row data associated with the provided Split.
-