Examples of filenameFor()

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

577
578
579
580
581
582
583
584
585
586
587
                                         directory,
                                         table.name,
                                         columnFamily,
                                         fileIndexGenerator.incrementAndGet(),
                                         true);
        return desc.filenameFor(Component.DATA);
    }

    /**
     * Switch and flush the current memtable, if it was dirty. The forceSwitch
     * flag allow to force switching the memtable even if it is clean (though
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

359
360
361
362
363
364
365
366
367
368
369
                    throw new IOError(e);
                }
                continue;
            }

            File dataFile = new File(desc.filenameFor(Component.DATA));
            if (components.contains(Component.DATA) && dataFile.length() > 0)
                // everything appears to be in order... moving on.
                continue;

            // missing the DATA file! all components are orphaned
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

370
371
372
373
374
375
376
377
378
379
380
            logger.warn("Removing orphans for {}: {}", desc, components);
            for (Component component : components)
            {
                try
                {
                    FileUtils.deleteWithConfirm(desc.filenameFor(component));
                }
                catch (IOException e)
                {
                    throw new IOError(e);
                }
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

630
631
632
633
634
635
636
637
638
639
640
                                         new File(directory),
                                         table.name,
                                         columnFamily,
                                         fileIndexGenerator.incrementAndGet(),
                                         true);
        return desc.filenameFor(Component.DATA);
    }

    public String getTempSSTablePath(String directory)
    {
        return getTempSSTablePath(directory, Descriptor.CURRENT_VERSION);
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

676
677
678
679
680
681
682
683
684
685
686
        for (int version = 1; version <= 2; ++version)
        {
            Descriptor desc = new Descriptor(backupDir, "Keyspace2", "Standard1", version, false);
            for (Component c : new Component[]{ Component.DATA, Component.PRIMARY_INDEX, Component.FILTER, Component.STATS })
                assertTrue("can not find backedup file:" + desc.filenameFor(c), new File(desc.filenameFor(c)).exists());
        }
    }
   
    @Test
    public void testSuperSliceByNamesCommand() throws Throwable
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

676
677
678
679
680
681
682
683
684
685
686
        for (int version = 1; version <= 2; ++version)
        {
            Descriptor desc = new Descriptor(backupDir, "Keyspace2", "Standard1", version, false);
            for (Component c : new Component[]{ Component.DATA, Component.PRIMARY_INDEX, Component.FILTER, Component.STATS })
                assertTrue("can not find backedup file:" + desc.filenameFor(c), new File(desc.filenameFor(c)).exists());
        }
    }
   
    @Test
    public void testSuperSliceByNamesCommand() throws Throwable
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

790
791
792
793
794
795
796
797
798
799
800
        update.apply();

        // check
        assert cfs.getIndexedColumns().isEmpty();
        ColumnFamilyStore.scrubDataDirectories("Keyspace6", "Indexed1");
        assert !new File(desc.filenameFor(Component.DATA)).exists();
    }

    private CFMetaData addTestCF(String ks, String cf, String comment)
    {
        return new CFMetaData(ks,
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

366
367
368
369
370
371
372
373
374
375
376
                    throw new IOError(e);
                }
                continue;
            }

            File dataFile = new File(desc.filenameFor(Component.DATA));
            if (components.contains(Component.DATA) && dataFile.length() > 0)
                // everything appears to be in order... moving on.
                continue;

            // missing the DATA file! all components are orphaned
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

377
378
379
380
381
382
383
384
385
386
387
            logger.warn("Removing orphans for {}: {}", desc, components);
            for (Component component : components)
            {
                try
                {
                    FileUtils.deleteWithConfirm(desc.filenameFor(component));
                }
                catch (IOException e)
                {
                    throw new IOError(e);
                }
View Full Code Here

Examples of org.apache.cassandra.io.sstable.Descriptor.filenameFor()

582
583
584
585
586
587
588
589
590
591
592
                                         directory,
                                         table.name,
                                         columnFamily,
                                         fileIndexGenerator.incrementAndGet(),
                                         true);
        return desc.filenameFor(Component.DATA);
    }

    public String getTempSSTablePath(File directory)
    {
        return getTempSSTablePath(directory, Descriptor.CURRENT_VERSION);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.