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

Question

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

Если вы пытаетесь использовать код ниже:

git reflog show
# head to recover to
git reset HEAD@{1}

и по какой-то причине получают:

error: неизвестный переключатель `e '

, затем попробуйте обернуть HEAD@{1} в кавычки
git reset 'HEAD@{1}'

-3

scala apache-spark spark-streaming mqtt apache-bahir

задан Ashok v 5 March 2019 в 10:14

1 ответ

Другие вопросы по тегам:

scala apache-spark spark-streaming mqtt apache-bahir

Похожие вопросы:

score 0 · Answer 1

Scala - это язык со статической типизацией, в котором аргументы, которые вы предоставляете методу, должны иметь определенные типы, чтобы вызов метода компилировался. Иногда методы перегружены, и в этом случае могут быть предоставлены различные комбинации аргументов, а в Scala иногда некоторые аргументы могут иметь значения по умолчанию, и в этом случае их вообще не нужно указывать.

Есть несколько способов определить, какие аргументы возможны для данного метода. Ваша IDE может показывать всплывающую подсказку при вводе MQTTUtils.createPairedStream(. Иногда разработчики библиотеки публикуют документацию API, в которой показаны сигнатуры методов (которые включают типы аргументов и возвращаемое значение) в удобном для чтения формате. Если ни один из этих вариантов для вас не подходит и проект имеет открытый исходный код, вы можете просто посмотреть исходный код. В этом случае вы найдете что-то следующее (обратите внимание, что вам может потребоваться изменить тег в интерфейсе GitHub, если вы используете другую версию):

  /**
   * Create an input stream that receives messages pushed by a MQTT publisher.
   * @param ssc           StreamingContext object
   * @param brokerUrl     Url of remote MQTT publisher
   * @param topics        Array of topic names to subscribe to
   * @param storageLevel  RDD storage level. Defaults to StorageLevel.MEMORY_AND_DISK_SER_2.
   */
  def createPairedStream(
      ssc: StreamingContext,
      brokerUrl: String,
      topics: Array[String],
      storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2
    ): ReceiverInputDStream[(String, String)] = {
    new MQTTPairedInputDStream(ssc, brokerUrl, topics, storageLevel)
}

This является самой простой из восьми перегрузок метода createPairedStream (все остальные принимают дополнительные аргументы). Это показывает, что вам необходимо предоставить (по порядку) StreamingContext, URL-адрес брокера и массив тем.