获取 hive 版本 pyspark

如果你想在使用Pyspark时获取hive版本信息，则可以按照以下方法进行操作。

首先你可以通过以下命令在Pyspark中创建一个SQLContext对象：

from pyspark.sql import SQLContext
sqlContext = SQLContext(sc)

接着，你可以使用SQLContext对象的sql方法来执行SQL查询，获取hive版本信息：

result = sqlContext.sql("SELECT * FROM org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore.Iface.serverInfo()") 
hive_version = result.collect()[0]["serverVersion"]
print("Hive 版本：", hive_version)

这个查询语句会执行ThriftHiveMetastore.Iface.serverInfo()方法，返回一个包含hive版本信息的结果集。我们通过collect方法把结果集转化为一个数组，然后通过数组的[0]来取得第一个结果行，最后通过["serverVersion"]把版本信息取出来。

完整代码如下：

from pyspark.sql import SQLContext
sqlContext = SQLContext(sc)

result = sqlContext.sql("SELECT * FROM org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore.Iface.serverInfo()") 
hive_version = result.collect()[0]["serverVersion"]
print("Hive 版本：", hive_version)

以上就是获取hive版本信息的方法，如果有问题欢迎提问。