Commit 0dc1812f authored by 王志伟's avatar 王志伟
parents ee2745bf 654e189f
......@@ -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