0

Spark を ActiveMQ または Mosquitto MQTT ブローカーにサブスクライブしたいと考えています。どうやってやるの？

4

3 に答える 3

1

Apache インキュベーター Spark リポジトリーの Spark Streaming 用 MQTT アダプターの最新のプル リクエストとコードはこちらです。

于 2013-10-19T03:56:40.437 に答える
0

カスタム Spark ストリーミング レシーバーを作成できます。これにより、任意のソースから読み取ることができます。

于 2015-01-05T14:16:51.503 に答える