From 0ba1e4d98495862daffccf41398e561e832c3284 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E5=BD=A6=E9=92=8A?= <zhangyanzhao@igengmei.com>
Date: Sun, 28 Apr 2019 10:02:48 +0800
Subject: [PATCH] change test file
---
tensnsorflow/multi.py | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/tensnsorflow/multi.py b/tensnsorflow/multi.py
index a84a34fe..a88b6f88 100644
--- a/tensnsorflow/multi.py
+++ b/tensnsorflow/multi.py
@@ -207,11 +207,11 @@ def con_sql(db,sql):
def test():
- spark.sql("use online")
- spark.sql("ADD JAR /srv/apps/brickhouse-0.7.1-SNAPSHOT.jar")
- spark.sql("ADD JAR /srv/apps/hive-udf-1.0-SNAPSHOT.jar")
- spark.sql("CREATE TEMPORARY FUNCTION json_map AS 'brickhouse.udf.json.JsonMapUDF'")
- spark.sql("CREATE TEMPORARY FUNCTION is_json AS 'com.gmei.hive.common.udf.UDFJsonFormatCheck'")
+ # spark.sql("use online")
+ # spark.sql("ADD JAR /srv/apps/brickhouse-0.7.1-SNAPSHOT.jar")
+ # spark.sql("ADD JAR /srv/apps/hive-udf-1.0-SNAPSHOT.jar")
+ # spark.sql("CREATE TEMPORARY FUNCTION json_map AS 'brickhouse.udf.json.JsonMapUDF'")
+ # spark.sql("CREATE TEMPORARY FUNCTION is_json AS 'com.gmei.hive.common.udf.UDFJsonFormatCheck'")
spark.sparkContext.setLogLevel("WARN")
df = spark.sql("select device_id,stat_date from esmm_train_data limit 60")
--
2.18.0