@@ -0,0 +1,1138 @@
+package com.thinkaurelius.titan.diskstorage.cassandra.thrift;%0A%0Aimport org.junit.After;%0Aimport org.junit.Before;%0Aimport org.junit.BeforeClass;%0A%0Aimport com.thinkaurelius.titan.CassandraStorageSetup;%0Aimport com.thinkaurelius.titan.diskstorage.DistributedStoreManagerTest;%0Aimport com.thinkaurelius.titan.diskstorage.StorageException;%0Aimport com.thinkaurelius.titan.diskstorage.cassandra.CassandraProcessStarter;%0A%0Apublic class InternalCassandraDistributedStoreManagerTest extends DistributedStoreManagerTest %7B%0A    %0A    private CassandraThriftStoreManager sm;%0A    %0A    @BeforeClass%0A    public static void startCassandra() %7B%0A        CassandraProcessStarter.startCleanEmbedded(CassandraStorageSetup.YAML_PATH);%0A    %7D%0A    %0A    @Before%0A    public void setUp() throws StorageException %7B%0A        sm = new CassandraThriftStoreManager(%0A                CassandraStorageSetup.getGenericCassandraStorageConfiguration(this.getClass().getSimpleName()));%0A        manager = sm;%0A        store = sm.openDatabase(%22distributedcf%22);%0A    %7D%0A    %0A    @After%0A    public void tearDown() throws StorageException %7B%0A        if (null != sm)%0A            sm.close();%0A    %7D%0A%7D%0A

Test CassThrift getDeployment/getLocalKeyPartition