2016-03-21 5 views
0

スパークCouchbaseオフィシャルコネクタでDCPベースのストリーミングが安定しているかどうかを知りたかったですか?文書には、まだ生産段階で使用する準備ができていないと書かれています。 Javaの例はありますか?またスパークCouchbaseコネクタDCP

、誰かが私が解決しようとしているユースケースにスパークコネクタがここに理にかなっているかどうかをいくつかの光を当てることができれば:

を私たちは、ゲートウェイを同期するためのCouchbase liteのDBから一部のバッジについての毎日の更新を入手。今、10日間のウィンドウで、5つ以上のバッジを獲得した場合、お祝いのバッジを押す必要があります。これは10日ごとに行う必要があります。

私は、DCPを使用して、毎日変更をチェックし、ジョブを実行してからそれを同期ゲートウェイにプッシュすることを計画していました。 10日の期間内に、5個の以上のバッジは、その後、獲得されている場合は、私はそれが

これはこれについて行くか、これを行うには良い方法があるために正しい方法..です同期のゲートウェイにプッシュ?

使用できるもう一つは次のとおりです。

http://developer.couchbase.com/documentation/mobile/1.2/develop/guides/sync-gateway/server-integration/changes-worker/index.html ..

ので、アプローチは、ここの方が良いでしょうか?

+0

ここでは2つの質問がありますが、分割するのが最適かもしれません。 –

答えて

0

Spark ConnectorからのDCPストリーミングは、その製品がGAであることをサポートしており、その機能には実験的とは示されていません。機能がサポートされていない場合、Couchbaseは機能を早期に導入し、注釈を使用して実験的にマークします。

前記、私はすぐに次の数週間内に固定されることが予想される。この書き込みのようJVMコアDCPの実装にいくつかの既知の問題がある知っている、そうでない場合。 https://issues.couchbase.com/browse/JVMCBC-312 新しいテストシナリオが追加されました.Couchbaseは、次のリリース前にさまざまな障害/リバランスモードでこれらのテストに合格していることを確認する作業を行っています。

+0

レスポンスありがとうございます..もし同期ゲートウェイからの変更フィードからストリームを読み込むために使用されるのであれば、それはlastSequnceの番号を記録していますか?または、常にバケットからすべてのデータを読み込みますか? – Sagar

+0

最後のシーケンス番号はCouchbaseバケットレベルのコンセプトではなく、Couchbase Sync Gatewayレベルのコンセプトではないので、そこには問題はありません。 Spark Connectorは、DCPを直接使用します.Sync Gatewayでは、いくつかのクラスタ概念を抽象化し、いくつかの概念を追加しています。詳細はこちらのドキュメントをご覧ください:http://developer.couchbase.com/documentation/mobile/current/develop/guides/sync-gateway/running-sync-gateway/connecting-sync-gateway-to-couchbase-server/index .html –