Я пытаюсь использовать структурированную потоковую передачу с Apache Bahir и Spark. Из исходной...

Когда я запускал spark-shell следующей командой bin / spark-shell --packages org.apache.bahir:...

Я не могу использовать MQTTUtils.createPairedStream () в Скале? Как указать список тем в качестве...

Прежде всего, я некоторое время искал эту проблему, и я вижу, что существуют другие решения по...