Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- $ pyspark --driver-class-path E:/Spark1_6/Spark_1_6/lib/mysql-connector-java-5.1.37.jar
- ## Import Pyspark Lib
- from pyspark.sql import SparkSession
- ## Spark Session Creating
- spark = SparkSession.builder.appName("Python Spark SQL basic example").getOrCreate()
- ## Creating Data Frarme
- jdbcDF = spark.read \
- .format("jdbc") \
- .option("url", "jdbc:mysql://localhost:3306/webdb") \
- .option("dbtable", "myjob") \
- .option("user", "root") \
- .option("password", "root") \
- .load()
- ## Display Results
- jdbcDF.printSchema()
- jdbcDF.show(10)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement