DataFrameでカウントクエリをクエリする際に整数値を取得する方法はありますか？

Question

私が指定したテーブル内の数の整数値を取得するには、このコードを書いています：

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") 

Answer 1

次のいずれかのようにあなたが実行することができますRDDする

hive_context.table("sales").count 

または

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

Answer 2

コンバートデータフレーム地図上のタスクで行の値を抽出するだけです -

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