com.amazon.titan.diskstorage.dynamodb

Class DynamoDBStoreManager

java.lang.Object

com.thinkaurelius.titan.diskstorage.common.AbstractStoreManager

com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager

com.amazon.titan.diskstorage.dynamodb.DynamoDBStoreManager

All Implemented Interfaces:

com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

public class DynamoDBStoreManager
extends com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager
implements com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager

The Titan manager for the Amazon DynamoDB Storage Backend for Titan. Opens AwsStores. Tracks implemented features. Implements mutateMany used by the concrete implementations.

Author:

Matthew Sowders, Alexander Patrikalakis

Nested Class Summary

Nested classes/interfaces inherited from class com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager

com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager.Deployment, com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager.MaskedTimestamp

Field Summary

Fields inherited from class com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager

connectionTimeoutMS, hostnames, pageSize, password, port, times, username

Fields inherited from class com.thinkaurelius.titan.diskstorage.common.AbstractStoreManager

batchLoading, isReadOnly, storageConfig, transactional

Constructor Summary

Constructors

Constructor and Description
DynamoDBStoreManager(com.thinkaurelius.titan.diskstorage.configuration.Configuration backendConfig)

Method Summary

Methods

Modifier and Type	Method and Description
com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction	beginTransaction(com.thinkaurelius.titan.diskstorage.BaseTransactionConfig config)
void	clearStorage()
Client	client()
void	close()
com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager.Deployment	getDeployment()
com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreFeatures	getFeatures()
java.util.List<com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyRange>	getLocalKeyPartition()
java.lang.String	getName()
static int	getPort(com.thinkaurelius.titan.diskstorage.configuration.Configuration config)
void	mutateMany(java.util.Map<java.lang.String,java.util.Map<com.thinkaurelius.titan.diskstorage.StaticBuffer,com.thinkaurelius.titan.diskstorage.keycolumnvalue.KCVMutation>> mutations, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
AwsStore	openDatabase(java.lang.String name)

Methods inherited from class com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager

getPageSize, getSingleHostname, getTimestampProvider, hasAuthentication, sleepAfterWrite, toString

Methods inherited from class com.thinkaurelius.titan.diskstorage.common.AbstractStoreManager

getMetaDataSchema, getStorageConfig

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamoDBStoreManager

public DynamoDBStoreManager(com.thinkaurelius.titan.diskstorage.configuration.Configuration backendConfig)
                     throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

Method Detail

getPort

public static final int getPort(com.thinkaurelius.titan.diskstorage.configuration.Configuration config)
                         throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

beginTransaction

public com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction beginTransaction(com.thinkaurelius.titan.diskstorage.BaseTransactionConfig config)
                                                                                     throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

beginTransaction in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

clearStorage

public void clearStorage()
                  throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

clearStorage in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

close

public void close()
           throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

close in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getFeatures

public com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreFeatures getFeatures()

Specified by:

getFeatures in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

getName

public java.lang.String getName()

Specified by:

getName in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

mutateMany

public void mutateMany(java.util.Map<java.lang.String,java.util.Map<com.thinkaurelius.titan.diskstorage.StaticBuffer,com.thinkaurelius.titan.diskstorage.keycolumnvalue.KCVMutation>> mutations,
              com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
                throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

mutateMany in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

openDatabase

public AwsStore openDatabase(java.lang.String name)
                      throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

openDatabase in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

client

public Client client()

getLocalKeyPartition

public java.util.List<com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyRange> getLocalKeyPartition()
                                                                                                 throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

getLocalKeyPartition in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreManager

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getDeployment

public com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager.Deployment getDeployment()

Specified by:

getDeployment in class com.thinkaurelius.titan.diskstorage.common.DistributedStoreManager