Commit c091f12a authored by 张彦钊's avatar 张彦钊

change test file

parent 330993c8
......@@ -26,7 +26,7 @@ def esmm_pre():
gw = SparkContext._gateway
# Import TiExtensions
java_import(gw.jvm, "org.apache.spark.sql.TiExtensions")
java_import(gw.jvm, "org.apache.spark.sql.TiContext")
# Inject TiExtensions, and get a TiContext
ti = gw.jvm.TiExtensions.getInstance(spark._jsparkSession).getOrCreateTiContext(spark._jsparkSession)
......
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