com.amazon.dax.client.dynamodbv2

Class ClusterDaxClient

java.lang.Object

com.amazonaws.services.dynamodbv2.AbstractAmazonDynamoDB

com.amazon.dax.client.dynamodbv2.ClusterDaxClient

All Implemented Interfaces:

AmazonDaxClient, AmazonDynamoDB

public class ClusterDaxClient
extends AbstractAmazonDynamoDB
implements AmazonDaxClient

A smart client for the DAX service that handles routing requests to cluster nodes and tracking cluster membership.

Field Summary

Fields inherited from interface com.amazonaws.services.dynamodbv2.AmazonDynamoDB

ENDPOINT_PREFIX

Constructor Summary

Constructors

Constructor and Description
ClusterDaxClient(ClientConfig cfg) Constructs a ClusterDaxClient with the provided configuration.

Method Summary

Modifier and Type	Method and Description
BatchGetItemResult	batchGetItem(BatchGetItemRequest arg0)
BatchGetItemResult	batchGetItem(Map<String,KeysAndAttributes> arg0)
BatchGetItemResult	batchGetItem(Map<String,KeysAndAttributes> arg0, String arg1)
BatchWriteItemResult	batchWriteItem(BatchWriteItemRequest arg0)
BatchWriteItemResult	batchWriteItem(Map<String,List<WriteRequest>> arg0)
CreateTableResult	createTable(CreateTableRequest arg0)
CreateTableResult	createTable(List<AttributeDefinition> arg0, String arg1, List<KeySchemaElement> arg2, ProvisionedThroughput arg3)
List<String>	defineAttributeList(Long attributeListId) Returns the attribute names for the provided attribute list identifier
Long	defineAttributeListId(List<String> attributeNames) Returns the attribute list identifier for the provided attributes.
Long	defineAttributeListId(List<String> attributeNames, List<String> keyNames) Returns the attribute list identifier for the provided attributes.
List<AttributeDefinition>	defineKeySchema(String tableName) Returns definitions of the key attributes for a table.
DeleteItemResult	deleteItem(DeleteItemRequest arg0)
DeleteItemResult	deleteItem(String arg0, Map<String,AttributeValue> arg1)
DeleteItemResult	deleteItem(String arg0, Map<String,AttributeValue> arg1, String arg2)
DeleteTableResult	deleteTable(DeleteTableRequest arg0)
DeleteTableResult	deleteTable(String arg0)
DescribeLimitsResult	describeLimits(DescribeLimitsRequest describeLimitsRequest)
DescribeTableResult	describeTable(DescribeTableRequest arg0)
DescribeTableResult	describeTable(String arg0)
List<com.amazon.dax.bits.disco.ServiceEndpoint>	endpoints() Returns the endpoints of the nodes belonging to the DAX cluster.
ResponseMetadata	getCachedResponseMetadata(AmazonWebServiceRequest arg0)
GetItemResult	getItem(GetItemRequest arg0)
GetItemResult	getItem(String arg0, Map<String,AttributeValue> arg1)
GetItemResult	getItem(String arg0, Map<String,AttributeValue> arg1, Boolean arg2)
ListTablesResult	listTables()
ListTablesResult	listTables(Integer arg0)
ListTablesResult	listTables(ListTablesRequest arg0)
ListTablesResult	listTables(String arg0)
ListTablesResult	listTables(String arg0, Integer arg1)
List<Integer>	methods(int serviceId) Returns the DAX RPC method identifiers supported by the service.
PutItemResult	putItem(PutItemRequest arg0)
PutItemResult	putItem(String arg0, Map<String,AttributeValue> arg1)
PutItemResult	putItem(String arg0, Map<String,AttributeValue> arg1, String arg2)
QueryResult	query(QueryRequest arg0)
ScanResult	scan(ScanRequest arg0)
ScanResult	scan(String arg0, List<String> arg1)
ScanResult	scan(String arg0, List<String> arg1, Map<String,Condition> arg2)
ScanResult	scan(String arg0, Map<String,Condition> arg1)
List<Integer>	services() Returns the DAX RPC service identifiers supported by the server.
void	setEndpoint(String arg0)
void	setRegion(Region region)
void	setRegion(String region) Set the AWS region where DAX cluster exists.
void	shutdown()
TransactGetItemsResult	transactGetItems(TransactGetItemsRequest request)
TransactWriteItemsResult	transactWriteItems(TransactWriteItemsRequest request)
UpdateItemResult	updateItem(String arg0, Map<String,AttributeValue> arg1, Map<String,AttributeValueUpdate> arg2)
UpdateItemResult	updateItem(String arg0, Map<String,AttributeValue> arg1, Map<String,AttributeValueUpdate> arg2, String arg3)
UpdateItemResult	updateItem(UpdateItemRequest arg0)
UpdateTableResult	updateTable(String arg0, ProvisionedThroughput arg1)
UpdateTableResult	updateTable(UpdateTableRequest arg0)
AmazonDynamoDBWaiters	waiters()

