您可以使用Scala反射在当前范围内查找变量吗?

我们有一个胖子用来存储Spark作业,并使用通用代码运行所说的Spark作业。

当我们从事新工作时,我们喜欢使用Zeppelin开发和测试我们的代码,但是通用代码已经变得足够有用,以至于我们希望允许我们的开发人员在Zeppelin中调用所述函数。

不幸的是,我们的设置方式是,我们在代码中埋藏了一个SparkSession变量,并说SparkSession与Zeppelin的spark会话不兼容。因此,我想编写一些魔术反射代码来查找zeppelin变量,并在找不到时创建一个新的SparkSession。 (通过这种方式,在教授中运行胖子罐时,我们使用生产版本的SparkSession;在从Zeppelin旋转时,使用Zeppelins会话)

一些基础研究没有发现任何问题,我怀疑这个特殊的问题是不可能的,但是我想看看是否有人做过这种奇怪的事情。

有什么想法吗?

libravilla 回答:您可以使用Scala反射在当前范围内查找变量吗?

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3165209.html

大家都在问