問題タブ [hazelcast-imap]

を 1200 (20 分) に設定し<time-to-live-seconds>ましたが、キャッシュの作成時間から 1 分後にキャッシュが自動的に削除されます。

指定した期間キャッシュを有効にする方法を教えてください。

Hazelcast を使用してクラスター内で互いに共有する 2 つのインスタンスで Java タスクを実行したいと考えています。そのため、タスクは単一のインスタンスで実行するよりも速く完了できます。助けてください！

私は次のように定義されたヘーゼルキャストマップを持っています。100万エントリー。

employeeObj.isCool()指定された従業員が「かっこいい」かどうかを返します。

からすべてのクールな従業員を見つけるメカニズムが必要employeeMapです。私は、次のいずれかを行うことができることを理解しています。

オプション 1 :employeeMap.keySet(predicate);クラスター内の各メンバーで並列に実行され、fork/join メカニズムを使用して呼び出し元によって結合される呼び出し。

質問 1 : ただし、これにより、述語を各エントリに適用する前に、各ノードのエントリ セットが一度にメモリに読み込まれると思います。確認してください。

オプション 2 : employeeMap.executeOnEntries(entryProcessor);entryprocessor のprocess()メソッドは次のようになります。

質問 2EntryProcessor :がパーティション スレッドで実行されることは理解しています。process()メソッドが呼び出される 前に、ローカル ノード内のすべてのローカル エントリを一度にロード (デシリアライズ) (および一時的に保存) するかどうかを知りたいです。

質問 3 : 利用可能な最良のオプション (時間と空間の複雑さの観点から) とその根拠を知りたいです。

Stringキーが で、値が の派生物である IMAP がありますArrayList。EntryProcessorこのマップのキーで実行する必要があります。また、インターフェイスEmployeeを実装する POJO であることに注意してください。Serializable

以下のコードを実行すると、コードは「Why so !」と出力します。そして、以下の方法ではキャストできないとClassCastException述べたものを手に入れました。java.util.ArrayListEmployeesprocess()ListValueEntryProcessor

Q1. オブジェクトとしてではなくオブジェクトEmployeesとしてシリアル化できるように、自分の型 ( ) にカスタム シリアライザーを追加する必要があることを知りました。アイテムもマークされているのような組み込み型に「カスタムシリアライザー」を追加することが必須である理由を知りたいですか?EmployeesArrayListArrayListSerializable

このクラスは MapStore を実装します

これは個人クラスのパッケージ データです。java.io.Serializable をインポートします。

このメインメソッドクラスですが、インスタンスにデータをロードできません。

データをロードするのを手伝ってください..null を返す 2 つのノードで実行しようとしました..しかし、データベース データが来ません..データベース挿入はマップに同期して反映できますか

MapStore 実装に裏打ちされた単純なマップがあります。マップで putAll() を呼び出し、マップに追加するキーと値のペアのマップを渡すと、Hazelcast は何らかの理由で、storeAll() を 1 回呼び出すのではなく、すべての値に対して MapStore で store() メソッドを呼び出します。

この動作が発生する理由は不明です。putAll/storeAll 関係は hazelcast マップでサポートされていますか?

ありがとう、コンラッド