ApacheSpark流上的ApacheBahir Stuctured Streaming连接器的架构问题 我正在尝试将Apache Spark结构化流连接到MQTT主题(在本例中为IBM Bluemix上的IBM Watson IoT Platform). 我正在创建结构化流，如下所示: val df = spark.readStream .format("org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider") .. 发布时间：2020-05-12 20:19:38 apache-spark mqtt spark-structured-streaming watson-iot apache-bahir 其他开发
