com.amazon.titan.diskstorage.dynamodb

Class AbstractDynamoDBStore

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore

All Implemented Interfaces:

AwsStore, com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStore

Direct Known Subclasses:

DynamoDBSingleRowStore, DynamoDBStore

public abstract class AbstractDynamoDBStore
extends java.lang.Object
implements AwsStore

The base class for the SINGLE and MULTI implementations of the Amazon DynamoDB Storage Backend for Titan distributed store type.

Author:

Matthew Sowders, Alexander Patrikalakis

Field Summary

Fields

Modifier and Type	Field and Description
protected Client	client
protected boolean	forceConsistentRead
protected DynamoDBStoreManager	manager
protected java.lang.String	storeName
protected java.lang.String	tableName

Fields inherited from interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStore

NO_ADDITIONS, NO_DELETIONS

Constructor Summary

Constructors

Constructor and Description
AbstractDynamoDBStore(DynamoDBStoreManager manager, java.lang.String prefix, java.lang.String storeName)

Method Summary

Methods

Modifier and Type	Method and Description
void	acquireLock(com.thinkaurelius.titan.diskstorage.StaticBuffer key, com.thinkaurelius.titan.diskstorage.StaticBuffer column, com.thinkaurelius.titan.diskstorage.StaticBuffer expectedValue, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
void	close()
void	deleteStore() Deletes the KCV store and underlying DynamoDB tables.
protected java.lang.String	encodeForLog(com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeySliceQuery query)
protected java.lang.String	encodeForLog(java.util.List<?> columns)
protected java.lang.String	encodeForLog(com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery query)
protected java.lang.String	encodeKeyForLog(com.thinkaurelius.titan.diskstorage.StaticBuffer key)
protected java.lang.String	encodeKeyForLog(com.thinkaurelius.titan.diskstorage.StaticBuffer hashKey, com.thinkaurelius.titan.diskstorage.StaticBuffer columnKey)
void	ensureStore() Creates the KCV store and underlying DynamoDB tables.
java.lang.String	getTableName() Titan relies on static store names to be used, but we want the ability to have multiple graphs in a single region, so prepend a configurable prefix to the underlying table names of each graph and get the DynamoDB table name with this method
abstract CreateTableRequest	getTableSchema() Creates the schemata for the DynamoDB table or tables each store requires.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.amazon.titan.diskstorage.dynamodb.AwsStore

createMutationWorkers

Methods inherited from interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStore

getKeys, getKeys, getName, getSlice, getSlice, mutate

Field Detail

manager

protected final DynamoDBStoreManager manager

client

protected final Client client

storeName

protected final java.lang.String storeName

tableName

protected final java.lang.String tableName

forceConsistentRead

protected final boolean forceConsistentRead

Constructor Detail

AbstractDynamoDBStore

public AbstractDynamoDBStore(DynamoDBStoreManager manager,
                     java.lang.String prefix,
                     java.lang.String storeName)

Method Detail

getTableSchema

public abstract CreateTableRequest getTableSchema()

Creates the schemata for the DynamoDB table or tables each store requires.

ensureStore

public final void ensureStore()
                       throws com.thinkaurelius.titan.diskstorage.BackendException

Description copied from interface: AwsStore

Creates the KCV store and underlying DynamoDB tables.

Specified by:

ensureStore in interface AwsStore

Throws:

com.thinkaurelius.titan.diskstorage.BackendException - if unable to ensure the underlying store

deleteStore

public final void deleteStore()
                       throws com.thinkaurelius.titan.diskstorage.BackendException

Description copied from interface: AwsStore

Deletes the KCV store and underlying DynamoDB tables.

Specified by:

deleteStore in interface AwsStore

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

acquireLock

public void acquireLock(com.thinkaurelius.titan.diskstorage.StaticBuffer key,
               com.thinkaurelius.titan.diskstorage.StaticBuffer column,
               com.thinkaurelius.titan.diskstorage.StaticBuffer expectedValue,
               com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
                 throws com.thinkaurelius.titan.diskstorage.BackendException

Specified by:

acquireLock in interface com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStore

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.KeyColumnValueStore

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getTableName

public java.lang.String getTableName()

Description copied from interface: AwsStore

Titan relies on static store names to be used, but we want the ability to have multiple graphs in a single region, so prepend a configurable prefix to the underlying table names of each graph and get the DynamoDB table name with this method

Specified by:

getTableName in interface AwsStore

Returns:

encodeKeyForLog

protected java.lang.String encodeKeyForLog(com.thinkaurelius.titan.diskstorage.StaticBuffer key)

encodeKeyForLog

protected java.lang.String encodeKeyForLog(com.thinkaurelius.titan.diskstorage.StaticBuffer hashKey,
                               com.thinkaurelius.titan.diskstorage.StaticBuffer columnKey)

encodeForLog

protected java.lang.String encodeForLog(java.util.List<?> columns)

encodeForLog

protected java.lang.String encodeForLog(com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery query)

encodeForLog

protected java.lang.String encodeForLog(com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeySliceQuery query)