Как извлечь значение из структурированного потокового фрейма данных pyspark в переменную?

Question

Я пытался с помощью следующего кода. Но это работает только для потокового Dataframe.

agentName = kinesisDF.select(kinesisDF.agentName.getItem(0).alias("agentName")).collect()[0][0]

Как извлечь его в переменную в Spark Structured Streaming?

Я использую Spark 2.3.2. Похоже, что операция foreach поддерживается только для Java и Scala. Есть ли альтернатива для Python?