1
ответ

Как использовать createpairedStream в MQTTUtils?

Я не могу использовать MQTTUtils.createPairedStream () в Scala? Как указать список тем в качестве параметров? Я перепробовал все способы, такие как словарь, список, кортежи, но это не сработало. И затем я ...
вопрос задан: 5 March 2019 10:14
0
ответов

Не удалось найти источник данных: org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider

Версия spark - 2.3.3. Я хочу подключиться к mqtt с помощью аргумента --packages в bin / spark-shell спарк-оболочки --packages org.apache.bahir: spark-sql-streaming-mqtt_2.11: 2.3 .2 Скала > Импортировать ...
вопрос задан: 22 March 2019 13:11