修改测试文件

tensnsorflow/test.py

-
-import datetime
+# -*- coding: utf-8 -*-
 from pyspark.sql import HiveContext
 from pyspark.context import SparkContext
 from pyspark.conf import SparkConf
@@ -7,20 +6,20 @@ from pyspark.sql import SQLContext
 from pyspark.sql import SparkSession
 # from py4j.java_gateway import java_import
 # import pytispark.pytispark as pti
-import pandas as pd
-
-def con_sql(db,sql):
-    cursor = db.cursor()
-    try:
-        cursor.execute(sql)
-        result = cursor.fetchall()
-        df = pd.DataFrame(list(result))
-    except Exception:
-        print("发生异常", Exception)
-        df = pd.DataFrame()
-    finally:
-        db.close()
-    return df
+# import pandas as pd
+#
+# def con_sql(db,sql):
+#     cursor = db.cursor()
+#     try:
+#         cursor.execute(sql)
+#         result = cursor.fetchall()
+#         df = pd.DataFrame(list(result))
+#     except Exception:
+#         print("发生异常", Exception)
+#         df = pd.DataFrame()
+#     finally:
+#         db.close()
+#     return df
 
 
 def test():