com.amazon.titan.diskstorage.dynamodb

Class Client

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.Client

public class Client
extends java.lang.Object

Operations setting up the DynamoDB client.

Author:

Matthew Sowders, Alexander Patrikalakis

Field Summary

Fields

Modifier and Type	Field and Description
protected com.thinkaurelius.titan.util.stats.MetricManager	metrics

Constructor Summary

Constructors

Constructor and Description
Client(com.thinkaurelius.titan.diskstorage.configuration.Configuration config)

Method Summary

Methods

Modifier and Type	Method and Description
static AWSCredentialsProvider	createAWSCredentialsProvider(java.lang.String credentialsClassName, java.lang.String[] credentialsConstructorArgsValues)
BackendDataModel	dataModel(java.lang.String storeName)
DynamoDBDelegate	delegate()
boolean	enableParallelScan()
boolean	forceConsistentRead()
static java.util.concurrent.ThreadPoolExecutor	getPoolFromNs(com.thinkaurelius.titan.diskstorage.configuration.Configuration ns)
java.lang.String	getPrefix()
long	readCapacity(java.lang.String tableName)
int	scanLimit(java.lang.String tableName)
long	writeCapacity(java.lang.String tableName)

Methods inherited from class java.lang.Object

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

Field Detail

metrics

protected final com.thinkaurelius.titan.util.stats.MetricManager metrics

Constructor Detail

Client

public Client(com.thinkaurelius.titan.diskstorage.configuration.Configuration config)

Method Detail

getPoolFromNs

public static final java.util.concurrent.ThreadPoolExecutor getPoolFromNs(com.thinkaurelius.titan.diskstorage.configuration.Configuration ns)

delegate

public DynamoDBDelegate delegate()

forceConsistentRead

public boolean forceConsistentRead()

enableParallelScan

public boolean enableParallelScan()

readCapacity

public long readCapacity(java.lang.String tableName)

writeCapacity

public long writeCapacity(java.lang.String tableName)

dataModel

public BackendDataModel dataModel(java.lang.String storeName)

scanLimit

public int scanLimit(java.lang.String tableName)

createAWSCredentialsProvider

public static final AWSCredentialsProvider createAWSCredentialsProvider(java.lang.String credentialsClassName,
                                                  java.lang.String[] credentialsConstructorArgsValues)

getPrefix

public java.lang.String getPrefix()