diff --git a/.gitignore b/.gitignore index 8e11918a6..ae9b81cb0 100644 --- a/.gitignore +++ b/.gitignore @@ -31,3 +31,4 @@ assembly/dependency-reduced-pom.xml # Sphinx _build **/_build +/python/venv 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 7868fd96f..3c4601ea2 100644 --- a/spark/client/src/main/java/zingg/spark/client/SparkClient.java +++ b/spark/client/src/main/java/zingg/spark/client/SparkClient.java @@ -30,22 +30,35 @@ public class SparkClient extends Client, Row, Column, private JavaSparkContext javaSparkContext; public SparkClient(IZArgs args, ClientOptions options) throws ZinggClientException { - super(args, options, zFactoryClassName); - + this(args, options, zFactoryClassName); } public SparkClient(IZArgs args, ClientOptions options, SparkSession s) throws ZinggClientException { - super(args, options, s, zFactoryClassName); - Analytics.track(Metric.IS_PYTHON, "true", args.getCollectMetrics()); + this(args, options, s, zFactoryClassName); } public SparkClient() { - super(zFactoryClassName); + this(zFactoryClassName); + } + + public SparkClient(IZArgs args, ClientOptions options, String zFactoryClassName) throws ZinggClientException { + super(args, options, zFactoryClassName); + } + public SparkClient(IZArgs args, ClientOptions options, SparkSession s, String zFactoryClassName) throws ZinggClientException { + super(args, options, s, zFactoryClassName); + Analytics.track(Metric.IS_PYTHON, "true", args.getCollectMetrics()); + } + + + public SparkClient(String zFactoryClassName) { + super(zFactoryClassName); + } + @Override public Client, Row, Column, DataType> getClient(IZArgs args, ClientOptions options) throws ZinggClientException {