Package com.amazonaws.athena.connectors.aws.cmdb.tables

Class EmrClusterTableProvider

java.lang.Object

com.amazonaws.athena.connectors.aws.cmdb.tables.EmrClusterTableProvider

All Implemented Interfaces:

TableProvider

public class EmrClusterTableProvider
extends Object
implements TableProvider

Maps your EMR Clusters to a table.

Constructor Summary

Constructors

Constructor	Description
EmrClusterTableProvider(com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduce emr)

Method Summary

Modifier and Type	Method	Description
String	getSchema()	The schema name (aka database) that this table provider's table belongs to.
GetTableResponse	getTable(BlockAllocator blockAllocator, GetTableRequest getTableRequest)	Provides access to the Schema details of the requested table.
TableName	getTableName()	The fully qualified name of the table represented by this TableProvider.
void	readWithConstraint(BlockSpiller spiller, ReadRecordsRequest recordsRequest, QueryStatusChecker queryStatusChecker)	Calls ListClusters and DescribeCluster on the AWS EMR Client returning all clusters that match the supplied predicate and attempting to push down certain predicates (namely queries for specific cluster) to EC2.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.amazonaws.athena.connectors.aws.cmdb.tables.TableProvider

enhancePartitionSchema, getPartitions

Constructor Detail

EmrClusterTableProvider

public EmrClusterTableProvider(com.amazonaws.services.elasticmapreduce.AmazonElasticMapReduce emr)

Method Detail

getSchema

public String getSchema()

Description copied from interface: TableProvider

The schema name (aka database) that this table provider's table belongs to.

Specified by:

getSchema in interface TableProvider

Returns:

String containing the schema name.

getTableName

public TableName getTableName()

Description copied from interface: TableProvider

The fully qualified name of the table represented by this TableProvider.

Specified by:

getTableName in interface TableProvider

Returns:

The TableName containing the fully qualified name of the Table.

getTable

public GetTableResponse getTable(BlockAllocator blockAllocator,
                                 GetTableRequest getTableRequest)

Description copied from interface: TableProvider

Provides access to the Schema details of the requested table.

Specified by:

getTable in interface TableProvider

readWithConstraint

public void readWithConstraint(BlockSpiller spiller,
                               ReadRecordsRequest recordsRequest,
                               QueryStatusChecker queryStatusChecker)

Calls ListClusters and DescribeCluster on the AWS EMR Client returning all clusters that match the supplied predicate and attempting to push down certain predicates (namely queries for specific cluster) to EC2.

Specified by:

readWithConstraint in interface TableProvider