chronicle-map

    1热度

    1回答

    我'尝试使用chronicleMap.parallelStream: myChronicleMap.entrySet().parallelStream().forEach((entry) -> { process(entry); //heavy process } 我得到了以下异常。 java.lang.IllegalStateException:ChronicleMap ...迭

    2热度

    1回答

    我想知道纪事图中的原子性语义。如果我有一个跨2个节点(服务器)共享的历史记录映射,并且我尝试在两个节点上同时将相同的密钥插入此映射,那么事务性语义是什么? 第一次成功,第二次失败? 我很好奇,如果Chronicle Map保证Apache Zookeeper具有相同的事务语义? 在我的用例中,我想依赖的事实是,如果node1将密钥K1放入地图中,则该节点2将能够检查K1的存在,如果不存在,它会明确

    3热度

    1回答

    我在玩ChronicleSet,它由ChronicleMap支持。我已经完成了一些初步测试,对我们的需求非常好。内存使用效率比其他解决方案高得多,访问时间稍慢,但仍然非常快。 但是,我测试的一件事是设置最大数量的条目,并且它似乎没有按预期工作。 我用下面的代码: ChronicleSetBuilder<Long> postalSetBuilder = ChronicleSetBuil

    2热度

    1回答

    嗨,我是编年史产品的新用户,直到现在文档/用法看起来相当顺利。 虽然我有一个问题,当Map数据在同一主机上的JVM之间共享时,消费者JVM等待数据时会收到任何类型的回调或信号,或者我们需要实现自定义回调机制。 想法?

    2热度

    2回答

    我正在尝试将Chronicle Queue实现到我们的系统中,并且每天都有一个关于文件滚动的问题,但是在特定的时间根据当地时区的流程。我读了几篇关于如何指定滚动周期的文章,但根据文档说明,纪元时间按UTC的午夜时间工作。我需要做些什么来配置滚动周期让我们说每天在运行过程的当地时区下午5点?有什么建议么? public class TestRollCycle { public class

    2热度

    1回答

    在此先感谢您的支持。 有没有什么办法可以在Chronicle-Map中创建Java NavigableMap?

    2热度

    1回答

    我成功将JavaSE8应用程序升级到ChronicleMap 3.14.1。 我有一个JavaEE7应用程序,它只是JavaSE8应用程序的一个外观。 从JavaEE7调用创建chronicleMap的方法时,会引发一个错误。它看起来像“net.openhft.chronicle.hash.impl.util.jna.PosixMsync”未加载! 在JavaSE8应用程序中未提出此错误。 欢迎任

    1热度

    1回答

    我在JavaEE7/CDI应用程序中使用ChronicleMap。对话范围被使用了很多。 要预测用户何时退出会话以关闭地图非常困难。 虽然我试图关闭@PreDestroy方法中的所有实例,但显然我没有关闭所有实例。 什么是以下错误的结果: 11:20:47,866 ERROR [net.openhft.chronicle.hash.impl.ChronicleHashResources] (Ref

    0热度

    1回答

    我正在处理的项目由几个组件组成 - 几个独立的库被编译为JAR,以及一个引用它们的主项目。所有的都是用Scala编写的。 我在其中一个库内部使用ChronicleMap,使用具有自己的编组器的自定义值类。 当运行的主要项目中,我得到这些错误: /net/openhft/chronicle/core/values/ByteValue$$Native.java:15: error: cannot fi

    1热度

    1回答

    我们有一个系统,在50台服务器上使用相同的数据集(键值对)。此数据集的更新数量约为每小时1000个,并且必须在这50个服务器上进行复制。我们有一个主系统接收这些更新并负责将这些更新传播到其他服务器。目前,我们每个小时都以文件的形式将整个数据集(而不是增量更新)同步到所有服务器。这些数据然后被加载到不可变的Koloboke地图中。每个服务器每秒钟处理大约25000个请求,每个请求对这个映射进行30次