在foreachRDD中使用变量时,是否需要使用广播变量?

在我的代码中,我订阅了一个Kafka流,并在一个函数中处理每个RDD:

  val myStream = KafkaUtils.createDirectStream[K, V](
      streamingContext,
      PreferConsistent,
      Subscribe[K, V](topics, consumerConfig)
    )

  val myMap: Map[ObjA, ObjB] = getMyMap() // This is the variable I want to access in 'process'

  def process(record: (RDD[ConsumerRecord[String, String]], Time)): Unit = record match {

     // Code that uses myMap.get("key")

  }

  myStream.foreachRDD((x, y) => process((x, y)))

我读了这篇关于 Spark and Kafka integration patterns .据我所知, foreachRDD 在驱动程序上本地执行,但任何内部循环都会分布到集群节点。那是不是意味着我 应该 broadcast myMap 出于性能原因?