問題タブ [data-stream]

これは私のコードです。

ランダムな順序で発生する監視イベントのストリームがあります 温度: 80、圧力: 70、湿度:80、温度:30...

上記のコードでは、stream 、eventType ごと、つまり temperatureStream と pressureStream を分割しています。

問題は、eventType がわかっている場合、splitStream のように選択できることです。

しかし、eventType は動的であり、事前定義されていません。

この動的ストリームに CEP を適用する方法を教えてください。CEP は次のようになります。

//10 個のアイテムのウィンドウを作成する

// ウィンドウ関数を適用し、ウィンドウ内のすべての値を評価するカスタムを追加します

//単純な CEP パターンの定義

このコードを実行すると、where 句内のフィルター関数がまったく呼び出されません。inactivityStream.print ()を出力しましたが、一致する値を確認できます。

さて、ウィンドウを適用せずにinputStreamを直接プラグインすると。柄が合っている

inputStream と WindowedStream を出力したところ、どちらも同様の種類のデータを送信していることがわかります。

何が足りないの

Hadoop フレームワークのストリーミング ツールでいくつかのパフォーマンス テストを実行するために、Kafka ブローカー用の単純なイベント/データストリーム ジェネレーターを探しています。これまでのところ、適切なものは見つかりませんでした。非常に短い時間 (ミリ秒) で大量の (ほぼ等しい) メッセージを送信できる必要があります。

ありがとう！

私は Redis にまったく慣れておらず、R にも比較的慣れていません。最初にソケットに接続する必要がある割り当てを行う必要があります (株式のキー値をストリーミングします)。

homebrew を使用して Mac に Redis をインストールし、次にrredisR にパッケージをインストールしました。ローカル ホストに接続しようとするたびに、次のエラーが表示されます。

設定すればnodelay = F つながる

今、特定のソケットに接続しようとしています (ip: 88.99.38.191, port:1337)

私はこれを取得します

設定しようとするとnodelay = F：

誰かが私が間違っていることを知っていますか? 私がウェブで見たすべてのガイド/チュートリアルは、デフォルト設定で問題ありませんnodelay = T

ps: 私の無知を許してください。さもなければ、似たような投稿がありましたが、見つけられませんでした。