Currently
def readDataFrameFromCloudant(database):
cloudantdata=spark.read.load(database, "org.apache.bahir.cloudant")
(...)
This results in exception Py4JJavaError: An error occurred while calling o274.load. : java.lang.ClassNotFoundException: Failed to find data source: org.apache.bahir.cloudant.
Expected
def readDataFrameFromCloudant(database):
cloudantdata=spark.read.load(database, "com.cloudant.spark")