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 voidMetadataHandler. 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 voidRecordHandler. 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 voidAwsCmdbMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)Delegates to the TableProvider that is registered for the requested table.protected voidAwsCmdbRecordHandler. 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 voidEmrClusterTableProvider. 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.voidRdsTableProvider. 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.voidTableProvider. 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 voidEbsTableProvider. 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.voidEc2TableProvider. 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.voidImagesTableProvider. 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.voidRouteTableProvider. 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.voidSecurityGroupsTableProvider. 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.voidSubnetTableProvider. 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.voidVpcTableProvider. 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 voidS3BucketsTableProvider. 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.voidS3ObjectsTableProvider. 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 voidClickHouseMetadataHandler. 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 voidHiveMetadataHandler. 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.voidImpalaMetadataHandler. 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 voidCloudwatchMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)Gets the list of LogStreams that need to be scanned to satisfy the requested table.protected voidCloudwatchRecordHandler. 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 voidMetricsMetadataHandler. 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 voidMetricsRecordHandler. 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 voidDataLakeGen2MetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)The partitions are being implemented based on the type of data externally in case of Gen 2.voidDataLakeGen2RecordHandler. readWithConstraint(BlockSpiller blockSpiller, ReadRecordsRequest readRecordsRequest, QueryStatusChecker queryStatusChecker) -
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 voidDb2MetadataHandler. 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 voidDb2As400MetadataHandler. 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 voidDocDBMetadataHandler. 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 voidDocDBRecordHandler. 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 voidDynamoDBMetadataHandler. 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 voidDynamoDBRecordHandler. 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 voidElasticsearchMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)Elasticsearch does not support partitioning so this method is a NoOp.protected voidElasticsearchRecordHandler. 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 voidExampleMetadataHandler. 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 voidExampleRecordHandler. 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 voidGcsMetadataHandler. 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 voidGcsRecordHandler. 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 voidBigQueryMetadataHandler. 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 limitvoidBigQueryRecordHandler. 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 voidHbaseMetadataHandler. 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 voidHbaseRecordHandler. 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 voidHiveMetadataHandler. 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 voidMultiplexingJdbcMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest getTableLayoutRequest, QueryStatusChecker queryStatusChecker)voidMultiplexingJdbcRecordHandler. 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 voidJdbcMetadataHandler. getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request, QueryStatusChecker queryStatusChecker)voidJdbcRecordHandler. 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 voidKafkaMetadataHandler. 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.voidKafkaRecordHandler. 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 voidAmazonMskMetadataHandler. 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.voidAmazonMskRecordHandler. 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 voidBaseMskConsumer. consume(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker, SplitParameters splitParameters, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)voidMskConsumer. 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 voidMySqlMetadataHandler. 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 voidNeptuneMetadataHandler. 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 voidNeptuneRecordHandler. 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 voidPropertyGraphHandler. 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 voidRDFHandler. 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 voidOracleMetadataHandler. 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 voidPostGreSqlMetadataHandler. 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 voidRedisMetadataHandler. 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 voidRedisRecordHandler. 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 voidSaphanaMetadataHandler. 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 voidSnowflakeMetadataHandler. 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.voidSnowflakeRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)Used to handle data transfer between Snowflake and Athena, supporting both direct query and S3 export paths, converts to arrow format, and manages spillover logic. -
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 voidSqlServerMetadataHandler. 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 voidSynapseMetadataHandler. 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.voidSynapseRecordHandler. 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 voidTeradataMetadataHandler. 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 voidTimestreamMetadataHandler. 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 voidTimestreamRecordHandler. 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 voidTPCDSMetadataHandler. 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 voidTPCDSRecordHandler. 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 voidVerticaMetadataHandler. 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 voidVerticaRecordHandler. readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)Used to read the row data associated with the provided Split.
-