-
分布式处理-Apache Spark,Flink,Samza,Siddhi,Hazelcast Jet
想象一个处理系统从其他内部系统或从Internet公开的REST端点接收数据。一旦接收到,一组(后台)任务 -
HazelcastSerializationException:当Jet作业在多个群集上运行时
我正在尝试在分布式系统上运行Hazelcast喷射<a href="https://github.com/hazelcast/hazelcast-jet-code-samples/blob/3.2-mainte -
Hazelcast Jet-将作业提交到远程Kubernetes集群
我在Kubernetes集群(Openshift)中设置了Jet(3实例)集群。我想将工作提交给它。我使用代理进行连接,但 -
Hazelcast Jet-将列表排入流
我的Jet作业正在转换Redis流数据-转换是-我为流中的每个项目查找一个<code>map</code>-如果发现其中包含一 -
Hazelcast Jet-处理Redis流中的容错
我有一个部署有3个节点的<code>Hazelcast Jet</code>集群,几乎没有读写<code>Redis Streams</code>的作业。 到 -
Hazelcast jet中的堆内存已满
我有一个客户端和服务器应用程序,客户端使用<strong> WebSockets </strong>从服务器接收数据。 客户端 -
用于Apache Pulsar的Hazelcast Jet连接器作为源
我找不到<code>Hazlecast Jet</code>的{{1}}源连接器。有人尝试过吗?如果我必须为<code>Apache Pulsar</code>写 -
如何编写Hazelcast Jet作业以处理Http请求并发出结果作为响应
我有一个http端点,客户端在其中请求其数据,并向其返回计算的响应。计算具有很少的阶段-<code>data look -
多节点hazelcast设置中的文件使用
我看到了一些示例,其中可以使用喷气机来使用CSV文件。 <pre><code>BatchSource<SalesRecordLine> source = S -
将[hazelcast-jet]添加到现有应用程序
我有一个现有的应用程序,该应用程序使用Hazelcast来跟踪集群成员资格和分布式任务执行。我认为Jet可 -
是否可以将依赖项注入Hazelcast Jet管线阶段?
例如,给定一个简单的管道,例如: <pre class="lang-java prettyprint-override"><code>Pipeline p = Pipeline.create(); p. -
Hazlecast Jet Cluster处理重复项
我已经部署了3个嵌入了Hazelcast Jet的Spring Boot应用程序。节点相互识别并作为群集运行。我有以下代码: -
Hazlecast Jet集群。工作量未分配
我有一个很大的csv文件。我有3个节点的Jet集群。提交作业时,只有一个节点处理整个文件。我想要的是 -
Hazelcast外部排序。将记录排序在大型csv中
我有一个用例,我需要对一个巨大的csv文件(例如1000万条记录)进行排序,然后将结果写入另一个文件 -
Hazelcast Jet。接收器上的“ onComplete”事件?
在典型的管道方案中,假设我有一个有界流,我从文件中读取该流。在Jet中,有什么方法可以订阅“ OnCo -
Hazelcast Jet IMap删除条目
我已经阅读了Hazelcast Jet的文档。 我已经看到可以在IMap接收器中添加/更新条目。 但是我从没见过 -
使用Hazelcast将单个节点转换为分布式Java应用程序
我们有一个使用简单的本地<code>HashMaps</code>用Vert.x构建的当前Java应用程序。为了在多个节点上分发我们 -
具有IMap源和OBJECT内存格式的Hazelcast Jet
我有<code>IMap</code>格式的Hazelcast <code>OBJECT</code>项目,并且我正在使用Jet聚合操作,并将该IMap作为管道源 -
Hazelcast Jet-如何在Jet管道中使用非静态方法
我在下面有一个基本的管道。在以下步骤之一中,我想通过从服务调用方法来转换对象,如下所示。但 -
Hazelcast IMDG和Hazelcast Jet
我在应用程序中使用的是Hazelcast IMDG。 我听说Hazelcast Jet比Hazelcast IMDG提供更快的数据处理。 -
通过REST / WebFlux公开整个IMap,而不会过多地利用堆
我有一个可能很大的分布式Hazelcast地图(IMap)。 我的任务是返回ENTIRE map values()集合作为对HTTP G -
仅在包含相关KEY的节点上运行流操作
假设我在一个大型群集上有一个大型IStreamMap,而我<em>仅</em>只想对几个键进行操作。我可以对过滤器表 -
左加入榛子喷气机
我在我的应用程序中使用 Hazelcast Jet。 <pre><code> // value1 BatchStageWithKey<Map<String, Object> -
对于 18k/s 吞吐量,Hazelcast 平均获取延迟 > 2 毫秒
<strong>背景:</strong>我们正在评估可以替代 Redis 的 Hazelcast。 <strong>设置</strong>: <ol> <li>单个子 -
我如何在 Hazelcast jet 中使用 mahout?
我想使用 Jet cluster & <a href="https://mahout.apache.org/" rel="nofollow noreferrer">Aapache mahout</a> 来计算 item cf 或 user c -
使用 Hazelcast jet 进行 JSON 处理
我使用 postgres SQL 作为数据库。 <pre><code>------------------------- id | name | value | ------------------------- 1 -
Hazelcast Jet mapWithUpdating 是否保留数据局部性
下面的最小工作示例展示了一些(简化的)处理,其中: <ul> <li>每个事件都单独处理(无窗口),</l -
Hazelcast Jet 是否允许从rollingAggregate 查询累加器值?
下面的最小工作示例展示了一些(简化的)处理,其中: <ul> <li>每个事件都单独处理(无窗口),</l -
为什么 Hazelcast IMap 日志没有产生所有预期的事件?
下面的最小工作示例快速生成事件,然后更新 IMap。 IMap 反过来从它的日志中产生更新事件。 <pre class -
Hazelcast jet 中的序列化
当我尝试处理来自 Hazelcast jet 的数据时出现以下错误。 <pre><code>Caused by: java.lang.IllegalArgumentException: In