Java CompactionInfo类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: Writer

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.COUNTER_CACHE)
        type = OperationType.COUNTER_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(CFMetaData.denseCFMetaData(Keyspace.SYSTEM_KS, cacheType.toString(), BytesType.instance),
                              type,
                              0,
                              keys.size(),
                              "keys");
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:24，代码来源:AutoSavingCache.java

示例2: Writer

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(new CFMetaData(Keyspace.SYSTEM_KS, cacheType.toString(), ColumnFamilyType.Standard, BytesType.instance, null),
                              type,
                              0,
                              keys.size(),
                              "keys");
}

开发者ID:pgaref，项目名称:ACaZoo，代码行数:22，代码来源:AutoSavingCache.java

示例3: getCompactionInfo

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public CompactionInfo getCompactionInfo()
{
    long rangesLeft = 0, rangesTotal = 0;
    Token lastToken = prevToken;

    // This approximation is not very accurate, but since we do not have a method which allows us to calculate the
    // percentage of a range covered by a second range, this is the best approximation that we can calculate.
    // Instead, we just count the total number of ranges that haven't been seen by the node (we use the order of
    // the tokens to determine whether they have been seen yet or not), and the total number of ranges that a node
    // has.
    for (Range<Token> range : StorageService.instance.getLocalRanges(baseCfs.keyspace.getName()))
    {
        rangesLeft++;
        rangesTotal++;
        // This will reset rangesLeft, so that the number of ranges left will be less than the total ranges at the
        // end of the method.
        if (lastToken == null || range.contains(lastToken))
            rangesLeft = 0;
    }
    return new CompactionInfo(baseCfs.metadata, OperationType.VIEW_BUILD, rangesLeft, rangesTotal, "ranges", compactionId);
}

开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:22，代码来源:ViewBuilder.java

示例4: afterTest

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
@After
public void afterTest()
{
    for (CompactionInfo.Holder holder: CompactionMetrics.getCompactions())
    {
        holder.stop();
    }

    String ksname = KEYSPACE1;
    String cfname = CF_STANDARDLOWiINTERVAL; // index interval of 8, no key caching
    Keyspace keyspace = Keyspace.open(ksname);
    ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(cfname);
    cfs.metadata.minIndexInterval(originalMinIndexInterval);
    cfs.metadata.maxIndexInterval(originalMaxIndexInterval);
    IndexSummaryManager.instance.setMemoryPoolCapacityInMB(originalCapacity);
}

开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:17，代码来源:IndexSummaryManagerTest.java

示例5: Writer

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(new CFMetaData(Table.SYSTEM_KS, cacheType.toString(), null, null, null),
                              type,
                              0,
                              keys.size(),
                              "keys");
}

开发者ID:dprguiuc，项目名称:Cassandra-Wasef，代码行数:22，代码来源:AutoSavingCache.java

示例6: Writer

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(CFMetaData.denseCFMetaData(Keyspace.SYSTEM_KS, cacheType.toString(), BytesType.instance),
                              type,
                              0,
                              keys.size(),
                              "keys");
}

开发者ID:mafernandez-stratio，项目名称:cassandra-cqlMod，代码行数:22，代码来源:AutoSavingCache.java

示例7: Writer

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
private Writer(String ksname, String cfname)
{
    keys = getKeySet();
    long bytes = 0;
    for (K key : keys)
        bytes += translateKey(key).remaining();
    // an approximation -- the keyset can change while saving
    estimatedTotalBytes = bytes;
    CompactionType type;

    if (cacheType.equals(ColumnFamilyStore.CacheType.KEY_CACHE_TYPE)) 
        type = CompactionType.KEY_CACHE_SAVE;
    else if (cacheType.equals(ColumnFamilyStore.CacheType.ROW_CACHE_TYPE))
        type = CompactionType.ROW_CACHE_SAVE;
    else
        type = CompactionType.UNKNOWN;

    info = new CompactionInfo(ksname,
                              cfname,
                              type,
                              0,
                              estimatedTotalBytes);
}

开发者ID:devdattakulkarni，项目名称:Cassandra-KVPM，代码行数:24，代码来源:AutoSavingCache.java

