Ссылайтесь на sqlContext как на глобальную переменную

Я создал объект, как показано ниже:

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, или мне обязательно нужно передать его в качестве аргумента?


person Steven    schedule 14.08.2018    source источник