Следующее работает отлично, когда любой внешний параметр может быть передан в UDF (измененный код, чтобы помочь кому-либо)
topicWord=udf(lambda tkn: label_maker_topic(tkn,topic_words),StringType())
myDF=myDF.withColumn("topic_word_count",topicWord(myDF.bodyText_token))
Подробная статья о сообщениях «Завещание и Завет» доступна в серии постов в блоге MQTT Essentials: http://www.hivemq.com/mqtt-essentials-part-9-last- воли и-завещание / .
Подводя итоги сообщения в блоге:
Функция «Последняя воля и завет» используется в MQTT для уведомления других клиентов о клиенте, грациозно отключенном.
MQTT часто используется в сценариях, где ненадежные сети очень распространены. Поэтому предполагается, что некоторые клиенты будут время от времени отключаться изящно, потому что они потеряли соединение, батарея разряжена или любой другой мыслимый случай. Было бы полезно узнать, корректно ли отключился подключенный клиент (что означает сообщение MQTT DISCONNECT ) или нет, чтобы предпринять соответствующие действия.