问题标签 [hazelcast-imap]

我正在使用 hazelcast 3.6.1。我已经为聚合实现了自定义 mapreduce，因为我需要 solr facet 类型的结果、不同的值及其计数。

我需要聚合 mapreduce 的结果，按 count desc 排序并支持分页。

hazelcast 的内置选项有什么方法可以实现吗？

我添加了一个自定义整理器并实现了它？但它将所有数据加载到内存中并排序和应用分页。有没有更好的方法来处理这个？

谢谢

我想创建一个使用 servlet 和 JSP 开发的 Web 应用程序集群。现在我需要跨实例缓存数据，因此任何机构都可以帮助我配置此步骤，任何引用或任何指针都会有所帮助。提前致谢

我是 spring-boot 和 hazelcast 的新手。我有一个带有服务层的 spring-boot 应用程序，它应该使用 hazelcast imap。我遇到的问题是我不知道如何获取将数据存储到仅具有 java 配置的 spring 组件的 mapstore。添加组件注释是不够的，我的自动装配存储库为空。

我编写了一个静态 ContextAccessor 来手动加载我的 bean，但这仅适用于 IDE 环境，如果我将应用程序作为 jar 启动则不起作用

这里的问题是并非所有 bean 都已经加载了 bean，并且存储库没有初始化。

是否有可能让 mapstore 作为 spring 组件运行，甚至在我的存储库加载后强制 hazelcast 初始化？谢谢你的帮助。

我正在使用 Hz PredicateBuilder 查询带有嵌套对象属性的 Hz 映射。在配置文件中也为嵌套字段创建了索引。

其中 rel 是具有 id 属性的对象，是 Person 对象的属性。

正确的记录正在返回，但要确定此查询是否正在使用索引。有没有办法确保这个查询正在使用索引？（任何信息性消息或其他东西）。之前使用过 DB2，调试级别显示这些消息。任何帮助深表感谢！提前致谢。

在 hazelcast IMap 中查找谓词结果大小的最佳方法是什么？

MapProxyImpl.java 中没有直接的大小支持，并且 size() 将根据返回的集合计算，这在这种情况下是不受欢迎的。

你有什么建议 ？

谢谢。

所以我有一个实现 Portable 接口的 Cart 对象。我需要在 Cart 对象下存储不同类型的产品对象（所有这些对象都实现 Portable）。我想在存储子便携式对象时没有问题，调用 WritePortable 作品。我不知道如何在阅读便携式设备时将儿童便携式设备类型转换为适当的类型。有什么建议么？

IMAP::values(Predicate) 也只返回用于分页谓词的 Collection。

集合对象的总数对于使用分页谓词非常重要。

除了使用 EntryProcessor 来获取大小之外，还有什么方法可以使用分页谓词来获取计数？

使用 entryprocessor/values(Predicate) 获取谓词的大小不是理想的解决方案。

理想情况下，值（分页谓词）必须返回集合 + 总数。我检查了代码 operationService.invokeOnTarget(MapService.SERVICE_NAME, operation, member.getAddress()) 返回分页查询结果。如果每页的项目数为 5，则仅返回 5。

谢谢。

我正在使用 hazelcast 3.6.1 并使用自定义 mapreduce 实现不同的聚合功能以获得 solr facet 类型的结果。

并且映射器因 NullPointerException 而失败。并且 sysout 语句说条目对象为空。

简单条目：https ://github.com/hazelcast/hazelcast/blob/v3.7-EA/hazelcast/src/main/java/com/hazelcast/mapreduce/aggregation/impl/SimpleEntry.java

你能指出我上面代码中的问题吗？谢谢。

我创建了一个 map reduce 作业来获取某个位置的员工数量。我正在使用 hazelcast 3.6.3。每个员工都有姓名和地址。

我已将我的代码添加到以下 git 存储库。 https://github.com/adasari/hazelcast-demo

例外 ：

java.util.concurrent.ExecutionException：java.lang.ClassCastException：com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry 无法在 com.hazelcast.mapreduce.impl.task 处转换为 com.hazelcast.query.impl.Extractable .TrackableJobFuture.setResult(TrackableJobFuture.java:68) 在 com.hazelcast.mapreduce.impl.task.JobSupervisor.notifyRemoteException(JobSupervisor.java:156) 在 com.hazelcast.mapreduce.impl.operation.NotifyRemoteExceptionOperation.run(NotifyRemoteExceptionOperation.java :54) 在 com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:172) 在 com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:393) 在com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.processPacket（OperationThread.java：184) 在 com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.process(OperationThread.java:137) 在 com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) 在 com .hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) 引起：java.lang.ClassCastException：com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry 不能转换为 com.hazelcast .query.impl.Extractable 在 com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) 在 com.hazelcast.query.impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) at com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) 原因：java.lang.ClassCastException: com.hazelcast。 mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry 不能在 com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) 在 com.hazelcast.query 上转换为 com.hazelcast.query.impl.Extractable。 impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) at com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) 原因：java.lang.ClassCastException: com.hazelcast。 mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry 不能在 com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) 在 com.hazelcast.query 上转换为 com.hazelcast.query.impl.Extractable。 impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)DistinctValuesAggregation$SimpleEntry 无法在 com.hazelcast.query.impl.predicates.AbstractPredicate 的 com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) 处转换​​为 com.hazelcast.query.impl.Extractable。应用（AbstractPredicate.java:55）DistinctValuesAggregation$SimpleEntry 无法在 com.hazelcast.query.impl.predicates.AbstractPredicate 的 com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) 处转换​​为 com.hazelcast.query.impl.Extractable。应用（AbstractPredicate.java:55）

你能指出我的问题吗？

谢谢。

我知道 Hazelcast 具有将 EntryListener 添加到我正在更新的地图（IMap）的功能，以便我根据整个地图的活动接收消息。

但是我想知道是否可以将侦听器添加到单个键及其值。即一个地图的一个条目的监听器，而不是整个地图。

谢谢