示例8: finishCompaction

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public void finishCompaction(CompactionInfo.Holder ci)
{
    // notify
    ci.finished();
    compactions.remove(ci);
    bytesCompacted.inc(ci.getCompactionInfo().getTotal());
    totalCompactionsCompleted.mark();
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:9，代码来源:CompactionMetrics.java

示例9: getCompactionInfo

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public CompactionInfo getCompactionInfo()
{
    return new CompactionInfo(cfs.metadata,
                              OperationType.INDEX_BUILD,
                              iter.getBytesRead(),
                              iter.getTotalBytes());
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:8，代码来源:SecondaryIndexBuilder.java

示例10: getCompactionInfo

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public CompactionInfo getCompactionInfo()
{
    return new CompactionInfo(cfs.metadata,
                              OperationType.INDEX_BUILD,
                              iter.getBytesRead(),
                              iter.getTotalBytes(),
                              compactionId);
}

开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:9，代码来源:SecondaryIndexBuilder.java

示例11: Writer

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    int size = size();
    if (keysToSave >= size || keysToSave == 0)
    {
        keyIterator = keyIterator();
        keysEstimate = size;
    }
    else
    {
        keyIterator = hotKeyIterator(keysToSave);
        keysEstimate = keysToSave;
    }

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.COUNTER_CACHE)
        type = OperationType.COUNTER_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(CFMetaData.createFake(SystemKeyspace.NAME, cacheType.toString()),
                              type,
                              0,
                              keysEstimate,
                              "keys",
                              UUIDGen.getTimeUUID());
}

开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:32，代码来源:AutoSavingCache.java

示例12: getCompactionInfo

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public CompactionInfo getCompactionInfo()
{
    return new CompactionInfo(cfs.table.name,
                              cfs.columnFamily,
                              CompactionType.INDEX_BUILD,
                              iter.getBytesRead(),
                              iter.getTotalBytes());
}

开发者ID:devdattakulkarni，项目名称:Cassandra-KVPM，代码行数:9，代码来源:Table.java

示例13: getCompactionInfo

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public CompactionInfo getCompactionInfo()
{
    long bytesWritten = this.bytesWritten;
    // keyset can change in size, thus totalBytes can too
    return info.forProgress(bytesWritten,
                            Math.max(bytesWritten, estimatedTotalBytes));
}

开发者ID:devdattakulkarni，项目名称:Cassandra-KVPM，代码行数:8，代码来源:AutoSavingCache.java

示例14: printCompactionStats

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public void printCompactionStats(PrintStream outs)
{
    CompactionManagerMBean cm = probe.getCompactionManagerProxy();
    outs.println("pending tasks: " + cm.getPendingTasks());
    if (cm.getCompactions().size() > 0)
        outs.printf("%25s%16s%16s%16s%16s%10s%n", "compaction type", "keyspace", "column family", "bytes compacted", "bytes total", "progress");
    for (CompactionInfo c : cm.getCompactions())
    {
        String percentComplete = c.getTotalBytes() == 0
                               ? "n/a"
                               : new DecimalFormat("0.00").format((double) c.getBytesComplete() / c.getTotalBytes() * 100) + "%";
        outs.printf("%25s%16s%16s%16s%16s%10s%n", c.getTaskType(), c.getKeyspace(), c.getColumnFamily(), c.getBytesComplete(), c.getTotalBytes(), percentComplete);
    }
}

开发者ID:devdattakulkarni，项目名称:Cassandra-KVPM，代码行数:15，代码来源:NodeCmd.java

示例15: beginCompaction

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public void beginCompaction(CompactionInfo.Holder ci)
{
    // notify
    ci.started();
    compactions.add(ci);
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:7，代码来源:CompactionMetrics.java

示例16: getCompactions

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public static List<CompactionInfo.Holder> getCompactions()
{
    return new ArrayList<CompactionInfo.Holder>(compactions);
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:5，代码来源:CompactionMetrics.java

示例17: getCompactionInfo

import org.apache.cassandra.db.compaction.CompactionInfo; //导入依赖的package包/类
public CompactionInfo getCompactionInfo()
{
    // keyset can change in size, thus total can too
    return info.forProgress(keysWritten, Math.max(keysWritten, keys.size()));
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:6，代码来源:AutoSavingCache.java

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java S2DPacketOpenWindow类代码示例发布时间：2022-05-22

Java Iterators类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18063|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9606|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8146|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8530|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8430|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9340|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8394|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7831|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8383|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7379|2022-11-06

客服电话

电子邮件

Java CompactionInfo类代码示例

示例1: Writer

示例2: Writer

示例3: getCompactionInfo

示例4: afterTest

示例5: Writer

示例6: Writer

示例7: Writer

示例8: finishCompaction

示例9: getCompactionInfo

示例10: getCompactionInfo

示例11: Writer

示例12: getCompactionInfo

示例13: getCompactionInfo

示例14: printCompactionStats

示例15: beginCompaction

示例16: getCompactions

示例17: getCompactionInfo

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

ekzhang/library: Advanced algorithm and

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053