# Using Spark connector for pyspark inside Apache Zeppellin

**URL:** <https://discuss.aerospike.com/t/using-spark-connector-for-pyspark-inside-apache-zeppellin/4079>\
**Category:** Spark\
**Tags:** spark\
**Created:** [April 14, 2017, 3:43pm UTC](https://discuss.aerospike.com/t/using-spark-connector-for-pyspark-inside-apache-zeppellin/4079 "2017-04-14T15:43:11Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![ser0t0nin](https://avatars.discourse-cdn.com/v4/letter/s/779978/32.png) [@ser0t0nin](https://discuss.aerospike.com/u/ser0t0nin)\
**Post date:** [April 14, 2017, 3:43pm UTC](https://discuss.aerospike.com/t/using-spark-connector-for-pyspark-inside-apache-zeppellin/4079/1 "2017-04-14T15:43:11Z")

</div>

Hello everyone!

I want to use the aerospark connector for some advanced data science tasks in Apache Zeppelin notebooks with the pyspark interpreter. It seems like finally everything is working, at least i can import the aerospike client in scala enviroment of spark without any exceptions. But i cannot find any examples of quering Aerospike from pyspark, do you have some? How can i create a proper SQLContext with pyspark using the driver?

Thanks

---

<div class="post-metadata">

**Author:** ![ser0t0nin](https://avatars.discourse-cdn.com/v4/letter/s/779978/32.png) [@ser0t0nin](https://discuss.aerospike.com/u/ser0t0nin)\
**Post date:** [April 17, 2017, 11:25am UTC](https://discuss.aerospike.com/t/using-spark-connector-for-pyspark-inside-apache-zeppellin/4079/2 "2017-04-17T11:25:38Z")

</div>

I have found out, how to connect to AS:

```
%spark.pyspark
conn = sqlc.read.format("com.aerospike.spark.sql").\
    option('aerospike.seedhost', AS_HOST).\
    option('aerospike.port', AS_PORT).\
    option('aerospike.namespace', NAMESPACE).\
    option('aerospike.set', SET_NAME).load()

```

how to query AS now? 🙂

---

<div class="post-metadata">

**Author:** ![ser0t0nin](https://avatars.discourse-cdn.com/v4/letter/s/779978/32.png) [@ser0t0nin](https://discuss.aerospike.com/u/ser0t0nin)\
**Post date:** [May 10, 2017, 8:21am UTC](https://discuss.aerospike.com/t/using-spark-connector-for-pyspark-inside-apache-zeppellin/4079/3 "2017-05-10T08:21:34Z")

</div>

yes, sorry for a dummy question)
