hi,
I am trying to connect to a mysql database on my machine.
But, I am getting some error
dataframe_mysql = sqlContext.read.format("jdbc").options(
url="jdbc:mysql://localhost:3306/my_db",
driver = "com.mysql.jdbc.Driver",
dbtable = "data1",
user="123").load()
below is the
I am trying to use hivecontext in spark. The following statements are
running fine :
from pyspark.sql import HiveContext
sqlContext = HiveContext(sc)
But, when i run the below statement,
sqlContext.sql("CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")
I get the following error :
Java
