擅长:python、mysql、java
<p>必须重写setUpClass方法:</p>
<pre><code>@classmethod
def setUpClass(cls):
"""Setup a basic Spark context for testing"""
class_name = cls.__name__
conf = SparkConf().set("spark.jars.packages", "org.postgresql:postgresql:42.1.1")
cls.sc = SparkContext(cls.getMaster(), appName=class_name, conf=conf)
quiet_py4j()
</code></pre>
<p>这样就可以将外部jar传递给Spark测试库。在</p>
<p>列奥纳多·诺莱托的作品:<a href="https://github.com/holdenk/spark-testing-base/issues/281#event-2200108290" rel="nofollow noreferrer">https://github.com/holdenk/spark-testing-base/issues/281#event-2200108290</a></p>