com.amazon.titan.diskstorage.dynamodb

Class DynamoDBSingleRowStore

java.lang.Object

com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore

com.amazon.titan.diskstorage.dynamodb.DynamoDBSingleRowStore

All Implemented Interfaces:

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

public class DynamoDBSingleRowStore
extends AbstractDynamoDBStore

Acts as if DynamoDB were a Column Oriented Database by using key as the hash key and each entry has their own column. Note that if you are likely to go over the DynamoDB 400kb per item limit you should use DynamoDBStore. See configuration storage.dynamodb.stores.***store_name***.data-model=SINGLE KCV Schema - actual table (Hash(S) only): hk | 0x02 | 0x04 <-Attribute Names 0x01 | 0x03 | 0x05 <-Row Values

Author:

Matthew Sowders, Alexander Patrikalakis

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log

Fields inherited from class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore

client, forceConsistentRead, manager, storeName, tableName

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

NO_ADDITIONS, NO_DELETIONS

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Collection<MutateWorker>	createMutationWorkers(java.util.Map<com.thinkaurelius.titan.diskstorage.StaticBuffer,com.thinkaurelius.titan.diskstorage.keycolumnvalue.KCVMutation> mutationMap, DynamoDBStoreTransaction txh) Creates workers whose job it is to commit the actual mutations in the given mutation map.
static CreateTableRequest	createTableRequest(java.lang.String tableName, long rcu, long wcu)
boolean	equals(java.lang.Object obj)
com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyIterator	getKeys(com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyRangeQuery query, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyIterator	getKeys(com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery query, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
java.lang.String	getName()
com.thinkaurelius.titan.diskstorage.EntryList	getSlice(com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeySliceQuery query, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
java.util.Map<com.thinkaurelius.titan.diskstorage.StaticBuffer,com.thinkaurelius.titan.diskstorage.EntryList>	getSlice(java.util.List<com.thinkaurelius.titan.diskstorage.StaticBuffer> keys, com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery query, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
CreateTableRequest	getTableSchema() Creates the schemata for the DynamoDB table or tables each store requires.
int	hashCode()
void	mutate(com.thinkaurelius.titan.diskstorage.StaticBuffer hashKey, java.util.List<com.thinkaurelius.titan.diskstorage.Entry> additions, java.util.List<com.thinkaurelius.titan.diskstorage.StaticBuffer> deletions, com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
java.lang.String	toString()

Methods inherited from class com.amazon.titan.diskstorage.dynamodb.AbstractDynamoDBStore

acquireLock, close, deleteStore, encodeForLog, encodeForLog, encodeForLog, encodeKeyForLog, encodeKeyForLog, ensureStore, getTableName

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

log

protected final org.slf4j.Logger log

Constructor Detail

DynamoDBSingleRowStore

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

Method Detail

getTableSchema

public CreateTableRequest getTableSchema()

Description copied from class: AbstractDynamoDBStore

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

Specified by:

getTableSchema in class AbstractDynamoDBStore

createTableRequest

public static final CreateTableRequest createTableRequest(java.lang.String tableName,
                                    long rcu,
                                    long wcu)

getKeys

public com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyIterator getKeys(com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyRangeQuery query,
                                                                     com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
                                                                       throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getKeys

public com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyIterator getKeys(com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery query,
                                                                     com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
                                                                       throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getName

public java.lang.String getName()

getSlice

public com.thinkaurelius.titan.diskstorage.EntryList getSlice(com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeySliceQuery query,
                                                     com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
                                                       throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getSlice

public java.util.Map<com.thinkaurelius.titan.diskstorage.StaticBuffer,com.thinkaurelius.titan.diskstorage.EntryList> getSlice(java.util.List<com.thinkaurelius.titan.diskstorage.StaticBuffer> keys,
                                                                                                                     com.thinkaurelius.titan.diskstorage.keycolumnvalue.SliceQuery query,
                                                                                                                     com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
                                                                                                                       throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

mutate

public void mutate(com.thinkaurelius.titan.diskstorage.StaticBuffer hashKey,
          java.util.List<com.thinkaurelius.titan.diskstorage.Entry> additions,
          java.util.List<com.thinkaurelius.titan.diskstorage.StaticBuffer> deletions,
          com.thinkaurelius.titan.diskstorage.keycolumnvalue.StoreTransaction txh)
            throws com.thinkaurelius.titan.diskstorage.BackendException

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

createMutationWorkers

public java.util.Collection<MutateWorker> createMutationWorkers(java.util.Map<com.thinkaurelius.titan.diskstorage.StaticBuffer,com.thinkaurelius.titan.diskstorage.keycolumnvalue.KCVMutation> mutationMap,
                                                       DynamoDBStoreTransaction txh)

Description copied from interface: AwsStore

Creates workers whose job it is to commit the actual mutations in the given mutation map.

Returns:

a collection of MutateWorker objects that when executed will commit all changes specified by mutationMap