Commit 3a271dda authored by 张彦钊's avatar 张彦钊

change test file

parent 5d8bfc6b
......@@ -204,8 +204,11 @@ def test():
# df.show(6)
# df = df.toPandas()
from hdfs import InsecureClient
from hdfs.ext.dataframe import read_dataframe
client = InsecureClient('http://nvwa01:50070')
df = hdfs.ext.dataframe.read_dataframe(client,"/recommend/nearby/part-00198-ad7e4833-f388-483e-8f68-c2fde8d3c4d8-c000.csv")
df = read_dataframe(client,"/recommend/nearby/part-00198-ad7e4833-f388-483e-8f68-c2fde8d3c4d8-c000.csv")
print(df.head())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment