如何根据最大日期过滤BatchStage结果。TestModel[key=0002, value=[{date=09/03/2021}, {date=11/03/2021}]]
现在，我只想在值对象中保留最大日期映射
浏览 8提问于2021-03-09得票数 0
回答已采纳
如何读取Hazelcast喷气机的黑兹拉广播IMDG数据。
HazelcastInstance hz = Hazelcast
浏览 12提问于2021-10-12得票数 0
回答已采纳
1回答
我想介绍一个流处理模型，它可以处理每个节点定期发布的元数据(cpu使用情况、内存使用情况、IO等)。我的系统只关心最新的数据。当处理模型下降时，也可以忽略几个数据点。因此，我选择了hazelcast-jet，这是一种性能优异的内存处理模型.在这里，我有几个关于模型的问题：
浏览 2提问于2019-09-25得票数 2
回答已采纳
我在应用程序中使用Hazelcast IMDG。如果是。
Hazelcast Jet是开源的吗？Hazelcast Jet提供所有可用的Hazelcast IMDG功能？
浏览 2提问于2020-09-14得票数 0
回答已采纳
我已经测试过在Hazelcast版本5.0.2中运行良好，但是当我尝试将它与Jet管道作业一起使用时，就会得到低于序列化错误的结果。线程"main“中的ProcessorTasklet{tb-batch-compact/mapSink(mymap1)#0}：com.hazelcast.nio.serialization.HazelcastSerializationException:异常: com.hazelcast.jet.JetException
浏览 0提问于2022-02-11得票数 0
我对jet和hazelcast有一些问题，但我的问题是出于逻辑目的，我有一个类，它将带来所有数据，当我们启动客户端时，我们得到了一个队列和两个映射，但另一个映射尚未调用，当我启动hazelcast jet实例并处理所有数据时，我使用Sink：
rulesIntoTransaction.writeTo(Sinks.map(jet.getHazelcastInstance().getMap(我知道当你调用这个实例时，就像是一个haz
浏览 5提问于2021-10-29得票数 0
我有一个http端点，客户端使用其数据发出请求，计算出的响应将返回到该请求。计算有几个阶段-- data lookup，calculations和少量的transformations。最终结果将作为对请求的响应写入。 我是否可以编写一个Hazelcast Jet作业，它接受在http中接收到的数据，上面定义的所有计算并将结果返回给请求吗？我看不到直接的方法，但是，我看到的一种方法是，有一个响应式http服务器，以响应式方式读取请求，将请求写入Ringbuffer或IQu
浏览 28提问于2020-01-08得票数 0
我在我的应用程序中使用hazelcast IMDG。 我在一个接一个地做三个不同的步骤： 步骤:1 当我启动应用程序时，我正在将表格数据加载到hazelcast IMap中。加载后：- 步骤：-2 我正在使用Hazelcast SqlPredicate过滤一些数据。sql);
Collection<HazelcastJsonValue> filterResult = dataEntity.values(predicateForObjs);
浏览 16提问于2020-10-12得票数 0
我还希望我的jet作业能够从ApplicationContext访问spring (参见)。我不想在每个jet作业上配置类路径，我想使用JVM的引导类路径。我认为我需要使用来获得一个，但这不允许我在底层上设置ManagedContext。Jet.bootstrappedInstance()的文档详细介绍了我想要与Jet交互的方式
@Beanat com.hazelc
浏览 4提问于2021-10-21得票数 0
我们在一台服务器上托管了Hazelcast集群，在同一区域的不同服务器上的不同应用程序使用Hazelcast Jet客户端实例通过管道聚合来自Kafka源的数据。在此设置中，Jet客户端实例是否发送从Kafka源Hazelcast集群接收的数据，这将涉及大量IO，或者当我们创建管道时，Hazelcast集群本身创建到Kafka的连接，此连接来自Jet集群而不是客户端应用程序
浏览 22提问于2019-01-25得票数 0
我正在尝试使用Hazelcast Jet根据最大日期对List<Map<String,Object>>对象进行排序。但我只想使用hazelcast jet聚合/滚动函数 // fetching jsonb type data from db
BatchStage<Object> jobJson = dbValuereturn extractedDateValue.get(extracte
浏览 31提问于2021-04-01得票数 0
回答已采纳
我试图使用RoutingPolicy.ISOLATED在上游和下游之间创建专用的连接，根据这个线程45:29,049 Loading hazelcast-jet-default.xml from classpath.
45:29,225 Loading hazelcast-jet-member-
浏览 1提问于2018-01-30得票数 0
回答已采纳
2回答
我刚接触Hazelcast，我正试着用它在一张地图中存储数据，这张地图太大了，一台机器无法容纳它。我需要实现的过程之一是遍历映射中的每个值，并对它们执行某些操作-而不是累加或聚合，并且我不需要一次查看所有数据，因此不需要考虑内存问题。我的简单实现是使用IMap.keySet()，然后迭代所有键，依次获得每个存储值(并允许值在处理后为GCed )，但我担心的是，系统中将有如此多的数据，以至于即使只是获得键的列表也会足够大，从而给系统带来不必要的压力
浏览 0提问于2017-02-14得票数 1
我的消息来源是UDP数据报。我希望在Jet的某些节点上并行处理它，并通过“域”将它们重新发送到其他地址。我想使用Hazelcast IMDG IMap与加载程序，以获得‘域’由‘源ip’。(Util.java:185) at com.hazelcast.jet.Vertex.(JetServer.java:46)
Caus
浏览 0提问于2017-07-24得票数 1
回答已采纳
使用客户端(Hazelcast或Jet)，我希望获得完整的地图，并获得所有后续更新以丰富地图。
我怎样才能做到这一点呢？
浏览 1提问于2018-10-24得票数 1
我有一个现有的应用程序，它使用Hazelcast来跟踪集群成员关系和执行分布式任务。我在想，Jet对于在现有应用程序上添加分析可能很有用，我正在尝试找出如何在现有应用程序的基础上更好地分层Jet。所以我的第一个问题是，如何在我们现有的Hazelcast配置之上运行Jet？我是否必须单独运行Jet，或者用Jet替换现有的Hazelcast配置(因为Jet确实公开了HazelcastInstance)。我使用</
浏览 15提问于2020-05-27得票数 1
回答已采纳
我是新来Hazelcast的。当在HazelCast Jet管道上触发带谓词的Imap filter时，在VDI中，我看到处理器计数只有2，而在我的机器上，我看到12个处理器。但是当我在我的机器上看到12个处理器时，过滤作业会持续运行更长的时间，并持续记录一行Hazelcast healthmonitor日志和超时。我假设这就是问题所在。根据我的搜索，我了解到Hazelcast基于CPU创建了多个处理器。如何控制此处理器的计数。
下面是创建Hazelcast</
浏览 6提问于2021-06-09得票数 0
我想对整个数据集进行简单的最大值运算。我从Kafka示例开始：p.drawFrom(KafkaSources.map(user -> (Integer) user.get(2))和转到：SECONDS.sleep(15);
System.out.println(res.ge
浏览 1提问于2019-03-19得票数 0
1回答
我在用CDC做我的Postgres数据库。 at com.hazelcast.jet.cdc.impl.CdcSourceP.isConnectionUp(CdcSourceP.java:236) at com
浏览 6提问于2021-10-13得票数 2
回答已采纳
我们的项目使用Hazelcast实现分布式地图保存密钥-值对，并在这些密钥上进行分布式计算，在持有密钥的节点上运行任务。我们也使用NearCache解决方案。
浏览 3提问于2017-02-21得票数 3
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
