変換の準備をする
動画で説明したとおり、PySpark で変換を行う前に、データを Spark フレームワークに取り込む必要があります。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")
この演習はコースの一部です