Methods inherited from class com.amazonaws.services.dynamodbv2.AbstractAmazonDynamoDB

batchExecuteStatement, createBackup, createGlobalTable, deleteBackup, describeBackup, describeContinuousBackups, describeContributorInsights, describeEndpoints, describeExport, describeGlobalTable, describeGlobalTableSettings, describeKinesisStreamingDestination, describeTableReplicaAutoScaling, describeTimeToLive, disableKinesisStreamingDestination, enableKinesisStreamingDestination, executeStatement, executeTransaction, exportTableToPointInTime, listBackups, listContributorInsights, listExports, listGlobalTables, listTagsOfResource, restoreTableFromBackup, restoreTableToPointInTime, tagResource, untagResource, updateContinuousBackups, updateContributorInsights, updateGlobalTable, updateGlobalTableSettings, updateTableReplicaAutoScaling, updateTimeToLive

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.amazonaws.services.dynamodbv2.AmazonDynamoDB

batchExecuteStatement, createBackup, createGlobalTable, deleteBackup, describeBackup, describeContinuousBackups, describeContributorInsights, describeEndpoints, describeExport, describeGlobalTable, describeGlobalTableSettings, describeKinesisStreamingDestination, describeTableReplicaAutoScaling, describeTimeToLive, disableKinesisStreamingDestination, enableKinesisStreamingDestination, executeStatement, executeTransaction, exportTableToPointInTime, listBackups, listContributorInsights, listExports, listGlobalTables, listTagsOfResource, restoreTableFromBackup, restoreTableToPointInTime, tagResource, untagResource, updateContinuousBackups, updateContributorInsights, updateGlobalTable, updateGlobalTableSettings, updateTableReplicaAutoScaling, updateTimeToLive

Constructor Detail

ClusterDaxClient

public ClusterDaxClient(ClientConfig cfg)

Constructs a ClusterDaxClient with the provided configuration.

Parameters:

cfg - configuration

Method Detail

batchGetItem

public BatchGetItemResult batchGetItem(BatchGetItemRequest arg0)

Specified by:

batchGetItem in interface AmazonDynamoDB

Overrides:

batchGetItem in class AbstractAmazonDynamoDB

batchGetItem

public BatchGetItemResult batchGetItem(Map<String,KeysAndAttributes> arg0,
                                       String arg1)

Specified by:

batchGetItem in interface AmazonDynamoDB

Overrides:

batchGetItem in class AbstractAmazonDynamoDB

batchGetItem

public BatchGetItemResult batchGetItem(Map<String,KeysAndAttributes> arg0)

Specified by:

batchGetItem in interface AmazonDynamoDB

Overrides:

batchGetItem in class AbstractAmazonDynamoDB

batchWriteItem

public BatchWriteItemResult batchWriteItem(BatchWriteItemRequest arg0)

Specified by:

batchWriteItem in interface AmazonDynamoDB

Overrides:

batchWriteItem in class AbstractAmazonDynamoDB

batchWriteItem

public BatchWriteItemResult batchWriteItem(Map<String,List<WriteRequest>> arg0)

Specified by:

batchWriteItem in interface AmazonDynamoDB

Overrides:

batchWriteItem in class AbstractAmazonDynamoDB

createTable

public CreateTableResult createTable(CreateTableRequest arg0)

Specified by:

createTable in interface AmazonDynamoDB

Overrides:

createTable in class AbstractAmazonDynamoDB

createTable

public CreateTableResult createTable(List<AttributeDefinition> arg0,
                                     String arg1,
                                     List<KeySchemaElement> arg2,
                                     ProvisionedThroughput arg3)

Specified by:

createTable in interface AmazonDynamoDB

Overrides:

createTable in class AbstractAmazonDynamoDB

defineKeySchema

public List<AttributeDefinition> defineKeySchema(String tableName)
                                          throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns definitions of the key attributes for a table.

Specified by:

defineKeySchema in interface AmazonDaxClient

Parameters:

tableName - the name of the table

Returns:

definitions of the table's key attributes. The first element defines the partition key; the second (if present) defines the sort key).

Throws:

AmazonClientException - if input is invalid or an error occurred

defineAttributeListId

public Long defineAttributeListId(List<String> attributeNames,
                                  List<String> keyNames)
                           throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns the attribute list identifier for the provided attributes.

Specified by:

defineAttributeListId in interface AmazonDaxClient

Parameters:

attributeNames - the names of the non-key attributes

keyNames - the names of the key attributes

Returns:

the identifier for the provided attributes

Throws:

AmazonClientException - if input is invalid or an error occurred

defineAttributeListId

public Long defineAttributeListId(List<String> attributeNames)
                           throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns the attribute list identifier for the provided attributes.

