List of disableAutoCompaction() Examples

Examples of disableAutoCompaction()

org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

    public void testNumberOfFiles_truncate() throws Exception
    {
        Keyspace keyspace = Keyspace.open(KEYSPACE);
        ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(CF);
        cfs.truncateBlocking();
        cfs.disableAutoCompaction();


        SSTableReader s = writeFile(cfs, 1000);
        cfs.addSSTable(s);
        Set<SSTableReader> compacting = Sets.newHashSet(s);
        SSTableRewriter.overrideOpenInterval(10000000);

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

    public void testSmallFiles() throws Exception
    {
        Keyspace keyspace = Keyspace.open(KEYSPACE);
        ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(CF);
        cfs.truncateBlocking();
        cfs.disableAutoCompaction();


        SSTableReader s = writeFile(cfs, 400);
        DecoratedKey origFirst = s.first;
        cfs.addSSTable(s);
        Set<SSTableReader> compacting = Sets.newHashSet(s);

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

    {
        String ksname = "Keyspace1";
        String cfname = "StandardLeveled";
        Keyspace keyspace = Keyspace.open(ksname);
        ColumnFamilyStore store = keyspace.getColumnFamilyStore(cfname);
        store.disableAutoCompaction();


        LeveledCompactionStrategy lcs = (LeveledCompactionStrategy)store.getCompactionStrategy();


        ByteBuffer value = ByteBuffer.wrap(new byte[100 * 1024]); // 100 KB value, make it easy to have multiple files

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

        final int SSTABLES = cfs.metadata.getIndexInterval() * 2 / ROWS_PER_SSTABLE;


        cfs.setCompactionStrategyClass(compactionStrategy);


        // disable compaction while flushing
        cfs.disableAutoCompaction();
        //test index corruption
        //now create a few new SSTables
        long maxTimestampExpected = Long.MIN_VALUE;
        Set<DecoratedKey> inserted = new HashSet<DecoratedKey>();
        for (int j = 0; j < SSTABLES; j++)

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

    {
        String ksname = "Keyspace1";
        String cfname = "StandardLeveled";
        Table table = Table.open(ksname);
        ColumnFamilyStore store = table.getColumnFamilyStore(cfname);
        store.disableAutoCompaction();


        LeveledCompactionStrategy lcs = (LeveledCompactionStrategy)store.getCompactionStrategy();


        ByteBuffer value = ByteBuffer.wrap(new byte[100 * 1024]); // 100 KB value, make it easy to have multiple files

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

            cfs.forceBlockingFlush();
        }
        waitForLeveling(cfs);
        cfs.forceBlockingFlush();
        LeveledCompactionStrategy strategy = (LeveledCompactionStrategy) cfs.getCompactionStrategy();
        cfs.disableAutoCompaction();


        while(CompactionManager.instance.isCompacting(Arrays.asList(cfs)))
            Thread.sleep(100);


        for (SSTableReader s : cfs.getSSTables())

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

{
    @Test
    public void testSimpleExpire() throws ExecutionException, InterruptedException
    {
        ColumnFamilyStore cfs = Keyspace.open("Keyspace1").getColumnFamilyStore("Standard1");
        cfs.disableAutoCompaction();
        cfs.metadata.gcGraceSeconds(0);
        long timestamp = System.currentTimeMillis();
        RowMutation rm = new RowMutation("Keyspace1", Util.dk("ttl").key);
        rm.add("Standard1", ByteBufferUtil.bytes("col"),
               ByteBufferUtil.EMPTY_BYTE_BUFFER,

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()


    @Test
    public void testNoExpire() throws ExecutionException, InterruptedException
    {
        ColumnFamilyStore cfs = Keyspace.open("Keyspace1").getColumnFamilyStore("Standard1");
        cfs.disableAutoCompaction();
        cfs.metadata.gcGraceSeconds(0);
        long timestamp = System.currentTimeMillis();
        RowMutation rm = new RowMutation("Keyspace1", Util.dk("ttl").key);
        rm.add("Standard1", ByteBufferUtil.bytes("col"),
               ByteBufferUtil.EMPTY_BYTE_BUFFER,

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

        Table systemTable = Table.open("system");
        ColumnFamilyStore hintStore = systemTable.getColumnFamilyStore(HintedHandOffManager.HINTS_CF);
        hintStore.clearUnsafe();
        hintStore.metadata.gcGraceSeconds(36000); // 10 hours
        hintStore.setCompactionStrategyClass(SizeTieredCompactionStrategy.class.getCanonicalName());
        hintStore.disableAutoCompaction();


        // insert 1 hint
        RowMutation rm = new RowMutation(TABLE4, ByteBufferUtil.bytes(1));
        rm.add(new QueryPath(STANDARD1_CF,
                             null,

View Full Code Here

Examples of org.apache.cassandra.db.ColumnFamilyStore.disableAutoCompaction()

        String ksname = "Keyspace1";
        String cfname = "Standard1";
        Keyspace keyspace = Keyspace.open(ksname);
        ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(cfname);
        cfs.truncateBlocking();
        cfs.disableAutoCompaction();


        ByteBuffer value = ByteBuffer.wrap(new byte[100]);


        // create 3 sstables
        int numSSTables = 3;

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.