hazelcast-jet

0熱度

1回答

如何在實現流時使用addJar（）方法？的newJob（）使用DAG： JobConfig config = new JobConfig(); config.addJar(".."); jet.newJob(dag, config).execute().get(); 流被改變爲內部的DAG： IMap<String, Long> counts = lines .strea

0熱度

2回答

如何爲Hazelcast Jet制定一個優雅的頂點以獲得最小值？

我試圖把我的頭包圍在Hazelcast Jets積累處理器中的雙功能用法。第一次嘗試是一個簡單的分鐘比較，但我提出的看起來很不雅觀。有沒有更好的方法來做到這一點？ Vertex min = dag.newVertex("min", accumulate(() -> new myObject(Type.SOME_ENUM,Double.MAX_VALUE,0L), (cMin,

0熱度

1回答

如何讓簡單的DAG在Hazelcast Jet中工作？

在hazelcast Jet上工作我的DAG時，我偶然發現了一個奇怪的問題。爲了檢查這個錯誤，我完全忽略了我的方法，並且：根據教程，似乎邊緣沒有工作。下面的代碼幾乎和它一樣簡單。兩個頂點（一個源，一個接收器），一個邊。源代碼正在讀取地圖，接收器應放入地圖。 data.addEntryListener正確告訴我該地圖由另一個應用程序填充了100個列表（每個列表有400個字節的25個對象）....

0熱度

2回答

是否有可能在Hazelcast中加入兩個不同的IMaps？

我有兩個hazelcast地圖 1. MAP2 2. MAP2 我想加入到這兩個地圖上的關鍵。我可以在榛子做嗎？謝謝

0熱度

1回答

如何打開一個tcp套接字並處理通過它在Hazelcast Jet中獲得的連續信息

我試圖使用Hazelcast jet來分析傳感器數據。爲此，我需要打開一個Tcp套接字並處理通過它獲得的信息。

9熱度

2回答

Hazelcast Jet和Apache Flink之間的區別是什麼

更具體地說，Hazelcast Jet解決了Flink無法解決的問題（反之亦然），反之亦然？

1熱度

1回答

Hazelcast Jet - 使用案例

Hazelcast Jet的使用案例有哪些？有沒有人開始使用它？我們的項目使用Hazelcast作爲分佈式地圖，在這些鍵上持有鍵值對和分佈式計算，以在持有鍵的節點上運行任務。我們也使用NearCache解決方案。我很想知道Hazelcast Jet的不同之處，它解決了哪些問題？

1熱度

1回答

hazelcast-jet如何實現與hazelcast EntryProcessor不同的任何不同

hazelcast-jet如何實現與通過在IMap中的鍵上提交EntryProcessors早先實現的內容大不相同的東西？很想知道。

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",

2熱度

1回答

如何在榛樹噴氣機集羣的新節點上工作

有人可以說新的噴氣機集羣實例應該如何開始工作嗎？用例1：開始噴射簇由3節點提交作業羣集所有3個節點開始工作和處理數據用例2：開始第4節點 4點什麼也不做，因爲它沒有新提交的作業命令如何利用新的羣集實例應該開始工作，已經在另一個節點開始了嗎？