Specified by:

defineAttributeListId in interface AmazonDaxClient

Parameters:

attributeNames - the names of the attributes

Returns:

the identifier for the provided attributes

Throws:

AmazonClientException - if input is invalid or an error occurred

defineAttributeList

public List<String> defineAttributeList(Long attributeListId)
                                 throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns the attribute names for the provided attribute list identifier

Specified by:

defineAttributeList in interface AmazonDaxClient

Parameters:

attributeListId - the attribute list identifier

Returns:

the attribute names

Throws:

AmazonClientException - if input is invalid or an error occurred

deleteItem

public DeleteItemResult deleteItem(DeleteItemRequest arg0)

Specified by:

deleteItem in interface AmazonDynamoDB

Overrides:

deleteItem in class AbstractAmazonDynamoDB

deleteItem

public DeleteItemResult deleteItem(String arg0,
                                   Map<String,AttributeValue> arg1,
                                   String arg2)

Specified by:

deleteItem in interface AmazonDynamoDB

Overrides:

deleteItem in class AbstractAmazonDynamoDB

deleteItem

public DeleteItemResult deleteItem(String arg0,
                                   Map<String,AttributeValue> arg1)

Specified by:

deleteItem in interface AmazonDynamoDB

Overrides:

deleteItem in class AbstractAmazonDynamoDB

deleteTable

public DeleteTableResult deleteTable(DeleteTableRequest arg0)

Specified by:

deleteTable in interface AmazonDynamoDB

Overrides:

deleteTable in class AbstractAmazonDynamoDB

deleteTable

public DeleteTableResult deleteTable(String arg0)

Specified by:

deleteTable in interface AmazonDynamoDB

Overrides:

deleteTable in class AbstractAmazonDynamoDB

describeLimits

public DescribeLimitsResult describeLimits(DescribeLimitsRequest describeLimitsRequest)

Specified by:

describeLimits in interface AmazonDynamoDB

Overrides:

describeLimits in class AbstractAmazonDynamoDB

describeTable

public DescribeTableResult describeTable(DescribeTableRequest arg0)

Specified by:

describeTable in interface AmazonDynamoDB

Overrides:

describeTable in class AbstractAmazonDynamoDB

describeTable

public DescribeTableResult describeTable(String arg0)

Specified by:

describeTable in interface AmazonDynamoDB

Overrides:

describeTable in class AbstractAmazonDynamoDB

endpoints

public List<com.amazon.dax.bits.disco.ServiceEndpoint> endpoints()
                                                          throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns the endpoints of the nodes belonging to the DAX cluster.

Specified by:

endpoints in interface AmazonDaxClient

Returns:

the cluster's current endpoints

Throws:

AmazonClientException - if input is invalid or an error occurred

services

public List<Integer> services()
                       throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns the DAX RPC service identifiers supported by the server.

Specified by:

services in interface AmazonDaxClient

Returns:

the service identifiers

Throws:

AmazonClientException - if input is invalid or an error occurred

methods

public List<Integer> methods(int serviceId)
                      throws AmazonClientException

Description copied from interface: AmazonDaxClient

Returns the DAX RPC method identifiers supported by the service.

Specified by:

methods in interface AmazonDaxClient

Parameters:

serviceId - the service who's methods are being requested

Returns:

the method identifiers

Throws:

AmazonClientException - if input is invalid or an error occurred

getCachedResponseMetadata

public ResponseMetadata getCachedResponseMetadata(AmazonWebServiceRequest arg0)

Specified by:

getCachedResponseMetadata in interface AmazonDynamoDB

Overrides:

getCachedResponseMetadata in class AbstractAmazonDynamoDB

getItem

public GetItemResult getItem(GetItemRequest arg0)

Specified by:

getItem in interface AmazonDynamoDB

Overrides:

getItem in class AbstractAmazonDynamoDB

getItem

public GetItemResult getItem(String arg0,
                             Map<String,AttributeValue> arg1,
                             Boolean arg2)

Specified by:

getItem in interface AmazonDynamoDB

Overrides:

getItem in class AbstractAmazonDynamoDB

getItem

public GetItemResult getItem(String arg0,
                             Map<String,AttributeValue> arg1)

Specified by:

getItem in interface AmazonDynamoDB

Overrides:

getItem in class AbstractAmazonDynamoDB

listTables

public ListTablesResult listTables()

Specified by:

listTables in interface AmazonDynamoDB

Overrides:

listTables in class AbstractAmazonDynamoDB

listTables

public ListTablesResult listTables(Integer arg0)

Specified by:

listTables in interface AmazonDynamoDB

Overrides:

listTables in class AbstractAmazonDynamoDB

listTables

public ListTablesResult listTables(ListTablesRequest arg0)

Specified by:

