The last line of the below code gives the error “java.lang.ClassNotFoundException: org.sqlite.JDBC”
in Python
driver = “org.sqlite.JDBC”
path = “H_data/flight-data/jdbc/my-sqlite.db”
url = “jdbc:sqlite:” + path
tablename = “flight_info”
dbDataFrame = spark.read.format(“jdbc”).option(“url”, url)
.option(“dbtable”, tablename).option(“driver”, driver).load()
dbDataFrame.select(“DEST_COUNTRY_NAME”).distinct().show(5)
What should i do to fix this?