1 package com.thinkaurelius.titan.diskstorage.cassandra.thrift;
3 import com.thinkaurelius.titan.diskstorage.BackendException;
4 import org.junit.BeforeClass;
6 import com.thinkaurelius.titan.CassandraStorageSetup;
7 import com.thinkaurelius.titan.diskstorage.LockKeyColumnValueStoreTest;
8 import com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager;
10 public class ThriftLockStoreTest extends LockKeyColumnValueStoreTest {
13 public static void startCassandra() {
14 CassandraStorageSetup.startCleanEmbedded();
18 public KeyColumnValueStoreManager openStorageManager(int idx) throws BackendException {
19 return new CassandraThriftStoreManager(CassandraStorageSetup.getCassandraThriftConfiguration(this.getClass().getSimpleName()));