增加hive代码

tensnsorflow/feature_engineering.py

@@ -80,8 +80,7 @@ def hive():
     conf = SparkConf().setMaster("spark://10.31.242.83:7077").setAppName("My app")
     sc = SparkContext(conf=conf)
     sqlContext = HiveContext(sc)
-    sql = "select params['business_id'],device['device_id'] from online.tl_hdfs_maidian_view " \
-          "where action = 'diarybook_detail_click_more_topic' limit 10;"
+    sql = "select partition_date from online.tl_hdfs_maidian_view limit 10"
     my_dataframe = sqlContext.sql(sql)
     my_dataframe.show(6)