listTables in interface AmazonDynamoDB

Overrides:

listTables in class AbstractAmazonDynamoDB

listTables

public ListTablesResult listTables(String arg0,
                                   Integer arg1)

Specified by:

listTables in interface AmazonDynamoDB

Overrides:

listTables in class AbstractAmazonDynamoDB

listTables

public ListTablesResult listTables(String arg0)

Specified by:

listTables in interface AmazonDynamoDB

Overrides:

listTables in class AbstractAmazonDynamoDB

putItem

public PutItemResult putItem(PutItemRequest arg0)

Specified by:

putItem in interface AmazonDynamoDB

Overrides:

putItem in class AbstractAmazonDynamoDB

putItem

public PutItemResult putItem(String arg0,
                             Map<String,AttributeValue> arg1,
                             String arg2)

Specified by:

putItem in interface AmazonDynamoDB

Overrides:

putItem in class AbstractAmazonDynamoDB

putItem

public PutItemResult putItem(String arg0,
                             Map<String,AttributeValue> arg1)

Specified by:

putItem in interface AmazonDynamoDB

Overrides:

putItem in class AbstractAmazonDynamoDB

query

public QueryResult query(QueryRequest arg0)

Specified by:

query in interface AmazonDynamoDB

Overrides:

query in class AbstractAmazonDynamoDB

scan

public ScanResult scan(ScanRequest arg0)

Specified by:

scan in interface AmazonDynamoDB

Overrides:

scan in class AbstractAmazonDynamoDB

scan

public ScanResult scan(String arg0,
                       List<String> arg1,
                       Map<String,Condition> arg2)

Specified by:

scan in interface AmazonDynamoDB

Overrides:

scan in class AbstractAmazonDynamoDB

scan

public ScanResult scan(String arg0,
                       List<String> arg1)

Specified by:

scan in interface AmazonDynamoDB

Overrides:

scan in class AbstractAmazonDynamoDB

scan

public ScanResult scan(String arg0,
                       Map<String,Condition> arg1)

Specified by:

scan in interface AmazonDynamoDB

Overrides:

scan in class AbstractAmazonDynamoDB

transactGetItems

public TransactGetItemsResult transactGetItems(TransactGetItemsRequest request)

Specified by:

transactGetItems in interface AmazonDynamoDB

Overrides:

transactGetItems in class AbstractAmazonDynamoDB

transactWriteItems

public TransactWriteItemsResult transactWriteItems(TransactWriteItemsRequest request)

Specified by:

transactWriteItems in interface AmazonDynamoDB

Overrides:

transactWriteItems in class AbstractAmazonDynamoDB

updateItem

public UpdateItemResult updateItem(String arg0,
                                   Map<String,AttributeValue> arg1,
                                   Map<String,AttributeValueUpdate> arg2,
                                   String arg3)

Specified by:

updateItem in interface AmazonDynamoDB

Overrides:

updateItem in class AbstractAmazonDynamoDB

updateItem

public UpdateItemResult updateItem(String arg0,
                                   Map<String,AttributeValue> arg1,
                                   Map<String,AttributeValueUpdate> arg2)

Specified by:

updateItem in interface AmazonDynamoDB

Overrides:

updateItem in class AbstractAmazonDynamoDB

updateItem

public UpdateItemResult updateItem(UpdateItemRequest arg0)

Specified by:

updateItem in interface AmazonDynamoDB

Overrides:

updateItem in class AbstractAmazonDynamoDB

updateTable

public UpdateTableResult updateTable(String arg0,
                                     ProvisionedThroughput arg1)

Specified by:

updateTable in interface AmazonDynamoDB

Overrides:

updateTable in class AbstractAmazonDynamoDB

updateTable

public UpdateTableResult updateTable(UpdateTableRequest arg0)

Specified by:

updateTable in interface AmazonDynamoDB

Overrides:

updateTable in class AbstractAmazonDynamoDB

setEndpoint

public void setEndpoint(String arg0)

Specified by:

setEndpoint in interface AmazonDynamoDB

Overrides:

setEndpoint in class AbstractAmazonDynamoDB

setRegion

public void setRegion(Region region)

Specified by:

setRegion in interface AmazonDynamoDB

Overrides:

setRegion in class AbstractAmazonDynamoDB

setRegion

public void setRegion(String region)

Description copied from interface: AmazonDaxClient

Set the AWS region where DAX cluster exists.

The region is needed for authentication.

Specified by:

setRegion in interface AmazonDaxClient

Parameters:

region - the cluster's region

waiters

public AmazonDynamoDBWaiters waiters()

Specified by:

waiters in interface AmazonDynamoDB

Overrides:

waiters in class AbstractAmazonDynamoDB

shutdown

public void shutdown()

Specified by:

shutdown in interface AmazonDynamoDB

Overrides:

shutdown in class AbstractAmazonDynamoDB