hazelcast-imap

0熱度

1回答

我使用Predicate和「in」條件查詢Hazelcast數據圖，如下所示。 List<String> liveVideoSourceIdList=new ArrayList(){"my_filter"}; Predicate predicate=Predicates.in("myField",liveVideoSourceIdList.toArray(new String[0]))

0熱度

1回答

Hazelcast分區丟失行爲初始模式=「LAZY/EAGER」

我想知道如何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