Commit 8662e492 authored by 张彦钊's avatar 张彦钊

修改测试文件

parent 8ec237c0
......@@ -201,9 +201,10 @@ def test():
from hdfs.ext.dataframe import read_dataframe
client = InsecureClient('http://nvwa01:50070')
df = read_dataframe(client,"/recommend/va/part-00000-a6aad7c8-149c-4eee-b718-5d350b26e8d2-c000.avro")
df = read_dataframe(client,"/recommend/va/*.avro")
print(df.head())
print(df.count())
# spark.sql("use online")
# spark.sql("ADD JAR /srv/apps/brickhouse-0.7.1-SNAPSHOT.jar")
......
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