scala – 如何在spark中执行初始化？

我想要做的是在每个分区上初始化一次geoip数据库对象,然后使用它来查找与IP地址相关的城市.

spark是否有每个节点的初始化阶段,或者我应该检查实例变量是否未定义,如果是,请在继续之前初始化它？例如.类似的东西(这是python,但我想要一个scala解决方案)：

class IPLookup(object):
    database = None

    def getCity(self,ip):
      if not database:
        self.database = self.initialise(geoipPath)
  ...

当然,这样做需要spark会将整个对象序列化,这是文档提醒的.