src/test/java/com/thinkaurelius/titan/diskstorage/cassandra/embedded/EmbeddedLogTest.java

   1 package com.thinkaurelius.titan.diskstorage.cassandra.embedded;
   2
   3 import com.thinkaurelius.titan.diskstorage.BackendException;
   4 import org.junit.BeforeClass;
   5 import org.junit.experimental.categories.Category;
   6
   7 import com.thinkaurelius.titan.CassandraStorageSetup;
   8 import com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager;
   9 import com.thinkaurelius.titan.diskstorage.log.KCVSLogTest;
  10 import com.thinkaurelius.titan.testcategory.SerialTests;
  11
  12 @Category(SerialTests.class)
  13 public class EmbeddedLogTest extends KCVSLogTest {
  14
  15     @BeforeClass
  16     public static void startCassandra() {
  17         CassandraStorageSetup.startCleanEmbedded();
  18     }
  19
  20     @Override
  21     public KeyColumnValueStoreManager openStorageManager() throws BackendException {
  22         return new CassandraEmbeddedStoreManager(CassandraStorageSetup.getEmbeddedConfiguration(getClass().getSimpleName()));
  23     }
  24 }