Подготовка к трансформациям
Как было показано в видео, прежде чем выполнять трансформации с помощью 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")
Это упражнение является частью курса
Введение в дата-инжиниринг
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение