如何在通过dataframe查询count查询时获取整数值？

yyyllmsg 于 2021-06-26 发布在 Hive

关注(0)|答案(2)|浏览(374)

我编写此代码是为了获取指定表中count的整数值：

sc = SparkContext("local", "spar")
hive_context = HiveContext(sc)
hive_context.sql("use zs_trainings_trainings_db")
df = hive_context.sql("select count(*) from ldg_sales")

Hive python pyspark pyspark-sql HiveContext

来源：https://stackoverflow.com/questions/43776574/how-to-get-an-integer-value-while-querying-a-count-query-through-dataframe

2条答案

按热度按时间

92dk7w1h1#

将dataframe转换为rdd，这样就可以对其运行map任务，只提取行值，如-

df = hive_context.sql("select count(*) as cnt from ldg_sales")
count = df.rdd.map(lambda _ : _.cnt).collect()[0]

赞(0）回复(0）举报 2021-06-26

ss2ws0br2#

或者：

hive_context.table("sales").count

或者

hive_context.sql("select count(*) from ldg_sales").first()[0]

赞(0）回复(0）举报 2021-06-26

我来回答

如何在通过dataframe查询count查询时获取整数值？

2条答案

相关问题

热门标签

最新问答