เตรียมพร้อมสำหรับการแปลงข้อมูล

อย่างที่กล่าวไว้ในวิดีโอ ก่อนจะทำการแปลงข้อมูลด้วย PySpark ต้องนำข้อมูลเข้าสู่ Spark framework ก่อน จากที่ได้เรียนรู้วิธีทำด้วย PySpark ลองเลือกโค้ดที่ ถูกต้อง

(A)

spark.read.jdbc("jdbc:postgresql://repl:password@localhost:5432/pagila",
                "customer")

(B)

spark.read.jdbc("jdbc:postgresql://localhost:5432/pagila",
                "customer",
                {"user":"repl","password":"password"})

(C)

spark.read.jdbc("jdbc:postgresql://repl:password@localhost:5432/pagila/customer")