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()