Должны ли / мы можем запустить функцию вывода в функции обновления mapWithState?

Question

Фактически я получил задачу восстановления кода предшественника.

вот его пример кода:

DStream.mapWithState(StateSpec.function(updateFunction))
   .foreachRDD(rdd => rdd.foreach(//do nothing))

def updateFuntion(key, optionValue, state): result = {
  //some staff
  if(trigger) {
     saveEventByHttpCall()     
  }
}

Я не уверен, что отправка события в updateFunction - правильный путь.

и я думаю, что он должен генерировать объект события для нисходящего потока внутри updateFunciton и отправлять событие в foreachRDD ()