Skip to content

F
ffm-baseline
Commit 8bfdf9af authored by 王志伟's avatar 王志伟
Browse files
Options

Merge branch 'master' of http://git.wanmeizhensuo.com/ML/ffm-baseline

parents 82160c13 34e8964c
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 5 deletions
tensnsorflow/test.py
View file @ 8bfdf9af
...@@ -2,8 +2,8 @@ ...@@ -2,8 +2,8 @@
from pyspark.sql import HiveContext from pyspark.sql import HiveContext
from pyspark.context import SparkContext from pyspark.context import SparkContext
from pyspark.conf import SparkConf from pyspark.conf import SparkConf
import pytispark.pytispark as pti # import pytispark.pytispark as pti
from pyspark.sql import SQLContext # from pyspark.sql import SQLContext
from pyspark.sql import SparkSession from pyspark.sql import SparkSession
# from py4j.java_gateway import java_import # from py4j.java_gateway import java_import
# import pytispark.pytispark as pti # import pytispark.pytispark as pti
...@@ -28,10 +28,10 @@ def test(): ...@@ -28,10 +28,10 @@ def test():
sc = SparkContext(conf = conf) sc = SparkContext(conf = conf)
hive_context = HiveContext(sc) hive_context = HiveContext(sc)
spark = SparkSession.builder.enableHiveSupport().getOrCreate() spark = SparkSession.builder.enableHiveSupport().getOrCreate()
ti = pti.TiContext(spark) # ti = pti.TiContext(spark)
ti.tidbMapDatabase("jerry_test") # ti.tidbMapDatabase("jerry_test")
spark = SparkSession.builder.appName("BinarizerExample").enableHiveSupport().getOrCreate() spark = SparkSession.builder.appName("hello test").enableHiveSupport().getOrCreate()
spark.sql("use online") spark.sql("use online")
spark.sql("ADD JAR hdfs:///user/hive/share/lib/udf/brickhouse-0.7.1-SNAPSHOT.jar") spark.sql("ADD JAR hdfs:///user/hive/share/lib/udf/brickhouse-0.7.1-SNAPSHOT.jar")
......
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