import org.apache.cassandra.db.compaction.SSTableSplitter; //导入依赖的package包/类
@Test
public void testSSTableSplit() throws InterruptedException
{
    Keyspace keyspace = Keyspace.open(KEYSPACE);
    ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(CF);
    cfs.truncateBlocking();
    cfs.disableAutoCompaction();
    SSTableReader s = writeFile(cfs, 1000);
    cfs.getDataTracker().markCompacting(Arrays.asList(s), true, false);
    SSTableSplitter splitter = new SSTableSplitter(cfs, s, 10);
    splitter.split();
    Thread.sleep(1000);
    assertFileCounts(s.descriptor.directory.list(), 0, 0);
    for (File f : s.descriptor.directory.listFiles())
    {
        // we need to clear out the data dir, otherwise tests running after this breaks
        f.delete();
    }
}
 

import org.apache.cassandra.db.compaction.SSTableSplitter; //导入依赖的package包/类
@Test
public void testSSTableSplit() throws InterruptedException
{
    Keyspace keyspace = Keyspace.open(KEYSPACE);
    ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(CF);
    truncate(cfs);
    cfs.disableAutoCompaction();
    SSTableReader s = writeFile(cfs, 1000);
    try (LifecycleTransaction txn = LifecycleTransaction.offline(OperationType.UNKNOWN, s))
    {
        SSTableSplitter splitter = new SSTableSplitter(cfs, txn, 10);
        splitter.split();

        assertFileCounts(s.descriptor.directory.list());
        LifecycleTransaction.waitForDeletions();

        for (File f : s.descriptor.directory.listFiles())
        {
            // we need to clear out the data dir, otherwise tests running after this breaks
            FileUtils.deleteRecursive(f);
        }
    }
    truncate(cfs);
}