Advertisement
Guest User

Untitled

a guest
Jul 18th, 2019
96
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.51 KB | None | 0 0
  1. spark = SparkSession
  2. .builder
  3. .appName("untitled")
  4. .getOrCreate()
  5.  
  6. def decisionTreeClassifier(spark):
  7. sqlContext = SQLContext(spark)
  8. dataSetParaquel = sqlContext.read.format("jdbc").options(
  9. url="jdbc:mysql://localhost:3306/insilicokdd",
  10. driver="com.mysql.jdbc.Driver",
  11. dbtable="#",
  12. user="root",
  13. password="#",
  14. properties={"driver": 'com.mysql.jdbc.Driver'}).load().cache()
  15.  
  16. dataSetParaquel.registerTempTable("data")
  17. dataSet = spark.table("data")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement