В spark-shell (scala) мы импортируем org.apache.spark.sql.hive.thriftserver._ для программного запуска сервера Hive Thrift для конкретного контекста куста как HiveThriftServer2.startWithContext (hiveContext), чтобы предоставить зарегистрированную временную таблицу для этот конкретный сеанс.

Как мы можем сделать то же самое с помощью Python? Есть ли пакет / API на Python для импорта HiveThriftServer? Любые другие мысли / рекомендации приветствуются.

Мы использовали pyspark для создания датафрейма

Спасибо

Рави Нараянан