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 class
BlockAllocatorImpl
Basic 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 BlockAllocator
BlockAllocatorRegistry. 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 Block
BlockUtils. 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 Block
BlockUtils. 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 Block
BlockUtils. 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 Marker
Marker. above(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)
static Range
Range. all(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)
static SortedRangeSet
SortedRangeSet. all(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)
static Marker
Marker. below(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)
ValueSet
AllOrNoneValueSet. complement(BlockAllocator allocator)
EquatableValueSet
EquatableValueSet. complement(BlockAllocator allocator)
SortedRangeSet
SortedRangeSet. complement(BlockAllocator allocator)
ValueSet
ValueSet. complement(BlockAllocator allocator)
default boolean
ValueSet. contains(BlockAllocator allocator, ValueSet other)
static Range
Range. equal(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)
static Marker
Marker. exactly(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object value)
static Range
Range. greaterThan(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object low)
static Range
Range. greaterThanOrEqual(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object low)
ValueSet
AllOrNoneValueSet. intersect(BlockAllocator allocator, ValueSet other)
EquatableValueSet
EquatableValueSet. intersect(BlockAllocator allocator, ValueSet other)
SortedRangeSet
SortedRangeSet. intersect(BlockAllocator allocator, ValueSet other)
ValueSet
ValueSet. intersect(BlockAllocator allocator, ValueSet other)
static Range
Range. lessThan(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object high)
static Range
Range. lessThanOrEqual(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object high)
static Marker
Marker. lowerUnbounded(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)
static EquatableValueSet.Builder
EquatableValueSet. newBuilder(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, boolean isWhiteList, boolean nullAllowed)
Used to construct new Builder for EquatableValueSet.static SortedRangeSet
SortedRangeSet. notNull(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)
static Marker
Marker. nullMarker(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type)
default boolean
ValueSet. overlaps(BlockAllocator allocator, ValueSet other)
static Range
Range. range(BlockAllocator allocator, org.apache.arrow.vector.types.pojo.ArrowType type, Object low, boolean lowInclusive, Object high, boolean highInclusive)
default ValueSet
ValueSet. subtract(BlockAllocator allocator, ValueSet other)
ValueSet
AllOrNoneValueSet. union(BlockAllocator allocator, ValueSet other)
EquatableValueSet
EquatableValueSet. union(BlockAllocator allocator, ValueSet other)
SortedRangeSet
SortedRangeSet. union(BlockAllocator allocator, ValueSet other)
SortedRangeSet
SortedRangeSet. union(BlockAllocator allocator, Collection<ValueSet> valueSets)
ValueSet
ValueSet. union(BlockAllocator allocator, ValueSet other)
default ValueSet
ValueSet. union(BlockAllocator allocator, Collection<ValueSet> valueSets)
static Marker
Marker. 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 GetDataSourceCapabilitiesResponse
MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Used to describe the types of capabilities supported by a data source.GetTableResponse
MetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Query PassThrough.abstract GetSplitsResponse
MetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
GlueMetadataHandler. 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 GetTableResponse
GlueMetadataHandler. 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 GetTableResponse
MetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Table.GetTableLayoutResponse
MetadataHandler. 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 void
MetadataHandler. doHandleRequest(BlockAllocator allocator, com.fasterxml.jackson.databind.ObjectMapper objectMapper, MetadataRequest req, OutputStream outputStream)
protected void
RecordHandler. doHandleRequest(BlockAllocator allocator, com.fasterxml.jackson.databind.ObjectMapper objectMapper, RecordRequest req, OutputStream outputStream)
protected void
UserDefinedFunctionHandler. doHandleRequest(BlockAllocator allocator, com.fasterxml.jackson.databind.ObjectMapper objectMapper, UserDefinedFunctionRequest req, OutputStream outputStream)
ListSchemasResponse
GlueMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)
Returns an unfiltered list of schemas (aka databases) from AWS Glue DataCatalog.protected ListSchemasResponse
GlueMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request, GlueMetadataHandler.DatabaseFilter filter)
Returns a list of schemas (aka databases) from AWS Glue DataCatalog with optional filtering.abstract ListSchemasResponse
MetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)
Used to get the list of schemas (aka databases) that this source contains.ListTablesResponse
GlueMetadataHandler. doListTables(BlockAllocator blockAllocator, ListTablesRequest request)
Returns an unfiltered list of tables from AWS Glue DataCatalog for the requested schema (aka database)protected ListTablesResponse
GlueMetadataHandler. 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 ListTablesResponse
MetadataHandler. doListTables(BlockAllocator allocator, ListTablesRequest request)
Used to get the list of tables that this source contains.RecordResponse
RecordHandler. doReadRecords(BlockAllocator allocator, ReadRecordsRequest request)
Used to read the row data associated with the provided Split.void
CompositeHandler. 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 Block
UserDefinedFunctionHandler. 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.ObjectMapper
ObjectMapperFactory. create(BlockAllocator allocator)
Deprecated.static com.fasterxml.jackson.databind.ObjectMapper
VersionedObjectMapperFactory. create(BlockAllocator allocator)
Creates anObjectMapper
using the current SDK SerDe version.static com.fasterxml.jackson.databind.ObjectMapper
VersionedObjectMapperFactory. create(BlockAllocator allocator, int version)
Creates anObjectMapper
using 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.ObjectMapper
ObjectMapperFactoryV2. 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.ObjectMapper
ObjectMapperFactoryV3. 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.ObjectMapper
ObjectMapperFactoryV4. 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.ObjectMapper
ObjectMapperFactoryV5. 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 GetSplitsResponse
AwsCmdbMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Delegates to the TableProvider that is registered for the requested table.GetTableResponse
AwsCmdbMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Delegates to the TableProvider that is registered for the requested table.ListSchemasResponse
AwsCmdbMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
Returns the list of supported schemas discovered from the loaded TableProvider scan.ListTablesResponse
AwsCmdbMetadataHandler. 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 GetTableResponse
EmrClusterTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
RdsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
TableProvider. 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 GetTableResponse
EbsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
Ec2TableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
ImagesTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
RouteTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
SecurityGroupsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
SubnetTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
VpcTableProvider. 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 GetTableResponse
S3BucketsTableProvider. getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableResponse
S3ObjectsTableProvider. 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 GetSplitsResponse
ClickHouseMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
ListSchemasResponse
ClickHouseMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
-
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 GetDataSourceCapabilitiesResponse
HiveMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Overridden this method to describe the types of capabilities supported by a data sourceGetDataSourceCapabilitiesResponse
ImpalaMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Used to describe the types of capabilities supported by a data source.GetSplitsResponse
HiveMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Used to split-up the reads required to scan the requested batch of partition(s).GetSplitsResponse
ImpalaMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
HiveMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Used to get definition (field names, types, descriptions, etc...) of a Hive Table.GetTableResponse
ImpalaMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Used to get definition (field names, types, descriptions, etc...) of an Impala Table. -
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 GetDataSourceCapabilitiesResponse
CloudwatchMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
CloudwatchMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
CloudwatchMetadataHandler. 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.GetTableResponse
CloudwatchMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Returns the pre-set schema for the request Cloudwatch table (LogStream) and schema (LogGroup) after validating that it exists.ListSchemasResponse
CloudwatchMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
List LogGroups in your Cloudwatch account treating each as a 'schema' (aka database)ListTablesResponse
CloudwatchMetadataHandler. 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 GetSplitsResponse
MetricsMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Each 'metric' in cloudwatch is uniquely identified by a quad of Namespace, List, MetricName, Statistic. GetTableResponse
MetricsMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Returns the details of the requested static table.ListSchemasResponse
MetricsMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
Only supports a single, static, schema defined by SCHEMA_NAME.ListTablesResponse
MetricsMetadataHandler. 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 GetDataSourceCapabilitiesResponse
DataLakeGen2MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
DataLakeGen2MetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
DataLakeGen2MetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
-
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 GetDataSourceCapabilitiesResponse
Db2MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Overridden this method to describe the types of capabilities supported by a data sourceGetSplitsResponse
Db2MetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Split(s) will be created based on table partition.GetTableResponse
Db2MetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Creating TableName object, Schema object for partition framing fields, and Schema object for table fields.ListSchemasResponse
Db2MetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
Overridden this method to fetch only user defined schema(s) in Athena Data window.ListTablesResponse
Db2MetadataHandler. 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.db2as400
Methods in com.amazonaws.athena.connectors.db2as400 with parameters of type BlockAllocator Modifier and Type Method Description GetDataSourceCapabilitiesResponse
Db2As400MetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
Db2As400MetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Split(s) will be created based on table partition.GetTableResponse
Db2As400MetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Creating TableName object, Schema object for partition framing fields, and Schema object for table fields.ListSchemasResponse
Db2As400MetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
Overridden this method to fetch only user defined schema(s) in Athena Data window.ListTablesResponse
Db2As400MetadataHandler. 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 GetDataSourceCapabilitiesResponse
DocDBMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
DocDBMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
DocDBMetadataHandler. 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.GetTableResponse
DocDBMetadataHandler. 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.ListSchemasResponse
DocDBMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)
List databases in your DocumentDB instance treating each as a 'schema' (aka database)ListTablesResponse
DocDBMetadataHandler. 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 GetDataSourceCapabilitiesResponse
DynamoDBMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
DynamoDBMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
DynamoDBMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Copies data from partitions and creates splits, serializing as necessary for later calls to RecordHandler#readWithContraint.GetTableResponse
DynamoDBMetadataHandler. 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.ListSchemasResponse
DynamoDBMetadataHandler. 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 .ListTablesResponse
DynamoDBMetadataHandler. 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 GetDataSourceCapabilitiesResponse
ElasticsearchMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
ElasticsearchMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
ElasticsearchMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Used to split-up the reads required to scan the requested index by shard.GetTableResponse
ElasticsearchMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponse
ElasticsearchMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)
Used to get the list of domains (aka databases) for the Elasticsearch service.ListTablesResponse
ElasticsearchMetadataHandler. 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 GetDataSourceCapabilitiesResponse
ExampleMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Used to describe the types of capabilities supported by a data source.GetSplitsResponse
ExampleMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
ExampleMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponse
ExampleMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)
Used to get the list of schemas (aka databases) that this source contains.ListTablesResponse
ExampleMetadataHandler. 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 GetSplitsResponse
GcsMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Used to split up the reads required to scan the requested batch of partition(s).GetTableResponse
GcsMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponse
GcsMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)
Used to get the list of schemas (aka databases) that this source contains.ListTablesResponse
GcsMetadataHandler. 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 GetDataSourceCapabilitiesResponse
BigQueryMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
BigQueryMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
BigQueryMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Making minimum(10) splits based on constraints.GetTableResponse
BigQueryMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
ListSchemasResponse
BigQueryMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
ListTablesResponse
BigQueryMetadataHandler. 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 GetDataSourceCapabilitiesResponse
HbaseMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
HbaseMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
HbaseMetadataHandler. 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.GetTableResponse
HbaseMetadataHandler. 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.ListSchemasResponse
HbaseMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)
List namespaces in your HBase instance treating each as a 'schema' (aka database)ListTablesResponse
HbaseMetadataHandler. 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 GetDataSourceCapabilitiesResponse
HiveMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Used to describe the types of capabilities supported by a data source.GetSplitsResponse
HiveMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
HiveMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Used to get definition (field names, types, descriptions, etc...) of a Hive Table. -
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 GetDataSourceCapabilitiesResponse
MultiplexingJdbcMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
MultiplexingJdbcMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetSplitsResponse
MultiplexingJdbcMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
MultiplexingJdbcMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetTableLayoutResponse
MultiplexingJdbcMetadataHandler. doGetTableLayout(BlockAllocator blockAllocator, GetTableLayoutRequest getTableLayoutRequest)
ListSchemasResponse
MultiplexingJdbcMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
ListTablesResponse
MultiplexingJdbcMetadataHandler. 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 GetTableResponse
JdbcMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
abstract GetSplitsResponse
JdbcMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
JdbcMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
ListSchemasResponse
JdbcMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
ListTablesResponse
JdbcMetadataHandler. 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 GetSplitsResponse
KafkaMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Creating splits for each partition.GetTableResponse
KafkaMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Creates new object of GetTableResponse.ListSchemasResponse
KafkaMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
It will list the schema name which is set to default.ListTablesResponse
KafkaMetadataHandler. 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 GetSplitsResponse
AmazonMskMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Creating splits for each partition.GetTableResponse
AmazonMskMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
Creates new object of GetTableResponse.ListSchemasResponse
AmazonMskMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
It will list the schema name which is set to default.ListTablesResponse
AmazonMskMetadataHandler. 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 GetDataSourceCapabilitiesResponse
MySqlMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
MySqlMetadataHandler. 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 GetDataSourceCapabilitiesResponse
NeptuneMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
NeptuneMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
NeptuneMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest request)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
NeptuneMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponse
NeptuneMetadataHandler. 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.ListTablesResponse
NeptuneMetadataHandler. 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 GetDataSourceCapabilitiesResponse
OracleMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Overridden this method to describe the types of capabilities supported by a data sourceGetSplitsResponse
OracleMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
OracleMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
-
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 GetDataSourceCapabilitiesResponse
PostGreSqlMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
PostGreSqlMetadataHandler. 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 GetDataSourceCapabilitiesResponse
RedisMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
RedisMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
RedisMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest request)
If the table is comprised of multiple key prefixes, then we parallelize those by making them each a split.GetTableResponse
RedisMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)
Retrieves the schema for the request Table from Glue then enriches that result with Redis specific metadata and columns.ListSchemasResponse
RedisMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)
ListTablesResponse
RedisMetadataHandler. 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 GetDataSourceCapabilitiesResponse
RedshiftMetadataHandler. 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 GetDataSourceCapabilitiesResponse
SaphanaMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
Used to describe the types of capabilities supported by a data source.GetSplitsResponse
SaphanaMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
SaphanaMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
-
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 GetDataSourceCapabilitiesResponse
SnowflakeMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
SnowflakeMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
SnowflakeMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
ListSchemasResponse
SnowflakeMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
-
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 GetDataSourceCapabilitiesResponse
SqlServerMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
SqlServerMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
SqlServerMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
ListSchemasResponse
SqlServerMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest listSchemasRequest)
-
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 GetDataSourceCapabilitiesResponse
SynapseMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
SynapseMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
SynapseMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
-
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 GetDataSourceCapabilitiesResponse
TeradataMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetSplitsResponse
TeradataMetadataHandler. doGetSplits(BlockAllocator blockAllocator, GetSplitsRequest getSplitsRequest)
GetTableResponse
TeradataMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
-
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 GetDataSourceCapabilitiesResponse
TimestreamMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
TimestreamMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
TimestreamMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
GetTableResponse
TimestreamMetadataHandler. doGetTable(BlockAllocator blockAllocator, GetTableRequest request)
ListSchemasResponse
TimestreamMetadataHandler. doListSchemaNames(BlockAllocator blockAllocator, ListSchemasRequest request)
ListTablesResponse
TimestreamMetadataHandler. 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 GetDataSourceCapabilitiesResponse
TPCDSMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
TPCDSMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator allocator, GetTableRequest request)
GetSplitsResponse
TPCDSMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
TPCDSMetadataHandler. 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.ListSchemasResponse
TPCDSMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)
Returns our static list of schemas which correspond to the scale factor of the dataset we will generate.ListTablesResponse
TPCDSMetadataHandler. 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 GetDataSourceCapabilitiesResponse
VerticaMetadataHandler. doGetDataSourceCapabilities(BlockAllocator allocator, GetDataSourceCapabilitiesRequest request)
GetTableResponse
VerticaMetadataHandler. doGetQueryPassthroughSchema(BlockAllocator blockAllocator, GetTableRequest getTableRequest)
GetSplitsResponse
VerticaMetadataHandler. doGetSplits(BlockAllocator allocator, GetSplitsRequest request)
Used to split-up the reads required to scan the requested batch of partition(s).GetTableResponse
VerticaMetadataHandler. doGetTable(BlockAllocator allocator, GetTableRequest request)
Used to get definition (field names, types, descriptions, etc...) of a Table.ListSchemasResponse
VerticaMetadataHandler. doListSchemaNames(BlockAllocator allocator, ListSchemasRequest request)
Used to get the list of schemas (aka databases) that this source contains.
-