問題タブ [hazelcast-imap]

hazelcast 3.6.1 を使用しています。solrファセットの種類の結果、個別の値、およびそのカウントが必要なため、集計用にカスタムmapreduceを実装しました。

ページネーションをサポートする count desc でソートされた集計 mapreduce の結果が必要です。

hazelcast の組み込みオプションで達成する方法はありますか?

カスタムコレーターを追加して実装しましたか? ただし、すべてのデータをメモリにロードし、ページネーションを並べ替えて適用します。これを処理するより良い方法はありますか?

ありがとう

サーブレットと JSP で開発された Web アプリケーションのクラスターを作成したいと考えています。ここで、インスタンス間でデータをキャッシュする必要があるため、これを構成する手順で任意のボディが役立ち、任意の参照または任意のポインターが役立ちます。前もって感謝します

Hz PredicateBuilder を使用して、ネストされたオブジェクトの属性に対するクエリで Hz マップをクエリしています。構成ファイルのネストされたフィールドにもインデックスを作成しました。

rel は id 属性を持つオブジェクトであり、Person オブジェクトの属性です。

正しいレコードが返されていますが、このクエリがインデックスを使用しているかどうかを確認したいと考えています。このクエリがインデックスを使用していることを確認する方法はありますか? (情報メッセージか何か)。以前は DB2 を使用していましたが、デバッグ レベルでこれらのメッセージが表示されます。どんな助けでも大歓迎です！前もって感謝します。

したがって、Portable インターフェイスを実装する Cart オブジェクトがあります。Cart オブジェクトの下にさまざまなタイプの製品オブジェクト (すべて Portable を実装) を格納する必要があります。子のポータブル オブジェクトを格納するときは問題ないと思いますが、WritePortable を呼び出しても問題ありません。ポータブルを読んでいるときに、子ポータブルを適切な型に型キャストする方法がわかりません。助言がありますか？

IMAP::values(Predicate) は、ページング述語についても Collection のみを返します。

ページング述語を使用するために非常に重要なコレクション オブジェクトの総数。

EntryProcessor を使用してサイズを取得する以外に、ページング述語でカウントを取得する方法はありますか?

entryprocessor/values(Predicate) を使用して述語のサイズを取得することは、理想的なソリューションではありません。

理想的には、値 (ページ分割された述語) はコレクション + 合計数を返す必要があります。ページ分割されたクエリ結果を返すコード operationService.invokeOnTarget(MapService.SERVICE_NAME, operation, member.getAddress()) を確認しました。1 ページあたりのアイテム数が 5 の場合、5 のみが返されます。

ありがとう。

私はhazelcast 3.6.1を使用しており、カスタムmapreduceを使用して個別の集計機能を実装して、solrファセットの種類の結果を取得しています。

マッパーは NullPointerException で失敗しています。およびsysoutステートメントは、エントリオブジェクトがnullであることを示しています。

SimpleEntry : https://github.com/hazelcast/hazelcast/blob/v3.7-EA/hazelcast/src/main/java/com/hazelcast/mapreduce/aggregation/impl/SimpleEntry.java

上記のコードの問題点を教えていただけますか? ありがとう。

ある場所の従業員数を取得するマップ削減ジョブを作成しました。hazelcast 3.6.3 を使用しています。各従業員には名前と住所があります。

次の git リポジトリにコードを追加しました。 https://github.com/adasari/hazelcast-demo

例外 ：

java.util.concurrent.ExecutionException: java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は、com.hazelcast.mapreduce.impl.task で com.hazelcast.query.impl.Extractable にキャストできません.TrackableJobFuture.setResult(TrackableJobFuture.java:68) com.hazelcast.mapreduce.impl.task.JobSupervisor.notifyRemoteException(JobSupervisor.java:156) で com.hazelcast.mapreduce.impl.operation.NotifyRemoteExceptionOperation.run(NotifyRemoteExceptionOperation.java) :54) com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:172) で com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:393) でcom.hazelcast.spi.impl.operationexecutor.classic.OperationThread.processPacket (OperationThread.java:184) com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.process(OperationThread.java:137) で com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) で.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) 原因: java.lang.ClassCastException: com.hazelcast.mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は com.hazelcast にキャストできません.query.impl.Extractable at com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) at com.hazelcast.query.impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) での operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) 原因: java.lang.ClassCastException: com.hazelcast. mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) の com.hazelcast.query.impl.Extractable にキャストできません。 impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)com.hazelcast.spi.impl.operationexecutor.classic.OperationThread.run(OperationThread.java:99) での operationexecutor.classic.OperationThread.doRun(OperationThread.java:124) 原因: java.lang.ClassCastException: com.hazelcast. mapreduce.aggregation.impl.DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) の com.hazelcast.query.impl.Extractable にキャストできません。 impl.predicates.AbstractPredicate.apply(AbstractPredicate.java:55)DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate の com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) で com.hazelcast.query.impl.Extractable にキャストできません。適用 (AbstractPredicate.java:55)DistinctValuesAggregation$SimpleEntry は、com.hazelcast.query.impl.predicates.AbstractPredicate の com.hazelcast.query.impl.predicates.AbstractPredicate.readAttributeValue(AbstractPredicate.java:129) で com.hazelcast.query.impl.Extractable にキャストできません。適用 (AbstractPredicate.java:55)

問題を指摘してもらえますか？

ありがとう。

Hazelcast には EntryListener をマップ (IMap) に追加する機能があり、マップ全体のアクティビティに基づいてメッセージを受け取るように更新していることを認識しています。

ただし、個々のキーとその値にリスナーを追加できるかどうかを知りたいです。つまり、マップ全体ではなく、マップの 1 つのエントリに対するリスナーです。

ありがとう