• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java LeveledManifest类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.cassandra.db.compaction.LeveledManifest的典型用法代码示例。如果您正苦于以下问题:Java LeveledManifest类的具体用法?Java LeveledManifest怎么用?Java LeveledManifest使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



LeveledManifest类属于org.apache.cassandra.db.compaction包,在下文中一共展示了LeveledManifest类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: realAppend

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
@Override
@SuppressWarnings("resource")
public boolean realAppend(UnfilteredRowIterator partition)
{
    long posBefore = sstableWriter.currentWriter().getOnDiskFilePointer();
    RowIndexEntry rie = sstableWriter.append(partition);
    totalWrittenInLevel += sstableWriter.currentWriter().getOnDiskFilePointer() - posBefore;
    partitionsWritten++;
    if (sstableWriter.currentWriter().getOnDiskFilePointer() > maxSSTableSize)
    {
        if (totalWrittenInLevel > LeveledManifest.maxBytesForLevel(currentLevel, maxSSTableSize))
        {
            totalWrittenInLevel = 0;
            currentLevel++;
        }

        averageEstimatedKeysPerSSTable = Math.round(((double) averageEstimatedKeysPerSSTable * sstablesWritten + partitionsWritten) / (sstablesWritten + 1));
        switchCompactionLocation(getWriteDirectory(expectedWriteSize));
        partitionsWritten = 0;
        sstablesWritten++;
    }
    return rie != null;

}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:25,代码来源:MajorLeveledCompactionWriter.java


