Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- spark = SparkSession
- .builder
- .appName("untitled")
- .getOrCreate()
- def decisionTreeClassifier(spark):
- sqlContext = SQLContext(spark)
- dataSetParaquel = sqlContext.read.format("jdbc").options(
- url="jdbc:mysql://localhost:3306/insilicokdd",
- driver="com.mysql.jdbc.Driver",
- dbtable="#",
- user="root",
- password="#",
- properties={"driver": 'com.mysql.jdbc.Driver'}).load().cache()
- dataSetParaquel.registerTempTable("data")
- dataSet = spark.table("data")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement