hazelcast-imap

0热度

1回答

我想知道如何initial-mode =“LAZY/EAGER”行为在一个分区丢失。根据在线文档 EAGER - 同步加载条目。电话设置为getMap（）被阻塞而发生这种情况我需要知道丢失的分区是如何加载在下列情况下，... 1）节点崩溃和丢失的分区时，有在另一个节点备份会丢失从数据库或备份加载的分区数据吗？如果这是从DB加载的，初始模式=“LAZY/EAGER”如何影响地图加载？将丢

2热度

1回答

Hazelcast近缓存：驱逐如果改变

我使用Spring + Hazelcast 3.8.2，并配置了地图像这样使用Spring配置不同的节点上： <hz:map name="test.*" backup-count="1" max-size="0" eviction-percentage="30" read-backup-data="true" time-to-live-seconds="900" ev

0热度

1回答

Hazelcast + Spring（xml config）+ hz map store error

使用hazelcast 3.8.2（hazelcast-all jar）+ IMap + mapstore + Spring 4.3.8（xml config）。在Spring xml配置中，'hz：map-store'会抛出一个错误： 17:49:40.519 ERROR [main] org.springframework.test.context.TestContextManager – C

0热度

1回答

Hazelcast仅用于一个Hazelcast实例的分布式查询

实际上，我正在尝试Hazelcast提供用于缓存数据的原型。 Hazelcast部署嵌入在弹簧引导微服务中。我们使用分布式查询来搜索具有密钥部分值的条目。我们的基础设施目前只能提供微服务的一个实例。该地图已经在数据库中用MapStore实现持久化了。如果微服务被关闭，我们会丢失内存中的所有数据，并且分布式查询不会返回任何结果。使用loadAllKeys（）等通过MapStore初始化内存中的

1热度

1回答

如何通过IMap <String，Set <MyObject>>中的对象属性进行查询？

Hazelcast docs解释了当我们有IMap<String,Object>时如何做到这一点，但是当地图值是一个集合时没有任何关于这种情况。我看到两个选项：包住Set<Object>成一个包装型，从而使返回Set，其然后将需要是局部过滤; 实施ValueExtractor，但不完全确定，因为迄今为止还没有使用它。编辑：执行结束了类似于米哈伊尔 - baksheev建议。请注意，Colle

0热度

1回答

Hazelcast - IMAP如何使用锁定操作的法定人数？

我想为我的地图使用Quorum进行地图锁定操作：myMap。我使用法定配置的编程配置。 QuorumConfig quorumConfig = new QuorumConfig(); quorumConfig.setName("xxx"); quorumConfig.setEnabled(true); quorumConfig.setQuorumFunct

-1热度

1回答

Hazelcast：为集群中存在临时网络故障的节点调整属性

我们嵌入了具有10个aws实例的hazelcast集群。 hazelcast的版本是3.7.3的hazelcast hazelcast.max.no.heartbeat.seconds=30 hazelcast.max.no.master.confirmation.seconds=150 hazelcast.heartbeat.interval.seconds=1 hazelcast

1热度

1回答

Hazelcast Jet处理器使用Hazelcast IMap

我刚开始学习Hazelcast Jet。我的源代码是UDP数据报。我想在Jet的某些节点处并行处理它，并通过'domain'将它们重新发送到其他地址。我想使用Hazelcast IMDG IMap加载器来通过'source ip'获取'域'。 DAG dag = new DAG(); Vertex source = dag.newVertex("datagram-source",

0热度

1回答

Hazelcast内存不足

我们有一个每分钟处理100k包的Java应用程序。这些软件包包括用户操作细节和一个用户操作。一个操作可以有3到14个包。所有收到的软件包都包含操作的唯一数据，不幸的是操作没有ID。因此，我们使用用户标识和操作日期来合并属于相同操作的包。我们保证，我们将在15分钟内收到用户操作的所有包裹。因此，要在保存之前合并所有软件包，我们会将所有收到的软件包缓存到Hazelcast上，并在收到OPSTART或O

0热度

1回答

Hazealcast Predicate在查询“in”时的重复结果

我使用Predicate和“in”条件查询Hazelcast数据图，如下所示。 List<String> liveVideoSourceIdList=new ArrayList(){"my_filter"}; Predicate predicate=Predicates.in("myField",liveVideoSourceIdList.toArray(new String[0]))