Я создал объект, как показано ниже:
class Pivot:
def __init__(self, pivot_name):
global sqlContext
self._df = sqlContext.table(pivot_name)
В Databricks я упаковал этот код в .egg, прикрепил его к моему кластеру, затем из блокнота (где sqlContext
определяется напрямую) я попробовал:
import Pivot
Pivot("my_pivot")
и получил ошибку name 'sqlContext' is not defined
Есть ли способ, которым мой пакет .egg может напрямую видеть объект sqlContext
, или мне обязательно нужно передать его в качестве аргумента?