Load Cloudant Data in Apache Spark Using a Scala Notebook
Learn how to load Cloudant data in IBM Analytics for Apache Spark using the Cloudant-Spark beta connector in a Scala notebook for easy access to filter and refine Cloudant data in IBM Analytics for Apache Spark.
You can download the Scala notebook shown in the video and referenced in this tutorial, or create your own notebook by cutting/pasting the code found below in the tutorial into a new notebook. Or watch the Python version of this notebook in Data Science Experience.
Try the tutorial
What you’ll learn
At the end of this tutorial, you should be able to:
- replicate a Cloundant database into your Cloudant account
- create a Scala notebook in IBM Analytics for Apache Spark.
- use Spark SQL to load and filter the Cloudant data.
- write data back to a Cloudant database.
Before you begin
Watch the Getting Started on Bluemix video to add the IBM Analytics for Apache Spark service to your Bluemix account.
You can download the Scala notebook shown in the video and referenced in this tutorial, or create your own notebook by cutting/pasting the code into a new notebook.
Procedure 1: Replicate the Crimes database into your Cloudant account
- Sign in to your Cloudant account or sign in to Bluemix, and access the Cloudant Dashboard.
- Click the Replication tab.
- Complete the form on the right side of the screen to create a new replication job with the following specifications.
- For the _id, type
- In this tutorial, you want to replicate a database from the Education account to your own personal account, so indicate that the source database is a Remote Database and type the URL to the database as
In this case, you don’t need to set any special permissions because this database is already set to allow anyone to replicate it locally.
- For the target database, click New Database, select Create a new database locally, and then specify the database name as
- Leave Make this replication continuous unchecked so this will be a singular replication event.
- For the _id, type
- Click Replicate.
- Next, type your password, and click Continue.
Under the covers, the process base64 encodes your credentials and includes that authentication information in the replication document.
- You get the success message: This replication has been posted to the _replicator database but hasn’t been fired yet. Check the _replicator DB to see its state.
Procedure 2: Create a Scala notebook to analyze the Cloudant data
- Log in to Data Science experience at http://datascience.ibm.com.
- Open an existing project, or create a new project.
- Create a new notebook, specifying a name, description, Spark service to use, Python 2, and Spark 2.0.
- Paste the following statement into the first cell, and then click Run. This command contains SQLContext which is the entry point into all functionality in Spark SQL and is necessary to execute SQL queries.
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
- Paste the following statement into the second cell, and then click Run. Replace hostname, username, and password with the hostname, username, and password for your Cloudant account. This command reads the crimes database from the Cloudant account and assigns it to the cloudantdata variable.
val cloudantdata = sqlContext.read.format("com.cloudant.spark").
- Paste the following statement into the third cell, and then click Run. This next command lets you take a look at that schema.
- Paste the following statement into the fourth cell, and then click Run. A DataFrame object can be created directly from a Cloudant database. This next line creates and displays a DataFrame containing all of the crime codes from the cloudantdata.
val resultsDF = cloudantdata.select("properties.naturecode")
- Paste the following statement into the fifth cell, and then click Run. This next line creates a DataFrame containing the cloudantdata filtered on only crime data where the crime code is a public disturbance. You’ll notice that the .select statement specified which column to select, and the .filter statement specifies which rows to select. Refer to the SQL Programming Guide for more information on the .select and .filter syntax.
val disturbDF = cloudantdata.filter(cloudantdata.col("properties.naturecode").startsWith("DISTRB"))
- Paste the following statement into the sixth cell, and then click Run. This line persists the DataFrame back to another Cloudant database. The Cloudant-Spark Connector does not create the database, so the database needs to already exist. This command writes 7 documents into a database named crimes_filtered and contains the properties of the crime. Replace hostname, username, and password with the hostname, username, and password for your Cloudant account.
Procedure 3: View the database from the Cloudant dashboard
- Open the Cloudant dashboard by signing in to your Cloudant account.
- In the list of databases, notice the original crimes database contains 273 documents, while the crimes_filtered database contains only 7 documents.
- Open the crimes_filtered database.
- Open the documents in the database to verify that all documents contain the naturecode “DISTRB”.