問題タブ [gemfire]

ここで何をする必要があるかを理解するのに役立つ例を見つけることができなかったので、私の問題を説明します:

Pivotal の Gemfire 製品のカスタム リスナーを実装する Java Bean があります。次のようにメソッドを定義する CqListener と呼ばれるインターフェイスを実装します。

基本的に、Gemfire グリッドで連続クエリ (CQ) を実行すると、この Bean をリスナーとして登録し、クエリに一致するグリッド内の変更を受け取ります。

たとえば、次のような CQ を実行します。

「table_name」テーブル（Gemfireではリージョンと呼ばれます）の何かが変更されるたびCQEventに、メソッドに aが表示されます（CRUD）onEvent

私が今やろうとしているのは、Camel を配線して、この基礎となる CQ のものからカスタム ルートに何かをルーティングすることです。とにかく、Camelに「onEventへの呼び出しが行われたときはいつでも、それを取り、別の場所にルーティングしてください」と言うことができますか?

私がルーティングしようとしている別の場所は、Akka Actor です。akka と camel ( http://doc.akka.io/docs/akka/snapshot/scala/camel.html ) をラップするプロジェクトは既にありますが、インバウンド CQ イベントを取得するためのこのエンドポイント URI ビジネスを理解できません。 .

Camel に関する概念的なキーが不足していることはわかっているので、どんな助けも大歓迎です。jmsエンドポイントを使用してこれを実装することができたので、よく知られているプロトコルでどのように機能するかを理解しましたが、実装が私から離れて抽象化されているカスタムプロトコルでこれを行う方法を理解しようとしています(そのままです) CQListenerの場合）

1. 特定のテーブルをレプリケート/パーティショニングする必要があると判断するにはどうすればよいですか?
2. GemfireXDデータベース設計でレプリケーション テーブルを使用しますか?

すべての説明は大歓迎です。

SpringXD に次のストリーム定義があります。

しかし、次のエラーが表示され、「失敗」とマークされます。

これは以前にも発生したことがあり、VM を再起動して修正しました。ただし、適切な方法で修正する方法を知りたいです。

ヒント、回避策、またはガイドラインは役に立ちます。また、さらに情報が必要な場合は教えてください。

Spring XD の最新バージョン 1.1.1 と Gemfire バージョン 7.0.2 を使用しています。ロケーターは、ストリームのデプロイと同じノードにあります。また、シングルノード トポロジを使用しています。

ありがとうございました！

gemfireキャッシングのキーと値のペアとして（文字列、文字列の配列リスト）を使用しています.リスト全体を取得せずに値リストから特定の値を追加または削除し、リストを追加/削除して再度公開する方法はありますか? !

sample.csvファイルから GenfireXD データベースにデータを挿入するための Rowloader JAVA コードの記述方法。

ファイルから GemfireXD にデータをロードしています .... ファイルには次のような情報が含まれています... ID NAME 1 |John Smth 2 |Jane 3 |Paul Joes 4 |Mark Jcobs 5 |Mary Sphenson 6 |Steve oberts 7 |Margaretジョンソ

GemfireXD にデータをロードした後、クエリ SELECT * FROM TABLE を起動すると、出力は次のようになります....

ID NAME 5 |Mary Sphenson 7 |Margaret Johnso 4 |Mark Jcobs 2 |Jane 3 |Paul Joes 1 |John Smth 6 |Steve oberts

多くの場合、IDがINPUTファイルのように適切な順序で保存されない理由を知っています

これについて助けてください....

ありがとう

私はJDBCRowLoaderに取り組んでいます..すべての指示に従い、attach_loaderの下で実行しました。

gemfire xd サーバー ログに Oracle 接続の詳細が出力されており、Oracle への接続が確立されていません。上記のステートメントは正常に実行されています。

ちなみに、私はsqlfインターフェースを使用しています。唯一の問題は、Oracle への接続が確立されていないことです。JDBCRowLoader の初期化が正常に終了しました。