示例2: createTestFiles

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
private static void createTestFiles() throws IOException
{
    for (String cf : CFS)
    {
        List<File> fs = new ArrayList<File>();
        files.put(cf, fs);
        File dir = cfDir(cf);
        dir.mkdirs();

        createFakeSSTable(dir, cf, 1, false, fs);
        createFakeSSTable(dir, cf, 2, true, fs);
        // leveled manifest
        new File(dir, cf + LeveledManifest.EXTENSION).createNewFile();

        File backupDir = new File(dir, Directories.BACKUPS_SUBDIR);
        backupDir.mkdir();
        createFakeSSTable(backupDir, cf, 1, false, fs);

        File snapshotDir = new File(dir, Directories.SNAPSHOT_SUBDIR + File.separator + "42");
        snapshotDir.mkdirs();
        createFakeSSTable(snapshotDir, cf, 1, false, fs);
    }
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:24,代码来源:DirectoriesTest.java


示例3: checkManifest

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
private static void checkManifest(AbstractCompactionStrategy strategy, ColumnFamilyStore cfs, Collection<SSTableReader> sstables)
{
    WrappingCompactionStrategy wrappingStrategy = (WrappingCompactionStrategy)strategy;
    int maxSizeInMB = (int)((cfs.getCompactionStrategy().getMaxSSTableBytes()) / (1024L * 1024L));
    if (wrappingStrategy.getWrappedStrategies().size() == 2 && wrappingStrategy.getWrappedStrategies().iterator().next() instanceof LeveledCompactionStrategy)
    {
        System.out.println("Checking leveled manifest");
        Predicate<SSTableReader> repairedPredicate = new Predicate<SSTableReader>()
        {
            @Override
            public boolean apply(SSTableReader sstable)
            {
                return sstable.isRepaired();
            }
        };

        List<SSTableReader> repaired = Lists.newArrayList(Iterables.filter(sstables, repairedPredicate));
        List<SSTableReader> unRepaired = Lists.newArrayList(Iterables.filter(sstables, Predicates.not(repairedPredicate)));

        LeveledManifest repairedManifest = LeveledManifest.create(cfs, maxSizeInMB, repaired);
        for (int i = 1; i < repairedManifest.getLevelCount(); i++)
        {
            repairedManifest.repairOverlappingSSTables(i);
        }
        LeveledManifest unRepairedManifest = LeveledManifest.create(cfs, maxSizeInMB, unRepaired);
        for (int i = 1; i < unRepairedManifest.getLevelCount(); i++)
        {
            unRepairedManifest.repairOverlappingSSTables(i);
        }
    }
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:32,代码来源:StandaloneScrubber.java


示例4: main

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
/**
 * @param args a list of sstables whose metadata we are changing
 */
public static void main(String[] args) throws IOException
{
    PrintStream out = System.out;
    if (args.length == 0)
    {
        out.println("This command should be run with Cassandra stopped!");
        out.println("Usage: sstablelevelreset <keyspace> <columnfamily>");
        System.exit(1);
    }

    if (!args[0].equals("--really-reset") || args.length != 3)
    {
        out.println("This command should be run with Cassandra stopped, otherwise you will get very strange behavior");
        out.println("Verify that Cassandra is not running and then execute the command like this:");
        out.println("Usage: sstablelevelreset --really-reset <keyspace> <columnfamily>");
        System.exit(1);
    }

    String keyspace = args[1];
    String columnfamily = args[2];
    Directories directories = Directories.create(keyspace, columnfamily);
    boolean foundSSTable = false;
    for (Map.Entry<Descriptor, Set<Component>> sstable : directories.sstableLister().list().entrySet())
    {
        if (sstable.getValue().contains(Component.STATS))
        {
            foundSSTable = true;
            Descriptor descriptor = sstable.getKey();
            Pair<SSTableMetadata, Set<Integer>> metadata = SSTableMetadata.serializer.deserialize(descriptor);
            out.println("Changing level from " + metadata.left.sstableLevel + " to 0 on " + descriptor.filenameFor(Component.DATA));
            LeveledManifest.mutateLevel(metadata, descriptor, descriptor.filenameFor(Component.STATS), 0);
        }
    }

    if (!foundSSTable)
    {
        out.println("Found no sstables, did you give the correct keyspace/columnfamily?");
    }
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:43,代码来源:SSTableLevelResetter.java


示例5: tryGetLeveledManifest

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
public File tryGetLeveledManifest()
{
    for (File dir : sstableDirectories)
    {
        File manifestFile = new File(dir, cfname + LeveledManifest.EXTENSION);
        if (manifestFile.exists())
        {
            logger.debug("Found manifest at {}", manifestFile);
            return manifestFile;
        }
    }
    logger.debug("No level manifest found");
    return null;
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:15,代码来源:Directories.java


示例6: getOrCreateLeveledManifest

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
public File getOrCreateLeveledManifest()
{
    File manifestFile = tryGetLeveledManifest();
    if (manifestFile == null)
        manifestFile = new File(sstableDirectories[0], cfname + LeveledManifest.EXTENSION);
    return manifestFile;
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:8,代码来源:Directories.java


示例7: migrateFile

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
private static void migrateFile(File file, File ksDir, String additionalPath)
{
    if (file.isDirectory())
        return;

    try
    {
        String name = file.getName();
        boolean isManifest = name.endsWith(LeveledManifest.EXTENSION);
        int separatorIndex = name.indexOf(Component.separator);

        if (isManifest || (separatorIndex >= 0))
        {
            String cfname = isManifest
                          ? getCfNameFromManifest(name)
                          : name.substring(0, separatorIndex);

            int idx = cfname.indexOf(SECONDARY_INDEX_NAME_SEPARATOR); // idx > 0 => secondary index
            String dirname = idx > 0 ? cfname.substring(0, idx) : cfname;
            File destDir = getOrCreate(ksDir, dirname, additionalPath);

            File destFile = new File(destDir, isManifest ? name : ksDir.getName() + Component.separator + name);
            logger.debug(String.format("[upgrade to 1.1] Moving %s to %s", file, destFile));
            FileUtils.renameWithConfirm(file, destFile);
        }
        else
        {
            logger.warn("Found unrecognized file {} while migrating sstables from pre 1.1 format, ignoring.", file);
        }
    }
    catch (Exception e)
    {
        throw new RuntimeException(String.format("Failed migrating file %s from pre 1.1 format.", file.getPath()), e);
    }
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:36,代码来源:Directories.java


示例8: getCfNameFromManifest

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
private static String getCfNameFromManifest(String name)
{
    String withoutExt = name.substring(0, name.length() - LeveledManifest.EXTENSION.length());
    return withoutExt.endsWith("-old") || withoutExt.endsWith("-tmp")
            ? withoutExt.substring(0, withoutExt.length() - 4)
            : withoutExt;
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:8,代码来源:Directories.java


示例9: testLeveledManifestPath

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
@Test
public void testLeveledManifestPath()
{
    for (String cf : CFS)
    {
        Directories directories = Directories.create(KS, cf);
        File manifest = new File(cfDir(cf), cf + LeveledManifest.EXTENSION);
        Assert.assertEquals(manifest, directories.tryGetLeveledManifest());
    }
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:11,代码来源:DirectoriesTest.java


示例10: checkManifest

import org.apache.cassandra.db.compaction.LeveledManifest; //导入依赖的package包/类
private static void checkManifest(LeveledManifest manifest)
{
    System.out.println(String.format("Checking leveled manifest"));
    for (int i = 1; i <= manifest.getLevelCount(); ++i)
        manifest.repairOverlappingSSTables(i);
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:7,代码来源:StandaloneScrubber.java



注:本文中的org.apache.cassandra.db.compaction.LeveledManifest类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java XAttrSetFlag类代码示例发布时间:2022-05-22
下一篇:
Java TestSerializable类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap