com.amazon.titan.diskstorage.dynamodb

Class MetricStore

java.lang.Object

com.thinkaurelius.titan.diskstorage.util.MetricInstrumentedStore

com.amazon.titan.diskstorage.dynamodb.MetricStore

All Implemented Interfaces:

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

public class MetricStore
extends com.thinkaurelius.titan.diskstorage.util.MetricInstrumentedStore
implements AwsStore

Proxies another store to centralize metrics gathering.

Author:

Matthew Sowders

Field Summary

Fields inherited from class com.thinkaurelius.titan.diskstorage.util.MetricInstrumentedStore

EVENT_NAMES, M_ACQUIRE_LOCK, M_CALLS, M_CLOSE, M_CONTAINS_KEY, M_ENTRIES_COUNT, M_ENTRIES_HISTO, M_EXCEPTIONS, M_GET_KEYS, M_GET_PART, M_GET_SLICE, M_ITERATOR, M_MUTATE, M_TIME, OPERATION_NAMES

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

NO_ADDITIONS, NO_DELETIONS

Constructor Summary

Constructors

Constructor and Description
MetricStore(AwsStore delegate)

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 class com.thinkaurelius.titan.diskstorage.util.MetricInstrumentedStore

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

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

MetricStore

public MetricStore(AwsStore delegate)

Method Detail

deleteStore

public 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

ensureStore

public 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

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:

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.

Specified by:

createMutationWorkers in interface AwsStore

Returns:

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