在 spark-shell (scala) 中,我们导入 org.apache.spark.sql.hive.thriftserver._ 以编程方式为特定的 hive 上下文启动 Hive Thrift 服务器作为 HiveThriftServer2.startWithContext(hiveContext) 以公开注册的临时表那个特定的会议。
我们如何使用 python 做同样的事情?python 上是否有用于导入 HiveThriftServer 的包/api?任何其他想法/建议表示赞赏。
我们已经使用 pyspark 创建了一个数据框
谢谢
拉维·纳拉亚南