我不太清楚我是否明白确切的要求。但是，根据问题描述和您在评论中的解释，这可能是可行的：

dstream.foreachRDD { rdd =>
  val config = loadConfiguration() //  executed at the driver
  rdd.foreach { record =>
   // do stuff here. e.g. config.get(). This code is executed at the worker.
  }
}

这里需要注意的一点是 Config 类必须是可序列化的，因为它将从驱动程序发送给工人。
另外，请注意，这可能是一个反模式，具体取决于您的用例。e、 g.对于每个批处理，config对象将被序列化并发送给worker，worker将根据config对象的大小增加网络开销。
我强烈建议您检查 forEachRDD 明智地构建和选择你的方法。以下是相同的链接：https://spark.apache.org/docs/latest/streaming-programming-guide.html#design-foreachrdd的使用模式