来自happybase data hbase的pysparkDataframe

0aydgbwb  于 2021-06-07  发布在  Hbase
关注(0)|答案(0)|浏览(285)

我需要从happybase表创建一个pysparkDataframe。数据是从hbase数据库中提取出来的。请,有人能帮我吗?
"""

import happybase
from pyspark.sql import SparkSession

spark = SparkSession.builder.master("local[1]").appName("andre").getOrCreate()

connection = happybase.Connection('localhost', autoconnect=False)
table = connection.table("books")

df = spark.createDataFrame(data=table.scan())
print(df.show())

connection.close()

"""

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题