Commit 5b8bb96a authored by 张彦钊's avatar 张彦钊

修改test文件

parent 11fee6af
......@@ -24,7 +24,7 @@ def con_sql(db,sql):
return df
# def test():
def test():
conf = SparkConf().setAppName("My App").set("spark.io.compression.codec", "lzf")
sc = SparkContext(conf = conf)
hive_context = HiveContext(sc)
......@@ -62,4 +62,5 @@ def con_sql(db,sql):
if __name__ == '__main__':
test()
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