Commit b9a5d42d authored by Your Name's avatar Your Name

change model path to hdfs

Merge branch 'master' of git.wanmeizhensuo.com:ML/ffm-baseline
parents 41bca7bb ec99efe0
......@@ -157,8 +157,19 @@ def get_hdfs(dir_in):
a.append(tmp)
return a
def get_pre():
db = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
sql = "select count(*) from esmm_pre_data"
cursor = db.cursor()
cursor.execute(sql)
result = cursor.fetchone()[0]
print(result)
db.close()
if __name__ == '__main__':
print("hello")
get_pre()
# sparkConf = SparkConf().set("spark.hive.mapred.supports.subdirectories", "true") \
# .set("spark.hadoop.mapreduce.input.fileinputformat.input.dir.recursive", "true") \
# .set("spark.tispark.plan.allow_index_double_read", "false") \
......
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