From 4fd68f9cd0ab7c0b61c00bed503b6e628f64e83b Mon Sep 17 00:00:00 2001 From: Vikas Gupta Date: Wed, 9 Aug 2023 08:54:03 +0530 Subject: [PATCH] using ZinggWithSpark in python causes error #640 --- .../client/src/main/java/zingg/spark/client/SparkClient.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/spark/client/src/main/java/zingg/spark/client/SparkClient.java b/spark/client/src/main/java/zingg/spark/client/SparkClient.java index 553e25c1d..fda95945f 100644 --- a/spark/client/src/main/java/zingg/spark/client/SparkClient.java +++ b/spark/client/src/main/java/zingg/spark/client/SparkClient.java @@ -6,6 +6,7 @@ import org.apache.spark.sql.Dataset; import org.apache.spark.sql.Row; import org.apache.spark.sql.types.DataType; +import org.apache.spark.sql.SparkSession; import zingg.common.client.Arguments; import zingg.common.client.Client; @@ -33,6 +34,10 @@ public SparkClient(Arguments args, ClientOptions options, ZSparkSession s) throw super(args, options, s); } + public SparkClient(Arguments args, ClientOptions options, SparkSession s) throws ZinggClientException { + this(args, options, new ZSparkSession(s,null)); + } + public SparkClient() { /*SparkSession session = SparkSession .builder()