com.amazon.titan.diskstorage.dynamodb

Interface AwsStore

All Superinterfaces:

com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStore

All Known Implementing Classes:

AbstractDynamoDBStore, DynamoDBSingleRowStore, DynamoDBStore, MetricStore

public interface AwsStore
extends com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStore

Responsible for communicating with a single AWS backing store table.

Author:

Matthew Sowders, Alexander Patrikalakis

Field Summary

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

NO_ADDITIONS, NO_DELETIONS

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.
void	deleteStore() Deletes the KCV store and underlying DynamoDB tables.
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

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

acquireLock, close, getKeys, getKeys, getName, getSlice, getSlice, mutate

Method Detail

ensureStore

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

Creates the KCV store and underlying DynamoDB tables.

Throws:

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

deleteStore

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

Deletes the KCV store and underlying DynamoDB tables.

Throws:

com.thinkaurelius.titan.diskstorage.BackendException

getTableName

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

Returns:

createMutationWorkers

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.

Parameters:

mutationMap -

txh -

Returns:

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