Skip to content
This repository was archived by the owner on Apr 15, 2022. It is now read-only.

Commit 9b7a432

Browse files
authored
Update context.py
1 parent 6736776 commit 9b7a432

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

splicemachine/spark/context.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,16 +24,16 @@ class PySpliceContext:
2424
This class implements a SpliceMachineContext object (similar to the SparkContext object)
2525
"""
2626

27-
def __init__(self, JDBC_URL, spark_sql_context, _unit_testing=False):
27+
def __init__(self, JDBC_URL, sparkSession, _unit_testing=False):
2828
"""
2929
:param JDBC_URL: (string) The JDBC URL Connection String for your Splice Machine Cluster
30-
:param spark_sql_context: (sparkContext) A SparkContext Object for executing Spark Queries
30+
:param spark_sql_context: (sparkContext) A SparkSession object for talking to Spark
3131
"""
3232
self.jdbcurl = JDBC_URL
3333
self._unit_testing = _unit_testing
3434

3535
if not _unit_testing: # Private Internal Argument to Override Using JVM
36-
self.spark_sql_context = spark_sql_context
36+
self.spark_sql_context = sparkSession._wrapped
3737
self.jvm = self.spark_sql_context._sc._jvm
3838
java_import(self.jvm, "com.splicemachine.spark.splicemachine.*")
3939
java_import(self.jvm,

0 commit comments

Comments
 (0)