Uses of Interface
com.amazonaws.athena.connector.lambda.data.BlockAllocator
-
-
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.data
Classes in com.amazonaws.athena.connector.lambda.data that implement BlockAllocator Modifier and Type Class Description classBlockAllocatorImplBasic BlockAllocator which uses reference counting to perform garbage collection of Apache Arrow resources.Methods in com.amazonaws.athena.connector.lambda.data that return BlockAllocator Modifier and Type Method Description BlockAllocatorBlockAllocatorRegistry. getOrCreateAllocator(String id)Gets or creates a new Block Allocator for the given context (id).Methods in com.amazonaws.athena.connector.lambda.data with parameters of type BlockAllocator Modifier and Type Method Description static BlockBlockUtils. newBlock(BlockAllocator allocator, String columnName, org.apache.arrow.vector.types.pojo.ArrowType type, Object... values)Creates a new Block with a single column and populated with the provided values.static BlockBlockUtils. newBlock(BlockAllocator allocator, String columnName, org.apache.arrow.vector.types.pojo.ArrowType type, Collection<Object> values)Creates a new Block with a single column and populated with the provided values.static BlockBlockUtils. newEmptyBlock(BlockAllocator allocator, String columnName, org.apache.arrow.vector.types.pojo.ArrowType type)Creates a new, empty, Block with a single column.Constructors in com.amazonaws.athena.connector.lambda.data with parameters of type BlockAllocator Constructor Description RecordBatchSerDe(BlockAllocator allocator)Deprecated.S3BlockSpiller(software.amazon.awssdk.services.s3.S3Client amazonS3, SpillConfig spillConfig, BlockAllocator allocator, org.apache.arrow.vector.types.pojo.Schema schema, ConstraintEvaluator constraintEvaluator, int maxRowsPerCall, Map<String,String> configOptions)Constructs a new S3BlockSpiller.S3BlockSpiller(software.amazon.awssdk.services.s3.S3Client amazonS3, SpillConfig spillConfig, BlockAllocator allocator, org.apache.arrow.vector.types.pojo.Schema schema, ConstraintEvaluator constraintEvaluator, Map<String,String> configOptions)Constructor which uses the default maxRowsPerCall.S3BlockSpillReader(software.amazon.awssdk.services.s3.S3Client amazonS3, BlockAllocator allocator) -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.domain.predicate
Methods in com.amazonaws.athena.connector.lambda.domain.predicate with parameters of type BlockAllocator Modifier and Type Method Description static MarkerMarker. above(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)static RangeRange. all(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)static SortedRangeSetSortedRangeSet. all(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)static MarkerMarker. below(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)ValueSetAllOrNoneValueSet. complement(BlockAllocator allocator)EquatableValueSetEquatableValueSet. complement(BlockAllocator allocator)SortedRangeSetSortedRangeSet. complement(BlockAllocator allocator)ValueSetValueSet. complement(BlockAllocator allocator)default booleanValueSet. contains(BlockAllocator allocator, ValueSet other)static RangeRange. equal(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)static MarkerMarker. exactly(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)static RangeRange. greaterThan(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object low)static RangeRange. greaterThanOrEqual(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object low)ValueSetAllOrNoneValueSet. intersect(BlockAllocator allocator, ValueSet other)EquatableValueSetEquatableValueSet. intersect(BlockAllocator allocator, ValueSet other)SortedRangeSetSortedRangeSet. intersect(BlockAllocator allocator, ValueSet other)ValueSetValueSet. intersect(BlockAllocator allocator, ValueSet other)static RangeRange. lessThan(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object high)static RangeRange. lessThanOrEqual(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object high)static MarkerMarker. lowerUnbounded(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)static EquatableValueSet.BuilderEquatableValueSet. newBuilder(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, boolean isWhiteList, boolean nullAllowed)Used to construct new Builder for EquatableValueSet.static SortedRangeSetSortedRangeSet. notNull(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)static MarkerMarker. nullMarker(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)default booleanValueSet. overlaps(BlockAllocator allocator, ValueSet other)static RangeRange. range(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object low, boolean lowInclusive, Object high, boolean highInclusive)default ValueSetValueSet. subtract(BlockAllocator allocator, ValueSet other)ValueSetAllOrNoneValueSet. union(BlockAllocator allocator, ValueSet other)EquatableValueSetEquatableValueSet. union(BlockAllocator allocator, ValueSet other)SortedRangeSetSortedRangeSet. union(BlockAllocator allocator, ValueSet other)SortedRangeSetSortedRangeSet. union(BlockAllocator allocator, Collection<ValueSet> valueSets)ValueSetValueSet. union(BlockAllocator allocator, ValueSet other)default ValueSetValueSet. union(BlockAllocator allocator, Collection<ValueSet> valueSets)static MarkerMarker. upperUnbounded(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)Constructors in com.amazonaws.athena.connector.lambda.domain.predicate with parameters of type BlockAllocator Constructor Description ConstraintEvaluator(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints)MarkerFactory(BlockAllocator allocator)Creates a new MarkerFactory using the provided BlockAllocator. -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.handlers
Methods in com.amazonaws.athena.connector.lambda.handlers with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Used to describe the types of capabilities supported by a data source.GetTableResponseMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Query PassThrough.abstract GetSplitsResponseMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponseGlueMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)Attempts to retrieve a Table (columns and properties) from AWS Glue for the request schema (aka database) and table name with no fitlering.protected GetTableResponseGlueMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request, GlueMetadataHandler.TableFilter filter)Attempts to retrieve a Table (columns and properties) from AWS Glue for the request schema (aka database) and table name with no filtering.abstract GetTableResponseMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table.GetTableLayoutResponseMetadataHandler. doGetTableLayout(BlockAllocator allocator, GetTableLayoutRequest request)Used to get the partitions that must be read from the request table in order to satisfy the requested predicate.protected voidMetadataHandler. doHandleRequest(BlockAllocator allocator, com.fasterxml.jackson.databind.ObjectMapper objectMapper, MetadataRequest req, OutputStream outputStream)protected voidRecordHandler. doHandleRequest(BlockAllocator allocator, com.fasterxml.jackson.databind.ObjectMapper objectMapper, RecordRequest req, OutputStream outputStream)protected voidUserDefinedFunctionHandler. doHandleRequest(BlockAllocator allocator, com.fasterxml.jackson.databind.ObjectMapper objectMapper, UserDefinedFunctionRequest req, OutputStream outputStream)ListSchemasResponseGlueMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)Returns an unfiltered list of schemas (aka databases) from AWS Glue DataCatalog.protected ListSchemasResponseGlueMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request, GlueMetadataHandler.DatabaseFilter filter)Returns a list of schemas (aka databases) from AWS Glue DataCatalog with optional filtering.abstract ListSchemasResponseMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Used to get the list of schemas (aka databases) that this source contains.ListTablesResponseGlueMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request)Returns an unfiltered list of tables from AWS Glue DataCatalog for the requested schema (aka database)protected ListTablesResponseGlueMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request, GlueMetadataHandler.TableFilter filter)Returns a paginated list of tables from AWS Glue DataCatalog with optional filtering for the requested schema (aka database).abstract ListTablesResponseMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get the list of tables that this source contains.RecordResponseRecordHandler. doReadRecords(BlockAllocator allocator, ReadRecordsRequest request)Used to read the row data associated with the provided Split.voidCompositeHandler. handleRequest(BlockAllocator allocator, FederationRequest rawReq, OutputStream outputStream, com.fasterxml.jackson.databind.ObjectMapper objectMapper)Handles routing the request to the appropriate Handler, either MetadataHandler or RecordHandler.protected BlockUserDefinedFunctionHandler. processRows(BlockAllocator allocator, Method udfMethod, Block inputRecords, org.apache.arrow.vector.types.pojo.Schema outputSchema)Processes a group by rows. -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.security
Constructors in com.amazonaws.athena.connector.lambda.security with parameters of type BlockAllocator Constructor Description AesGcmBlockCrypto(BlockAllocator allocator)NoOpBlockCrypto(BlockAllocator allocator) -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.serde
Methods in com.amazonaws.athena.connector.lambda.serde with parameters of type BlockAllocator Modifier and Type Method Description static com.fasterxml.jackson.databind.ObjectMapperObjectMapperFactory. create(BlockAllocator allocator)Deprecated.static com.fasterxml.jackson.databind.ObjectMapperVersionedObjectMapperFactory. create(BlockAllocator allocator)Creates anObjectMapperusing the current SDK SerDe version.static com.fasterxml.jackson.databind.ObjectMapperVersionedObjectMapperFactory. create(BlockAllocator allocator, int version)Creates anObjectMapperusing the provided SerDe version.Constructors in com.amazonaws.athena.connector.lambda.serde with parameters of type BlockAllocator Constructor Description BlockDeserializer(BlockAllocator allocator)Deprecated. -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.serde.v2
Methods in com.amazonaws.athena.connector.lambda.serde.v2 with parameters of type BlockAllocator Modifier and Type Method Description static com.fasterxml.jackson.databind.ObjectMapperObjectMapperFactoryV2. create(BlockAllocator allocator)Deprecated.Constructors in com.amazonaws.athena.connector.lambda.serde.v2 with parameters of type BlockAllocator Constructor Description Deserializer(BlockAllocator allocator, VersionedSerDe.Deserializer<org.apache.arrow.vector.types.pojo.Schema> schemaDeserializer) -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.serde.v3
Methods in com.amazonaws.athena.connector.lambda.serde.v3 with parameters of type BlockAllocator Modifier and Type Method Description static com.fasterxml.jackson.databind.ObjectMapperObjectMapperFactoryV3. create(BlockAllocator allocator)Constructors in com.amazonaws.athena.connector.lambda.serde.v3 with parameters of type BlockAllocator Constructor Description Deserializer(BlockAllocator allocator, VersionedSerDe.Deserializer<org.apache.arrow.vector.types.pojo.Schema> schemaDeserializer) -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.serde.v4
Methods in com.amazonaws.athena.connector.lambda.serde.v4 with parameters of type BlockAllocator Modifier and Type Method Description static com.fasterxml.jackson.databind.ObjectMapperObjectMapperFactoryV4. create(BlockAllocator allocator)Constructors in com.amazonaws.athena.connector.lambda.serde.v4 with parameters of type BlockAllocator Constructor Description Deserializer(BlockAllocator allocator, VersionedSerDe.Deserializer<org.apache.arrow.vector.types.pojo.Schema> schemaDeserializer) -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.serde.v5
Methods in com.amazonaws.athena.connector.lambda.serde.v5 with parameters of type BlockAllocator Modifier and Type Method Description static com.fasterxml.jackson.databind.ObjectMapperObjectMapperFactoryV5. create(BlockAllocator allocator) -
Uses of BlockAllocator in com.amazonaws.athena.connector.lambda.serde.v6
Methods in com.amazonaws.athena.connector.lambda.serde.v6 with parameters of type BlockAllocator Modifier and Type Method Description static com.fasterxml.jackson.databind.ObjectMapperObjectMapperFactoryV6. create(BlockAllocator allocator) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.aws.cmdb
Methods in com.amazonaws.athena.connectors.aws.cmdb with parameters of type BlockAllocator Modifier and Type Method Description GetSplitsResponseAwsCmdbMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Delegates to the TableProvider that is registered for the requested table.GetTableResponseAwsCmdbMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)Delegates to the TableProvider that is registered for the requested table.ListSchemasResponseAwsCmdbMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)Returns the list of supported schemas discovered from the loaded TableProvider scan.ListTablesResponseAwsCmdbMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest)Returns the list of supported tables on the requested schema discovered from the loaded TableProvider scan. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.aws.cmdb.tables
Methods in com.amazonaws.athena.connectors.aws.cmdb.tables with parameters of type BlockAllocator Modifier and Type Method Description GetTableResponseEmrClusterTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseRdsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)Provides access to the Schema details of the requested table. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.aws.cmdb.tables.ec2
Methods in com.amazonaws.athena.connectors.aws.cmdb.tables.ec2 with parameters of type BlockAllocator Modifier and Type Method Description GetTableResponseEbsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseEc2TableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseImagesTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseRouteTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseSecurityGroupsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseSubnetTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseVpcTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.aws.cmdb.tables.s3
Methods in com.amazonaws.athena.connectors.aws.cmdb.tables.s3 with parameters of type BlockAllocator Modifier and Type Method Description GetTableResponseS3BucketsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableResponseS3ObjectsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.clickhouse
Methods in com.amazonaws.athena.connectors.clickhouse with parameters of type BlockAllocator Modifier and Type Method Description GetSplitsResponseClickHouseMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.cloudera
Methods in com.amazonaws.athena.connectors.cloudera with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseHiveMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Overridden this method to describe the types of capabilities supported by a data sourceGetDataSourceCapabilitiesResponseImpalaMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Used to describe the types of capabilities supported by a data source.GetSplitsResponseHiveMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Used to split-up the reads required to scan the requested batch of partition(s).GetSplitsResponseImpalaMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Used to split-up the reads required to scan the requested batch of partition(s). -
Uses of BlockAllocator in com.amazonaws.athena.connectors.cloudwatch
Methods in com.amazonaws.athena.connectors.cloudwatch with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseCloudwatchMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseCloudwatchMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseCloudwatchMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Each partition is converted into a single Split which means we will potentially read all LogStreams required for the query in parallel.GetTableResponseCloudwatchMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)Returns the pre-set schema for the request Cloudwatch table (LogStream) and schema (LogGroup) after validating that it exists.ListSchemasResponseCloudwatchMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)List LogGroups in your Cloudwatch account treating each as a 'schema' (aka database)ListTablesResponseCloudwatchMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest)List LogStreams within the requested schema (aka LogGroup) in your Cloudwatch account treating each as a 'table'. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.cloudwatch.metrics
Methods in com.amazonaws.athena.connectors.cloudwatch.metrics with parameters of type BlockAllocator Modifier and Type Method Description GetSplitsResponseMetricsMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Each 'metric' in cloudwatch is uniquely identified by a quad of Namespace, List, MetricName, Statistic. GetTableResponseMetricsMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)Returns the details of the requested static table.ListSchemasResponseMetricsMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)Only supports a single, static, schema defined by SCHEMA_NAME.ListTablesResponseMetricsMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest)Supports a set of static tables defined by: TABLES -
Uses of BlockAllocator in com.amazonaws.athena.connectors.datalakegen2
Methods in com.amazonaws.athena.connectors.datalakegen2 with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseDataLakeGen2MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseDataLakeGen2MetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.db2
Methods in com.amazonaws.athena.connectors.db2 with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseDb2MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Overridden this method to describe the types of capabilities supported by a data sourceGetSplitsResponseDb2MetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Split(s) will be created based on table partition.ListSchemasResponseDb2MetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)Overridden this method to fetch only user defined schema(s) in Athena Data window. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.db2as400
Methods in com.amazonaws.athena.connectors.db2as400 with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseDb2As400MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseDb2As400MetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Split(s) will be created based on table partition.ListSchemasResponseDb2As400MetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)Overridden this method to fetch only user defined schema(s) in Athena Data window.ListTablesResponseDb2As400MetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest)Overridden this method to fetch table(s) for selected schema in Athena Data window. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.docdb
Methods in com.amazonaws.athena.connectors.docdb with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseDocDBMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseDocDBMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseDocDBMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest request)Since our connector does not support parallel scans we generate a single Split and include the connection details as a property on the split so that the RecordHandler has easy access to it.GetTableResponseDocDBMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)If Glue is enabled as a source of supplemental metadata we look up the requested Schema/Table in Glue and filters out any results that don't have the DOCDB_METADATA_FLAG set.ListSchemasResponseDocDBMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)List databases in your DocumentDB instance treating each as a 'schema' (aka database)ListTablesResponseDocDBMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request)List collections in the requested schema in your DocumentDB instance treating the requested schema as an DocumentDB database. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.dynamodb
Methods in com.amazonaws.athena.connectors.dynamodb with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseDynamoDBMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseDynamoDBMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseDynamoDBMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Copies data from partitions and creates splits, serializing as necessary for later calls to RecordHandler#readWithContraint.GetTableResponseDynamoDBMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Fetches a table's schema from Glue DataCatalog if present and not disabled, otherwise falls back to doing a small table scan derives a schema from that.ListSchemasResponseDynamoDBMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Since DynamoDB does not have "schemas" or "databases", this lists all the Glue databases (if not disabled) that contain "dynamo-db-flag" in their URIs .ListTablesResponseDynamoDBMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Lists all Glue tables (if not disabled) in the schema specified that indicate use for DynamoDB metadata. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.elasticsearch
Methods in com.amazonaws.athena.connectors.elasticsearch with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseElasticsearchMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseElasticsearchMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseElasticsearchMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Used to split-up the reads required to scan the requested index by shard.GetTableResponseElasticsearchMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponseElasticsearchMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Used to get the list of domains (aka databases) for the Elasticsearch service.ListTablesResponseElasticsearchMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get the list of indices contained in the specified domain. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.example
Methods in com.amazonaws.athena.connectors.example with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseExampleMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Used to describe the types of capabilities supported by a data source.GetSplitsResponseExampleMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponseExampleMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponseExampleMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Used to get the list of schemas (aka databases) that this source contains.ListTablesResponseExampleMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get a paginated list of tables that this source contains. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.gcs
Methods in com.amazonaws.athena.connectors.gcs with parameters of type BlockAllocator Modifier and Type Method Description GetSplitsResponseGcsMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Used to split up the reads required to scan the requested batch of partition(s).GetTableResponseGcsMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponseGcsMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Used to get the list of schemas (aka databases) that this source contains.ListTablesResponseGcsMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get the list of tables that this source contains. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.google.bigquery
Methods in com.amazonaws.athena.connectors.google.bigquery with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseBigQueryMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseBigQueryMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseBigQueryMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Making minimum(10) splits based on constraints.GetTableResponseBigQueryMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)ListSchemasResponseBigQueryMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)ListTablesResponseBigQueryMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.hbase
Methods in com.amazonaws.athena.connectors.hbase with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseHbaseMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseHbaseMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseHbaseMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest request)If the table is spread across multiple region servers, then we parallelize the scan by making each region server a split.GetTableResponseHbaseMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)If Glue is enabled as a source of supplemental metadata we look up the requested Schema/Table in Glue and filters out any results that don't have the HBASE_METADATA_FLAG set.ListSchemasResponseHbaseMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)List namespaces in your HBase instance treating each as a 'schema' (aka database)ListTablesResponseHbaseMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request)List tables in the requested schema in your HBase instance treating the requested schema as an HBase namespace. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.hortonworks
Methods in com.amazonaws.athena.connectors.hortonworks with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseHiveMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Used to describe the types of capabilities supported by a data source.GetSplitsResponseHiveMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)Used to split-up the reads required to scan the requested batch of partition(s). -
Uses of BlockAllocator in com.amazonaws.athena.connectors.jdbc
Methods in com.amazonaws.athena.connectors.jdbc with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseMultiplexingJdbcMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseMultiplexingJdbcMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetSplitsResponseMultiplexingJdbcMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)GetTableResponseMultiplexingJdbcMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetTableLayoutResponseMultiplexingJdbcMetadataHandler. doGetTableLayout(BlockAllocator blockAllocator, GetTableLayoutRequest getTableLayoutRequest)ListSchemasResponseMultiplexingJdbcMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)ListTablesResponseMultiplexingJdbcMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.jdbc.manager
Methods in com.amazonaws.athena.connectors.jdbc.manager with parameters of type BlockAllocator Modifier and Type Method Description GetTableResponseJdbcMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator blockAllocator, GetTableRequest getTableRequest)abstract GetSplitsResponseJdbcMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)GetTableResponseJdbcMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)ListSchemasResponseJdbcMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)ListTablesResponseJdbcMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest listTablesRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.kafka
Methods in com.amazonaws.athena.connectors.kafka with parameters of type BlockAllocator Modifier and Type Method Description GetSplitsResponseKafkaMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Creating splits for each partition.GetTableResponseKafkaMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)Creates new object of GetTableResponse.ListSchemasResponseKafkaMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)It will list the schema name which is set to default.ListTablesResponseKafkaMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest federationListTablesRequest)List all the tables. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.msk
Methods in com.amazonaws.athena.connectors.msk with parameters of type BlockAllocator Modifier and Type Method Description GetSplitsResponseAmazonMskMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Creating splits for each partition.GetTableResponseAmazonMskMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)Creates new object of GetTableResponse.ListSchemasResponseAmazonMskMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)It will list the schema name which is set to default.ListTablesResponseAmazonMskMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest federationListTablesRequest)List all the tables. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.mysql
Methods in com.amazonaws.athena.connectors.mysql with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseMySqlMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseMySqlMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.neptune
Methods in com.amazonaws.athena.connectors.neptune with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseNeptuneMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseNeptuneMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseNeptuneMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest request)Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponseNeptuneMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponseNeptuneMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Since the entire Neptune cluster is considered as a single graph database, just return the glue database name provided as a single database (schema) name.ListTablesResponseNeptuneMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get the list of tables that this data source contains. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.oracle
Methods in com.amazonaws.athena.connectors.oracle with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseOracleMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Overridden this method to describe the types of capabilities supported by a data sourceGetSplitsResponseOracleMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.postgresql
Methods in com.amazonaws.athena.connectors.postgresql with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponsePostGreSqlMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponsePostGreSqlMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.redis
Methods in com.amazonaws.athena.connectors.redis with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseRedisMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseRedisMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseRedisMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest request)If the table is comprised of multiple key prefixes, then we parallelize those by making them each a split.GetTableResponseRedisMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)Retrieves the schema for the request Table from Glue then enriches that result with Redis specific metadata and columns.ListSchemasResponseRedisMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)ListTablesResponseRedisMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.redshift
Methods in com.amazonaws.athena.connectors.redshift with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseRedshiftMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.saphana
Methods in com.amazonaws.athena.connectors.saphana with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseSaphanaMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)Used to describe the types of capabilities supported by a data source.GetSplitsResponseSaphanaMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.snowflake
Methods in com.amazonaws.athena.connectors.snowflake with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseSnowflakeMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseSnowflakeMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.sqlserver
Methods in com.amazonaws.athena.connectors.sqlserver with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseSqlServerMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseSqlServerMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.synapse
Methods in com.amazonaws.athena.connectors.synapse with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseSynapseMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseSynapseMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.teradata
Methods in com.amazonaws.athena.connectors.teradata with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseTeradataMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetSplitsResponseTeradataMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.timestream
Methods in com.amazonaws.athena.connectors.timestream with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseTimestreamMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseTimestreamMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseTimestreamMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)GetTableResponseTimestreamMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)ListSchemasResponseTimestreamMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)ListTablesResponseTimestreamMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request) -
Uses of BlockAllocator in com.amazonaws.athena.connectors.tpcds
Methods in com.amazonaws.athena.connectors.tpcds with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseTPCDSMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseTPCDSMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)GetSplitsResponseTPCDSMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponseTPCDSMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table using the static metadata provided by TerraData's TPCDS generator.ListSchemasResponseTPCDSMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Returns our static list of schemas which correspond to the scale factor of the dataset we will generate.ListTablesResponseTPCDSMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get the list of static tables from TerraData's TPCDS generator. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.tpcds.mock.pagination
Methods in com.amazonaws.athena.connectors.tpcds.mock.pagination with parameters of type BlockAllocator Modifier and Type Method Description GetTableResponseTPCDSMockMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table using the static metadata provided by TerraData's TPCDS generator.ListSchemasResponseTPCDSMockMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Returns our static list of schemas which correspond to the scale factor of the dataset we will generate.ListTablesResponseTPCDSMockMetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)Used to get the list of static tables from TerraData's TPCDS generator. -
Uses of BlockAllocator in com.amazonaws.athena.connectors.vertica
Methods in com.amazonaws.athena.connectors.vertica with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponseVerticaMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)GetTableResponseVerticaMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator blockAllocator, GetTableRequest getTableRequest)GetSplitsResponseVerticaMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponseVerticaMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponseVerticaMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)Used to get the list of schemas (aka databases) that this source contains.
-